消息队列（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如果把消息重新加入待消费队列的话，那么这条消息就会被重复消费了。
感谢阅读，希望对你有所帮助 :)
来源：blog.csdn.net/qq_29229567/article/details/86490519
END
题外推荐
●【301期】面试官：dubbo为什么没有采用jdk的spi机制？
●【305期】面试官：Redis用过是吧？那你讲讲Redis都有哪些监控指标？
与其在网上拼命找题？ 不如马上关注我们~
PS：因为公众号平台更改了推送规则，如果不想错过内容，记得读完点一下“在看”，加个“星标”，这样每次新文章推送才会第一时间出现在你的订阅列表里。点“在看”支持我们吧！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/8445.html
