标签:插件 get 队列 RabbitMQ 延时 推送 延迟
延时消息推送的应用场景想必大家都不陌生:
- 自动收货
- 订单10分钟后自动取消
废话不多说,直接上代码。在 RabbitMQ 3.6.x 开始,RabbitMQ官方提供了延迟队列的插件,可以下载放置到RabbitMQ 根目录下的 plugins 下。延迟队列插件下载地址:https://github.com/rabbitmq/rabbitmq-delayed-message-exchange
maven依赖如下
application.properties如下
MQ的配置如下
我们在 Exchange 的声明中可以设置exchange.setDelayed(true)来开启延迟队列。以上就是各种配置信息,接下来我们来看producer和consumer。
生产者
消费者
我们来测试一下效果,我们期望6秒后可以收到消息。
从单元测试来看是没问题的,证明我们的延时消息推送功能正常。
标签:插件,get,队列,RabbitMQ,延时,推送,延迟 来源: https://blog.csdn.net/wangchengming1/article/details/120740776
本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享; 2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关; 3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关; 4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除; 5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。