mq

rebbitmq/consumer/src/main/java/com/lovecoding/rabbitmq/consumer/ConsumerTemplate.java

@@ -0,0 +1,19 @@
+package com.lovecoding.rabbitmq.consumer;
+
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.stereotype.Component;
+
+@Component
+public class ConsumerTemplate {
+
+    @RabbitListener(queues = "testQueue")
+    public void t1( String msg ){
+        System.out.println( "T1 消费了消息： " + msg );
+    }
+
+    @RabbitListener(queues = "testQueue")
+    public void t2( String msg ){
+        System.out.println( "T2 消费了消息： " + msg );
+    }
+
+}

rebbitmq/consumer/src/main/resources/application.properties

@@ -1 +1,3 @@
-
+spring.rabbitmq.port=25672
+spring.rabbitmq.username=admin
+spring.rabbitmq.password=123456

rebbitmq/producer/src/main/resources/application.properties

@@ -1 +1,3 @@
-
+spring.rabbitmq.port=25672
+spring.rabbitmq.username=admin
+spring.rabbitmq.password=123456

rebbitmq/producer/src/test/java/com/lovecoding/rabbitmq/producer/ProducerApplicationTests.java

@@ -6,8 +6,11 @@ import com.rabbitmq.client.Connection;
 import com.rabbitmq.client.ConnectionFactory;
 import com.rabbitmq.client.impl.AMQImpl;
 import org.junit.jupiter.api.Test;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
 
+import javax.annotation.Resource;
 import java.io.IOException;
 import java.nio.charset.StandardCharsets;
 import java.util.concurrent.TimeoutException;
@@ -15,6 +18,24 @@ import java.util.concurrent.TimeoutException;
 @SpringBootTest
 class ProducerApplicationTests {
 
+    @Resource
+    RabbitTemplate rabbitTemplate;
+
+    @Test
+    void t1() throws InterruptedException {
+
+        for (int i = 0; i < 100; i++) {
+            rabbitTemplate.convertAndSend(
+                    "testQueue", "测试消息ID ：" + i );
+            Thread.sleep(100);
+        }
+
+    }
+
+
+
+
+
     @Test
     void sendMsg() throws IOException, TimeoutException {
         //创建一个连接