RabbitMQ:交换机(Exchange)

发布于:2025-08-20 ⋅ 阅读:(54) ⋅ 点赞:(0)


一、概述

RabbitMQ最简单的实现流程如下:首先生产者将消息推送至RabbitMQ服务,然后经过交换机,队列等各种关系,将数据处理入列后,最终由消费者获取对应监听的消息。

在这里插入图片描述
常用的交换机有以下六种,因为消费者是从队列获取信息的,队列是绑定交换机的(一般),所以对应的消息推送/接收模式也会有以下几种:

  • Direct Exchange (直连型交换机)
  • Fanout Exchange(扇型交换机)
  • Topic Exchange(主题交换机)
  • Header Exchange(头交换机)
  • Default Exchange(默认交换机)
  • Dead Letter Exchange(死信交换机)

二、Direct Exchange (直连型交换机)

直连型交换机,也可以叫做定向交换机。根据消息携带的路由键将消息投递给对应的队列。

大致流程:有一个队列绑定了一个直连交换机,同时赋予了一个路由键routing key。然后当一个消息携带路由值为X,这个消息通过生产者发送给交换机时,交换机就会根据这个路由值X去寻找绑定值也是X的队列。

RabbitMQ:SpringAMQP Direct Exchange(直连型交换机)

三、Fanout Exchange(扇型交换机)

扇型交换,也可以叫做广播交换机。这个交换机没有路由的概念,就算绑定了路由键也是无视的。交换机在接收到消息后,会直接转发到绑定到它上面的所有队列上。

RabbitMQ:SpringAMQP Fanout Exchange(扇型交换机)

四、Topic Exchange(主题交换机)

主题交换机,这个交换机跟直接交换机流程差不多,但是它的特点就是它的路由键跟绑定键是有规则的

  1. * (星号) 用来表示一个单词 (必须出现的)
  2. # (井号) 用来表示任意数量(零个或多个)单词

通配的绑定键是跟队列进行绑定的,举个小例子
队列Q1 绑定键为 *.TT.* 队列Q2绑定键为 TT.#
如果一条消息携带的路由键为 A.TT.B,那么队列Q1将会收到;
如果一条消息携带的路由键为TT.AA.BB,那么队列Q2将会收到;

总结:

  1. 当一个队列的绑定键为 “#”(井号) 的时候,这个队列将会无视消息的路由键,接收所有的消息
  2. * (星号) # (井号) 这两个特殊字符都未在绑定键中出现的时候,此时主题交换机就拥有的直连交换机的行为。

所以主题交换机也就实现了扇形交换机的功能,和直连交换机的功能。

RabbitMQ:SpringAMQP Topic Exchange(主题交换机)

五、Header Exchange(头交换机)

六、Default Exchange(默认交换机)

七、Dead Letter Exchange(死信交换机)


网站公告

今日签到

点亮在社区的每一天
去签到