RabbitMq利用死信队列实现延时消息消费(延时队列)

在此,实现一个延迟10秒进行数据插入的功能。各位看官有具体需求具体实现,这里只用于延时如何利用rabbitmq实现消息的延迟消费。 1.首先为springIOC容器注入rabbitmq的链接池,如下图 2.然后利用链接池创建链接通道。rabbitmq对交换机、队列的操作都是基于channel通道上实现的。而channel是建立在真实的connect上的虚拟链接。获取channel通道如下图: 3.
相关文章
相关标签/搜索