springBoot对接多个mq并且实现延迟队列---未完待续

mq调用流程

创建统一消息转换器

创建exchange交换机：普通交换机、延迟交换机、死信交换机

创建master的connection

创建slave的connection

创建队列A:  分为普通队列、延迟队列、死信队列

创建队列B: 分为普通队列、延迟队列、死信队列

创建队列C: 分为普通队列、延迟队列、死信队列

创建master的消息监听RabbitListenerContainerFactory

后续使用注解 @RabbitListener 时指定ListenerContainerFactory

@RabbitListener(queues = DEAD_LETTER_QUEUE_B, containerFactory = "masterListenerContainerFactory")

创建slave的消息监听RabbitListenerContainerFactory

后续使用注解 @RabbitListener 时指定ListenerContainerFactory

@RabbitListener(queues = DEAD_LETTER_QUEUE_B, containerFactory = "slaveListenerContainerFactory")

创建普通队列监听器

创建延迟消息监听器

注意：因为采用的死信队列实现的延迟效果，所以此处直接监听对应死信队列即可