目的

全部了解一下MQ结合自己多年来的疑惑

消息队列的相关

什么是MQ

消息队列(MQ)，是一种应用程序对应用程序的通信方法。应用程序通过写和检索出入列队的针对应用程序的数据(消息)来通信，而无需专用连接来链接它们。

消息传递指的是程序之间通过在消息中发送数据进行通信，而不是通过直接调用彼此来通信，直接调用通常是用于诸如远程过程调用的技术。排队指的是应用程序通过队列来通信。队列的使用除去了接收和发送应用程序同时执行的要求。

image.png

什么是JMS

*Java消息传递服务（Java Messaging Service (JMS)）
*JMS是最成功的异步消息传递技术之一。随着Java在许多大型企业应用中的使用，JMS就成为了企业系统的首选。它定义了构建消息传递系统的API。

image.png

下面是JMS的主要特性：

• 面向Java平台的标准消息传递API
• 在Java或JVM语言比如Scala、Groovy中具有互用性
• 无需担心底层协议
• 有queues和topics两种消息传递模型
• 支持事务
• 能够定义消息格式（消息头、属性和内容）

什么是AMQP

高级消息队列协议（Advanced Message Queueing Protocol (AMQP)）

JMS非常棒而且人们也非常乐意使用它。微软开发了NMS（.NET消息传递服务）来支持他们的平台和编程语言，它效果还不错。但是碰到了互用性的问题。两套使用两种不同编程语言的程序如何通过它们的异步消息传递机制相互通信呢。此时就需要定义一个异步消息传递的通用标准。JMS或者NMS都没有标准的底层协议。它们可以在任何底层协议上运行，但是API是与编程语言绑定的。AMQP解决了这个问题，它使用了一套标准的底层协议，加入了许多其他特征来支持互用性，为现代应用丰富了消息传递需求。

image.png

下面是AMQP的主要特性：

• 独立于平台的底层消息传递协议

• 消费者驱动消息传递

• 跨语言和平台的互用性

• 它是底层协议的

• 有5种交换类型direct，fanout，topic，headers，system

• 面向缓存的

• 可实现高性能

• 支持长周期消息传递

• 支持经典的消息队列，循环，存储和转发

• 支持事务（跨消息队列）

• 支持分布式事务（XA，X/OPEN，MS DTC）

• 使用SASL和TLS确保安全性

• 支持代理安全服务器

• 元数据可以控制消息流

• 不支持LVQ

• 客户端和服务端对等

• 可扩展

• 基于TCP模仿使用类似 GET POST PUT 进行交互

• AMQP模型: 发布->分拣->队列->消费->确认回执

什么是MQTT

消息队列遥测传输（Message Queueing Telemetry Transport (MQTT)）

现在我们已经有了面向基于Java的企业应用的JMS和面向所有其他应用需求的AMQP。为什么我们还需要第三种技术？它是专门为小设备设计的。计算性能不高的设备不能适应AMQP上的复杂操作，它们需要一种简单而且可互用的方式进行通信。这是MQTT的基本要求，而如今，MQTT是物联网（IOT）生态系统中主要成分之一。

image.png

• 下面是MQTT的主要特性：
• 面向流，内存占用低
• 为小型无声设备之间通过低带宽发送短消息而设计
• 不支持长周期存储和转发
• 不允许分段消息（很难发送长消息）
• 支持主题发布-订阅
• 不支持事务（仅基本确认）
• 消息实际上是短暂的（短周期）
• 简单用户名和密码，基于没有足够信息熵的安全
• 不支持安全连接
• 消息不透明
• Topic是全局的（一个全局的命名空间）
• 支持最新值队列（Last Value Queue (LVQ) ）
• 客户端和服务端不对称
• 不能扩展

总结

了解完MQ 基础知识后，后续补充实战文章。

参考

http://rabbitmq.mr-ping.com/AMQP/AMQP_0-9-1_Model_Explained.html
https://baijiahao.baidu.com/s?id=1608411516249221334&wfr=spider&for=pc
https://blog.csdn.net/dongfengkuayue/article/details/51329110