JMS与AMQP简述以及比较

深藏阁楼爱情的钟 2022-05-11 11:18 314阅读 0赞

# 一、简述 #

### 1.**JMS**（java message service） ###

> 由Sun公司早期提出的消息标准，是一个Java平台中关于面向消息中间件（MOM）的**API**，旨在为java应用提供统一的消息操作。

> 相关概念：  
> \- 提供者：实现JMS规范的消息中间服务器  
> \- 客户端：发送或接收消息的应用程序  
> \- 生产者/发布者：创建并发送消息的客户端  
> \- 消费者/订阅者：接收并处理消息的客户端  
> \- 消息：应用程序之间传递的数据内容

JMS具有两种通信方式：  
**1.队列（点对点）模式（Point to Point）**

> 特点：

*  每个消息只有一个消费者（Consumer）(即一旦被消费，消息就不再在消息队列中)；
 *  发送者和接收者之间在时间上没有依赖性，也就是说当发送者发送了消息之后，不管接收者有没有正在运行，它不会影响到消息被发送到队列；
 *  接收者在成功接收消息之后需向队列应答成功。

![在这里插入图片描述][20190328160727203.gif]

2.**主题模式模式（Publish/Subscribe）**

> 特点：

*  一个消息可以传递个多个订阅者（即：一个消息可以有多个接受方）
 *  发布者与订阅者具有时间约束，针对某个主题（Topic）的订阅者，它必须创建一个订阅者之后，才能消费发布者的消息，而且为了消费消息，订阅者必须保持运行的状态。
 *  为了缓和这样严格的时间相关性，JMS允许订阅者创建一个可持久化的订阅。这样，即使订阅者没有被激活（运行），它也能接收到发布者的消息。

![在这里插入图片描述][2019032816074672.gif]

*注：ActiveMQ,HornetMQ是基于JMS实现的*

### 2.**AMQP**（Advanced Message Queuing Protocol） ###

> AMQP（advanced message queuing protocol）在2003年时被提出，最早用于解决金融领不同平台之间的消息传递交互问题。顾名思义，AMQP是一种协议，更准确的说是一种binary wire-level protocol（**链接协议**）。这是其和JMS的本质差别，AMQP不从API层进行限定，而是直接定义网络交换的数据格式。这使得实现了AMQP的provider天然性就是跨平台的。意味着我们可以使用Java的AMQP provider，同时使用一个python的producer加一个rubby的consumer。从这一点看，AQMP可以用http来进行类比，不关心实现的语言，只要大家都按照相应的数据格式去发送报文请求，不同语言的client均可以和不同语言的server链接。  
> 相关概念：

*  消息（Message）：消息是不具名的，它是有消息头和消息体组成。消息体是不透明的，而消息头是由一系列的可选属性组成，这些属性包括routing-key（路由键）、priority（权重）、delivery-mode（指出该消息可能需要持久化存储）等
 *  消息的生成者（Pulisher）：也是一个想交换器发布消息的客户端应用程序
 *  交换器（Exchange）：用来接收生产者发送的消息路由给服务器中的队列。它具有四种类型：direct（默认：点对点），fanout，topic，headers
 *  消息队列（Queue）：用来保存消息直到发送给消费者。它是消息的容器，也是消息的终点。一个消息可投入一个或者多个队列、消息一致在队列里面，等待消费者连接到这个队列将其取走。
 *  绑定（Binding）：用于消息队列和交换器之间的关联。一个绑定就是基于路由键将交换器和消息队列连接起来的路由规则，所以可以将路由器理解成一个由绑定构成的路由表。Exchange和Queue的绑定可以是多对多的关系。
 *  网络连接（Connection）：例如TCP连接。
 *  信道（Channel）：多路复用连接中的一条独立的双向庶几乎流通道。信道是建立在真实的TCP连接内的虚拟连接，AMQP命令都是通过信道发出去的，不管是发布消息，订阅队列还是接收消息也都是由信道完成的。因为对于操作系统来说建立和销毁TCP都是非常昂贵的开销，所以引入了信道的概念，以服用一条TCP连接。
 *  消息的消费者（Consumer）：白哦是一个从消息队列中取得消息的客户端应用程序。
 *  虚拟主机（Virtual Host）：表示一批交换器、消息队列和相关的对象。虚拟主机是共享相同的身份认证和加密环境的独立服务器域。每个virtual host本质上就是一个mini半的RabbitMQ服务器，拥有自己的队列、交换器、绑定和权限机制。virtual host 是AMQP概念的基础，必须在连接时指定，Rabbit MQ默认的Virtual Host是/。
 *  实体（Broker）：表示消息队列服务器实体。

![在这里插入图片描述][20190328160653370.png]

Exchange四种类型：  
**1.Direct**  
单播，消息中的路由键（routing-key） 如果和Binding中的binding key一致，交换器就发到对应的队列中。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JlbG9uZ2h1YW5nMTU3NDA1_size_16_color_FFFFFF_t_70]

**2.Fanout**  
广播，每个发到fanout类型交换器的消息都会分到所有绑定队列上去。fanout交换器不处理路由键，只是简单的将队列绑定到交换器上，每个发送到交换器的消息都会被转发到与该交换器绑定的所有队列上。很像子网广播，每台子网内的主机都获得了一份复制的消息。fanout类型转发消息是最快的。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JlbG9uZ2h1YW5nMTU3NDA1_size_16_color_FFFFFF_t_70 1]

**3.Topic**  
有选择的广播，topic交换器通过模式匹配分配消息的路由键属性，将路由键和某个模式进行匹配，此时队列需要绑定到一个模式上。它将路由键和绑定键的字符串分成单词，这些单词用点隔开（a.b）。它同样也会识别两个通配符：符号：\# 匹配0或者多个单词，\*匹配一个单词。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JlbG9uZ2h1YW5nMTU3NDA1_size_16_color_FFFFFF_t_70 2]

**4.headers**  
不常用

*注：RabbitMQ是基于AMQP实现的*

# 二、对比 #

<table> 
 <tbody> 
 <tr> 
 <td> &nbsp; </td> 
 <td> JMS </td> 
 <td> AMQP </td> 
 </tr> 
 <tr> 
 <td> 定义 </td> 
 <td> Java api </td> 
 <td> Wire-protocol </td> 
 </tr> 
 <tr> 
 <td> 跨语言 </td> 
 <td> 否 </td> 
 <td> 是 </td> 
 </tr> 
 <tr> 
 <td> 跨平台 </td> 
 <td> 否 </td> 
 <td> 是 </td> 
 </tr> 
 <tr> 
 <td> Model </td> 
 <td> 提供两种消息模型： （1）、Peer-2-Peer （2）、Pub/sub </td> 
 <td> 提供了五种消息模型： （1）、direct exchange （2）、fanout exchange （3）、topic change （4）、headers exchange （5）、system exchange 本质来讲，后四种和JMS的pub/sub模型没有太大差别，仅是在路由机制上做了更详细的划分； </td> 
 </tr> 
 <tr> 
 <td> 支持消息类型 </td> 
 <td> 多种消息类型： TextMessage MapMessage BytesMessage StreamMessage ObjectMessage Message （只有消息头和属性） </td> 
 <td> byte[] 当实际应用时，有复杂的消息，可以将消息序列化后发送。 </td> 
 </tr> 
 <tr> 
 <td> 综合评价 </td> 
 <td> JMS 定义了JAVA API层面的标准；在java体系中，多个client均可以通过JMS进行交互，不需要应用修改代码，但是其对跨平台的支持较差； </td> 
 <td> AMQP定义了wire-level层的协议标准；天然具有跨平台、跨语言特性。 </td> 
 </tr> 
 </tbody> 
</table>

[20190328160727203.gif]: /images/20220505/e004e0e64bd84ac8b755cb1ab406a00e.png
[2019032816074672.gif]: /images/20220505/8b2612d980084b6fa0d0d09af096cd6d.png
[20190328160653370.png]: /images/20220505/4ff49153ab6a4544a8bbac2a6ec92b9e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JlbG9uZ2h1YW5nMTU3NDA1_size_16_color_FFFFFF_t_70]: /images/20220505/b0fa8cab36c9439fbb8afcce4a6b80f9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JlbG9uZ2h1YW5nMTU3NDA1_size_16_color_FFFFFF_t_70 1]: /images/20220505/3720746a125940b2bf809c4a62b38162.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JlbG9uZ2h1YW5nMTU3NDA1_size_16_color_FFFFFF_t_70 2]: /images/20220505/b8626b1138ed4f4b80816a41025d73ac.png