我是靠谱客的博主 尊敬太阳,最近开发中收集的这篇文章主要介绍rabbitmq_delayed_message_exchange插件使用记录,觉得挺不错的,现在分享给大家,希望可以做个参考。

概述

列举一个延迟消息使用的场景:
在某些特殊系统订单中,一个用户下单支付之后,有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插件使用记录所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错,欢迎将靠谱客网站推荐给程序员好友。

本图文内容来源于网友提供,作为学习参考使用,或来自网络收集整理,版权属于原作者所有。
点赞(51)

评论列表共有 0 条评论

立即
投稿
返回
顶部