STOMP协议规范

发布时间:2017-7-9 7:10:55编辑:www.fx114.net 分享查询网我要评论
本篇文章主要介绍了"STOMP协议规范 ",主要涉及到STOMP协议规范 方面的内容,对于STOMP协议规范 感兴趣的同学可以参考一下。

摘要

STOMP是一个简单的可互操作的协议, 被用于通过中间服务器在客户端之间进行异步消息传递。它定义了一种在客户端与服务端进行消息传递的文本格式.

STOMP已经被使用了很多年,并且支持很多消息brokers和客户端库。这个规范定义STOMP 1.2协议以及对1.1版本的更新。

发送反馈到stomp-spec@googlegroups.com.

概述

背景

由于需要用脚本语言如RubyPythonPerl去连接企业级的消息brokers, STOMP产生了.在这种情况下,STMOP实现了一些简单的操作,比如可靠地发送单一的消息,然后断开或者从目的地消费所有消息。

STOMP是除AMQP开放消息协议之外地另外一个选择, 实现了被用在JMS brokers中特定的有线协议,比如OpenWire. 它仅仅是实现通用消息操作中的一部分,并非想要覆盖全面的消息API.

STOMP目前已经是个成熟的协议,在wire-level方面, 它提供了一些简单的用例,但仍保持其核心设计原则:简单性和互操作性。 ### 协议概述

STOMP是基于frame的协议, 与HTTP的frame相似.一个frame包含一个command,一系列可选的headersbody.STOMP虽然是基于消息但同于也允许传递二进制消息。STMOP的默认消息格式是UTF-8,但是在消息体中同样支持其他格式编码。

STOMP服务器就好像是一系列的目的地, 消息会被发送到这里。STOMP协议把目的地当作不透明的字符串,其语法是服务端具体的实现。 此外STOMP没有定义目的地的交付语义是什么。 交付,或“消息交换”,语义的目的地可以从服务器到服务器,甚至从目的地到目的地。这使得服务器有可创造性的语义,去支持STOMP。

STOMP client的用户代理可以充当两个角色(可能同时): * 作为生产者,通过SENDframe发送消息到server * 作为消费者,发送SUBSCRIBEframe到目的地并且通过MESSAGEframe从server获取消息。

STOMP版本之间的变化

STOMP 1.2 大部分向后兼容1.1. 有两点不兼容的改变: * 用回车加换行符代替只用换行符结束frame * 简化了消息应答,用专用的header

除此之外,STOMP 1.2并没有增加新特性,而是阐述规格中的一些模糊概念,比如: * 重复的frame header条目 * content-lengthcontent-typeheaders的用法 * 必须支持servers STOMP frame * 连接延迟 * 作用域,订阅的唯一,事务的标示符 *RECEIPTframe的含义

设计哲学

简易性,互通性是STOMP主要设计哲学.
STOMP被设计成为轻量级的协议,它很容易用其他语言在client和server实现。这就意味着servers的架构没有太多的约束,以及没有太多的特性比如目的地命名空间,可靠的语法需要去实现。

在这份规格书里面,注意,我们没有明确定义的STOMP 1.2 servers特性。你应该查阅STMOMP servers 文档去获得这些特性的详细描述。

一致性

RFC 2119中详细地解释了MUSTMUST NOTREQUIREDSHALLSHALL NOTSHOULDSHOULD NOT,RECOMMENDEDMAY, 和 OPTIONAL这些关键字
为了阻止来自服务端地攻击,保护内存溢出,消除平台限制,限制了不受约束的输入。

规格中一致性的级别适用于STOMP clients and STOMP servers.

STOMP Frames

STOMP是基于帧的协议,它假定底层为一个2-way的可靠流的网络协议(如TCP)。客户端和服务器通信使用STOMP帧流通讯。帧的结构看起来像:

COMMAND
header1:value1
header2:value2

Body^@

帧以command字符串开始,以EOL结束,其中包括可选回车符(13字节),紧接着是换行符(10字节)。command下面是0个或多个<key>:<value>格式的header条目, 每个条目由EOL结束。一个空白行(即额外EOL)表示header结束和body开始。body连接着NULL字节。本文档中的例子将使用^@,在ASCII中用control-@表示,代表NULL字节。NULL字节可以选择跟多个EOLs。欲了解更多关于STOMP帧的详细信息,请参阅Augmented BNF节本文件。

本文档中引用的所有command 和header 名字都是大小写敏感的.

编码方式

commands和headers 都是用UTF-8编码的.在用UTF-8编码的headers中除了CONNECTCONNECTED帧以外,任何的回车符,换行符,colon found(?)都将被转义.

转义的目的在于允许header中的键值包含那些把octets当作值的frame header.

为了向后兼容STOMP 1.0, CONNECTCONNECTED不会转义回车符,换行符,colon found(?)

C风格的字符串转义被用在UTF-8编码的headers中去转义回车符,换行符以及colon found.当解码headers时,必须使用下列转换: * \r (octet 92 and 114) translates to carriage return (octet 13) * \n (octet 92 and 110) translates to line feed (octet 10) * \c (octet 92 and 99) translates to : (octet 58) * \\ (octet 92 and 92) translates to \ (octet 92)

未定义转义序列如\t(octet 92 and 116)必须被视为一个致命的错误。相反,当编码帧头,必须使用逆转变.

The STOMP 1.0 specification included many example frames with padding in the headers and many servers and clients were implemented to trim or pad header values. This causes problems if applications want to send headers that SHOULD not get trimmed. In STOMP 1.2, clients and servers MUST never trim or pad headers with spaces.

Body

只有SENDMESSAGE, 和ERROR帧有body。所有其他的帧不能有body。

标准header

大多数被用的header都有特殊的含义。

Header content-length

所有的帧可能都包括有content-length的header。它定义了消息体的大小。如果header包含了content-length, 包含空字节的消息体的最大字节数不能超过这个数. 帧仍然需要以空字节结束。

如帧体存在,SENDMESSAGE 和 ERROR帧应该包含content-length.如果帧体包含空字节,那么这个帧必须包括content-length.

Header content-type

如果帧体存在,SENDMESSAGE 和 ERROR帧应该包含content-type帮助接受者去理解帧体.如果设置了content-type, 它的值必须是描述帧体格式的MINE类型.否则,接收者应该认为帧体格式为二进制Blob.

text/开头的MINE类型的默认文本编码是UTF-8. 如果你正在用一个基于MINE类型的不同编码, 你应该添加;charset=<encoding>MINE类型。例如:如果你发送一个UTF-16编码的HTML body, 应该设置text/html;charset=utf-16;charset=<encoding>也能添加到任何非text/ MINE类型后去作为说明。UTF-8编码的XML是个很好的例子。它的编码被设置为application/xml;charset=utf-8.

所有STOMP客户端和服务端必须支持UTF-8编码和解码。因此,为了最大限度地使用在异构环境中的互操作性,建议基于文本的内容使用UTF-8编码.

Header receipt

任何除了CONNECT的客户端帧可以为receipt header指定任何值。这会让服务端应答带有RECEIPT的客户端帧的处理过程。

Repeated Header Entries

Since messaging systems can be organized in store and forward topologies, similar to SMTP, a message may traverse several messaging servers before reaching a consumer. A STOMP server MAY ‘update’ header values by either prepending headers to the message or modifying a header in-place in the message.

如果client或者server受到重复的header条目,只有第一个会被用作header条目的值。其他的值仅仅用来维持状态改变,或者被丢弃。

例如,如果client收到:

MESSAGE
foo:World
foo:Hello

^@

foo header的值为World.

大小限制

为了客户端滥用服务端的内存分配,服务端可以设置可分配的内存大小:

  • 单个帧允许帧头的个数
  • header中每一行的最大长度
  • 帧体的大小

如果超出了这些限制,server应该向client发送一个error frame,然后关闭连接.

连接延迟

STOMP servers必须支持client快速地连接server和断开连接。 这意味着server在连接重置前只允许被关闭的连接短时间地延迟.

结果就是,在socket重置前client可能不会收到server发来的最后一个frame(比如ERROR或者RECEIPTframe去应答DISCONNECTframe)

Connecting

STOMP client通过CONNECTframe与server建立流或者TCP连接.

CONNECT
accept-version:1.2
host:stomp.github.org

^@

如果server收到请求,将返回CONNECTEDframe:

CONNECTED
version:1.2

^@

server能拒绝所有的连接请求。server应该响应ERRORframe去说明为什么连接被拒绝然后关闭连接。

CONNECT or STOMP Frame

STOMP servers 处理STOMPframe必须和处理CONNECTframe一样。STOMP1.2 clients应该继续使用CONNECTcommand去向后兼容1.0.

使用STOMPframe的clients只能连接上STOMP1.2 servers(以及一些STOMP1.1 servers),但是好处在于协议探针能够从HTTP连接中区分开STOMP连接。

STOMP 1.2 clients 必须设置以下headers: * accept-version: clients支持的STOMP的版本号。详情见Protocol_Negotiation * host:client希望连接的虚拟主机名字,建议设置已经连接的socket为主机名,或者任何名字。如果headers没有匹配到任何可用的虚拟主机,支持虚拟主机的servers将选择默认的虚拟主机或者拒绝连接。

STOMP 1.2 clients可选择设置以下headers: * login: 用于在server验证的用户id *passcode: 用于在server验证的密码 * heart-beat: 心跳设置

CONNECTED Frame

STOMP 1.2 servers 必须设置以下headers:

  • version: 会话中STOMP版本。详情见Protocol_Negotiation

STOMP 1.2 servers可选择设置以下headers:

  • heart-beat: 心跳设置
  • session: 唯一的会话identifier
  • server: 描述STOMP server信息。它必须包含server-name,可以包含一些注释信息(用空格分开) server-name后面也可以带着可选的版本号.

      server = name ["/" version] *(comment)
    

    例如:

      server:Apache/1.3.9
    
Protocol Negotiation

STOMP1.1 以后的版本,CONNECTframe必须包括accept-versionheader.它的值为clients支持的STOMP版本号,多个版本号用,隔开。如果不存在accept-versionheader,那么表明clients只支持1.0.

在一次会话中将使用双方都支持的最高版本。

例如,如果client发送:

CONNECT
accept-version:1.0,1.1,2.0
host:stomp.github.org

^@

server将返回与客户端同时支持的最高版本。

CONNECTED
version:1.1

^@

如果client和server不支持共同的协议版本,server必须返回如下的ERRORframe,然后断开连接。

ERROR
version:1.2,2.1
content-type:text/plain

Supported protocol versions are 1.2 2.1^@
心跳

心跳被用于去测试底层TCP连接的可用性,确保远端服务处于活动状态。

要使用心跳,每个部分必须声明它能干什么以及想要其他部分干什么. 通过在CONNECTCONNECTEDframe中增加heart-beatheader, 让心跳在会话开始被定义好。heart-beatheader必须包含两个用逗号隔开的正整数。

第一个数字代表发送方能做什么: * 0表示它不能发送心跳 * 否则它是能保证两次心跳的最小毫秒数

第二个数字代表发送方能获得什么: * 0表示它不想接收心跳 * 否则它表示两次心跳期望的毫秒数

heart-beatheader是OPTIONAL的。没有的话会被当作heart-beat:0,0header 处理,意思就是说它不会发送心跳并且不想接收心跳。

heart-beatheader提供了足够的信息去了解每个部分心跳是否可用,发送到哪里,频率的大小.

原始frame像这个样子:

CONNECT
heart-beat:<cx>,<cy>
   
CONNECTED:
heart-beat:<sx>,<sy>

对于client发送server的心跳: * 如果<cx>为0(client不能发送心跳)或者<sy>为0(server不想接收心跳),将不起任何作用。 * 否则心跳频率为MAX(<cx>,<sy>)毫秒数.

相反,<sx><cy>同样是这样的.

关于心跳本身,通过网络连接收到的任何数据表明远端服务是可用的。在给定的指向,如果心跳的频率被期望是<n>毫秒:

  • 发送者必须每<n>毫秒发送新数据。
  • 如果发送者没有真实的STOMP frame,必须发送一个end-of-line (EOL)
  • 如果接受者在规定的时间内没有收到新数据,表明连接已经断开
  • 由于时间误差,接收者应该容错和考虑定义错误的界限

Client Frames

client可以发送下列列表以外的frame,但是STOMP1.2 server会响应ERRORframe,然后关闭连接。

  • SEND
  • SUBSCRIBE
  • UNSUBSCRIBE
  • BEGIN
  • COMMIT
  • ABORT
  • ACK
  • NACK
  • DISCONNECT
SEND

SENDframe发送消息到目的地,它必须包含表示目的地地址的destinationheader.SENDframe body是被发送的消息。例如:

SEND
destination:/queue/a
content-type:text/plain

hello queue a
^@

这个消息被发送到/queue/a.注意STOMP把目的地看作为一个不透明的字符串,没有目的地假设的交互语义.你应该查阅STOMP server文档,搞清楚如何构造目的地名字。

可靠的消息语义是server指定的,依赖备用的目的地的值和其他消息headers,比如事务headers,或者其他server指定的消息headers。

SEND可以添加transactionheader来支持事务处理.

如果body存在,那么SENDframe应该包含一个content-lengthcontent-typeheader

一个应用可以给SENDframe增加任意多个用户定义的headers。 通常用于用户定义的头,让消费者能够根据应用程序定义的报头使用选择订阅帧过滤消息。 被定义的用户必须通过MESSAGEframe传送。

如果server不能无故成功处理SENDframe,那么server必须向client发送ERRORframe然后关闭连接。

SUBSCRIBE

SUBSCRIBEframe用于注册给定的目的地.和SENDframe一样,SUBSCRIBEframe需要包含destinationheader表明client想要订阅目的地。 被订阅的目的地收到的任何消息将通过MESSAGEframe发送给client。 ackheader控制着确认模式。

例子:

SUBSCRIBE
id:0
destination:/queue/foo
ack:client

^@

如果server不能成功创建此次订阅,那么server将返回ERRORframe然后关闭连接。

STOMP服务器可能支持额外的服务器特定的头文件,来自定义有关订阅传递语义.

SUBSCRIBE id Header

一个单连接可以对应多个开放的servers订阅,所以必须包含idheader去唯一标示这个订阅.这个idframe可以把此次订阅与接下来的MESSAGEframe和UNSUBSCRIBEframe联系起来。

在相同的连接中,不同的订阅必须拥有不同订阅id。

SUBSCRIBE ack Header

ackheader可用的值有autoclient,client-individual, 默认为auto.

ackauto时,client收到server发来的消息后不需要回复ACKframe.server假定消息发出去后client就已经收到。这种确认方式可以减少消息传输的次数.

ackclient时, client必须发送ACkframe给servers, 让它处理消息.如果在client发送ACKframe之前连接断开了,那么server将假设消息没有被处理,可能会再次发送消息给另外的客户端。client发送的ACKframe被当作时积累的确认。这就意味这种确认方式会去操作ACKframe指定的消息和订阅的所有消息

由于client不能处理某些消息,所以client应该发送NACKframe去告诉server它不能消费这些消息。

当ack模式是client-individual,确认工作就像客户端确认模式(除了由客户端发送的ACKNACK帧)不会被累计。这意味着,后续ACKNACK消息帧,也不能影响前面的消息的确认。

UNSUBSCRIBE

UNSUBSCRIBEframe被用于去移除已经存在订阅。一旦订阅被删除后,STOMP连接将不再会收到来自订阅发出的消息。

一个单连接可以对应多个开放的server订阅,所以必须包含idheader去唯一标示被删除的订阅.这个header中的id必须匹配已存在订阅.

例如:

UNSUBSCRIBE


上一篇:使用Android Studio 1.3 版本号进行NDK开发
下一篇:Nginx接收的host值会影响alias的规则匹配

相关文章

关键词: STOMP协议规范

相关评论

本站评论功能暂时取消,后续此功能例行通知。

一、不得利用本站危害国家安全、泄露国家秘密,不得侵犯国家社会集体的和公民的合法权益,不得利用本站制作、复制和传播不法有害信息!

二、互相尊重,对自己的言论和行为负责。

好贷网好贷款