如何用.NetCore实现RabbitMQ死信队列和延时队列处理长尾词?
- 内容介绍
- 文章标签
- 相关推荐
本文共计3432个文字,预计阅读时间需要14分钟。
目录
一、死信队列
二、延时队列
三、延时消息设置不同过期时间
四、延时消息使用延时插件实现
一、死信队列
Q1:死信队列绑定了x-dead-letter-exchange到X2,x-dead-letter为dead-letter。目录
- 一、死信队列
- 二、延时队列
- 三、延时消息设置不同过期时间
- 四、延时消息用延时插件的方式实现
一、死信队列
描述:Q1队列绑定了x-dead-letter-exchange(死信交换机)为X2,x-dead-letter-routing-key(死信路由key)指向Q2(队列2)
P(生产者)发送消息经X1(交换机1)路由到Q1(队列1),Q1的消息触发特定情况,自动把消息经X2(交换机2)路由到Q2(队列2),C(消费者)直接消息Q2的消息。
特定情况有哪些呢:
- 1.消息被拒(basic.reject or basic.nack)并且没有重新入队(requeue=false);
- 2.当前队列中的消息数量已经超过最大长度(创建队列时指定" x-max-length参数设置队列最大消息数量)。
本文共计3432个文字,预计阅读时间需要14分钟。
目录
一、死信队列
二、延时队列
三、延时消息设置不同过期时间
四、延时消息使用延时插件实现
一、死信队列
Q1:死信队列绑定了x-dead-letter-exchange到X2,x-dead-letter为dead-letter。目录
- 一、死信队列
- 二、延时队列
- 三、延时消息设置不同过期时间
- 四、延时消息用延时插件的方式实现
一、死信队列
描述:Q1队列绑定了x-dead-letter-exchange(死信交换机)为X2,x-dead-letter-routing-key(死信路由key)指向Q2(队列2)
P(生产者)发送消息经X1(交换机1)路由到Q1(队列1),Q1的消息触发特定情况,自动把消息经X2(交换机2)路由到Q2(队列2),C(消费者)直接消息Q2的消息。
特定情况有哪些呢:
- 1.消息被拒(basic.reject or basic.nack)并且没有重新入队(requeue=false);
- 2.当前队列中的消息数量已经超过最大长度(创建队列时指定" x-max-length参数设置队列最大消息数量)。

