增加 activemq 示例

Author: YunaiV

lab-32/lab-32-activemq-demo-orderly/src/main/java/cn/iocoder/springboot/lab32/activemqdemo/consumer/Demo04Consumer.java

@@ -1,6 +1,6 @@
 package cn.iocoder.springboot.lab32.activemqdemo.consumer;
 
-import cn.iocoder.springboot.lab32.activemqdemo.message.Demo4Message;
+import cn.iocoder.springboot.lab32.activemqdemo.message.Demo04Message;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.jms.annotation.JmsListener;
@@ -11,9 +11,11 @@ public class Demo04Consumer {
 
     private Logger logger = LoggerFactory.getLogger(getClass());
 
-    @JmsListener(destination = Demo4Message.QUEUE,
-        concurrency = "2")
-    public void onMessage(Demo4Message message) {
+    @JmsListener(destination = Demo04Message.QUEUE_0)
+    @JmsListener(destination = Demo04Message.QUEUE_1)
+    @JmsListener(destination = Demo04Message.QUEUE_2)
+    @JmsListener(destination = Demo04Message.QUEUE_3)
+    public void onMessage(Demo04Message message) {
         logger.info("[onMessage][线程编号:{} 消息内容：{}]", Thread.currentThread().getId(), message);
     }
 

lab-32/lab-32-activemq-demo-orderly/src/main/java/cn/iocoder/springboot/lab32/activemqdemo/message/Demo04Message.java

@@ -0,0 +1,36 @@
+package cn.iocoder.springboot.lab32.activemqdemo.message;
+
+import java.io.Serializable;
+
+public class Demo04Message implements Serializable {
+
+    public static final String QUEUE_BASE = "QUEUE_DEMO_04-";
+    public static final String QUEUE_0 = QUEUE_BASE + "0";
+    public static final String QUEUE_1 = QUEUE_BASE + "1";
+    public static final String QUEUE_2 = QUEUE_BASE + "2";
+    public static final String QUEUE_3 = QUEUE_BASE + "3";
+
+    public static final int QUEUE_COUNT = 4;
+
+    /**
+     * 编号
+     */
+    private Integer id;
+
+    public Demo04Message setId(Integer id) {
+        this.id = id;
+        return this;
+    }
+
+    public Integer getId() {
+        return id;
+    }
+
+    @Override
+    public String toString() {
+        return "Demo04Message{" +
+                "id=" + id +
+                '}';
+    }
+
+}

lab-32/lab-32-activemq-demo-orderly/src/main/java/cn/iocoder/springboot/lab32/activemqdemo/message/Demo4Message.java

@@ -1,22 +1,26 @@
 package cn.iocoder.springboot.lab32.activemqdemo.producer;
 
-import cn.iocoder.springboot.lab32.activemqdemo.message.Demo4Message;
+import cn.iocoder.springboot.lab32.activemqdemo.message.Demo04Message;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.jms.core.JmsMessagingTemplate;
 import org.springframework.stereotype.Component;
 
 @Component
-public class Demo03Producer {
+public class Demo04Producer {
 
     @Autowired
     private JmsMessagingTemplate jmsTemplate;
 
     public void syncSend(Integer id) {
-        // 创建 Demo03Message 消息
-        Demo4Message message = new Demo4Message();
+        // 创建 Demo04Message 消息
+        Demo04Message message = new Demo04Message();
         message.setId(id);
         // 同步发送消息
-        jmsTemplate.convertAndSend(Demo4Message.QUEUE, message);
+        jmsTemplate.convertAndSend(this.getQueue(id), message);
+    }
+
+    private String getQueue(Integer id) {
+        return Demo04Message.QUEUE_BASE + (id % Demo04Message.QUEUE_COUNT);
     }
 
 }

lab-32/lab-32-activemq-demo-orderly/src/main/java/cn/iocoder/springboot/lab32/activemqdemo/producer/Demo03Producer.java renamed to lab-32/lab-32-activemq-demo-orderly/src/main/java/cn/iocoder/springboot/lab32/activemqdemo/producer/Demo04Producer.java

@@ -13,19 +13,20 @@
 
 @RunWith(SpringRunner.class)
 @SpringBootTest(classes = Application.class)
-public class Demo03ProducerTest {
+public class Demo04ProducerTest {
 
     private Logger logger = LoggerFactory.getLogger(getClass());
 
     @Autowired
-    private Demo03Producer producer;
+    private Demo04Producer producer;
 
     @Test
     public void testSyncSend() throws InterruptedException {
-        for (int i = 0; i < 10; i++) {
-            int id = (int) (System.currentTimeMillis() / 1000);
-            producer.syncSend(id);
-//            logger.info("[testSyncSend][发送编号：[{}] 发送成功]", id);
+        for (int i = 0; i < 2; i++) {
+            for (int id = 0; id < 4; id++) {
+                producer.syncSend(id);
+//                logger.info("[testSyncSend][发送编号：[{}] 发送成功]", id);
+            }
         }
 
         // 阻塞等待，保证消费