Stomp协议以及debug方法
2016-03-12 23:33
309 查看
http://blog.csdn.net/zsomsom/article/details/27076249 http://blog.csdn.net/yinwenjie/article/details/50698695 (一系列文章)
http://www.cnblogs.com/xuelu/p/3812817.html
Stomp是一个简单的消息文本协议,它的设计核心理念就是简单与可用性,官方文档:http://stomp.github.io/
现在我们就来实践一下Stomp协议,你需要的是:
1.一个支持stomp消息协议的messaging server(譬如activemq,rabbitmq);
2.一个终端(譬如linux shell);
3.一些基本命令与操作(譬如nc,telnet)
1.建立连接
当我们(Client端)向服务器发送一个CONNECT Frame,就向服务器发起了一个连接请求,此时服务器端返回一个CONNECTED Frame表示建立连接成功,其中头字段version表示采用的stomp协议版本(这里默认是1.0)
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/d9416e7e60eb911121d4fe6d4549af86.jpg)
ps: ^@符号 ctrl+@键(用来提交请求),删除之前输入的数据 ctrl+n+backspace键
当然Client端也可指定所支持的协议版本(accept-version字段,多个版本按递增顺序排列,并用逗号分隔);
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/c735b4abcc1e70491b60cde91e6ffaf8.jpg)
服务器此时返回的CONNECTED Frame中会列出它所支持的协议版本号中最高的那个(如上图的version:1.1)
如果服务器端不支持客户端所列举的协议版本(比如这里的2.1),那么服务器会返回一个ERROR Frame并且列举出服务器自己所支持的协议版本(如下图的version:1.0,1.1)
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/057b6bdf5929f8484fbf72d26e801867.jpg)
2.消息传递
客户端一旦与服务器端建立连接,那么就可发送下列Frame进行消息传递
SEND Frame 用来将客户端消息发送到目的地(destination),因此它必须指定一个destination头字段,另外在所有头字段之后,新起一个空行,之后就是需要发送的消息(譬如这里的 hello stomp!)
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/f19c02ad4670175b8aa50b7f0052e344.jpg)
此时"hello stomp!" 这条消息就被发送到了队列 my_queue中去
现在我们再起一个客户端clinet_a,来接受这个队列(myqueue)中的消息
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/8ff74e7f8cbf74d9bd886283d6ddabef.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就好了?
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/097b344c7c45e2f6bcac8f932bd28ce3.jpg)
结果发现服务器端返回了ERROR Frame 告诉我们SUBSCRIBE失败,原来同一个subscription id只能订阅一个destination,要想订阅令一个destination,必须先发送UNSUBSCRIBE Frame,然后再SUBSCRIBE 到新的目的地
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/e0d96609c451f528595a77ec9998542d.jpg)
UNSCUBSCRIBE Frame中的id标示需要取消订阅的subscription,然后我们在订阅到新的destination(这里是/queue/other_queue),可以发现订阅成功,服务器没有再发送ERROR Frame
至此,我们就模拟出了一个PTP(point-to-point)消息模型,下面我们也模拟下另外一个pub/sub消息模型:
准备工作,新起两个连接订阅到/topic/my_topic上,如下图:
clinet_a
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/d6d898583570b45a809034063ce99884.jpg)
client b
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/7d09cbe0ce6691ef5d9a834ca655f416.jpg)
Send端发送广播消息:
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/621db4101949ed99c122acfdba5d7b6c.jpg)
我们去检查下两个消息接收客户端,果然发现收到了这条广播消息^_^
client a
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/75cf8f7cb3163b089d292a721833e283.jpg)
client b
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/ed6eb87bb30857daa693594c4955ffc5.jpg)
默认情况下,只要服务器端发送消息,就认为客户端接收成功(即ack模式为auto),若我们需要更严格的消息保证,则必须采用client模式,即由客户端确认消息的接受
服务器发送了一个消息到/queue/ackqueue
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/fa1552dc923665c3b1946937fb31244a.jpg)
此时我们的客户端client_a确实接受到了该消息
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/062eb41bf5227bba2dd157158ce53be3.jpg)
虽然该消息已经发送到客户端,但是由于该消息没有确认(ack),则该消息还保存在队列/queue/ackqueue中(直到客户端确认才删除),我们可以通过rabbitmq提供的命令来查看(sudo rabbitmqctl list_queues name messages_ready messages_unacknowledged):
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/5051093cb6e27f08d0e2ddd6e5a500d1.jpg)
若客户端在确认消息前与客户端断开连接,那么服务器可能(根据不同server的设计而不同)会选择将该消息发送给另一个subscription(这里是client_b)
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/bcf8f43fdad0df5132b38328435aaa4d.jpg)
可以看出rabbit是选择将它发送给另一个subscription, 我们在使用命令查ack_queue队列中是否还有未确认的消息
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/8dcf9db0afab4f3ec5d244f423f04818.jpg)
结果发现没有了 ^_^
若是客户端希望确认一个消息,该如何做呢?,只要发送一个ACK Frame即可!
在ACK Frame中,subscription标示是谁确认消息,message-id标示是确认哪条消息(即MESSAGE Frame中携带的message-id)
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/71fad5d181c67475fd107e3624b13458.jpg)
另外我在rabbitmq的测试结果发现,ack具有累积效应,譬如接收了10条消息,如果你ack了第8条消息,那么1-7条消息都会被ack,只有9-10两条消息还保持未ack状态
除了有ACK Frame,还有NACK Frame,它表示客户端未成功接收某条消息,这时候服务器可以选择重发或者丢弃(对于rabbitmq,我的测试结果是选择重发)
3.断开连接
说完了连接的建立,消息的发送与接收,现在我们来看看客户端如何与服务器断开连接的,更重要的是如何安全的断开连接
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/44bbfc5d76597b8db7fb84411830b1e2.jpg)
通过发送DISCONNNECT Frame表示向服务器发送一个断开连接请求,其中receipt表示服务器收到请求后请告知客户端,并返回一个相同的receipt-id
http://www.cnblogs.com/xuelu/p/3812817.html
Stomp是一个简单的消息文本协议,它的设计核心理念就是简单与可用性,官方文档:http://stomp.github.io/
现在我们就来实践一下Stomp协议,你需要的是:
1.一个支持stomp消息协议的messaging server(譬如activemq,rabbitmq);
2.一个终端(譬如linux shell);
3.一些基本命令与操作(譬如nc,telnet)
1.建立连接
当我们(Client端)向服务器发送一个CONNECT Frame,就向服务器发起了一个连接请求,此时服务器端返回一个CONNECTED Frame表示建立连接成功,其中头字段version表示采用的stomp协议版本(这里默认是1.0)
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/d9416e7e60eb911121d4fe6d4549af86.jpg)
ps: ^@符号 ctrl+@键(用来提交请求),删除之前输入的数据 ctrl+n+backspace键
当然Client端也可指定所支持的协议版本(accept-version字段,多个版本按递增顺序排列,并用逗号分隔);
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/c735b4abcc1e70491b60cde91e6ffaf8.jpg)
服务器此时返回的CONNECTED Frame中会列出它所支持的协议版本号中最高的那个(如上图的version:1.1)
如果服务器端不支持客户端所列举的协议版本(比如这里的2.1),那么服务器会返回一个ERROR Frame并且列举出服务器自己所支持的协议版本(如下图的version:1.0,1.1)
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/057b6bdf5929f8484fbf72d26e801867.jpg)
2.消息传递
客户端一旦与服务器端建立连接,那么就可发送下列Frame进行消息传递
SEND |
SUBSCRIBE |
UNSUBSCRIBE |
ACK |
NACK |
BEGIN |
COMMIT |
ABORT |
DISCONNECT |
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/f19c02ad4670175b8aa50b7f0052e344.jpg)
此时"hello stomp!" 这条消息就被发送到了队列 my_queue中去
现在我们再起一个客户端clinet_a,来接受这个队列(myqueue)中的消息
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/8ff74e7f8cbf74d9bd886283d6ddabef.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就好了?
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/097b344c7c45e2f6bcac8f932bd28ce3.jpg)
结果发现服务器端返回了ERROR Frame 告诉我们SUBSCRIBE失败,原来同一个subscription id只能订阅一个destination,要想订阅令一个destination,必须先发送UNSUBSCRIBE Frame,然后再SUBSCRIBE 到新的目的地
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/e0d96609c451f528595a77ec9998542d.jpg)
UNSCUBSCRIBE Frame中的id标示需要取消订阅的subscription,然后我们在订阅到新的destination(这里是/queue/other_queue),可以发现订阅成功,服务器没有再发送ERROR Frame
至此,我们就模拟出了一个PTP(point-to-point)消息模型,下面我们也模拟下另外一个pub/sub消息模型:
准备工作,新起两个连接订阅到/topic/my_topic上,如下图:
clinet_a
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/d6d898583570b45a809034063ce99884.jpg)
client b
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/7d09cbe0ce6691ef5d9a834ca655f416.jpg)
Send端发送广播消息:
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/621db4101949ed99c122acfdba5d7b6c.jpg)
我们去检查下两个消息接收客户端,果然发现收到了这条广播消息^_^
client a
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/75cf8f7cb3163b089d292a721833e283.jpg)
client b
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/ed6eb87bb30857daa693594c4955ffc5.jpg)
默认情况下,只要服务器端发送消息,就认为客户端接收成功(即ack模式为auto),若我们需要更严格的消息保证,则必须采用client模式,即由客户端确认消息的接受
服务器发送了一个消息到/queue/ackqueue
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/fa1552dc923665c3b1946937fb31244a.jpg)
此时我们的客户端client_a确实接受到了该消息
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/062eb41bf5227bba2dd157158ce53be3.jpg)
虽然该消息已经发送到客户端,但是由于该消息没有确认(ack),则该消息还保存在队列/queue/ackqueue中(直到客户端确认才删除),我们可以通过rabbitmq提供的命令来查看(sudo rabbitmqctl list_queues name messages_ready messages_unacknowledged):
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/5051093cb6e27f08d0e2ddd6e5a500d1.jpg)
若客户端在确认消息前与客户端断开连接,那么服务器可能(根据不同server的设计而不同)会选择将该消息发送给另一个subscription(这里是client_b)
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/bcf8f43fdad0df5132b38328435aaa4d.jpg)
可以看出rabbit是选择将它发送给另一个subscription, 我们在使用命令查ack_queue队列中是否还有未确认的消息
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/8dcf9db0afab4f3ec5d244f423f04818.jpg)
结果发现没有了 ^_^
若是客户端希望确认一个消息,该如何做呢?,只要发送一个ACK Frame即可!
在ACK Frame中,subscription标示是谁确认消息,message-id标示是确认哪条消息(即MESSAGE Frame中携带的message-id)
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/71fad5d181c67475fd107e3624b13458.jpg)
另外我在rabbitmq的测试结果发现,ack具有累积效应,譬如接收了10条消息,如果你ack了第8条消息,那么1-7条消息都会被ack,只有9-10两条消息还保持未ack状态
除了有ACK Frame,还有NACK Frame,它表示客户端未成功接收某条消息,这时候服务器可以选择重发或者丢弃(对于rabbitmq,我的测试结果是选择重发)
3.断开连接
说完了连接的建立,消息的发送与接收,现在我们来看看客户端如何与服务器断开连接的,更重要的是如何安全的断开连接
![](https://oscdn.geek-share.com/Uploads/Images/Content/201909/18/44bbfc5d76597b8db7fb84411830b1e2.jpg)
通过发送DISCONNNECT Frame表示向服务器发送一个断开连接请求,其中receipt表示服务器收到请求后请告知客户端,并返回一个相同的receipt-id
相关文章推荐
- 说说毕业两年多的经历
- Git 推送分支
- 使用单链表反转的递归和非递归实现方式
- 使用intellij idea搭建MAVEN+springmvc+mybatis框架
- 【LeetCode题意分析&解答】34. Search for a Range
- Spring学习笔记--环境搭建和初步理解IOC
- Scala学习笔记--第3章 函数
- 堆排序 两种实现(最小堆和最大堆)
- 复利计算1.0,2.0
- Git Feature分支
- 集成hbase
- 《第一行代码》 随手笔记——第三章 UI开发的点点滴滴
- oracle创建表空间
- 配置mysql允许远程连接的方法
- UITableView介绍 之 复杂cell的高度计算
- 1016-06-首页20-封装工具条---UITableView控件距离顶部的间距问题----cell选中时的背景颜色设置
- Servlet+msql+ android客户端实现从服务器获取信息
- 第三周上机实践项目——项目4-穷举法解决组合问题
- 目前流行的源程序版本管理软件和项目管理软件都有哪些?各有什么优缺点?
- Git Bug分支