跳到主要内容

服务异步通信-高级篇

消息队列在使用过程中，面临着很多实际问题需要思考：

image-20210718155003157

1.消息可靠性

消息从发送，到消费者接收，会经理多个过程：

image-20210718155059371

其中的每一步都可能导致消息丢失，常见的丢失原因包括：

  • 发送时丢失：
    • 生产者发送的消息未送达exchange
    • 消息到达exchange后未到达queue
  • MQ宕机，queue将消息丢失
  • consumer接收到消息后未消费就宕机

针对这些问题，RabbitMQ分别给出了解决方案：

  • 生产者确认机制
  • mq持久化
  • 消费者确认机制
  • 失败重试机制

下面我们就通过案例来演示每一个步骤。

首先，导入课前资料提供的demo工程：

image-20210718155328927

项目结构如下：

image-20210718155448734

1.1.生产者消息确认​

RabbitMQ提供了publisher confirm机制来避免消息发送到MQ过程中丢失。这种机制必须给每个消息指定一个唯一ID。消息发送到MQ以后，会返回一个结果给发送者，表示消息是否处理成功。