消息中间件

什么是中间件？

MQ全称为Message Queue，消息队列是应用程序和应用程序之间的通信方法。
中间件是为应用程序提供操作系统所提供服务之外的服务，简化应用程序的通信、输入输出的开发，使他们专注于自己的业务逻辑。

为什么使用MQ？

在项目中，可以将一些不需要即时处理且耗时的操作提取出来，进行异步处理。
这样的操作大大减少了服务器的请求响应时间，从而提高了系统的吞吐量

应用场景？

适用于需要使用可靠的数据传送的分布式环境。

• 采用消息中间件机制的系统中，不同对象之间通过传递消息来完成对对方事件的激活，完成相应的操作。发送者将消息发送到消息服务器中，消息服务器将消息存放在若干队列中，在合适的时候再将消息发送给接收者。
• 消息中间件能在不同平台之间进行通信，常用来屏蔽平台或协议之间的特性，从而实现应用之间的协同。其优点在于能够在客户和服务器之间提供异步或是同步的连接，并且可以在任何时刻完成对消息进行传送或者存储、转发，这也是比远程过程调用更近一步的点。

在开发中消息队列的作用

• 任务【异步处理】
  将不需要同步处理且耗时长的操作由消息队列通知给消息接收方进行异步操作。
  提高了应用程序的响应时间。
• 应用程序【解耦合】
  MQ相当于一个中介，生产方通过MQ与消费方进行交互，它将应用程序进行
• 【削峰填谷】
  如订单系统，在下单的时候会有很大的数据需要写入数据库。假设数据库只能承受每秒1000的写入量，并发量超过1000数据库就会宕机。当低峰期的时候并发量只有不到100，但到高峰期却会激增至5000以上，这个时候数据库一定会崩坏。
  
  但如果在用户和订单系统之间加入一个mq，消息被保存在mq中，请求高峰时压力不会直接给到订单系统而是由mq缓存一下。比如每秒1000个数据，这样慢慢写入数据库，这样就不会卡死数据库了。
  
  使用了MQ之后，限制消费消息的速度为1000，但是这样一来，高峰期产生的数据势必会被积压在MQ中，高峰就被“削”掉了。但是因为消息积压，在高峰期过后的一段时间内，消费消息的速度还是会维持在1000QPS，直到消费完积压的消息,这就叫做“填谷”。

JMS和AMQP

消息队列有两种通信方式：分别为JMS和AMQP

JMS

JMS，Java消息服务（JavaMessage Service）应用程序接口，是一个Java平台中关于面向消息中间件（MOM）的API，用于在两个应用程序之间，或分布式系统中发送消息，进行异步通信。

AMQP

AMQP是一种协议，更准确的说是一种binary wire-level protocol（链接协议）。这是其和JMS的本质差别，AMQP不从API层进行限定，而是直接定义网络交换的数据格式。

JMS和AMQP的区别

JMS是定义了统一的接口，来对消息操作进行统一；AMQP是通过规定协议来统一数据交互的格式
JMS限定了必须使用Java语言；AMQP只是协议，不规定实现方式，因此是跨语言的。
JMS规定了两种消息模式；而AMQP的消息模式更加丰富

消息队列产品

市场上常见的消息队列有如下：

• ActiveMQ：基于JMS
• ZeroMQ：基于C语言开发
• RabbitMQ：基于AMQP协议，erlang语言开发，稳定性好
• RocketMQ：基于JMS，阿里巴巴产品
• Kafka：类似MQ的产品；分布式消息系统，高吞吐量