消息队列MQ

2026年9月18日星期五·782 字·4 分钟·
-浏览量
微服务与中间件消息队列MQ
AI 摘要- DeepSeek

消息队列是采用“异步(两个微服务并不需要同时完成请求)”的方式来传递数据完成业务操作流程的业务处理方式

消息队列MQ - 封面图

消息队列#

消息队列(Message Queue)简称MQ

消息队列是采用“异步(两个微服务并不需要同时完成请求)”的方式来传递数据完成业务操作流程的业务处理方式

为什么要使用消息队列#

微服务项目普通存在远程调用的关系，这些操作时同步的

这里的“同步”指：消费者A调用生产者B之后，A的线程会进入阻塞状态，等待生产者B运行结束返回之后，A才能运行之后的代码

Dubbo消费者发送调用后进入阻塞状态，这个状态表示该线程仍占用内存资源，但是什么动作都不做，如果生产者运行耗时比较久，消费者就会一直等待，如果消费者利用这个时间可以处理更多请求，业务整体效率会提升。

实际情况下，Dubbo有些必要的返回值必须等待，但是不必要等待的服务返回值，我们可以不等待去做别的事情，这种情况下我们就要使用消息队列

消息队列的经典使用场景#

异步调用#

image-20230218113405252
image-20230218113405252

服务解耦#

image-20230218113824118
image-20230218113824118

流量削峰(削峰填谷)#

image-20230218114321731
image-20230218114321731
延迟处理时间

面试题#

消息队列的特征(作用)#

  • 利用异步的特性，提供服务器的运行效率，减少因为远程调用出现的线程等待\阻塞
  • 削峰填谷：在并发峰值超过当前系统处理能力时，我们将没处理的信息保存到消息队列中，在后面出现的比较空闲的时间中去处理，直到所有数据一次处理完成，能够放置在并发高峰值短时间大量请求而导致的系统不稳定
  • 消息队列的延时：因为是异步执行，请求的发起者并不知道消息何时能处理完成，如果业务不能接受这种延迟，就不要使用消息队列

消息队列异常处理#

问：消息队列运行时发生异常，没有完成业务，怎么通知消息的发送者，完成数据的回滚？

当消息队列中发生异常时，在异常处理的代码中，我们可以向消息的发送者发送消息，然后通知发送者处理。消息的发送者接收到消息后，一般要手写代码回滚，如果回滚代码过程中再发送异常，可以将这信息直接给“死信队列”

死信队列没有任何处理者，通常情况下会有专人周期性的处理死信队列的消息

常见消息队列软件#

  • kafka：性能好\功能弱，适合大数据量，高并发的情况，大数据临湖使用较多
  • RabbitMQ：功能强\性能一般，适合发送业务需求复杂的消息队列，java业务中使用较多
  • RocketMQ：阿里的
  • ActiveMQ：前几年流行的，老项目可能用到
消息队列MQ
https://blog.fileoz.com/posts/mq-message-queue-basics/
作者
MIAOWU
发布于
2026-09-18
许可协议
CC BY-NC-SA 4.0

相关文章

Kafka集群MQ
消息队列-RabbitMQ

评论区

欢迎在评论区留言交流

动作模组
等待模型加载…
看板娘
公告
公告大版本更新

一口气全面统一博客样式，移除部分冗余导航页面，更专注内容展示。

公告稳定性修复一批

统一Swup生命周期（BUG更少了、牺牲了首屏部分性能）、升级astro 7（构建速度翻倍）、文章封面图片加载（更流畅）、更换音乐播放器 API（更稳定）等多个问题，站点更稳了。

公告互换友链

欢迎各位大佬互换友链，要求内容原创、稳定更新。申请前请先看友链页的说明，期待和你交换链接。

查看详情
公告关于我的介绍

欢迎来到我的博客，我是深耕java、python和agent技术开发。热爱技术、持续学习，欢迎同好交流探讨。

查看详情
音乐
封面

音乐

暂未播放

0:00
0:00
暂无歌词

日历

正在加载日历...

--

    最近节日

    正在加载日历...
    ----

    最近生日/纪念日

    正在加载日历...
    ----
    距月底--
    距年底--

    隐私政策

    更新日期： 2026 年 7 月 15 日
    生效日期： 2026 年 7 月 15 日

    适用范围#

    本政策适用于 MiaoWu 的博客（以下简称“本站”）。本站是个人博客，用于发布和分享内容；不提供账户注册、支付、定位或广告投放服务。访问本站、发表文章评论或在留言板留言前，请阅读本政策。

    信息收集与使用#

    本站只在提供内容、评论和留言功能，以及维护站点安全所需的范围内处理信息。

    • 访问与统计信息：访问页面时，统计服务可能处理访问时间、页面地址、来源页、浏览器和设备相关信息，用于了解内容访问情况、排查故障和改进站点。
    • 评论信息：使用文章评论功能时，Waline 可能处理您主动提交的昵称、邮箱、站点链接和评论内容；还可能处理 IP 地址等必要信息，用于防止垃圾评论、滥用和维护服务安全。评论内容、昵称和站点链接（如填写）可能公开展示在文章下方；邮箱不会公开展示。
    • 留言信息：留言板使用 Waline /guestbook/ 频道。Waline 可能处理您主动提交的昵称、可选邮箱、站点链接、留言内容和图片，以及浏览器、操作系统、IP 地址等必要的反滥用信息。默认情况下，留言图片以内嵌数据随留言提交；如站点维护者配置了远程图片上传接口，图片会先发送至该接口并在留言中保存返回的图片地址。留言内容、昵称、图片和站点链接（如填写）可能公开展示；邮箱和 IP 地址不会在留言板公开展示。

    请不要在评论或留言中提交身份证件、银行卡、住址、密码或其他不必要的敏感个人信息。

    第三方服务#

    为实现本站功能，以下第三方会在各自服务范围内处理相关数据：

    • Umami：用于匿名化的网站访问统计和出站链接点击统计，帮助我了解本站的使用情况。
    • Waline：用于文章评论、留言板及访问量统计。服务会按照其自身规则处理您在评论或留言时提交的信息及必要的反滥用信息。
    • Cloudflare：可为本站提供静态资源分发和域名基础设施。
    • unpkg：用于加载 Waline 的前端脚本、样式和表情资源；请求这些资源时，您的浏览器会与该服务建立连接。

    第三方服务可能有独立的隐私政策和数据保存规则。请在使用相关功能前查阅其规则；本站无法控制其独立的数据处理活动。

    本站主要使用浏览器本地存储（Local Storage 或 Session Storage）保存使用偏好，例如主题颜色、明暗模式、文章列表视图和音乐播放设置。留言板会在本地保存匿名资料、未发送草稿和登录状态，以便恢复输入与会话；管理员登录状态仅保存在当前会话。

    本站不主动设置用于广告定向的第一方 Cookie。评论、统计或资源服务可能按照其自身规则使用 Cookie 或类似技术。您可以通过浏览器设置查看、删除或限制 Cookie 和本地存储；清除后，部分偏好或互动状态可能会恢复为默认值，评论功能也可能受到影响。

    信息公开、保存与安全#

    评论和留言属于公开互动内容，提交后可能被搜索引擎收录、被他人引用或在缓存中短暂保留。请谨慎决定发布内容。除非您提出删除请求、内容违反规则或法律法规另有要求，公开内容会持续保留以维持讨论上下文。

    本站会采取合理措施保护数据安全，包括使用 HTTPS、输入校验、内容转义和访问频率限制。但互联网传输和第三方服务均无法保证绝对安全，请理解并自行承担公开发布信息的相应风险。

    你的权利#

    你可以通过 996491835@qq.com 联系我，申请查询、更正或删除由本站直接保存的评论、留言或相关公开内容。为保护他人权益，请在请求中提供足以定位内容的信息，并说明你与该内容的关系；必要时可能需要进行合理核验。

    对于由 Waline、Umami、Cloudflare 或 unpkg 独立处理的数据，你也可以直接向对应服务提供方行使相关权利。删除公开评论或留言后，第三方缓存、搜索引擎索引或他人转载的副本可能无法立即同步删除。

    未成年人条款#

    未满 14 周岁的未成年人应在监护人同意和指导下使用本站的评论、留言等互动功能。监护人如发现未成年人未经同意提交了个人信息，可通过上述联系方式与我联系，我会在合理范围内协助处理。

    政策更新与联系#

    我可能因本站功能或适用规则变化更新本政策，更新后的版本将在本站公布并标明日期。继续使用相关功能即表示你已阅读并理解更新后的政策。

    如对本政策或数据处理有疑问，请联系 996491835@qq.com。

    用户协议

    更新日期： 2026 年 5 月 19 日
    生效日期： 2026 年 5 月 19 日

    适用范围#

    本协议适用于你访问 MiaoWu 的博客，以及使用文章评论、留言板等互动功能的行为。继续浏览本站或提交评论、留言，即表示你已阅读、理解并同意遵守本协议及本站的隐私政策。

    评论及留言规则#

    请在交流中保持友善、理性和尊重。你不得利用本站发布、传播或实施以下行为：

    • 发布任何违反中华人民共和国法律法规的内容。
    • 发布任何侵犯他人合法权益的内容，包括但不限于隐私、名誉、肖像、著作权、商标权和其他知识产权。
    • 恶意攻击、辱骂、骚扰、威胁、歧视其他用户或任何第三方。
    • 发布垃圾广告、恶意推广、刷屏、灌水，或与讨论主题明显无关的重复内容。
    • 利用本站进行网络诈骗、钓鱼、传播恶意软件，或发布可能危害网络和信息安全的内容。
    • 绕越或试图绕越本站的审核、限流、封禁等管理措施。
    • 冒充他人、伪造身份，或收集、公开他人的个人信息。

    内容与访问管理#

    你应对自己发布的评论和留言负责，并保证拥有发布该等内容所需的合法权利。论坛管理员有权在不另行通知的情况下删除违规内容、限制或封禁违规账号，或限制其继续使用本站互动功能。

    如发现涉嫌违法犯罪、严重侵权或危及本站安全的内容，本站可保留相关记录，并在法律法规要求或必要时向有关部门提供协助。对管理措施有疑问时，可通过文末联系方式说明情况；本站会结合实际情况处理，但不承诺恢复已删除内容或访问权限。

    知识产权与内容授权#

    本站原创文章、页面设计和其他受保护内容的权利归作者或权利人所有。未经授权，请勿复制、转载、镜像或用于商业用途；法律法规允许的合理使用除外。

    你发布评论或留言时，授予本站为展示、存储、备份、审核、删除和维护互动功能所必需的非独占、免费的使用许可。该许可不改变你对原创内容依法享有的权利。

    免责声明#

    本站内容仅用于个人记录、学习交流和一般信息参考，不构成任何专业意见、承诺或担保。你应结合自身情况独立判断，并对据此采取的行动负责。

    评论、留言和外部链接中的内容由其发布者或运营者负责，不代表本站立场。本站会在合理范围内处理明显违规内容，但不保证所有内容均及时发现，也不对第三方网站的可用性、内容、安全性或隐私实践承担责任。

    因网络故障、不可抗力、第三方服务异常、维护升级或超出合理控制范围的原因导致本站暂时无法访问、内容延迟或数据丢失的，本站会尽力恢复，但不承担由此产生的间接损失。

    未成年人条款#

    未满 14 周岁的未成年人应在监护人同意和指导下使用评论、留言等互动功能。监护人应协助未成年人理解本协议，并对其使用行为进行必要的引导。

    其他条款#

    我可以根据本站功能、管理需要或法律法规变化更新本协议，更新后的版本将在本站公布并标明日期。继续使用本站即视为接受更新后的协议。

    本协议的订立、执行和解释适用中华人民共和国法律。因本协议或使用本站产生争议时，双方应先友好协商；协商不成的，依法向有管辖权的人民法院解决。

    如对本协议或内容管理有疑问，请联系 996491835@qq.com。

    复制成功，转载请标注本文地址