3.5. 使用带有网络连接的 STOMP

使用 STOMP 时，会有以下限制：

当通过 JMS 使用者或 QueueBrowser 接收 STOMP 消息时，消息默认不包含任何 JMS 属性，如 JMSMessageID。但是，您可以使用代理参数在每个传入的 STOMP 消息上设置消息 ID。

<acceptors>
  <acceptor name="stomp-acceptor">tcp://localhost:61613?protocols=STOMP;stompEnableMessageId=true</acceptor>
  ...
</acceptors>

<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

amq-message-id : STOMP12345

如果配置中没有指定 stompEnableMessageId，则默认值为 false。

STOMP 客户端必须在关闭其连接之前发送 DISCONNECT 帧。这允许代理关闭任何服务器端资源，如会话和消费者。但是，如果 STOMP 客户端在不发送 DISCONNECT 帧的情况下退出，或者如果失败，代理将无法立即知道客户端是否仍然处于活动状态。因此，STOMP 连接被配置为 "Time to Live" (TTL)为 1 分钟。这意味着，如果代理闲置超过 1 分钟，代理会停止与 STOMP 客户端的连接。

<acceptors>
  <acceptor name="stomp-acceptor">tcp://localhost:61613?protocols=STOMP;connectionTTL=20000</acceptor>
  ...
</acceptors>

<acceptors>
  <acceptor name="stomp-acceptor">tcp://localhost:61613?protocols=STOMP;connectionTTL=20000</acceptor>
  ...
</acceptors>

在前面的示例中，使用 stomp-acceptor 的任何 stomp 连接都会将其 TTL 设置为 20 秒。

将代理默认时间设置为 live

如前文所述，STOMP 连接的默认 TTL 为一分钟。您可以通过在代理配置中添加 connection-ttl-override 属性来覆盖这个值。

<configuration ...>
  ...
  <core ...>
    ...
    <connection-ttl-override>30000</connection-ttl-override>
    ...
  </core>
<configuration>

<configuration ...>
  ...
  <core ...>
    ...
    <connection-ttl-override>30000</connection-ttl-override>
    ...
  </core>
<configuration>

在前面的示例中，STOMP 连接的默认生存时间(TTL)被设置为 30 秒，30000 毫秒。

STOMP 主要是一个文本性协议。为了更容易与 JMS 交互，STOMP 实施会检查 内容长度 标头的存在，以决定如何将 STOMP 消息映射到 JMS。

当将 JMS 消息映射到 STOMP 时，也会应用相同的逻辑。STOMP 客户端可以确认是否存在 content-length 标头，以确定消息正文的类型（字符串或字节数）。

有关消息标头的更多信息，请参阅 STOMP 规格。

在发送消息和订阅时，STOMP 客户端通常包含一个 目的地 标头。目标名称是字符串值，映射到代理上的目的地。在 AMQ Broker 中，这些目的地映射到 addresses 和 queues。有关目的地帧的更多信息，请参阅 STOMP 规格。

取一个发送以下消息的 STOMP 客户端示例（包括 headers 和 body）：

SEND
destination:/my/stomp/queue

hello queue a
^@

SEND
destination:/my/stomp/queue

hello queue a
^@

在这种情况下，代理会将消息转发到与地址 /my/stomp/queue 关联的任何队列。

例如，当 STOMP 客户端发送一条消息时（使用 SEND 帧），指定的目的地映射到一个地址。

当客户端发送 SUBSCRIBE 或 UNSUBSCRIBE 帧时，它的工作方式相同，但在这种情况下，AMQ Broker 将 目的地映射 到队列。

SUBSCRIBE
destination: /other/stomp/queue
ack: client

^@

SUBSCRIBE
destination: /other/stomp/queue
ack: client

^@

在前面的示例中，代理会将 目的地映射 到队列 /other/stomp/queue。

将 STOMP 目的地映射到 JMS 目的地

JMS 目的地也映射到代理地址和队列。如果要使用 STOMP 发送消息到 JMS 目的地，stomp 目的地必须遵循相同的约定：