当前位置:首页 > 科技  > 软件

SpringBoot整合RabbitMQ四种交换机类型详解

来源: 责编: 时间:2023-08-14 22:01:41 276观看
导读环境:Spring Boot2.3.10 + RabbitMQ 3.8.12 + Erlang 23.2.51.1 RabbitMQ介绍RabbitMQ是实现了高级消息队列协议(AMQP)的开源消息代理软件(亦称面向消息的中间件)。RabbitMQ服务器是用Erlang语言编写的。所有主要的编程语

环境:Spring Boot2.3.10 + RabbitMQ 3.8.12 + Erlang 23.2.5nSE28资讯网——每日最新资讯28at.com

1.1 RabbitMQ介绍

RabbitMQ是实现了高级消息队列协议(AMQP)的开源消息代理软件(亦称面向消息的中间件)。RabbitMQ服务器是用Erlang语言编写的。所有主要的编程语言均有与代理接口通讯的客户端库。nSE28资讯网——每日最新资讯28at.com

1.2 RabbitMQ核心概念

Server:又称Broker, 接受客户端的连接,实现AMQP实体服务,这里指RabbitMQ 服务器nSE28资讯网——每日最新资讯28at.com

Connection:连接,应用程序与Broker的网络连接。nSE28资讯网——每日最新资讯28at.com

Channel:通信通道,几乎所有的操作都在 Channel 中进行,Channel是进行消息读写的通道。客户端可建立多个Channel:,每个Channel代表一个会话任务。(一个Socket连接可以创建多个Channel)nSE28资讯网——每日最新资讯28at.com

Virtual Host:虚拟主机,用于逻辑隔离,是最上层的消息路由。一个 Virtual Host 里面可以有若干个 Exchange(交换机)和 Queue(队列)。nSE28资讯网——每日最新资讯28at.com

Binding:Exchange 和 Queue 之间的虚拟绑定关系。nSE28资讯网——每日最新资讯28at.com

Routing key:一 个路由规则,虚拟机可用它来确定如何路由一个特定消息,即交换机绑定到 Queue 的键。支持模式匹配,* 和#,*用来匹配一个单词,#用来匹配多个单词(可以是0个)这里的通配符只有在exchange的类型为topic才有效。nSE28资讯网——每日最新资讯28at.com

Queue:也称为Message Queue,消息队列,保存消息并将它们转发给消费者。(接收端通过监听Queue来接受消息)。nSE28资讯网——每日最新资讯28at.com

Message:消息,服务器和应用程序之间传送的数据,由 Properties 和 Body 组成。Properties 可以对消息进行修饰,比如消息的优先级、延迟,过期时间,消息大小等高级特性;,Body 则就 是消息体内容。nSE28资讯网——每日最新资讯28at.com

Exchange类型:如下四种类型:fanout,headers,direct,topic。nSE28资讯网——每日最新资讯28at.com

图片图片nSE28资讯网——每日最新资讯28at.com

nSE28资讯网——每日最新资讯28at.com

1.3 Exchange交换机类型

  • fanout

发布/订阅,消费发送到该种类型的交换机后会将消息发送到所有与之绑定的Queue中,不管你有没有设置routing key。nSE28资讯网——每日最新资讯28at.com

  • headers

该类型用得极少,主要就是根据设置的header来进行匹配。如下红框中你所设置的arguments:nSE28资讯网——每日最新资讯28at.com

图片图片nSE28资讯网——每日最新资讯28at.com

nSE28资讯网——每日最新资讯28at.com

  • direct

在exchange与queue进行绑定时需要设置routing key,只有发送消息的端设置的routing key与这里绑定的routingkey完全相同才会将消息发到队列中。nSE28资讯网——每日最新资讯28at.com

  • topic
exchange与queue绑定时设置的routing key支持通配符*和#,*用来匹配一个单词,#用来匹配多个单词(可以是0个)。

1.4 使用案例

准备环境:nSE28资讯网——每日最新资讯28at.com

依赖nSE28资讯网——每日最新资讯28at.com

<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>

配置文件nSE28资讯网——每日最新资讯28at.com

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类型交换机nSE28资讯网——每日最新资讯28at.com

  • 通过RabbitMQ控制台新建fanout类型交换机:fanout-exchange

图片图片nSE28资讯网——每日最新资讯28at.com

nSE28资讯网——每日最新资讯28at.com

  • 新建队列:fanout-queue1,fanout-queue2,fanout-queue3

图片图片nSE28资讯网——每日最新资讯28at.com

nSE28资讯网——每日最新资讯28at.com

按照上面的方式分别建立3个队列。nSE28资讯网——每日最新资讯28at.com

  • 将fanout-exchange与3个队列(fanout-queue*)进行绑定

图片图片nSE28资讯网——每日最新资讯28at.com

将3个队列分别于fanout-exchange进行绑定,这里在绑定时分别设定了不同的路由key,就是为了验证fanout类型的交换机是否与routing key有关系。nSE28资讯网——每日最新资讯28at.com

  • 测试

发送接口:nSE28资讯网——每日最新资讯28at.com

@RestController@RequestMapping("/messages")public class MessageController {  @Resource  private MessageSend ms ;  @GetMapping("/sendFanout")  public Object send(String msg) {    ms.send(msg) ;    return "success" ;}}@Resourceprivate RabbitTemplate rabbitTemplate ;public void send(String msg) {  logger.info("准备发送消息:{}", msg);  rabbitTemplate.convertAndSend("fanout-exchange", "rk.1.2", msg) ;}

这里故意设置了路由key 就是为了看fanout类型的交换机是否与routing key 有关系。nSE28资讯网——每日最新资讯28at.com

图片图片nSE28资讯网——每日最新资讯28at.com

3个队列都收到了消息,说明fanout类型的交换机与绑定queue时routing key是没有关系的,只要绑定了该类型的交换机都会收到消息。nSE28资讯网——每日最新资讯28at.com

2、headers类型交换机nSE28资讯网——每日最新资讯28at.com

  • 通过RabbitMQ控制台新建headers类型交换机:headers-exchange

图片图片nSE28资讯网——每日最新资讯28at.com

  • 新建队列:headers-queue1,headers-queue2

图片图片nSE28资讯网——每日最新资讯28at.com

  • 将headers-exchange与2个队列(headers-queue*)进行绑定

图片图片nSE28资讯网——每日最新资讯28at.com

  • 测试

发送接口nSE28资讯网——每日最新资讯28at.com

@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绑定时设置的参数完全相同。nSE28资讯网——每日最新资讯28at.com

图片图片nSE28资讯网——每日最新资讯28at.com

headers-queue2就没有收到消息。如果在进行绑定时没有设置x-match参数默认是完全要匹配绑定时设定的参数,也就是x-match:all。如下,如果不配置x-match也就相当于:nSE28资讯网——每日最新资讯28at.com

图片图片nSE28资讯网——每日最新资讯28at.com

x-match 还有一个取值就是any,只要有任意的一个匹配上那就成功。nSE28资讯网——每日最新资讯28at.com

修改headers-queue1,headers-queue2绑定的参数,如下:nSE28资讯网——每日最新资讯28at.com

图片图片nSE28资讯网——每日最新资讯28at.com

两个参数中都加入了x-match:any 只要有任意一个参数匹配即可。nSE28资讯网——每日最新资讯28at.com

再次发送消息:nSE28资讯网——每日最新资讯28at.com

图片图片nSE28资讯网——每日最新资讯28at.com

两个队列都收到了消息。nSE28资讯网——每日最新资讯28at.com

3、direct类型交换机nSE28资讯网——每日最新资讯28at.com

  • 通过RabbitMQ控制台新建direct类型交换机:direct-exchange

图片图片nSE28资讯网——每日最新资讯28at.com

  • 新建队列:direct-queue1,direct-queue2

图片图片nSE28资讯网——每日最新资讯28at.com

  • 将direct-exchange与2个队列(direct-queue*)进行绑定

图片图片nSE28资讯网——每日最新资讯28at.com

  • 测试

发送接口:nSE28资讯网——每日最新资讯28at.com

@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) ;}

图片nSE28资讯网——每日最新资讯28at.com

2个队列都收到了消息。nSE28资讯网——每日最新资讯28at.com

4、topic类型交换机nSE28资讯网——每日最新资讯28at.com

  • 通过RabbitMQ控制台新建topic类型交换机:topic-exchange

图片图片nSE28资讯网——每日最新资讯28at.com

  • 新建队列:topic-queue1,topic-queue2

图片图片nSE28资讯网——每日最新资讯28at.com

  • 将topic-exchange与2个队列(topic-queue*)进行绑定

图片图片nSE28资讯网——每日最新资讯28at.com

*: 只能匹配一个单词;#:能匹配多个单词(也可以是0个)。nSE28资讯网——每日最新资讯28at.com

  • 测试

发送接口:nSE28资讯网——每日最新资讯28at.com

@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) ;}

图片图片nSE28资讯网——每日最新资讯28at.com

两个队列都收到了消息。nSE28资讯网——每日最新资讯28at.com

修改发送消息的routing keynSE28资讯网——每日最新资讯28at.com

rabbitTemplate.convertAndSend("topic-exchange", "te.2.ok", msg) ;

图片图片nSE28资讯网——每日最新资讯28at.com

只有topic-queue2收到了消息,因为绑定时设置的routing-key 是:nSE28资讯网——每日最新资讯28at.com

图片图片nSE28资讯网——每日最新资讯28at.com

能够匹配多个单词。nSE28资讯网——每日最新资讯28at.com

以上就介绍完了rabbitmq的四种交换机类型。nSE28资讯网——每日最新资讯28at.com

本文链接:http://www.28at.com/showinfo-26-5752-0.htmlSpringBoot整合RabbitMQ四种交换机类型详解

声明:本网页内容旨在传播知识,若有侵权等问题请及时与本网联系,我们将在第一时间删除处理。邮件:2376512515@qq.com

上一篇: 谷歌全栈多平台应用开发神器Project IDX来了!PaLM 2加持,代码效率翻倍

下一篇: 前端请求大比拼:Fetch、Axios、Ajax、XHR

标签:
  • 热门焦点
Top