MQ
MQ的定义
百度百科定义：MQ（Message Queue）消息队列，是基础数据结构中“先进先出”的一种数据结构。一般用来解决应用解耦，异步消息，流量削峰等问题，实现高性能，高可用，可伸缩和最终一致性架构。指把要传输的数据（消息）放在队列中，用队列机制来实现消息传递——生产者产生消息并把消息放入队列，然后由消费者去处理。消费者可以到指定队列拉取消息，或者订阅相应的队列，由MQ服务端给其推送消息。
MQ是面向消息的中间件（message-oriented middleware0）MOM，能够很好的解决以上的问题。
MQ是指利用高效可靠的消息传递机制进行与平台无关的数据交流，并基于数据通信来进行分布式系统的集成。
通过提供消息传递和消息排队模型在分布式环境下提供应用解耦，弹性伸缩，冗余存储，流量削峰，异步通信，数据同步等。
大致流程
发送者把消息发给消息服务器，消息服务器把消息存放在若干队列/主题中，在合适的时候，消息服务器会把消息转发给接受者。
在这个过程中，发送和接受是异步的,也就是发送无需等待，发送者和接受者的生命周期也没有必然关系。
在发布pub/订阅sub模式下，也可以完成一对多的通信，可以让一个消息有多个接受者。如微信订阅号。
MQ的作用
微服务架构后，链式调用是我们在写程序时候的一般流程，为了这完成一个整体功能会把它拆分成多个函数（或子模块）比如模块A调用模块B，模块B调用模块C，模块C调用模块D。但是大型分布式应用中，系统间的RPC交互复杂，一个功能后面要调用上百个接口并非不可能，从单机架构过渡到分布式微服务架构，这样的架构会产生许多问题。
根据上面的的问题，在设置系统时可以明确要克到的目标：
1、要做到系统解耦，当新的模块进来时，可以做到代码改动最小；能够解耦。
2、设置流程缓冲池，可以让后端系统按自身吞吐能力进行消费，不被冲垮；能够削峰。
3、强弱依赖梳理能把非关键调用链路的操作异步化并提升整体系统的吞吐能力；能够异步。
MQ的特点
异步处理模式
消息发送者可以发送一个消息而无需等待响应。消息发送者把消息发送到一条虚拟的通道（主题或队列）上。
消息接收者则订阅或监听该通道。一条信息可能最络转发给一个或多个消息接收者，这些接收者都无需对消息发送者做出回应。整个过程都是异步的。
案例：也就是说，一个系统和另一个系统这间进行通信的时候，假如系统A希望发送一个消息给系统B，让它去处理，但是系统A不关注系统B到底怎么处理或者有没有处理好，所以系统A把消息发送给MQ，然后就不管这条消息的”死活”了，接着系统B从MQ里面消费出来处理即可。至于怎么处理，是否处理完毕，什么时候处理，都是系统B的事，与系统A无关。
这样的一种通信方式，就是所谓的“异步”通信方式，对于系统A来说，只要把消息发给MQ，然后系统B就会异步处去进行处理了，系统A不能”同步”的等待系统B处理完。这样的好处是解耦。
应用系统的解耦
发送者和接收者不必了解对方，只需要确认消息。发送者和接收者不必同时在线。
现实中的业务
ActiveMQ
ActiveMQ 是 Apache 出品，最流行的，能力强劲的开源消息总线。ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现，尽管JMS规范出台已经是很久的事情了，但是JMS在当今的J2EE应用中间仍然扮演着特殊的地位。
主要特点：
1、多种语言和协议编写客户端。语言：Java、C、C++、C#、Ruby、Perl、Python、PHP。应用协议：OpenWire、Stomp REST、WS Notification、XMPP、AMQP。
2、完全支持JMS1.1和J2EE 1.4规范（持久化、XA消息、事务）。
3、对Spring的支持，ActiveMQ可以很容易内嵌到使用Spring的系统里面去，而且也支持Spring2.0的特性。
4、通过了常见J2EE服务器（如 Geronimo、JBoss 4、GlassFish、WebLogic）的测试，其中通过JCA 1.5 resourceadaptors的配置，可以让ActiveMQ可以自动的部署到任何兼容J2EE1.4 商业服务器上。
5、支持多种传送协议：in-VM、TCP、SSL、NIO、UDP、JGroups、JXTA。
6、支持通过JDBC和journal提供高速的消息持久化。
7、从设计上保证了高性能的集群、客户端-服务器、点对点。
8、支持Ajax。
9、支持与Axis（Apache Extensible Interaction System 即Apache可扩展交互系统。Axis本质上就是一个SOAP引擎，提供创建服务器端、客户端和网关SOAP操作的基本框架）的整合。
10、可以很容易得调用内嵌JMS provider，进行测试。
11、支持集群。
评论区