feat: example 添加测试 mq 发送 text json 类型消息的接口

Author: cadecode

example/example_svc/src/main/java/com/github/cadecode/uniboot/example/svc/bean/data/ExampleMsgDo.java

@@ -0,0 +1,23 @@
+package com.github.cadecode.uniboot.example.svc.bean.data;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ * 测试消息 DO
+ *
+ * @author Cade Li
+ * @since 2023/8/20
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@Builder
+public class ExampleMsgDo {
+
+    private String testKey;
+
+    private String testVal;
+}

example/example_svc/src/main/java/com/github/cadecode/uniboot/example/svc/consumer/RabbitExampleConsumer.java

@@ -1,6 +1,7 @@
 package com.github.cadecode.uniboot.example.svc.consumer;
 
 import cn.hutool.core.util.ObjectUtil;
+import com.github.cadecode.uniboot.example.svc.bean.data.ExampleMsgDo;
 import com.rabbitmq.client.Channel;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.core.Message;
@@ -19,18 +20,36 @@
 @Component
 public class RabbitExampleConsumer {
 
-    @RabbitListener(queues = "demo-queue-0", id = "demo-queue-0", ackMode = "AUTO")
-    public void demoQueue0(String body, Message message, Channel channel) throws IOException {
+    @RabbitListener(queues = "example-delay-queue-0", id = "example-delay-queue-0", ackMode = "AUTO")
+    public void exampleDelayQueue0(String body, Message message, Channel channel) throws IOException {
+        log.info("Received msg:{}", body);
+    }
+
+    /**
+     * 测试 SpEL 获取 queue name
+     */
+    @RabbitListener(queues = "#{@'example-delay-queue-1'.name}", id = "example-delay-queue-1")
+    public void exampleDelayQueue1(String body, Message message, Channel channel) throws IOException {
+        log.info("Received msg:{}", body);
+        channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
+    }
+
+
+    @RabbitListener(queues = "example-biz-queue-0", id = "example-biz-queue-0", ackMode = "AUTO")
+    public void exampleBizQueue0(String body, Message message, Channel channel) throws IOException {
         log.info("Received msg:{}", body);
         // 自动模式下，测试重试机制
         if (ObjectUtil.equal(body, "ERROR")) {
             throw new RuntimeException("ERROR");
         }
     }
 
-    @RabbitListener(queues = "#{@'demo-queue-1'.name}", id = "demo-queue-1")
-    public void demoQueue1(String body, Message message, Channel channel) throws IOException {
-        log.info("Received msg:{}", body);
-        channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
+    /**
+     * 测试用对象获取消息
+     */
+    @RabbitListener(queues = "example-biz-queue-1", id = "example-biz-queue-1", ackMode = "AUTO")
+    public void exampleBizQueue1(ExampleMsgDo msgDo, Message message, Channel channel) throws IOException {
+        log.info("Received msg:{}", msgDo);
     }
+
 }

example/example_svc/src/main/java/com/github/cadecode/uniboot/example/svc/controller/MqExampleController.java

@@ -1,11 +1,12 @@
 package com.github.cadecode.uniboot.example.svc.controller;
 
+import com.github.cadecode.uniboot.common.plugin.mq.util.RabbitUtil;
+import com.github.cadecode.uniboot.example.svc.bean.data.ExampleMsgDo;
 import com.github.cadecode.uniboot.framework.base.annotation.ApiFormat;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
-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.RequestParam;
@@ -25,16 +26,25 @@
 @RequestMapping("demo/mq")
 public class MqExampleController {
 
-    private final RabbitTemplate rabbitTemplate;
-
     @ApiOperation("发送 delay 消息")
     @GetMapping("send_delay")
-    public boolean sendDelay(@RequestParam String exc, @RequestParam String routingKey,
-                             @RequestParam String msg, @RequestParam Integer ms) {
-        rabbitTemplate.convertAndSend(exc, routingKey, msg, message -> {
-            message.getMessageProperties().setDelay(ms);
-            return message;
-        });
+    public boolean sendDelay(@RequestParam String exchange, @RequestParam String routingKey, @RequestParam Integer ms) {
+        RabbitUtil.sendDelay(exchange, routingKey, "Test delay msg", ms);
+        return true;
+    }
+
+    @ApiOperation("发送字符串消息")
+    @GetMapping("send_str")
+    public boolean sendStr(@RequestParam String exchange, @RequestParam String routingKey) {
+        RabbitUtil.send(exchange, routingKey, "Test str msg");
+        return true;
+    }
+
+    @ApiOperation("发送对象消息")
+    @GetMapping("send_obj")
+    public boolean sendObj(@RequestParam String exchange, @RequestParam String routingKey) {
+        ExampleMsgDo msgDo = new ExampleMsgDo("Test key", "Test name");
+        RabbitUtil.send(exchange, routingKey, msgDo);
         return true;
     }
 }