总阅读量:次

⭐⭐⭐ Spring Boot 项目实战 ⭐⭐⭐ Spring Cloud 项目实战
《Dubbo 实现原理与源码解析 —— 精品合集》 《Netty 实现原理与源码解析 —— 精品合集》
《Spring 实现原理与源码解析 —— 精品合集》 《MyBatis 实现原理与源码解析 —— 精品合集》
《Spring MVC 实现原理与源码解析 —— 精品合集》 《数据库实体设计合集》
《Spring Boot 实现原理与源码解析 —— 精品合集》 《Java 面试题 + Java 学习指南》

摘要: 原创出处 blog.csdn.net/qq_29229567/article/details/86490519 「qq_29229567」欢迎转载，保留摘要，谢谢！

🙂🙂🙂关注**微信公众号：【芋道源码】**有福利：

  1. RocketMQ / MyCAT / Sharding-JDBC 所有源码分析文章列表
  2. RocketMQ / MyCAT / Sharding-JDBC 中文注释源码 GitHub 地址
  3. 您对于源码的疑问每条留言都将得到认真回复。甚至不知道如何读源码也可以请教噢。
  4. 新的源码解析文章实时收到通知。每周更新一篇左右。
  5. 认真的源码交流微信群。

消息队列（MessageQueue）是服务架构中常见的组件，可用于服务间解耦、事件广播、任务异步/延迟处理等，常用于分布式系统之间互相信息的传递。接下来对消息队列的实现如何满足几种消费场景进行简单阐述。

一 . 消息队列相关概念

1、生产者（Producer）： 负责产生消息；

2、消费者（Consumer）： 负责消费消息；

3、消息（Message）： 在应用间传送的数据。消息可以非常简单，比如只包含文本字符串，也可以更复杂，可能包含嵌入对象；

4、消息队列（Message Queue）： 一种应用间的通信方式，消息发送后可以立即返回，由消息系统来确保消息的可靠传递。消息发布者只管把消息发布到 MQ 中而不用管谁来取，消息使用者只管从 MQ 中取消息而不管是谁发布的。这样发布者和使用者都不用知道对方的存在。

5、消息代理（Message Broker）： 负责存储/转发消息，转发分为推和拉两种。

  • 拉是指Consumer主动从Message Broker获取消息；
  • 推是指Message Broker主动将Consumer感兴趣的消息推送给Consumer。

图片

二 . 消息队列的消费场景

1、消息至多被消费一次

该场景是最容易满足的，特点是整个消息队列吞吐量大，实现简单。适合能容忍丢消息，消息重复消费的任务。

a）Producer发送消息到Message Broker阶段：

Producer发消息给Message Broker，不要求Message Broker对接收到的消息响应确认，Producer也不用关心Message Broker是否收到消息了。

b）Message Broker存储/转发阶段：

对Message Broker的存储不要求持久性，转发消息时也不用关心Consumer是否真的收到了。

c）Consumer消费阶段：

Consumer从Message Broker中获取到消息后，可以从Message Broker删除消息，或Message Broker在消息被Consumer拿去消费时删除消息，不用关心Consumer最后对消息的处理结果。

2、消息至少被消费一次

适合不能容忍丢消息，但允许重复消费的任务。

a）Producer发送消息到Message Broker阶段：

Producer发消息给Message Broker，Message Broker必须响应对消息的确认。

b）Message Broker存储/转发阶段：

Message Broker必须提供持久性保障，转发消息时，Message Broker需要Consumer通知删除消息，才能将消息删除。

c）Consumer消费阶段：

Consumer从Message Broker中获取到消息，必须在消费完成后，Message Broker上的消息才能被删除。

3、消息仅被消费一次

适合对消息消费情况要求非常高的任务，实现较为复杂，这里的“仅被消费一次”包含如下两种场景：

1）Message Broker上存储的消息被Consumer仅消费一次，场景要求：

a）Producer发送消息到Message Broker阶段：

Producer发消息给Message Broker，不要求Message Broker对接收到的消息响应确认，Producer也不用关心Message Broker是否收到消息了。

b）Message Broker存储/转发阶段：

Message Broker必须提供持久性保障，并且每条消息在其消费队列里有唯一标识（这个唯一标识可以由Producer产生，也可以由Message Broker产生）。

c）Consumer消费阶段：

Consumer从Message Broker中获取到消息后，需要记录下消费的消息标识，以便在后续消费中防止对某个消息重复消费。比如Consumer获取到消息，消费完后，还没来得及从Message Broker删除消息，就挂了，这样Message Broker如果把消息重新加入待消费队列的话，那么这条消息就会被重复消费了。

2）Producer上产生的消息被Consumer仅消费一次，场景要求：

a）Producer发送消息到Message Broker阶段：

Producer发消息给Message Broker，Message Broker必须响应对消息的确认，并且Producer负责为该消息产生唯一标识，以防止Consumer重复消费（因为Producer发消息给Message Broker后，由于网络问题没收到Message Broker的响应，可能会重发消息给到Message Broker）。

b）Message Broker存储/转发阶段：

Message Broker必须提供持久性保障，并且每条消息在其消费队列里有唯一标识（这个唯一标识需要由Producer产生）。

c）Consumer消费阶段：

Consumer从Message Broker中获取到消息后，需要记录下消费的消息标识，以便在后续消费中防止对某个消息重复消费。比如Consumer获取到消息，消费完后，还没来得及从Message Broker删除消息，就挂了，这样Message Broker如果把消息重新加入待消费队列的话，那么这条消息就会被重复消费了。

文章目录
  1. 1. 一 . 消息队列相关概念
  2. 2. 二 . 消息队列的消费场景
    1. 2.1. 1、消息至多被消费一次
    2. 2.2. 2、消息至少被消费一次
    3. 2.3. 3、消息仅被消费一次
      1. 2.3.0.1. 1）Message Broker上存储的消息被Consumer仅消费一次，场景要求：
      2. 2.3.0.2. 2）Producer上产生的消息被Consumer仅消费一次，场景要求：