概述
列举一个延迟消息使用的场景:
在某些特殊系统订单中,一个用户下单支付之后,有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插件使用记录所遇到的程序开发问题。
如果觉得靠谱客网站的内容还不错,欢迎将靠谱客网站推荐给程序员好友。
本图文内容来源于网友提供,作为学习参考使用,或来自网络收集整理,版权属于原作者所有。
发表评论 取消回复