SpringBoot整合RabbitMQ开发的示例分析-创新互联

这篇文章主要介绍了Spring Boot整合RabbitMQ开发的示例分析,具有一定借鉴价值,感兴趣的朋友可以参考下,希望大家阅读完这篇文章之后大有收获,下面让小编带着大家一起了解一下。

创新互联企业建站,十载网站建设经验,专注于网站建设技术,精于网页设计,有多年建站和网站代运营经验,设计师为客户打造网络企业风格,提供周到的建站售前咨询和贴心的售后服务。对于网站制作、成都做网站中不同领域进行深入了解和探索,创新互联在网站建设中充分了解客户行业的需求,以灵动的思维在网页中充分展现,通过对客户行业精准市场调研,为客户提供的解决方案。

RabbitMQ 中的一些术语

如果你打开 RabbitMQ web 控制台,你会发现其中有一个 Exhanges 不好理解。下面简单说明一下。

Spring Boot整合RabbitMQ开发的示例分析

交换器(Exchange)

交换器就像路由器,我们先是把消息发到交换器,然后交换器再根据路由键(routingKey)把消息投递到对应的队列。(明白这个概念很重要,后面的代码里面充分体现了这一点)

队列(Queue)

队列很好理解,就不用解释了。

绑定(Binding)

交换器怎么知道把这条消息投递到哪个队列呢?这就需要用到绑定了。大概就是:使用某个路由键(routingKey)把某个队列(Queue)绑定到某个交换器(Exchange),这样交换器就知道根据路由键把这条消息投递到哪个队列了。(后面的代码里面充分体现了这一点)

加入 RabbitMQ maven 依赖


 org.springframework.boot
 spring-boot-starter-amqp

再加入另外一个依赖(这个依赖可省略,主要是用来简化代码)


 cn.hutool
 hutool-all
 4.0.2

RabbitMQConfig.java 配置

@Configuration
public class RabbitMQConfig {

 public final static String QUEUE_NAME = "spring-boot-queue";
 public final static String EXCHANGE_NAME = "spring-boot-exchange";
 public final static String ROUTING_KEY = "spring-boot-key";

 // 创建队列
 @Bean
 public Queue queue() {
 return new Queue(QUEUE_NAME);
 }

 // 创建一个 topic 类型的交换器
 @Bean
 public TopicExchange exchange() {
 return new TopicExchange(EXCHANGE_NAME);
 }

 // 使用路由键(routingKey)把队列(Queue)绑定到交换器(Exchange)
 @Bean
 public Binding binding(Queue queue, TopicExchange exchange) {
 return BindingBuilder.bind(queue).to(exchange).with(ROUTING_KEY);
 }

 @Bean
 public ConnectionFactory connectionFactory() {
 CachingConnectionFactory connectionFactory = new CachingConnectionFactory("127.0.0.1", 5672);
 connectionFactory.setUsername("guest");
 connectionFactory.setPassword("guest");
 return connectionFactory;
 }

 @Bean
 public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
 return new RabbitTemplate(connectionFactory);
 }

}

生产者

直接调用 rabbitTemplate 的 convertAndSend 方法就可以了。从下面的代码里也可以看出,我们不是把消息直接发送到队列里面的,而是先发送到了交换器,交换器再根据路由键把我们的消息投递到对应的队列。

@RestController
public class ProducerController {

 @Autowired
 private RabbitTemplate rabbitTemplate;

 @GetMapping("/sendMessage")
 public Object sendMessage() {
 new Thread(() -> {
  for (int i = 0; i < 100; i++) {
  String value = new DateTime().toString("yyyy-MM-dd HH:mm:ss");
  Console.log("send message {}", value);
  rabbitTemplate.convertAndSend(RabbitMQConfig.EXCHANGE_NAME, RabbitMQConfig.ROUTING_KEY, value);
  }
 }).start();
 return "ok";
 }

}

消费者

消费者也很简单,只需要对应的方法上加入 @RabbitListener 注解,指定需要监听的队列名称即可。

@Component
public class Consumer {

 @RabbitListener(queues = RabbitMQConfig.QUEUE_NAME)
 public void consumeMessage(String message) {
 Console.log("consume message {}", message);
 }
}

运行项目

运行项目,然后打开浏览器,输入 http://localhost:9999/sendMessage 。在控制台就可以看到生产者在不停的的发送消息,消费者不断的在消费消息。

Spring Boot整合RabbitMQ开发的示例分析

打开 RabbitMQ web 控制台,也可以看到刚才我们在代码里面配置的交换器和队列,以及绑定信息。

Spring Boot整合RabbitMQ开发的示例分析

点击进入交换器的详情

Spring Boot整合RabbitMQ开发的示例分析

Spring Boot整合RabbitMQ开发的示例分析

感谢你能够认真阅读完这篇文章,希望小编分享的“Spring Boot整合RabbitMQ开发的示例分析”这篇文章对大家有帮助,同时也希望大家多多支持创新互联,关注创新互联行业资讯频道,更多相关知识等着你来学习!


新闻标题:SpringBoot整合RabbitMQ开发的示例分析-创新互联
网站URL:http://bzwzjz.com/article/igped.html

其他资讯

Copyright © 2007-2020 广东宝晨空调科技有限公司 All Rights Reserved 粤ICP备2022107769号
友情链接: app网站建设 网站设计 成都网站设计 成都品牌网站设计 定制网站设计 企业网站建设公司 成都网站制作 LED网站设计方案 手机网站建设 四川成都网站制作 专业网站设计 成都企业网站建设公司 重庆电商网站建设 高端网站设计推广 网站设计公司 上市集团网站建设 重庆网站建设 成都营销网站制作 成都网站设计 成都网站制作 成都网站设计公司 成都响应式网站建设公司