需要在MQ中进行安装插件 地址链接
插件介绍地址：https://www.rabbitmq.com/blog/2015/04/16/scheduling-messages-with-rabbitmq/
作为一个新的预支付订单被初始化放置，如果该订单在指定时间内未进行支付，则将被认为超时订单进行关闭处理；电商系统中应用较多，用户购买商品产生订单，但未进行支付，订单产生30分钟内未支付将关闭订单（且满足该场景数量庞大），不可能采用人工干预。
生产者
消费者(自动绑定队列写法)
消费者(手动绑定队列写法)
最终实现效果(两个消费者)
在上述实现中，其实主要靠以下参数来帮我们实现当前功能
声明Exchange中的 type: "x-delayed-message" 这个表明当前队列为延时消息队列
声明Exchange中arguments中的 {"x-delayed-type", "topic"} 当前表明当前队列为Topic模式
最后 我们在CreateBasicProperties的Header中设置 { "x-delay", 5000 }来达到消息延时的功能(单位为ms)
如果使用当前模式来做定时任务,在要求消息不丢失的前提下，需要运维同学提供稳定的MQ环境
如有哪里讲得不是很明白或是有错误，欢迎指正 如您喜欢的话不妨点个赞收藏一下吧🙂