消息队列那点事，面试必问

傷城~ 2023-01-03 04:18 121阅读 0赞

*  一、消息模型
    
     *  点对点
     *  发布/订阅
 *  二、使用场景
    
     *  异步处理
     *  流量削锋
     *  应用解耦
 *  三、可靠性
    
     *  发送端的可靠性
     *  接收端的可靠性
 *  参考资料

# 一、消息模型 #

## 点对点 ##

消息生产者向消息队列中发送了一个消息之后，只能被一个消费者消费一次。

## 发布/订阅 ##

消息生产者向频道发送一个消息之后，多个消费者可以从该频道订阅到这条消息并消费。

发布与订阅模式和观察者模式有以下不同：

*  观察者模式中，观察者和主题都知道对方的存在；而在发布与订阅模式中，生产者与消费者不知道对方的存在，它们之间通过频道进行通信。
 *  观察者模式是同步的，当事件触发时，主题会调用观察者的方法，然后等待方法返回；而发布与订阅模式是异步的，生产者向频道发送一个消息之后，就不需要关心消费者何时去订阅这个消息，可以立即返回。

# 二、使用场景 #

## 异步处理 ##

发送者将消息发送给消息队列之后，不需要同步等待消息接收者处理完毕，而是立即返回进行其它操作。消息接收者从消息队列中订阅消息之后异步处理。

例如在注册流程中通常需要发送验证邮件来确保注册用户身份的合法性，可以使用消息队列使发送验证邮件的操作异步处理，用户在填写完注册信息之后就可以完成注册，而将发送验证邮件这一消息发送到消息队列中。

只有在业务流程允许异步处理的情况下才能这么做，例如上面的注册流程中，如果要求用户对验证邮件进行点击之后才能完成注册的话，就不能再使用消息队列。

## 流量削锋 ##

在高并发的场景下，如果短时间有大量的请求到达会压垮服务器。

可以将请求发送到消息队列中，服务器按照其处理能力从消息队列中订阅消息进行处理。

## 应用解耦 ##

如果模块之间不直接进行调用，模块之间耦合度就会很低，那么修改一个模块或者新增一个模块对其它模块的影响会很小，从而实现可扩展性。

通过使用消息队列，一个模块只需要向消息队列中发送消息，其它模块可以选择性地从消息队列中订阅消息从而完成调用。

# 三、可靠性 #

## 发送端的可靠性 ##

发送端完成操作后一定能将消息成功发送到消息队列中。

实现方法：在本地数据库建一张消息表，将消息数据与业务数据保存在同一数据库实例里，这样就可以利用本地数据库的事务机制。事务提交成功后，将消息表中的消息转移到消息队列中，若转移消息成功则删除消息表中的数据，否则继续重传。

## 接收端的可靠性 ##

接收端能够从消息队列成功消费一次消息。

两种实现方法：

*  保证接收端处理消息的业务逻辑具有幂等性：只要具有幂等性，那么消费多少次消息，最后处理的结果都是一样的。
 *  保证消息具有唯一编号，并使用一张日志表来记录已经消费的消息编号。

发表评论取消回复

表情：

评论列表（有 0 条评论，121人围观）

还没有评论，来说两句吧...

相关阅读

相关消息队列那点事，面试必问

一、消息模型点对点发布/订阅二、使用场景异步处理流量削锋应用解

傷城~/ 2023年01月03日 04:18/ 0 赞/ 122 阅读

相关面试必问Spring知识点

1、什么是Spring? Spring是一个开源框架，为简化企业级开发而生，是一个IOC(DI)和AOP容器框架。使用Spring，JavaBean就可以实现很多以前要靠

浅浅的花香味﹌/ 2022年12月11日 02:29/ 0 赞/ 285 阅读

相关关于优先队列那点事

在优先队列中，优先级高的元素先出队列。标准库默认使用元素类型的 < 操作符来确定它们之间的优先级关系。 1.用法一 priority_queue<

以你之姓@/ 2022年08月23日 11:58/ 0 赞/ 198 阅读

相关 Java面试那点事——网络200305

1. http1.0 与 http1.1 的区别？什么是 keep-alive 模式？缓存处理，在 HTTP1.0 中主要使用 header 里的 If-Modifi

落日映苍穹つ/ 2021年09月21日 03:38/ 0 赞/ 215 阅读

相关 Java面试那点事——网络200302

1. 内网和外网 IP 地址的区别？ABC 三类 IP 地址的划分区别：外网 IP 是全世界唯一的 IP 地址，仅分配给一个网络设备。公网 IP

蔚落/ 2021年09月21日 03:36/ 0 赞/ 225 阅读

相关 Java面试那点事——基础200119

1. 说一下 synchronized 底层实现原理？ 2.volatile 有是没用？synchronized 和 volatile 的区别是什么？ 3.synchron

我会带着你远行/ 2021年09月21日 02:28/ 0 赞/ 85 阅读

相关 Java面试那点事——基础200116

1. 并行和并发有什么区别？同步、异步、阻塞、非阻塞有什么区别？同步等同于阻塞吗？并行：宏观上和微观上都是多个线程一起执行，需要的是多个处理器并发：微观是多个

本是古典何须时尚/ 2021年09月21日 02:16/ 0 赞/ 309 阅读

相关 Java面试那点事——基础200112

1. 说一下 HashMap 的实现原理？底层实现：hashmap底层实现是：数组+链表+红黑树（链表元素大于8，并且数组长度大于64的时候，链表会转化为红黑树）

悠悠/ 2021年09月21日 02:06/ 0 赞/ 281 阅读

相关 Java面试那点事——基础200110

1. 说一下 jvm 有哪些垃圾回收算法？标记是通过可达性分析法，以GC Roots 对象为根节点把引用链上的对象标记标记-清除算法：分标记和清除两个部分，

水深无声/ 2021年09月21日 02:04/ 0 赞/ 265 阅读

相关消息队列面试连环问

最近我一直扎在消息队列实现细节之中无法自拔，已经写了 3 篇`Kafka源码分析`，还剩很多没肝完。之前还存着`RocketMQ源码分析`还没整理。今儿暂时先跳出来盘一盘大方向

叁歲伎倆/ 2021年09月02日 10:56/ 0 赞/ 396 阅读