3.5. 使用带有网络连接的 STOMP
Stomp 是一个文本线协议,它允许 STOMP 客户端与 STOMP Broker 进行通信。代理支持 STOMP 1.0、1.1 和 1.2。STOMP 客户端可用于多种语言和平台,使其成为可互操作性的理想选择。
流程
-
打开 &
lt;broker_instance_dir> /etc/broker.xml
配置文件。 -
配置现有的
acceptor
或创建一个新的,其中包含值为STOMP
的protocol
参数,如下所示:
<acceptors> <acceptor name="stomp-acceptor">tcp://localhost:61613?protocols=STOMP</acceptor> ... </acceptors>
在上例中,代理接受端口 61613
上的 STOMP 连接,这是默认设置。
有关如何使用 STOMP 配置代理的示例,请参阅 STOMP 示例。
3.5.1. STOMP 限制
使用 STOMP 时,会有以下限制:
-
代理目前不支持虚拟主机,这意味着
CONNECT
帧中的host
标头被忽略。 -
消息确认不是事务性。
ACK
框架不能是事务的一部分,如果设置了其事务
标头,则忽略该帧。
3.5.2. 为 STOMP 消息提供 ID
当通过 JMS 消费者或 QueueBrowser 接收 STOMP 消息时,消息不包含任何 JMS 属性,如 JMSMessageID
。但是,您可以使用代理参数参数为每个传入的 STOMP 消息设置消息 ID。
流程
-
打开 &
lt;broker_instance_dir> /etc/broker.xml
配置文件。 -
对于用于 STOMP 连接的
acceptor
,将stompEnableMessageId
参数设置为true
,如下例所示:
<acceptors> <acceptor name="stomp-acceptor">tcp://localhost:61613?protocols=STOMP;stompEnableMessageId=true</acceptor> ... </acceptors>
通过使用 stompEnableMessageId
参数,使用此接受者发送的每个 stomp 消息都添加了额外的属性。属性键是 amq-message-id
,值是带有 "STOMP" 前缀的内部消息 id 的 String 表示,如下例所示:
amq-message-id : STOMP12345
如果配置中没有指定 stompEnableMessageId
,则默认值为 false
。
3.5.3. 将连接时间设置为 live
STOMP 客户端必须在关闭连接前发送 DISCONNECT
帧。这允许代理关闭任何服务器端资源,如会话和消费者。但是,如果 STOMP 客户端在没有发送 DISCONNECT 帧的情况下退出,或者如果失败,代理将无法立即知道客户端是否处于活动状态。因此,STOMP 连接被配置为 1 分钟的"生存时间" (TTL)。这意味着,如果代理闲置超过 1 分钟,代理会停止与 STOMP 客户端的连接。
流程
-
打开 &
lt;broker_instance_dir> /etc/broker.xml
配置文件。 -
将
connectionTTL
参数添加到用于 STOMP 连接的acceptor
的 URI 中,如下例所示:
<acceptors> <acceptor name="stomp-acceptor">tcp://localhost:61613?protocols=STOMP;connectionTTL=20000</acceptor> ... </acceptors>
在前面的示例中,使用 stomp-acceptor
的任何 stomp 连接都将其 TTL 设置为 20 秒。
STOMP 协议的版本 1.0 不包含任何心跳帧。因此,用户的责任可确保数据在 connection-ttl 中发送,否则代理会假定客户端死机并清理服务器端资源。对于 1.1 版本,您可以使用 core-beats 来维护 stomp 连接的生命周期。
将代理默认时间覆盖为 live
如前文所述,STOMP 连接的默认 TTL 为一分钟。您可以通过在代理配置中添加 connection-ttl-override
属性来覆盖这个值。
流程
-
打开 &
lt;broker_instance_dir> /etc/broker.xml
配置文件。 -
添加
connection-ttl-override
属性,并为新默认值提供一个值(毫秒)。它属于 <core>
; 小节,如下所示。
<configuration ...> ... <core ...> ... <connection-ttl-override>30000</connection-ttl-override> ... </core> <configuration>
在前面的示例中,STOMP 连接的默认生存时间(TTL)被设置为 30 秒,30000
毫秒。
3.5.4. 从 JMS 发送和使用 STOMP 消息
STOMP 主要是一个基于文本的协议。为了便于与 JMS 互操作,STOMP 实施检查是否存在 content-length
标头,以确定如何将 STOMP 消息映射到 JMS。
如果您希望 STOMP 消息映射到 … | 消息应该…。 |
---|---|
JMS TextMessage |
不包含 |
JMS BytesMessage |
包括一个 |
将 JMS 消息映射到 STOMP 时应用相同的逻辑。STOMP 客户端可以确认存在 content-length
标头来确定消息正文的类型(字符串或字节数)。
有关消息标头的更多信息,请参阅 STOMP 规格。
3.5.5. 将 STOMP 目的地映射到 AMQ Broker 地址和队列
在发送消息和订阅时,STOMP 客户端通常包含 一个目标
标头。目的地名称是字符串值,它们映射到代理上的目的地。在 AMQ Broker 中,这些目的地映射到 addresses 和 queues。有关目标帧的更多信息,请参阅 STOMP 规格。
例如,一个发送以下消息的 STOMP 客户端(包括headers 和 body):
SEND destination:/my/stomp/queue hello queue a ^@
在这种情况下,代理会将消息转发到与地址 /my/stomp/queue
关联的任何队列。
例如,当 STOMP 客户端使用 SEND
帧发送消息时,指定的目的地映射到地址。
当客户端发送 SUBSCRIBE
或 UNSUBSCRIBE
帧时,它的工作方式相同,但在本例中为 AMQ Broker 将 目的地
映射到一个队列。
SUBSCRIBE destination: /other/stomp/queue ack: client ^@
在前面的示例中,代理会将 目的地映射
到队列 /other/stomp/queue
。
将 STOMP 目的地映射到 JMS 目的地
JMS 目的地也映射到代理地址和队列。如果要使用 STOMP 将消息发送到 JMS 目的地,STOMP 目标必须遵循相同的约定:
通过
jms.queue
添加队列名称来发送或订阅 JMS Queue。例如,要将信息发送到orders
JMS Queue,STOMP 客户端需要发送帧:SEND destination:jms.queue.orders hello queue orders ^@
通过添加主题名称作为
jms.topic.
前,发送或订阅 JMS 主题。例如,要订阅库存
JMS 主题,STOMP 客户端必须发送类似如下的帧:SUBSCRIBE destination:jms.topic.stocks ^@