SpringBoot整合RabbitMQ，简单实现消息发送和订阅

avatar 2019年07月05日00:46:43 6 7291 views
博主分享免费Java教学视频，B站账号：Java刘哥
通常为了测试两个服务之间消息生产和消费可以创建两个 SpringBoot 项目，这里为了简单，就用一个项目了，一个在正常的项目中，作为消费者(订阅者)，等待接受消息；另一个通过 测试类生产消息，发送消息。 just do it!

一、SpringBoot整合 RabbitMQ

1.首先需要添加依赖 pom.xml
  1. <dependency>
  2.     <groupId>org.springframework.boot</groupId>
  3.     <artifactId>spring-boot-starter-amqp</artifactId>
  4. </dependency>
  2.配置文件 application.yml
  1. spring:
  2.   rabbitmq:
  3.     host: localhost
  4.     port: 5672
  5.     username: guest
  6.     password: guest
  3.服务消费者(消息订阅者)
  1. package com.liuyanzhao.blog.core.message;
  3. import lombok.extern.slf4j.Slf4j;
  4. import org.springframework.amqp.rabbit.annotation.Exchange;
  5. import org.springframework.amqp.rabbit.annotation.Queue;
  6. import org.springframework.amqp.rabbit.annotation.QueueBinding;
  7. import org.springframework.amqp.rabbit.annotation.RabbitListener;
  8. import org.springframework.stereotype.Component;
  10. /**
  11.  * 服务订阅者
  12.  * @author 言曌
  13.  * @date 2019-07-02 23:58
  14.  */
  15. @Slf4j
  16. @Component
  17. public class MqReceiver {
  19.     //测试1 简单接收(订阅)
  20.     //1. @RabbitListener(queues = "myQueue") //需要手动创建队列
  21.     //2. @RabbitListener(queuesToDeclare = @Queue("myQueue")) //自动创建队列
  22.     //3. 自动创建，Exchange和Queue绑定
  23.     @RabbitListener(bindings = @QueueBinding(
  24.             value = @Queue("myQueue"),
  25.             exchange = @Exchange("myExchange")
  26.     ))
  27.     public void process(String message) {
  28.         log.info("MqReceiver:{}", message);
  29.     }
  31.     //测试2 消息分组
  33.     /**
  34.      * 数码供应商 接受消息
  35.      * 只接受 computer 这个key的消息
  36.      * @param message
  37.      */
  38.     @RabbitListener(bindings = @QueueBinding(
  39.             value = @Queue("myOrder"),
  40.             key = "computer",
  41.             exchange = @Exchange("computerOrder")
  42.     ))
  43.     public void processComputer(String message) {
  44.         log.info("computer MqReceiver:{}", message);
  45.     }
  47.     /**
  48.      * 水果供应商服务 接收消息
  49.      * 只接受 fruit 这个key的消息
  50.      * @param message
  51.      */
  52.     @RabbitListener(bindings = @QueueBinding(
  53.             value = @Queue("myOrder"),
  54.             key = "fruit",
  55.             exchange = @Exchange("fruitOrder")
  56.     ))
  57.     public void processFruit(String message) {
  58.         log.info("fruit MqReceiver:{}", message);
  59.     }
  61. }
  4、服务生产者(消息发送者)
  1. package com.liuyanzhao.blog.core.message;
  4. import org.junit.Test;
  5. import org.junit.runner.RunWith;
  6. import org.springframework.amqp.core.AmqpTemplate;
  7. import org.springframework.beans.factory.annotation.Autowired;
  8. import org.springframework.boot.test.context.SpringBootTest;
  9. import org.springframework.test.context.junit4.SpringRunner;
  11. import java.util.Date;
  13. /**
  14.  *
  15.  * 服务生产者
  16.  * @author 言曌
  17.  * @date 2019-07-03 00:05
  18.  */
  20. @SpringBootTest
  21. @RunWith(SpringRunner.class)
  22. public class MqSenderTest {
  24.     @Autowired
  25.     private AmqpTemplate amqpTemplate;
  27.     /**
  28.      * 生产者将消息直接发送到队列
  29.      * @throws Exception
  30.      */
  31.     @Test
  32.     public void send() throws Exception {
  33.         amqpTemplate.convertAndSend("myQueue", "hello saysky, now is " + new Date());
  34.     }
  37.     /**
  38.      * 生产者将消息发送到Exchange
  39.      * @throws Exception
  40.      */
  41.     @Test
  42.     public void sendComputer() throws Exception {
  43.         amqpTemplate.convertAndSend("computerOrder", "computer", "hello saysky, now is " + new Date());
  44.     }
  46.     /**
  47.      * 生产者将消息发送到Exchange
  48.      * @throws Exception
  49.      */
  50.     @Test
  51.     public void sendFruit() throws Exception {
  52.         amqpTemplate.convertAndSend("fruitOrder", "fruit", "hello saysky, now is " + new Date());
  53.     }
  54. }
 

二、启动项目

1.启动RabbitMQ RabbitMQ 的安装和启动之前介绍了，点此直达 2.运行项目，目的是启动服务消费者，可以在接收消息里打个断点，方便感知订阅到消息 3.启动测试方法，目的是启动服务生产者，发送消息 经过测试没有问题  
历史上的今天
七月
05日
  • 微信
  • 交流学习，有偿服务
  • weinxin
  • 博客/Java交流群
  • 资源分享，问题解决，技术交流。群号：590480292
  • weinxin
avatar

发表评论

avatar 登录者：匿名
匿名评论，评论回复后会有邮件通知

  

已通过评论：0   待审核评论数：0