From d02813f7e407ff6e307a2ae1a2f9eac3525a7b16 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=99=A8=E5=93=80?= <2076029107@qq.com>
Date: Fri, 4 Oct 2024 10:18:16 +0800
Subject: [PATCH] =?UTF-8?q?feat:()=20=E6=96=B0=E5=A2=9EMQ=E7=94=9F?=
 =?UTF-8?q?=E4=BA=A7=E8=80=85=20=E5=92=8C=20=E4=BF=AE=E6=94=B9kafka?=
 =?UTF-8?q?=E7=94=9F=E4=BA=A7=E8=80=85=E7=9A=84=E4=BF=A1=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../muyu/processing/controller/TestKafka.java | 43 +++++++++++++++++--
 1 file changed, 40 insertions(+), 3 deletions(-)

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<String, String> kafkaProducer;
 
+    @Resource
+    private RabbitTemplate rabbitTemplate;
+
+    /**
+     * 发送Kafka消息
+     * @return String
+     */
     @GetMapping("/send")
-    public void sendMsg(){
-        ProducerRecord<String, String> producerRecord = new ProducerRecord<>("zeshi", "你好啊");
+    public String sendMsg(){
+        JSONObject entries = new JSONObject();
+        entries.set("vin","vin123468");
+        entries.set("name","宝马");
+        String entriesString = entries.toString();
+        ProducerRecord<String, String> 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";
+    }
 }