列举一个延迟消息使用的场景:
在某些特殊系统订单中,一个用户下单支付之后,有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
下面为代码片段
在这里插入图片描述

x-delayed-type 交换机类型 direct
durable 表示 持久化
下面为消息生产者

setHeader 为延时时间 不填及为及时发送
再来一个消息消费者

最后测试一下

测试结果
绿色为消息数量 截屏时已消费一条 所以是5

红色圈圈里不会显示数量

消费的log

数量为0标识已消费完毕

最后
以上就是尊敬太阳最近收集整理的关于rabbitmq_delayed_message_exchange插件使用记录的全部内容,更多相关rabbitmq_delayed_message_exchange插件使用记录内容请搜索靠谱客的其他文章。
本图文内容来源于网友提供,作为学习参考使用,或来自网络收集整理,版权属于原作者所有。
发表评论 取消回复