diff --git a/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/controller/TestKafka.java b/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/controller/TestKafka.java index 732eb0f..9fcd7e9 100644 --- a/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/controller/TestKafka.java +++ b/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/controller/TestKafka.java @@ -1,12 +1,14 @@ package com.muyu.processing.controller; -import com.alibaba.fastjson.JSONObject; +import cn.hutool.json.JSONObject; import com.muyu.common.core.constant.KafkaConstants; +import com.muyu.common.core.utils.uuid.UUID; import com.muyu.common.kafka.config.KafkaProducerConfig; import lombok.extern.log4j.Log4j2; import org.apache.kafka.clients.producer.KafkaProducer; import org.apache.kafka.clients.producer.ProducerRecord; import org.apache.kafka.common.protocol.types.Field; +import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; @@ -14,6 +16,7 @@ import org.springframework.web.bind.annotation.RestController; import javax.annotation.Resource; /** + * 消息队列测试-生产者 * @Author:杨鹏 * @Package:com.muyu.processing.controller * @Project:car-cloud-server @@ -29,10 +32,44 @@ public class TestKafka { @Resource private KafkaProducer kafkaProducer; + @Resource + private RabbitTemplate rabbitTemplate; + + /** + * 发送Kafka消息 + * @return String + */ @GetMapping("/send") - public void sendMsg(){ - ProducerRecord producerRecord = new ProducerRecord<>("zeshi", "你好啊"); + public String sendMsg(){ + JSONObject entries = new JSONObject(); + entries.set("vin","vin123468"); + entries.set("name","宝马"); + String entriesString = entries.toString(); + ProducerRecord producerRecord = new ProducerRecord<>("zeshi", entriesString); kafkaProducer.send(producerRecord); + return "OK"; } + /** + * 发送MQ消息 + * @return String + */ + @GetMapping("/sendMQ") + public String sendMQ(){ + rabbitTemplate.convertAndSend("long_time_no_see","晨哀,好久不见",message -> { + message.getMessageProperties().setMessageId(UUID.randomUUID().toString()); + return message; + }); + return "OK"; + } + + /** + * 发送MQ队列消息 + * @return String + */ + @GetMapping("/sendDui") + public String sedDui() { + rabbitTemplate.convertAndSend("myExchange","Im.fine",""); + return "OK"; + } }