stomp协议简介服务器客户端通讯协议

深碍√TFBOYSˉ_ 2021-08-27 01:36 776阅读 0赞

### 一、STOMP协议介绍 ###

STOMP即Simple (or Streaming) Text Orientated Messaging Protocol，简单(流)文本定向消息协议，它提供了一个可互操作的连接格式，允许STOMP客户端与任意STOMP消息代理（Broker）进行交互。STOMP协议由于设计简单，易于开发客户端，因此在多种语言和多种平台上得到广泛地应用。

STOMP协议的前身是TTMP协议（一个简单的基于文本的协议），专为消息中间件设计。

STOMP是一个非常简单和容易实现的协议，其设计灵感源自于HTTP的简单性。尽管STOMP协议在服务器端的实现可能有一定的难度，但客户端的实现却很容易。例如，可以使用Telnet登录到任何的STOMP代理，并与STOMP代理进行交互。

STOMP协议与2012年10月22日发布了最新的STOMP 1.2规范。  
要查看STOMP 1.2规范，见： [https://stomp.github.io/stomp-specification-1.2.html][https_stomp.github.io_stomp-specification-1.2.html]

### 二、STOMP的实现 ###

业界已经有很多优秀的STOMP的服务器/客户端的开源实现，下面就介绍一下这方面的情况。

**1、STOMP服务器**

<table> 
 <thead> 
  <tr> 
   <th>项目名</th> 
   <th>兼容STOMP的版本</th> 
   <th>描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>Apache Apollo</td> 
   <td>1.0 1.1 1.2</td> 
   <td>ActiveMQ的继承者&nbsp;<a href="http://activemq.apache.org/apollo" rel="nofollow">http://activemq.apache.org/apollo</a></td> 
  </tr> 
  <tr> 
   <td>Apache ActiveMQ</td> 
   <td>1.0 1.1</td> 
   <td>流行的开源消息服务器&nbsp;<a href="http://activemq.apache.org/" rel="nofollow">http://activemq.apache.org/</a></td> 
  </tr> 
  <tr> 
   <td>HornetQ</td> 
   <td>1.0</td> 
   <td>来自JBoss的消息中间件&nbsp;<a href="http://www.jboss.org/hornetq" rel="nofollow">http://www.jboss.org/hornetq</a></td> 
  </tr> 
  <tr> 
   <td>RabbitMQ</td> 
   <td>1.0 1.1 1.2</td> 
   <td>基于Erlang、支持多种协议的消息Broker，通过插件支持STOMP协议&nbsp;<a href="http://www.rabbitmq.com/plugins.html#rabbitmq-stomp" rel="nofollow">http://www.rabbitmq.com/plugins.html#rabbitmq-stomp</a></td> 
  </tr> 
  <tr> 
   <td>Stampy</td> 
   <td>1.2</td> 
   <td>STOMP 1.2规范的一个Java实现&nbsp;<a href="http://mrstampy.github.com/Stampy/" rel="nofollow">http://mrstampy.github.com/Stampy/</a></td> 
  </tr> 
  <tr> 
   <td>StompServer</td> 
   <td>1.0</td> 
   <td>一个轻量级的纯Ruby实现的STOMP服务器&nbsp;<a href="http://stompserver.rubyforge.org/" rel="nofollow">http://stompserver.rubyforge.org/</a></td> 
  </tr> 
 </tbody> 
</table>

这里只列了部分。

**2、STOMP客户端库**

<table> 
 <thead> 
  <tr> 
   <th>项目名</th> 
   <th>兼容STOMP的版本</th> 
   <th>描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>activemessaging</td> 
   <td>1.0</td> 
   <td>Ruby客户端库&nbsp;<a href="http://code.google.com/p/activemessaging/" rel="nofollow">http://code.google.com/p/activemessaging/</a></td> 
  </tr> 
  <tr> 
   <td>onstomp</td> 
   <td>1.0 1.1</td> 
   <td>Ruby客户端库&nbsp;<a href="https://rubygems.org/gems/onstomp" rel="nofollow">https://rubygems.org/gems/onstomp</a></td> 
  </tr> 
  <tr> 
   <td>Apache CMS</td> 
   <td>1.0</td> 
   <td>C++客户端库&nbsp;<a href="http://activemq.apache.org/cms/" rel="nofollow">http://activemq.apache.org/cms/</a></td> 
  </tr> 
  <tr> 
   <td>Net::STOMP::Client</td> 
   <td>1.0 1.1 1.2</td> 
   <td>Perl客户端库&nbsp;<a href="http://search.cpan.org/dist/Net-STOMP-Client/" rel="nofollow">http://search.cpan.org/dist/Net-STOMP-Client/</a></td> 
  </tr> 
  <tr> 
   <td>Gozirra</td> 
   <td>1.0</td> 
   <td>Java客户端库&nbsp;<a href="http://www.germane-software.com/software/Java/Gozirra/" rel="nofollow">http://www.germane-software.com/software/Java/Gozirra/</a></td> 
  </tr> 
  <tr> 
   <td>libstomp</td> 
   <td>1.0</td> 
   <td>C客户端库，基于APR库&nbsp;<a href="http://stomp.codehaus.org/C" rel="nofollow">http://stomp.codehaus.org/C</a></td> 
  </tr> 
  <tr> 
   <td>Stampy</td> 
   <td>1.2</td> 
   <td>Java客户端库&nbsp;<a href="http://mrstampy.github.com/Stampy/" rel="nofollow">http://mrstampy.github.com/Stampy/</a></td> 
  </tr> 
  <tr> 
   <td>stomp.js</td> 
   <td>1.0 1.1</td> 
   <td>JavaScript客户端库&nbsp;<a href="http://jmesnil.net/stomp-websocket/doc/" rel="nofollow">http://jmesnil.net/stomp-websocket/doc/</a></td> 
  </tr> 
  <tr> 
   <td>stompest</td> 
   <td>1.0 1.1 1.2</td> 
   <td>Python客户端库，全功能实现，包括同步和异步&nbsp;<a href="https://github.com/nikipore/stompest" rel="nofollow">https://github.com/nikipore/stompest</a></td> 
  </tr> 
  <tr> 
   <td>StompKit</td> 
   <td>1.2</td> 
   <td>Objective-C客户端库，事件驱动&nbsp;<a href="https://github.com/mobile-web-messaging/StompKit/" rel="nofollow">https://github.com/mobile-web-messaging/StompKit/</a></td> 
  </tr> 
  <tr> 
   <td>stompngo</td> 
   <td>1.0 1.1 1.2</td> 
   <td>Go客户端库&nbsp;<a href="https://github.com/gmallard/stompngo" rel="nofollow">https://github.com/gmallard/stompngo</a></td> 
  </tr> 
  <tr> 
   <td>stomp.py</td> 
   <td>1.0 1.1 1.2</td> 
   <td>Python客户端库&nbsp;<a href="https://github.com/jasonrbriggs/stomp.py" rel="nofollow">https://github.com/jasonrbriggs/stomp.py</a></td> 
  </tr> 
  <tr> 
   <td>tStomp</td> 
   <td>1.1</td> 
   <td>TCL客户端库&nbsp;<a href="https://github.com/siemens/tstomp" rel="nofollow">https://github.com/siemens/tstomp</a></td> 
  </tr> 
 </tbody> 
</table>

这里只列了部分。

### 三、STOMP协议分析 ###

STOMP协议与HTTP协议很相似，它基于TCP协议，使用了以下命令：

CONNECT  
SEND  
SUBSCRIBE  
UNSUBSCRIBE  
BEGIN  
COMMIT  
ABORT  
ACK  
NACK  
DISCONNECT

STOMP的客户端和服务器之间的通信是通过“帧”（Frame）实现的，每个帧由多“行”（Line）组成。  
第一行包含了命令，然后紧跟键值对形式的Header内容。  
第二行必须是空行。  
第三行开始就是Body内容，末尾都以空字符结尾。  
STOMP的客户端和服务器之间的通信是通过MESSAGE帧、RECEIPT帧或ERROR帧实现的，它们的格式相似。

[https_stomp.github.io_stomp-specification-1.2.html]: https://stomp.github.io/stomp-specification-1.2.html