列举一个延迟消息使用的场景:
在某些特殊系统订单中,一个用户下单支付之后,有3分钟使用期限, 如果3分钟之内没有使用,那么这个订单将进行异常处理,这时候就可以使用延迟队列来处理这些订单了。
这次就使用rabbitmq_delayed_message_exchange插件进行记录
以windows为例 其他操作系统请自行百度
1.下载rabbitmq_delayed_meaage_exchange
下载地址:http://www.rabbitmq.com/community-plugins.html
2 安装插件
命令: rabbitmq-plugins enable rabbitmq_delayed_message_exchange
下面为代码片段

在这里插入图片描述
rabbitmq_delayed_message_exchange插件使用记录
x-delayed-type 交换机类型 direct
durable 表示 持久化

下面为消息生产者
rabbitmq_delayed_message_exchange插件使用记录
setHeader 为延时时间 不填及为及时发送

再来一个消息消费者
rabbitmq_delayed_message_exchange插件使用记录
最后测试一下
rabbitmq_delayed_message_exchange插件使用记录
测试结果
绿色为消息数量 截屏时已消费一条 所以是5
rabbitmq_delayed_message_exchange插件使用记录

红色圈圈里不会显示数量
rabbitmq_delayed_message_exchange插件使用记录

消费的log
rabbitmq_delayed_message_exchange插件使用记录
数量为0标识已消费完毕

rabbitmq_delayed_message_exchange插件使用记录

相关文章:

  • 2021-12-29
  • 2022-01-22
  • 2021-06-28
  • 2021-09-15
  • 2022-12-23
  • 2021-11-13
  • 2021-10-10
猜你喜欢
  • 2021-12-21
  • 2021-11-28
  • 2021-11-29
  • 2021-04-29
  • 2021-07-07
  • 2022-12-23
  • 2022-12-23
相关资源
相似解决方案