目录

一、概述

二、RabbitMQ简介

三、RabbitMQ运行机制

四、RabbitMQ整合

1、启动RabbitMQ服务

2、添加交换器

3、添加消息队列

4、绑定交换器和队列

5、发送消息


本文简要介绍JMS、AMQP、RabbitMQ

一、概述

SpringBoot与消息—Rabbitmq消息队列

SpringBoot与消息—Rabbitmq消息队列

SpringBoot与消息—Rabbitmq消息队列

SpringBoot与消息—Rabbitmq消息队列

SpringBoot与消息—Rabbitmq消息队列

SpringBoot与消息—Rabbitmq消息队列

二、RabbitMQ简介

SpringBoot与消息—Rabbitmq消息队列

SpringBoot与消息—Rabbitmq消息队列

SpringBoot与消息—Rabbitmq消息队列

三、RabbitMQ运行机制

SpringBoot与消息—Rabbitmq消息队列

SpringBoot与消息—Rabbitmq消息队列

SpringBoot与消息—Rabbitmq消息队列

四、RabbitMQ整合

按照如下图所示来进行测试

SpringBoot与消息—Rabbitmq消息队列

1、启动RabbitMQ服务

这里我使用的是docker,如何安装和启动和参考我的上一篇博客【 Docker使用及安装过程中的问题

启动rabbitmq:docker start b53c7b934c9d

SpringBoot与消息—Rabbitmq消息队列

2、添加交换器

访问:http://10.12.78.3:15672/

账号:guest      密码:guest

【exchang.direct】

SpringBoot与消息—Rabbitmq消息队列

最后点击Add exchange 就会看到列表中多了我们刚刚添加的交换器

类似地创建交换器【exchang.fanout】(类型为fanout)和【exchang.topic】(类型为topic)

SpringBoot与消息—Rabbitmq消息队列

3、添加消息队列

SpringBoot与消息—Rabbitmq消息队列

以此添加这四个队列:

SpringBoot与消息—Rabbitmq消息队列

4、绑定交换器和队列

(1)绑定exchange.direct

例如:点进去exchange.direct来绑定队列(四个都绑定):

以exchange.direct绑定atguigu为例

SpringBoot与消息—Rabbitmq消息队列

全部绑定完成后如下图所示:

SpringBoot与消息—Rabbitmq消息队列

(2)绑定exchang.fanout

同样的,将exchang.fanout也分别和这四个队列绑定,方法同上

(3)绑定exchang.topic

例如【aiguigu】

SpringBoot与消息—Rabbitmq消息队列

按照最上面的图示,最终绑定为:

SpringBoot与消息—Rabbitmq消息队列

5、发送消息

(1)测试direct

Routing Key :atguigu

SpringBoot与消息—Rabbitmq消息队列

接收情况:只有atguigu队列会接收到消息

点击atguigu,可以查看到message的详情

SpringBoot与消息—Rabbitmq消息队列

(2)测试fanout

每一个队列都收到消息

(3)测试topic

匹配规则的队列会收到消息

Routing Key :atguigu

SpringBoot与消息—Rabbitmq消息队列

相关文章: