小伙伴们最近有没有看到这样一个视频：一位人民警察陈警官在某音上开直播并和其他主播连线？有人会想了，一名警察，咋也开起直播来了？是真警察还是假警察啊？不会是诈骗吧？巧了，还真不是诈骗，这位陈警官恰好是为了宣传国家反诈中心APP才开直播并和其他主播连线的。他首先说服和他对连的主播，让ta试图相信自己连线到了一位真警察。有些主播很淡定并且很配合，自己先下载了这个APP，然后和ta的粉丝们说要听警察的话，都下载这个APP（话不多说，这是应该有的正能量）。而有些主播就不淡定了，陈警官连线时发生了很多好玩搞笑的事，例如有些主播情急之下竟然向陈警官自首了。陈警官一脸懵，随后才反应过来(内心PS：今天有收获啊~)

“咋？说说你干啥诈骗的事了？”那位自首的主播说：我是个良民，我一直正能量，我没干啥坏事，就是看到警察紧张~(快要哭的样子，说实话我隔着屏幕看到他那个样子就很想笑图片)咳咳，跑题了，话说你下载国家反诈中心APP了吗？没有的话，要不你也找陈警官和你连线聊一聊？

说到普及和宣传，让我想到了消息传播，陈警官用连线的方法把消息传递给视频对面的主播，主播再通过粉丝观看直播而接收到陈警官的消息：你下载国家反诈中心APP了吗？这相当于一个发送者通过中间人把消息传递给更多的消费者。诶？这不是有点像消息队列吗？(不知道这个举例恰不恰当~)

那么问题来了，消息队列是个啥？

消息队列：即MessageQueue，简称“MQ”，又称“报文队列”，是存储消息的容器，可以进行异步传输。所谓“消息”，是在两台计算机之间传送的数据单位。消息可以很简单，例如只包含文本字符串，也可以很复杂，例如包含嵌入对象。

消息被发送到队列中，消息队列管理器在消息源传送到消息目标中充当中间人。队列的主要目的是提供路由并保证消息的传递；如果发送消息时接收者不可用，消息队列会保留消息，直到可以成功发送。

编程中为啥要使用MQ？(你也可以不用~)

消息队列是分布式系统中重要的组件之一。使用消息队列的三点好处：

1、通过异步处理提高系统性能（减少响应时间）

比如，用户提交订单后，订单数据写入消息队列，不立即返回用户告知订单提交成功，而是需要在消息队列的订单消费者进程真正处理完该订单后，甚至出库后，再通过电子邮件或短信告知用户订单成功，以免造成交易纠纷。类似我们平时手机订火车票、电影票等。

先将短时间内高并发产生的事务消息存储在消息队列中，然后后端服务再根据自己的业务逻辑去消费这些消息，这样可以避免后端服务因事务带来的压力出现崩溃等情况。

举个栗子：在电子商务一些秒杀、促销活动中，合理使用消息队列可以有效抵御促销活动刚开始涌入大量订单而对系统产生冲击。

消息发送者(客户端) -> 发送消息到消息队列中，即结束对消息的处理 -> 消息接受者(服务器)按照相关业务去消息队列中取出消息进行后续处理。

说白了：不需要和其他系统有耦合，接受者不需要知道消息从何而来，对新增业务，只要对该类消息感兴趣，即可订阅该消息，对原有系统和业务无影响，从而实现网站业务的可扩展性。

讲到消息队列，不得不说说JMS(JAVA Message Service，java消息服务，进行异步消息传输)模式，它提供了两种常用消息模式：点对点订阅模式、发布-订阅模式。

点对点(P2P)订阅模式：就是一个消息只有一个消费者。使用队列(Queue)作为消息通信载体。

发布-订阅模式(Pub/Sub)：使用主题（Topic）作为消息通信载体，类似广播模式。消息发送者发布消息，该消息通过主题传递给一个/多个订阅者，在一条消息广播后才订阅的用户收不到该条信息。发布和订阅二者之间没有直接耦合性，使用场景：解耦的特定业务环境下。

聊一聊JMS：JMS定义的是API规范，在Java体系中，多个客户端可以通过JMS进行交互，不需要修改应用代码，但JMS不支持跨平台，也不支持跨语言。它支持5种不同的消息类型，允许我们发送并接收一些不同类型的数据：

还有一种消息队列，是AMQP(Advanced Message QueuingProtocol，高级消息队列协议，也是二进制应用层协议)，一个提供统一消息服务的应用层标准，为消息定义了线路层(wire-level protocol)。看到这儿，想必就知道它是一个协议。它是应用层协议的一个开放标准，为面向消息的中间件设计，兼容JMS。

优点：基于该协议的客户端与消息中间件可传递消息，不受语言和平台等条件的限制。RabbitMQ就是基于AMQP协议实现的。

缺点：只支持byte[] (二进制)的消息类型，复杂的类型可序列化后发送。

上面提到JMS只支持两种消息模型，而AMQP就比较腻害了，由于Exchange提供的路由算法，AMQP可以提供多样化的路由方法传递消息到消息队列，它提供了5种消息模型：

本质来讲，后四种和 JMS 的pub/sub 模型没有太大差别，仅是在路由机制上做了更详细的划分。

（内心PS：看起来挺厉害的样子！我孤陋寡闻了~~）

那么，要是消息队列的服务器宕机了，我们存储到其中的数据会咋样呢？

为避免消息队列服务器宕机而造成消息丢失，会将成功发送到消息队列的消息——备份到消息生产者服务器中(相当于创建了副本)——等消息真正被消费者服务器处理后才删除消息。于是，在消息队列服务器宕机后，生产者服务器会选择分布式消息队列服务器集群中的其他服务器发布信息，以保证消息正常发送给消费者。

介绍完消息队列的好处，聊一聊它会带来哪些问题？

①系统可用性降低：使用MQ之后，需要考虑消息丢失、MQ挂掉等情况，系统可用性在某种程度上会受到损失；

②系统复杂性提高：使用MQ需要保证消息没有被重复消费、保证消息传递的顺序性等情况；

③一致性问题：消息队列可以实现异步，提高了系统的响应速度，但是如果消息的消费者没有正确消费消息，则会导致数据不一致的情况。

今天先简单了解了消息队列，对于其中具体的消息队列，比如ActiveMQ、RabbitMQ、RocketMQ、Kafka等具体常见的消息队列，作为一名软件编程的小学生，我还有待学习，希望看到这篇文章的各位同行老师们多多指点，在此抱拳了！

言归正传，你下载国家反诈中心APP了吗？不光要下载，还需要实名认证，不然的话，就相当于枪没上子弹!!!

【喜欢就点个关注吧~微信公众号同名哦~】