3.5. 네트워크 연결에서 STOMP 사용

STOMP를 사용하는 경우 다음과 같은 제한 사항이 적용됩니다.

JMS 소비자 또는 QueueForwardedr를 통해 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 매개변수를 사용하면 이 acceptor를 사용하여 전송된 각 stomp 메시지에 추가 속성이 추가됩니다. 속성 키는 amq-message-id 이고 값은 다음 예와 같이 "STOMP" 접두사가 붙은 내부 메시지 id의 문자열 표현입니다.

amq-message-id : STOMP12345

amq-message-id : STOMP12345

stompEnableMessageId 가 구성에 지정되지 않은 경우 기본값은 false 입니다.

STOMP 클라이언트는 연결을 종료하기 전에 DISCONNECT 프레임을 보내야 합니다. 이를 통해 브로커는 세션 및 소비자와 같은 서버 측 리소스를 모두 닫을 수 있습니다. 그러나 STOMP 클라이언트가 DISCONNECT 프레임을 전송하지 않고 종료하거나 실패하는 경우 브로커는 클라이언트가 아직 활성 상태인지 여부를 즉시 알 수 없습니다. 따라서 STOMP 연결은 1분이라는 "Time to Live"(TTL)를 갖도록 구성됩니다. 브로커는 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초로 설정됩니다.

브로커의 기본 시간 재정의

앞서 언급했듯이 STOMP 연결의 기본 TTL은 1분입니다. 브로커 구성에 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 연결의 기본 Time to Live(TTL)는 30초, 30000 밀리초로 설정됩니다.

STOMP는 주로 텍스트 지향 프로토콜입니다. JMS와 상호 운용하기 위해 STOMP 구현에서는 콘텐츠 길이 헤더가 있는지 확인하여 STOMP 메시지를 JMS에 매핑하는 방법을 결정합니다.

JMS 메시지를 STOMP에 매핑할 때 동일한 논리가 적용됩니다. STOMP 클라이언트는 콘텐츠 길이 헤더가 있는지 확인하여 메시지 본문(문자열 또는 바이트)의 유형을 확인할 수 있습니다.

메시지 헤더에 대한 자세한 내용은 STOMP 사양을 참조하십시오.

메시지와 구독을 보낼 때 STOMP 클라이언트는 일반적으로 대상 헤더를 포함합니다. 대상 이름은 브로커의 대상에 매핑되는 문자열 값입니다. AMQ Broker에서 이러한 대상은 주소 및 큐에 매핑됩니다. 대상 프레임에 대한 자세한 내용은 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 대상은 동일한 규칙을 따라야 합니다.