STOMP Protocol

柔情只为你懂 2022-09-30 10:55 173阅读 0赞

官方定义：

STOMP是一个通过中介服务器简单的可互操作的协议设计的异步消息传递给客户端。它定义了一个基于文本的有线形式为这些客户端和服务器之间的消息传递。

**以下转载至：http://diaocow.iteye.com/blog/1725186 DiaoCow   **

Stomp是一个简单的消息文本协议,它的设计核心理念就是简单与可用性，官方文档：[http://stomp.github.com/stomp-specification-1.1.html][http_stomp.github.com_stomp-specification-1.1.html]   
  
现在我们就来实践一下Stomp协议，你需要的是：   
  
1.一个支持stomp消息协议的messaging server(譬如activemq，rabbitmq）；   
2.一个终端（譬如linux shell);   
3.一些基本命令与操作（譬如nc，telnet)   
  
1.建立连接   
当我们（Client端）向服务器发送一个CONNECT Frame，就向服务器发起了一个连接请求，此时服务器端返回一个CONNECTED Frame表示建立连接成功，其中头字段version表示采用的stomp协议版本（这里默认是1.0）   
  
![fe7ab85e-7311-3dda-8e98-de5489b6cd63.jpg][]   
ps: ^@符号 ctrl+@键(用来提交请求），删除之前输入的数据 ctrl+n+backspace键   
  
当然Client端也可指定所支持的协议版本（accept-version字段，多个版本按递增顺序排列，并用逗号分隔）；   
  
![34146e53-85dc-3399-b0db-1065bc9a8678.jpg][]   
  
服务器此时返回的CONNECTED Frame中会列出它所支持的协议版本号中最高的那个（如上图的version：1.1）   
  
如果服务器端不支持客户端所列举的协议版本（比如这里的2.1），那么服务器会返回一个ERROR Frame并且列举出服务器自己所支持的协议版本（如下图的version:1.0,1.1）   
  
![c095ff8e-de28-393e-aa12-be6435f00369.jpg][]   
  
  
2.消息传递   
客户端一旦与服务器端建立连接，那么就可发送下列Frame进行消息传递

<table style="border:1px solid rgb(204,204,204); color:rgb(0,0,0); font-family:Helvetica,Tahoma,Arial,sans-serif; font-size:14px; line-height:25.2px"> 
 <tbody> 
 <tr> 
 <td style="border:1px solid rgb(204,204,204); padding:3px">SEND 发送</td> 
 </tr> 
 <tr> 
 <td style="font-size:1em; border:1px solid rgb(204,204,204); padding:3px">SUBSCRIBE 订阅</td> 
 </tr> 
 <tr> 
 <td style="font-size:1em; border:1px solid rgb(204,204,204); padding:3px">UNSUBSCRIBE 取消订阅</td> 
 </tr> 
 <tr> 
 <td style="font-size:1em; border:1px solid rgb(204,204,204); padding:3px">ACK 确认</td> 
 </tr> 
 <tr> 
 <td style="font-size:1em; border:1px solid rgb(204,204,204); padding:3px">NACK 否定</td> 
 </tr> 
 <tr> 
 <td style="font-size:1em; border:1px solid rgb(204,204,204); padding:3px">BEGIN 开始</td> 
 </tr> 
 <tr> 
 <td style="font-size:1em; border:1px solid rgb(204,204,204); padding:3px">COMMIT 提交</td> 
 </tr> 
 <tr> 
 <td style="font-size:1em; border:1px solid rgb(204,204,204); padding:3px">ABORT 取消</td> 
 </tr> 
 <tr> 
 <td style="font-size:1em; border:1px solid rgb(204,204,204); padding:3px">DISCONNECT 断开连接</td> 
 </tr> 
 </tbody> 
</table>

SEND Frame 用来将客户端消息发送到目的地（destination）,因此它必须指定一个destination头字段，另外在所有头字段之后，新起一个空行，之后就是需要发送的消息（譬如这里的 hello stomp!)   
  
![8c34b256-ae33-337c-9963-ea5c99c723a4.jpg][]    
  
此时"hello stomp!" 这条消息就被发送到了队列 my\_queue中去   
  
现在我们再起一个客户端clinet\_a，来接受这个队列（myqueue）中的消息   
  
![ac407f1a-8681-363b-95bb-e4e1306277e4.jpg][]    
  
SUBSCRIBE Frame 表示客户端希望订阅某一个目的地（destination）的消息（这里是/queue/my\_queue），其中头字段id表示在一个会话连接里，唯一标示一个订阅者（subscription），头字段destination标示该订阅者（subscription）需要订阅的目的地（这里是一个队列，/queue/my\_queue)   
  
紧接着，我们就接受到服务器端发送来的消息（MESSAGE Frame），其中message\_id:唯一标示了这条消息（后面我们会使用这个消息id进行ack,uack操作），content-length:标示消息体的长度，在所有这些头后面，新起一个空行就是消息内容（如这里的hello stomp!）   
  
如此时我们希望订阅另一个destination，该如何办呢？，是不是再发送一个SUBSCRIBE Frame就好了？   
  
![8ba4858c-f9db-3436-bfa6-cac411c57243.jpg][]    
  
结果发现服务器端返回了ERROR Frame 告诉我们SUBSCRIBE失败，原来同一个subscription id只能订阅一个destination，要想订阅令一个destination，必须先发送UNSUBSCRIBE Frame,然后再SUBSCRIBE 到新的目的地   
  
![28060320-383b-30d0-abdc-d43b871799d5.jpg][]    
  
UNSCUBSCRIBE Frame中的id标示需要取消订阅的subscription，然后我们在订阅到新的destination（这里是/queue/other\_queue),可以发现订阅成功，服务器没有再发送ERROR Frame   
  
至此，我们就模拟出了一个PTP（point-to-point）消息模型，下面我们也模拟下另外一个pub/sub消息模型：   
  
准备工作，新起两个连接订阅到/topic/my\_topic上，如下图:   
clinet\_a   
![a327f707-a6c4-3d4d-8fef-0c92865695e4.jpg][]    
  
client b   
![79dee18d-068d-36b2-8114-fda77216bab5.jpg][]    
  
Send端发送广播消息：   
![31084fbf-e343-3727-ab9b-a40240b12a1c.jpg][]    
  
我们去检查下两个消息接收客户端，果然发现收到了这条广播消息^\_^   
client a   
![12a6bb8c-a4b9-3201-9d96-aa3bdf7006ff.jpg][]    
  
client b   
![295f8b9a-b9fa-383c-b9fd-85f36562a7d4.jpg][]    
  
默认情况下，只要服务器端发送消息，就认为客户端接收成功（即ack模式为auto），若我们需要更严格的消息保证，则必须采用client模式，即由客户端确认消息的接受   
  
服务器发送了一个消息到/queue/ackqueue   
  
![c45d3ae0-2211-3fc4-b3f4-685f5a9e2ddf.jpg][]    
  
此时我们的客户端client\_a确实接受到了该消息   
  
![3e792cb6-fbbb-3f5a-a380-7e0164e4860e.jpg][]    
  
虽然该消息已经发送到客户端，但是由于该消息没有确认（ack），则该消息还保存在队列/queue/ackqueue中（直到客户端确认才删除），我们可以通过rabbitmq提供的命令来查看（sudo rabbitmqctl list\_queues name messages\_ready   messages\_unacknowledged ）：   
  
![4fdcdc0b-ad63-3d8f-86f4-7051dbce52c4.jpg][]    
  
若客户端在确认消息前与客户端断开连接，那么服务器可能(根据不同server的设计而不同)会选择将该消息发送给另一个subscription（这里是client\_b）   
  
![8dcb5910-0bd8-31cc-b47f-125b9f75c8ce.jpg][]    
  
可以看出rabbit是选择将它发送给另一个subscription， 我们在使用命令查ack\_queue队列中是否还有未确认的消息   
  
![ccf73230-1861-34e3-bdcd-bd49b5a1623a.jpg][]    
  
结果发现没有了 ^\_^   
  
若是客户端希望确认一个消息，该如何做呢？，只要发送一个ACK Frame即可!   
在ACK Frame中，subscription标示是谁确认消息，message-id标示是确认哪条消息（即MESSAGE Frame中携带的message-id）   
  
![e2307ae3-6940-3574-9d99-43354707114d.jpg][]    
  
另外我在rabbitmq的测试结果发现，ack具有累积效应，譬如接收了10条消息，如果你ack了第8条消息，那么1-7条消息都会被ack，只有9-10两条消息还保持未ack状态   
  
除了有ACK Frame，还有NACK Frame，它表示客户端未成功接收某条消息，这时候服务器可以选择重发或者丢弃（对于rabbitmq，我的测试结果是选择重发）   
  
  
3.断开连接    
说完了连接的建立，消息的发送与接收，现在我们来看看客户端如何与服务器断开连接的，更重要的是如何安全的断开连接   
  
![8294e46f-56e7-325a-8842-063928af90f4.jpg][]    
  
通过发送DISCONNNECT Frame表示向服务器发送一个断开连接请求，其中receipt表示服务器收到请求后请告知客户端，并返回一个相同的receipt-id   
  
  
至此关于Stmop绝大部分概念，我们已经实践完毕，如需更详细的还请翻阅官方文档 ^\_^

[http_stomp.github.com_stomp-specification-1.1.html]: http://stomp.github.com/stomp-specification-1.1.html
[fe7ab85e-7311-3dda-8e98-de5489b6cd63.jpg]: /images/20220706/80e6e0be820a4e95ac99b57a10662299.png
[34146e53-85dc-3399-b0db-1065bc9a8678.jpg]: /images/20220706/d892e7cdd11e4132ace8f1e49412ff38.png
[c095ff8e-de28-393e-aa12-be6435f00369.jpg]: /images/20220706/60b763e14b6d43e08d32081be35bc063.png
[8c34b256-ae33-337c-9963-ea5c99c723a4.jpg]: /images/20220706/67f4fd9f741442ad9e2aac6ea7b80c5a.png
[ac407f1a-8681-363b-95bb-e4e1306277e4.jpg]: /images/20220706/07b35a026f9444a69fe80bb3aa94553f.png
[8ba4858c-f9db-3436-bfa6-cac411c57243.jpg]: /images/20220706/e639060fdde44afea4af0e41eb9b7b4c.png
[28060320-383b-30d0-abdc-d43b871799d5.jpg]: /images/20220706/f6bdb67c86a8420aab7ce18207110559.png
[a327f707-a6c4-3d4d-8fef-0c92865695e4.jpg]: /images/20220706/4a0f5c67ee3c4e138f46bdf06878219c.png
[79dee18d-068d-36b2-8114-fda77216bab5.jpg]: /images/20220706/5b18d887e76c435da182790ee50f0572.png
[31084fbf-e343-3727-ab9b-a40240b12a1c.jpg]: /images/20220706/1d83fe258d184b31a1a942a6de889ea4.png
[12a6bb8c-a4b9-3201-9d96-aa3bdf7006ff.jpg]: /images/20220706/2925f2ae05a244b7a851cb5a72dbd2c9.png
[295f8b9a-b9fa-383c-b9fd-85f36562a7d4.jpg]: /images/20220706/d8e23f41d0104cafb3efd23f74f2899f.png
[c45d3ae0-2211-3fc4-b3f4-685f5a9e2ddf.jpg]: /images/20220706/c5a3594b9bdc496eb93faa3c9fb24e8c.png
[3e792cb6-fbbb-3f5a-a380-7e0164e4860e.jpg]: /images/20220706/c74af6859d984acca63ce156d9abee77.png
[4fdcdc0b-ad63-3d8f-86f4-7051dbce52c4.jpg]: /images/20220706/5c925dba5daf4490b81ddbb295b45fbf.png
[8dcb5910-0bd8-31cc-b47f-125b9f75c8ce.jpg]: /images/20220706/df194cf46b3d4926aecaaba0df1d327c.png
[ccf73230-1861-34e3-bdcd-bd49b5a1623a.jpg]: /images/20220706/8ffcb0c3943b4a75b1c17d0396ee4fdf.png
[e2307ae3-6940-3574-9d99-43354707114d.jpg]: /images/20220706/c342cc2a203a4115b3f6175cadc41889.png
[8294e46f-56e7-325a-8842-063928af90f4.jpg]: /images/20220706/037f2409be5e43d284645662d2fa3f8e.png