消息队列(代码片段)

关键词：

什么是消息队列

MQ全称为Message Queue 消息队列（MQ）是一种应用程序对应用程序的通信方法。MQ是消费-生产者模型的一个典型的代表，一端往消息队列中不断写入消息，而另一端则可以读取队列中的消息。消息发布者只管把消息发布到 MQ 中而不用管谁来取，消息使用者只管从 MQ 中取消息而不管是谁发布的。这样发布者和使用者都不用知道对方的存在。 

你可以想想在生活中的一种场景：当你把信件的投进邮筒，邮递员肯定最终会将信件送给收件人。我们可以把MQ比作 邮局和邮递员。 

MQ和邮局的主要区别是,它不处理消息,但是,它会接受数据、存储消息数据、转发消息

为什么使用消息队列

其实就是问问你消息队列都有哪些使用场景，然后你项目里具体是什么场景，说说你在这个场景里用消息队列是什么？

如果有人问你这个问题，期望的一个回答是说，你们公司有个什么业务场景，这个业务场景有个什么技术挑战，如果不用 MQ 可能会很麻烦，但是你现在用了 MQ 之后带给了你很多的好处。

先说一下消息队列常见的使用场景吧，其实场景有很多，但是比较核心的有 3 个：解耦、异步、削峰。

解耦

看这么个场景。A 系统发送数据到 BCD 三个系统，通过接口调用发送。如果 E 系统也要这个数据呢？那如果 C 系统现在不需要了呢？A 系统负责人几乎崩溃......

在这个场景中，A 系统跟其它各种乱七八糟的系统严重耦合，A 系统产生一条比较关键的数据，很多系统都需要 A 系统将这个数据发送过来。A 系统要时时刻刻考虑 BCDE 四个系统如果挂了该咋办？要不要重发，要不要把消息存起来？头发都白了啊！

如果使用 MQ，A 系统产生一条数据，发送到 MQ 里面去，哪个系统需要数据自己去 MQ 里面消费。如果新系统需要数据，直接从 MQ 里消费即可；如果某个系统不需要这条数据了，就取消对 MQ 消息的消费即可。这样下来，A 系统压根儿不需要去考虑要给谁发送数据，不需要维护这个代码，也不需要考虑人家是否调用成功、失败超时等情况。

总结：通过一个 MQ，Pub/Sub 发布订阅消息这么一个模型，A 系统就跟其它系统彻底解耦了。

你需要去考虑一下你负责的系统中是否有类似的场景，就是一个系统或者一个模块，调用了多个系统或者模块，互相之间的调用很复杂，维护起来很麻烦。但是其实这个调用是不需要直接同步调用接口的，如果用 MQ 给它异步化解耦，也是可以的，你就需要去考虑在你的项目里，是不是可以运用这个 MQ 去进行系统的解耦。

异步

再来看一个场景，A 系统接收一个请求，需要在自己本地写库，还需要在 BCD 三个系统写库，自己本地写库要 3ms，BCD 三个系统分别写库要 300ms、450ms、200ms。最终请求总延时是 3 + 300 + 450 + 200 = 953ms，接近 1s，用户感觉搞个什么东西，慢死了慢死了。用户通过浏览器发起请求，等待个 1s，这几乎是不可接受的。

一般互联网类的企业，对于用户直接的操作，一般要求是每个请求都必须在 200 ms 以内完成，对用户几乎是无感知的。

如果使用 MQ，那么 A 系统连续发送 3 条消息到 MQ 队列中，假如耗时 5ms，A 系统从接受一个请求到返回响应给用户，总时长是 3 + 5 = 8ms，对于用户而言，其实感觉上就是点个按钮，8ms 以后就直接返回了，爽！网站做得真好，真快！

削峰

每天 0:00 到 12:00，A 系统风平浪静，每秒并发请求数量就 50 个。结果每次一到 12:00 ~ 13:00 ，每秒并发请求数量突然会暴增到 5k+ 条。但是系统是直接基于 MySQL 的，大量的请求涌入 MySQL，每秒钟对 MySQL 执行约 5k 条 SQL。

一般的 MySQL，扛到每秒 2k 个请求就差不多了，如果每秒请求到 5k 的话，可能就直接把 MySQL 给打死了，导致系统崩溃，用户也就没法再使用系统了。

但是高峰期一过，到了下午的时候，就成了低峰期，可能也就 1w 的用户同时在网站上操作，每秒中的请求数量可能也就 50 个请求，对整个系统几乎没有任何的压力。

如果使用 MQ，每秒 5k 个请求写入 MQ，A 系统每秒钟最多处理 2k 个请求，因为 MySQL 每秒钟最多处理 2k 个。A 系统从 MQ 中慢慢拉取请求，每秒钟就拉取 2k 个请求，不要超过自己每秒能处理的最大请求数量就 ok，这样下来，哪怕是高峰期的时候，A 系统也绝对不会挂掉。而 MQ 每秒钟 5k 个请求进来，就 2k 个请求出去，结果就导致在中午高峰期（1 个小时），可能有几十万甚至几百万的请求积压在 MQ 中。

这个短暂的高峰期积压是 ok 的，因为高峰期过了之后，每秒钟就 50 个请求进 MQ，但是 A 系统依然会按照每秒 2k 个请求的速度在处理。所以说，只要高峰期一过，A 系统就会快速将积压的消息给解决掉。

消息队列有什么优缺点

优点上面已经说了，就是在特殊场景下有其对应的好处，解耦、异步、削峰。

缺点有以下几个：

• 系统可用性降低 系统引入的外部依赖越多，越容易挂掉。本来你就是 A 系统调用 BCD 三个系统的接口就好了，人 ABCD 四个系统好好的，没啥问题，你偏加个 MQ 进来，万一 MQ 挂了咋整，MQ 一挂，整套系统崩溃的，你不就完了？如何保证消息队列的高可用，可以点击这里查看。

• 系统复杂度提高 硬生生加个 MQ 进来，你怎么保证消息没有重复消费？怎么处理消息丢失的情况？怎么保证消息传递的顺序性？头大头大，问题一大堆，痛苦不已。

• 一致性问题 A 系统处理完了直接返回成功了，人都以为你这个请求就成功了；但是问题是，要是 BCD 三个系统那里，BD 两个系统写库成功了，结果 C 系统写库失败了，咋整？你这数据就不一致了。

• 如何保障数据不丢失

1. 在队列里,设置durable=true 代表队列持久化

2. 在生产者端,设置
properties = pika.BasicProperties(
delivery_mode=2, # make message persistent
)

3. 在消费者端
auto_ack = False
ch.basic_ack(delivery_tag=method.delivery_tag)

所以消息队列实际是一种非常复杂的架构，你引入它有很多好处，但是也得针对它带来的坏处做各种额外的技术方案和架构来规避掉，做好之后，你会发现，妈呀，系统复杂度提升了一个数量级，也许是复杂了 10 倍。但是关键时刻，用，还是得用的。

Kafka、ActiveMQ、RabbitMQ、RocketMQ 有什么优缺点？

一般的业务系统要引入 MQ，最早大家都用 ActiveMQ，但是现在确实大家用的不多了，没经过大规模吞吐量场景的验证，社区也不是很活跃，所以大家还是算了吧，我个人不推荐用这个了；综上，各种对比之后，有如下建议：

后来大家开始用 RabbitMQ，但是确实 erlang 语言阻止了大量的 Java 工程师去深入研究和掌控它，对公司而言，几乎处于不可控的状态，但是确实人家是开源的，比较稳定的支持，活跃度也高；

不过现在确实越来越多的公司会去用 RocketMQ，确实很不错，毕竟是阿里出品，但社区可能有突然黄掉的风险（目前 RocketMQ 已捐给 Apache，但 GitHub 上的活跃度其实不算高）对自己公司技术实力有绝对自信的，推荐用 RocketMQ，否则回去老老实实用 RabbitMQ 吧，人家有活跃的开源社区，绝对不会黄。

所以中小型公司，技术实力较为一般，技术挑战不是特别高，用 RabbitMQ 是不错的选择；大型公司，基础架构研发实力较强，用 RocketMQ 是很好的选择。

如果是大数据领域的实时计算、日志采集等场景，用 Kafka 是业内标准的，绝对没问题，社区活跃度很高，绝对不会黄，何况几乎是全世界这个领域的事实性规范。

ipc-消息队列（messagequeue）-使用(代码片段)

...IPC标识IPC键值IPC对象的访问IPC对象的权限和所有者结构体消息队列消息特性消息队列属性结构体打开或创建消息队列控制消息队列发送消息队列接收消息队列发送消息队列实例代码运行接收消息队列实例代码运行参考资料XSIIPCXSI... 查看详情

消息队列(代码片段)

消息队列MQ维基百科中是这样介绍消息队列的消息队列（Messagequeue）是一种进程间通信或同一进程的不同线程间的通信方式，软件的贮列用来处理一系列的输入，通常是来自用户。消息队列提供了异步的通信协议，每一个贮列中... 查看详情

text消息队列(代码片段)

查看详情

什么是消息队列啊？(代码片段)

大家好，我是walking，今天我们来聊一聊什么是消息队列，为什么要用消息队列，有什么好处呢？同样使用消息队列有什么坏处？我们的项目要引入消息队列了，之前只是听说使用消息队列有什么什么好处，感觉挺高大上的，自... 查看详情

mq消息队列(代码片段)

mq1、什么是消息队列1.1MQ基本框架1.2消息队列的优点1.3消息队列的缺点1.4消息队列比对2、RabbitMQ2.1、RabbitMQ如何保证消息不被重复消费2.2、RabbitMQ如何保证消息不丢失2.2.1生产者丢数据2.2.2消息队列丢数据2.2.3消费者丢数据2.3、Rabbit... 查看详情

systemvipc之消息队列(代码片段)

消息队列和共享内存、信号量一样，同属SystemVIPC通信机制。消息队列是一系列连续排列的消息，保存在内核中，通过消息队列的引用标识符来访问。使用消息队列的好处是对每个消息指定了特定消息类型，接收消息的进程可以... 查看详情

分布式之消息队列复习精讲(代码片段)

本文大概围绕如下几点进行阐述:为什么使用消息队列？使用消息队列有什么缺点?消息队列如何选型?如何保证消息队列是高可用的？如何保证消息不被重复消费?如何保证消费的可靠性传输?如何保证消息的顺序性？我们围绕以上... 查看详情

基于stream的redis消息队列(代码片段)

目录一、消息队列二、基于List结构模拟消息队列基于List的消息队列的优点：基于List的消息队列的缺点：三、基于PubSub的消息队列基于PubSub的消息队列的优点：基于PubSub的消息队列的缺点：四、基于Stream的消息队... 查看详情

rabbitmq消息队列笔记(代码片段)

...（direct）测试 主题（topic）测试死信队列消息TTL过期测试队列达到最大长度测试消息被拒绝测试延迟队列延迟队列测试延迟队列优化 插件实现延迟队列安装插件测试插件交换机RabbitMQ消息传递模型的核心思想是&#... 查看详情

rabbitmq消息队列笔记(代码片段)

...（direct）测试 主题（topic）测试死信队列消息TTL过期测试队列达到最大长度测试消息被拒绝测试延迟队列延迟队列测试延迟队列优化 插件实现延迟队列安装插件测试插件交换机RabbitMQ消息传递模型的核心思想是&#... 查看详情

消息队列rabbitmq(代码片段)

消息队列RabbitMQ 消息队列消息（Message）是指在应用间传送的数据。消息可以非常简单，比如只包含文本字符串，也可以更复杂，可能包含嵌入对象。　　消息队列（MessageQueue）是一种应用间的通信方式，消息发送后可以立即... 查看详情

rt_thread的消息队列(代码片段)

目录前言一、概念 二、实例1、消息队列控制块2、消息队列创建函数2.1、创建消息队列3、消息队列的删除函数3.1、删除消息队列4、发送消息列表函数4.1、发送消息线程4.2、创建发送消息线程五、接收消息5.1、接受消息函数5.2、... 查看详情

rt_thread的消息队列(代码片段)

目录前言一、概念 二、实例1、消息队列控制块2、消息队列创建函数2.1、创建消息队列3、消息队列的删除函数3.1、删除消息队列4、发送消息列表函数4.1、发送消息线程4.2、创建发送消息线程五、接收消息5.1、接受消息函数5.2、... 查看详情

posix消息队列(代码片段)

消息队列是LinuxIPC中很常用的一种通信方式，它通常用来在不同进程间发送特定格式的消息数据。消息队列和管道和FIFO区别　　　　1.一个进程向消息队列写入消息之前，并不需要某个进程在该队列上等待该消息的到达　　管道... 查看详情

场景应用：redis如何做消息队列？(代码片段)

文章目录Redis做消息队列消息保序处理重复的消息证消息可靠性总结Redis做消息队列因为Redis中的list是双向链表也可以当队列的特性消息队列在存取消息时，必须要满足三个需求，分别是消息保序、处理重复的消息和保证... 查看详情

rpc和消息队列(代码片段)

目录RPC和消息队列1消息队列2Rabbitmq2.1安装2.2基本使用2.3消息确认机制2.4持久化2.5闲置消费2.6发布订阅2.7关键字2.8模糊匹配2.9rabbitmq实现rpc3python中的rpc框架3.1SimpleXMLRPCServer3.2ZeroRPC实现rpcRPC和消息队列1消息队列1两个服务调用：restf... 查看详情

消息队列经典十连问，你能扛到第几问？(代码片段)

大家好呀。金三银四即将来临，整理了十道十分经典的消息队列面试题，看完肯定对面试有帮助的，大家一起加油哈~什么是消息队列消息队列的应用场景消息队列如何解决消息丢失问题消息队列如何保证消息的顺序性。消息有... 查看详情

systemv消息队列(代码片段)

文章目录1.消息队列概述2.消息队列函数2.1msgget函数2.2msgctl函数2.3msgsnd函数2.4msgrcv函数1.消息队列概述消息队列提供了一个从一个进程到另外一个进程发送一块数据的方法；每个数据块都被认为是有一个类型，接受者进程... 查看详情