环境:Spring Boot2.3.10 + RabbitMQ 3.8.12 + Erlang 23.2.5
1.1 RabbitMQ介绍
RabbitMQ是实现了高级消息队列协议(AMQP)的开源消息代理软件(亦称面向消息的中间件)。RabbitMQ服务器是用Erlang语言编写的。所有主要的编程语言均有与代理接口通讯的客户端库。
1.2 RabbitMQ核心概念
Server:又称Broker, 接受客户端的连接,实现AMQP实体服务,这里指RabbitMQ 服务器
Connection:连接,应用程序与Broker的网络连接。
Channel:通信通道,几乎所有的操作都在 Channel 中进行,Channel是进行消息读写的通道。客户端可建立多个Channel:,每个Channel代表一个会话任务。(一个Socket连接可以创建多个Channel)
Virtual Host:虚拟主机,用于逻辑隔离,是最上层的消息路由。一个 Virtual Host 里面可以有若干个 Exchange(交换机)和 Queue(队列)。
Binding:Exchange 和 Queue 之间的虚拟绑定关系。
Routing key:一 个路由规则,虚拟机可用它来确定如何路由一个特定消息,即交换机绑定到 Queue 的键。支持模式匹配,* 和#,*用来匹配一个单词,#用来匹配多个单词(可以是0个)这里的通配符只有在exchange的类型为topic才有效。
Queue:也称为Message Queue,消息队列,保存消息并将它们转发给消费者。(接收端通过监听Queue来接受消息)。
Message:消息,服务器和应用程序之间传送的数据,由 Properties 和 Body 组成。Properties 可以对消息进行修饰,比如消息的优先级、延迟,过期时间,消息大小等高级特性;,Body 则就 是消息体内容。
Exchange类型:如下四种类型:fanout,headers,direct,topic。
1.3 Exchange交换机类型
1、 fanout发布/订阅,消费发送到该种类型的交换机后会将消息发送到所有与之绑定的Queue中,不管你有没有设置routing key。
2、 headers该类型用得极少,主要就是根据设置的header来进行匹配。如下红框中你所设置的
arguments:
3、 direct在exchange与queue进行绑定时需要设置routing key,只有发送消息的端设置的routing key与这里绑定的routingkey完全相同才会将消息发到队列中。
4、 topic
exchange与queue绑定时设置的routing key支持通配符*和#,*用来匹配一个单词,#用来匹配多个单词(可以是0个)。
1.4 使用案例
准备环境:
依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
配置文件
spring:
rabbitmq:
host: localhost
port: 5672
username: admin
password: 123456
virtual-host: /
publisherConfirmType: correlated
publisherReturns: true
listener:
simple:
concurrency: 5
maxConcurrency: 10
prefetch: 5
acknowledgeMode: MANUAL
retry:
enabled: true
initialInterval: 3000
maxAttempts: 3
defaultRequeueRejected: false
1、fanout类型交换机
- 通过RabbitMQ控制台新建fanout类型交换机:fanout-exchange
- 新建队列:fanout-queue1,fanout-queue2,fanout-queue3
按照上面的方式分别建立3个队列。
- 将fanout-exchange与3个队列(fanout-queue*)进行绑定
将3个队列分别于fanout-exchange进行绑定,这里在绑定时分别设定了不同的路由key,就是为了验证fanout类型的交换机是否与routing key有关系。
发送接口:
@RestController
@RequestMApping("/messages")
public class MessageController {
@Resource
private MessageSend ms ;
@GetMapping("/sendFanout")
public Object send(String msg) {
ms.send(msg) ;
return "success" ;
}
}
@Resource
private RabbitTemplate rabbitTemplate ;
public void send(String msg) {
logger.info("准备发送消息:{}", msg);
rabbitTemplate.convertAndSend("fanout-exchange", "rk.1.2", msg) ;
}
这里故意设置了路由key 就是为了看fanout类型的交换机是否与routing key 有关系。
3个队列都收到了消息,说明fanout类型的交换机与绑定queue时routing key是没有关系的,只要绑定了该类型的交换机都会收到消息。
2、
headers类型交换机
- 通过RabbitMQ控制台新建headers类型交换机:headers-exchange
- 新建队列:headers-queue1,headers-queue2
- 将headers-exchange与2个队列(headers-queue*)进行绑定
发送接口
@GetMapping("/sendHeaders")
public Object sendHeaders(String msg) {
ms.sendHeaders(msg) ;
return "success" ;
}
public void sendHeaders(String msg) {
logger.info("准备发送消息:{}", msg);
Message message = MessageBuilder.withBody(msg.getBytes()).setHeader("a", "b").setHeader("pack", "xg").build() ;
rabbitTemplate.send("headers-exchange", "rk.1.2", message) ;
}
注意:这里设置了Header信息与headers-exchange和headers-queue1绑定时设置的参数完全相同。
headers-queue2就没有收到消息。如果在进行绑定时没有设置x-match参数默认是完全要匹配绑定时设定的参数,也就是x-match:all。如下,如果不配置x-match也就相当于:
x-match 还有一个取值就是any,只要有任意的一个匹配上那就成功。
修改headers-queue1,headers-queue2绑定的参数,如下:
两个参数中都加入了x-match:any 只要有任意一个参数匹配即可。
再次发送消息:
两个队列都收到了消息。
3、
direct类型交换机
- 通过RabbitMQ控制台新建direct类型交换机:direct-exchange
- 新建队列:direct-queue1,direct-queue2
- 将direct-exchange与2个队列(direct-queue*)进行绑定
发送接口:
@GetMapping("/sendDirect")
public Object sendDirect(String msg) {
ms.sendDirect(msg) ;
return "success" ;
}
public void sendDirect(String msg) {
logger.info("准备发送消息:{}", msg);
rabbitTemplate.convertAndSend("direct-exchange", "de.m", msg) ;
}
2个队列都收到了消息。
4、
topic类型交换机
- 通过RabbitMQ控制台新建topic类型交换机:topic-exchange
- 新建队列:topic-queue1,topic-queue2
- 将topic-exchange与2个队列(topic-queue*)进行绑定
*: 只能匹配一个单词;#:能匹配多个单词(也可以是0个)。
发送接口:
@GetMapping("/sendTopic")
public Object sendTopic(String msg) {
ms.sendTopic(msg) ;
return "success" ;
}
public void sendTopic(String msg) {
logger.info("准备发送消息:{}", msg);
rabbitTemplate.convertAndSend("topic-exchange", "te.1.ok", msg) ;
}
两个队列都收到了消息。
修改发送消息的routing key
rabbitTemplate.convertAndSend("topic-exchange", "te.2.ok", msg) ;
只有topic-queue2收到了消息,因为绑定时设置的routing-key 是:
能够匹配多个单词。
以上就介绍完了rabbitmq的四种交换机类型。
完毕!!!
声明:本站部分内容及图片来自互联网,转载是出于传递更多信息之目的,内容观点仅代表作者本人,如有任何标注错误或版权侵犯请与我们联系(Email:2595517585@qq.com),我们将及时更正、删除,谢谢。