环境:Spring Boot2.3.10 + RabbitMQ 3.8.12 + Erlang 23.2.5
RabbitMQ是实现了高级消息队列协议(AMQP)的开源消息代理软件(亦称面向消息的中间件)。RabbitMQ服务器是用Erlang语言编写的。所有主要的编程语言均有与代理接口通讯的客户端库。
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。
图片
fanout
发布/订阅,消费发送到该种类型的交换机后会将消息发送到所有与之绑定的Queue中,不管你有没有设置routing key。
headers
该类型用得极少,主要就是根据设置的header来进行匹配。如下红框中你所设置的arguments:
图片
direct
在exchange与queue进行绑定时需要设置routing key,只有发送消息的端设置的routing key与这里绑定的routingkey完全相同才会将消息发到队列中。
topic
exchange与queue绑定时设置的routing key支持通配符*和#,*用来匹配一个单词,#用来匹配多个单词(可以是0个)。
准备环境:
依赖
<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:5672username: admin password:123456virtual-host:/publisherConfirmType: correlated publisherReturns:truelistener:simple: concurrency:5maxConcurrency:10prefetch:5acknowledgeMode: MANUAL retry: enabled:trueinitialInterval:3000maxAttempts:3defaultRequeueRejected: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")publicclass MessageController {@Resourceprivate MessageSend ms;@GetMapping("/sendFanout")publicObject send(String msg){ ms.send(msg);return"success";} }@Resourceprivate RabbitTemplate rabbitTemplate;publicvoid 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")publicObject sendHeaders(String msg){ ms.sendHeaders(msg);return"success";}publicvoid 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")publicObject sendDirect(String msg){ ms.sendDirect(msg);return"success";}publicvoid 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")publicObject sendTopic(String msg){ ms.sendTopic(msg);return"success";}publicvoid 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的四种交换机类型。