天天看点

(需求实战_终章_08)SSM集成RabbitMQ 订阅模式 关键代码讲解、开发、测试

(需求实战_终章_08)SSM集成RabbitMQ 订阅模式 关键代码讲解、开发、测试
(需求实战_终章_08)SSM集成RabbitMQ 订阅模式 关键代码讲解、开发、测试
(需求实战_终章_08)SSM集成RabbitMQ 订阅模式 关键代码讲解、开发、测试
(需求实战_终章_08)SSM集成RabbitMQ 订阅模式 关键代码讲解、开发、测试

首先,confirm确认机制和return确认机制都是相对于生产者而言的,

生产者发送消息一般会有消息发送成功和消息发送失败两种场景。

生产者消息发送成功有两种情况:

一种是:消息发到了指定的消息队列中, 在指定的消息队列中可以找到信息;

另一种情况就是:消息也发送成功了,但是,没有指定路由key也就是消息发出了无法路由到指定消息队列的消息,消息会被return监听到一些关键、唯一标识性信息,例如:全局唯一ID,可以通过补偿机制,结合关键信息,重新处理此信息。

生产者消息发送失败

(需求实战_终章_08)SSM集成RabbitMQ 订阅模式 关键代码讲解、开发、测试
(需求实战_终章_08)SSM集成RabbitMQ 订阅模式 关键代码讲解、开发、测试

(需求实战_终章_08)SSM集成RabbitMQ 订阅模式 关键代码讲解、开发、测试

(需求实战_终章_08)SSM集成RabbitMQ 订阅模式 关键代码讲解、开发、测试

创建交换机

(需求实战_终章_08)SSM集成RabbitMQ 订阅模式 关键代码讲解、开发、测试
(需求实战_终章_08)SSM集成RabbitMQ 订阅模式 关键代码讲解、开发、测试

首先,confirm确认机制和return确认机制都是相对于生产者而言的,生产者发送消息一般会有消息发送成功和消息发送失败两种场景。生产者消息发送成功有两种情况:一种是:消息发到了指定的消息队列中, 在指定的消息队列中可以找到信息; 另一种情况就是:消息也发送成功了,但是,没有指定路由key也就是消息发出了无法路由到指定消息队列的消息,消息会被return监听到一些关键、唯一标识性信息,例如:全局唯一ID,可以通过补偿机制,结合关键信息,重新处理此信息。

(需求实战_终章_08)SSM集成RabbitMQ 订阅模式 关键代码讲解、开发、测试
(需求实战_终章_08)SSM集成RabbitMQ 订阅模式 关键代码讲解、开发、测试

生产者消息发送失败只有一种情况:

交换机没有创建。

为什么呢?

这个项目采用的RabbitMQ的订阅模式Topic,生产者发送消息到交换机中,消费者进行队列声明或者创建,然后,在交换机中进行队列绑定交换机操作。

(需求实战_终章_08)SSM集成RabbitMQ 订阅模式 关键代码讲解、开发、测试
(需求实战_终章_08)SSM集成RabbitMQ 订阅模式 关键代码讲解、开发、测试