sping boot 集成 rabbitmq

  • 小编 发布于 2019-12-09 02:37:42
  • 栏目:科技
  • 来源:全栈研究者
  • 6972 人围观

说起消息队列,我们听到的是rabbitmq activemq kafka最为常见;

生产者,消费者,队列,交换机,topic,解耦,异步,削峰等常见的名词;

今天就spring boot 集成 rabbit mq温习下知识点,rabbitmq可以在官网下载安装,默认端口15672:

spring boot 的概念不懂的可以看我前面的文章,实在不懂可以留言私信交流;

rabbitmq 我们主要掌握的是两个知识点一个是交换机,一个是消息队列;

我们知道生成者发送给消费者消息的时候是通过rabbitmq的交换机到消息队列,然后消息队列的消息被消费者消费的这样一个过程

rabbitmq的交换机几种模式是重点:

1 direct (直连)路由键 和绑定键 匹配上,消息会携带路由键发送,匹配对应的队列名字;(路由键可以和队列名字相同也可以不同,前提是消息队列绑定交换器------消息队列的初始化)

2 fanout(扇形)广播形式

3 topic(主题)可以涵盖上述两种形式 路由键 * 代表一个单词 #代表0个或多个单词;

废话不多说,代码上理解,pom文件

<!--rabbitmq-->

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-amqp</artifactId>

</dependency>

<!--web-->

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-web</artifactId>

</dependency>

生产者发送消息的时候,要指定交换器,路由键值,消息信息;

消费者监听某一个队列来消费消息;

A 直连模式

(1)消息队列初始化

sping boot 集成 rabbitmq

消息队列初始化

(2)发送消息


sping boot 集成 rabbitmq

生产者发送消息


(3)接收消息


sping boot 集成 rabbitmq

消费者消费消息

B 扇形模式(广播形式)

无路由键

(1)消息队列初始化

sping boot 集成 rabbitmq

消息队列初始化

(2)发送消息



sping boot 集成 rabbitmq

生产者发送消息


(3)接收消息


sping boot 集成 rabbitmq

某一个消息队列消费消息

B 主题模式

(1)消息队列初始化

sping boot 集成 rabbitmq

消息队列初始化

(2)发送消息



sping boot 集成 rabbitmq

生产者发送消息


(3)接收消息


sping boot 集成 rabbitmq

消费者消费消息


sping boot 集成 rabbitmq

消费者消费消息2

总结,首先初始化消息队列和交换机,然后用路由键绑定消息队列到指定的交换器上;

当生产者发送消息的时候会携带路由键,发送指定的交换器再到消费者;有上述三种形式;

最常用的spring boot 集成rabbitmq 如此简单;如有疑问欢迎留言私信交流,要源码的小伙伴可与我联系;


sping boot 集成 rabbitmq

spring 给程序员带来了春天

转载请说明出处:五号时光网 ©