分布式消息服务RABBITMQ版-Exchange类型介绍:x-delayed-message Exchange

时间:2024-10-17 14:38:40

x-delayed-message Exchange

工作原理:

  1. 创建x-delayed-message Exchange,并指定Exchange类型,Exchange类型用于确定路由规则。支持x-delayed-message的Exchange类型为:Direct ExchangeFanout ExchangeTopic ExchangeHeader Exchange
  2. 将一个Queue绑定到某个x-delayed-message Exchange。
  3. 将消息发送给x-delayed-message Exchange时,需要设置消息的Header属性“x-delay”,“x-delay”用于指定消息延迟投递的时间,单位为毫秒。
  4. x-delayed-message Exchange接收到消息后,不会立刻投递,而是在到达延迟投递时间后才会根据Exchange类型的路由规则路由消息。

路由规则:

根据创建x-delayed-message Exchange时设定的Exchange类型的路由规则路由消息。

应用场景:

x-delayed-message Exchange适用于需要延时投递消息的场景。

应用示例:

以Exchange类型为“direct”介绍。

图5 x-delayed-message Exchange示例

如上图所示,x-delayed-message Exchange在接收到Message A后,等待100毫秒,然后将Message A发送到Queue 1和Queue 2。

support.huaweicloud.com/productdesc-rabbitmq/rabbitmq_pd_0012.html