【311期】面试官:谈谈消息队列(MessageQueue)

>>强大,10k+点赞的 SpringBoot 后台管理系统竟然出了详细教程!

【311期】面试官:谈谈消息队列(MessageQueue)

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

一 . 消息队列相关概念

1、生产者(Producer): 负责产生消息;

2、消费者(Consumer): 负责消费消息;

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

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

5、消息代理(Message Broker): 负责存储/转发消息,转发分为推和拉两种。

  • 拉是指Consumer主动从Message Broker获取消息;
  • 推是指Message Broker主动将Consumer感兴趣的消息推送给Consumer。
【311期】面试官:谈谈消息队列(MessageQueue)

二 . 消息队列的消费场景

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

题外推荐

推荐一个“摸鱼程序员”聚集地


【311期】面试官:谈谈消息队列(MessageQueue)

【301期】面试官:dubbo为什么没有采用jdk的spi机制?

【302期】面试官:幂等性的接口该如何设计?

【303期】如何理解算法中的时间复杂度?

【304期】堆排序算法(图解详细流程)

【305期】面试官:Redis用过是吧?那你讲讲Redis都有哪些监控指标?

【306期】面试官:解决集群环境下定时任务多次执行的办法有哪些?

【307期】面试官:什么是NIO?NIO的原理是什么?


与其在网上拼命找题? 不如马上关注我们~

【311期】面试官:谈谈消息队列(MessageQueue)

PS:因为公众号平台更改了推送规则,如果不想错过内容,记得读完点一下“在看”,加个“星标”,这样每次新文章推送才会第一时间出现在你的订阅列表里。“在看”支持我们吧!

原文始发于微信公众号(Java面试题精选):【311期】面试官:谈谈消息队列(MessageQueue)