AMQ Broker 구성

절차

1. &lt ;broker_instance_dir>/etc/artemis.profile 파일을 엽니다.

2. Java 시스템 인수의 JAVA_ARGS 목록에 새 인수 -Dartemis.disableXxe 를 추가합니다.

   -Dartemis.disableXxe=true

   Copy to Clipboard Toggle word wrap
3. artemis.profile 파일을 저장합니다.

1. 브로커는 현재 가상 호스팅을 지원하지 않으므로 CONNECT 프레임의 호스트 헤더가 무시됩니다.
2. 메시지 승인은 트랜잭션이 아닙니다. ACK 프레임은 트랜잭션의 일부일 수 없으며 트랜잭션 헤더가 설정된 경우 무시됩니다.

절차

1. &lt ;broker_instance_dir> /etc/broker.xml 구성 파일을 엽니다.
2. 다음 예와 같이 STOMP 연결에 사용되는 acceptor 에 대해 stompEnableMessageId 매개변수를 true 로 설정합니다.

절차

1. &lt ;broker_instance_dir> /etc/broker.xml 구성 파일을 엽니다.
2. 다음 예와 같이 STOMP 연결에 사용되는 acceptor URI에 connectionTTL 매개변수를 추가합니다.

절차

1. &lt ;broker_instance_dir> /etc/broker.xml 구성 파일을 엽니다.
2. connection-ttl-override 특성을 추가하고 새 기본값에 대해 밀리초 단위 값을 제공합니다. 아래와 같이 &lt ;core& gt; 스탠자 내부에 있습니다.

절차

1. &lt ;broker_instance_dir> /etc/broker.xml 구성 파일을 엽니다.

2. 아래 예제 와 같이 <wildcard-addresses > 섹션을 구성에 추가합니다.

   <configuration>
     <core>
       ...
       <wildcard-addresses> //
         <enabled>true</enabled> //
         <delimiter>,</delimiter> //
         <any-words>@</any-words> //
         <single-word>$</single-word>
       </wildcard-addresses>
       ...
     </core>
   </configuration>

   Copy to Clipboard Toggle word wrap

   enabled

   true 로 설정하면 브로커가 사용자 정의 설정을 사용하도록 지시합니다.

   delimiter

   기본값 대신 구분자 로 사용할 사용자 지정 문자를 제공합니다 .

   any-words

   any-words 의 값으로 제공되는 문자는 ''match any sequence of zero or more words' and will replace the default #. 표현식 끝에 이 문자를 사용합니다.

   single-word

   단일어의 값으로 제공되는 문자는 ' 단일 단어 '를 의미하고 기본값 * 을 대체하는 데 사용됩니다. 이 문자는 표현식 내에서 어디에서나 사용하십시오.

절차

1. &lt ;broker_instance_dir> /etc/broker.xml 구성 파일을 엽니다.

2. 주소의 선택한 대기열 요소에서 anycast 구성 요소를 래핑합니다. address 및 queue 요소에 대한 name 특성 값이 모두 같은지 확인합니다. 예를 들면 다음과 같습니다.

   <configuration ...>
     <core ...>
       ...
       <address name="my.anycast.destination">
         <anycast>
           <queue name="my.anycast.destination"/>
         </anycast>
       </address>
     </core>
   </configuration>

   Copy to Clipboard Toggle word wrap

절차

1. &lt ;broker_instance_dir> /etc/broker.xml 구성 파일을 엽니다.

2. address 요소의 큐 요소에 대해 anycast 구성 요소를 래핑합니다. 예를 들면 다음과 같습니다.

   <configuration ...>
     <core ...>
       ...
       <address name="my.anycast.destination">
         <anycast>
           <queue name="q1"/>
           <queue name="q2"/>
         </anycast>
       </address>
     </core>
   </configuration>

   Copy to Clipboard Toggle word wrap

절차

1. &lt ;broker_instance_dir> /etc/broker.xml 구성 파일을 엽니다.

2. 선택한 큐에 위치 구성 요소를 추가합니다. true 값을 설정합니다.

   <configuration ...>
     <core ...>
       ...
       <address name="my.durable.address">
         <multicast>
           <queue name="q1">
             <durable>true</durable>
           </queue>
         </multicast>
       </address>
     </core>
   </configuration>

   Copy to Clipboard Toggle word wrap
   참고

   미용성 요소를 포함하여 기본적으로 대기열은 장래하지 않기 때문에 값을 true 로 설정하는 것은 지속성 큐를 만드는 데 엄격하게 필요하지 않습니다. 그러나 명시적으로 요소를 포함하면 나중에 큐의 동작을 필요한 경우 취소할 수 없습니다.However, explicitly including the element enables you to later change the behavior of the queue to non-durable, if necessary.

절차

1. &lt ;broker_instance_dir> /etc/broker.xml 구성 파일을 엽니다.

2. 선택한 각 큐에 위치 구성 요소를 추가합니다. true 값을 설정합니다.

   <configuration ...>
     <core ...>
       ...
       <address name="my.non.shared.durable.address">
         <multicast>
           <queue name="orders1">
             <durable>true</durable>
           </queue>
           <queue name="orders2">
             <durable>true</durable>
           </queue>
         </multicast>
       </address>
     </core>
   </configuration>

   Copy to Clipboard Toggle word wrap
   참고

   미용성 요소를 포함하여 기본적으로 대기열은 장래하지 않기 때문에 값을 true 로 설정하는 것은 지속성 큐를 만드는 데 엄격하게 필요하지 않습니다. 그러나 명시적으로 요소를 포함하면 나중에 큐의 동작을 필요한 경우 취소할 수 없습니다.However, explicitly including the element enables you to later change the behavior of the queue to non-durable, if necessary.

3. 선택한 각 큐에 max-consumers 특성을 추가합니다. 1 의 값을 설정합니다.

   <configuration ...>
     <core ...>
       ...
       <address name="my.non.shared.durable.address">
         <multicast>
           <queue name="orders1" max-consumers="1">
             <durable>true</durable>
           </queue>
           <queue name="orders2" max-consumers="1">
             <durable>true</durable>
           </queue>
         </multicast>
       </address>
     </core>
   </configuration>

   Copy to Clipboard Toggle word wrap

절차

1. &lt ;broker_instance_dir> /etc/broker.xml 구성 파일을 엽니다.

2. 선택한 각 큐에 purge-on-no-consumers 특성을 추가합니다. true 값을 설정합니다.

   <configuration ...>
     <core ...>
       ...
       <address name="my.non.durable.address">
           <multicast>
               <queue name="orders1" purge-on-no-consumers="true"/>
           </multicast>
       </address>
     </core>
   </configuration>

   Copy to Clipboard Toggle word wrap

절차

1. &lt ;broker_instance_dir> /etc/broker.xml 구성 파일을 엽니다.

2. 자동 생성 및 삭제를 위한 address-setting 을 구성합니다. 다음 예제에서는 이전 표에 언급된 모든 구성 요소를 사용합니다.

   <configuration ...>
    <core ...>
     ...
     <address-settings>
       <address-setting match="activemq.#">
         <auto-create-addresses>true</auto-create-addresses>
         <auto-delete-addresses>true</auto-delete-addresses>
         <auto-create-queues>true</auto-create-queues>
         <auto-delete-queues>true</auto-delete-queues>
         <default-address-routing-type>ANYCAST</default-address-routing-type>
       </address-setting>
     </address-settings>
     ...
    </core>
   </configuration>

   Copy to Clipboard Toggle word wrap

   address-setting

   address-setting 요소의 구성은 와일드카드 주소 activemq.# 과 일치하는 주소 또는 큐에 적용됩니다.

   auto-create-addresses

   클라이언트가 아직 존재하지 않는 주소에 연결하도록 요청하면 브로커는 주소를 생성합니다.

   auto-delete-addresses

   자동으로 생성된 주소는 더 이상 연결된 큐가 없는 경우 삭제됩니다.

   auto-create-queues

   클라이언트가 아직 존재하지 않는 큐에 연결하도록 요청하면 브로커는 큐를 생성합니다.

   auto-delete-queues

   자동 생성된 큐는 더 이상 소비자 또는 메시지가 없으면 삭제됩니다.

   default-address-routing-type

   클라이언트가 연결할 때 라우팅 유형을 지정하지 않으면 브로커는 메시지를 주소에 전달할 때 ANYCAST 를 사용합니다. 기본값은 MULTICAST 입니다.

1. &lt ;broker_instance_dir> /etc/broker.xml 구성 파일을 엽니다.

2. 지정된 큐의 경우 last-value-key 키를 추가하고 사용자 지정 값을 지정합니다. 예를 들면 다음과 같습니다.

   <address name="my.address">
       <multicast>
           <queue name="prices1" last-value-key="stock_ticker"/>
       </multicast>
   </address>

   Copy to Clipboard Toggle word wrap

3. 또는 _AMQ_LVQ_NAME 의 기본 마지막 값 키 이름을 사용하는 마지막 값 큐를 구성할 수 있습니다. 이렇게 하려면 지정된 큐에 마지막-값 키를 추가합니다. 값을 true 로 설정합니다. 예를 들면 다음과 같습니다.

   <address name="my.address">
       <multicast>
           <queue name="prices1" last-value="true"/>
       </multicast>
   </address>

   Copy to Clipboard Toggle word wrap

1. &lt ;broker_instance_dir> /etc/broker.xml 구성 파일을 엽니다.

2. address-setting 요소에서 일치하는 주소에 대해 default-last-value-key 를 추가합니다. 사용자 지정 값을 지정합니다. 예를 들면 다음과 같습니다.

   <address-setting match="lastValue">
      <default-last-value-key>stock_ticker</default-last-value-key>
   </address-setting>

   Copy to Clipboard Toggle word wrap

   앞의 구성에 따라 lastValue 주소와 연결된 모든 큐는 lost _ticker 의 마지막 값 키를 사용합니다. 기본적으로 default-last-value-key 값은 설정되지 않습니다.

3. 주소 집합에 대한 마지막 값 대기열을 구성하려면 주소 와일드카드를 지정할 수 있습니다. 예를 들면 다음과 같습니다.

   <address-setting match="lastValue.*">
      <default-last-value-key>stock_ticker</default-last-value-key>
   </address-setting>

   Copy to Clipboard Toggle word wrap

4. 또는 _AMQ_LVQ_NAME 의 기본 마지막 값 키 이름을 사용하도록 주소 또는 주소 세트 와 연결된 모든 대기열을 구성할 수 있습니다. 이렇게 하려면 default-last-value-key 대신 default-last-value-queue 를 추가합니다. 값을 true 로 설정합니다. 예를 들면 다음과 같습니다.

   <address-setting match="lastValue">
      <default-last-value-queue>true</default-last-value-queue>
   </address-setting>

   Copy to Clipboard Toggle word wrap

절차

1. &lt ;broker_instance_dir> /etc/broker.xml 구성 파일을 엽니다.

2. 이전에 대기열을 마지막 값 큐로 개별적으로 구성한 경우 디 지드되지 않은 키를 추가합니다. 값을 true 로 설정합니다. 예를 들면 다음과 같습니다.

   <address name="my.address">
      <multicast>
         <queue name="orders1" last-value-key="stock_ticker" non-destructive="true" />
      </multicast>
   </address>

   Copy to Clipboard Toggle word wrap

3. 이전에 마지막 값 큐에 대한 주소 또는 주소 집합을 구성한 경우 default-non-destructive 키를 추가합니다. 값을 true 로 설정합니다. 예를 들면 다음과 같습니다.

   <address-setting match="lastValue">
      <default-last-value-key>stock_ticker </default-last-value-key>
      <default-non-destructive>true</default-non-destructive>
   </address-setting>

   Copy to Clipboard Toggle word wrap
   참고

   기본적으로 default-non-destructive 의 값은 false 입니다.

절차

1. &lt ;broker_instance_dir> /etc/broker.xml 구성 파일을 엽니다.

2. core 요소에서 message-expiry-scan-period 를 설정하여 브로커의 만료된 메시지를 스캔하는 빈도를 지정합니다.

   <configuration ...>
      <core ...>
         ...
         <message-expiry-scan-period>1000</message-expiry-scan-period>
         ...

   Copy to Clipboard Toggle word wrap

   위 구성에 따라 브로커는 1000밀리초 마다 만료된 메시지의 대기열을 스캔합니다.

3. 일치하는 주소 또는 주소 집합에 대한 address-setting 요소에서 만료 주소를 지정합니다. 메시지 만료 시간을 설정합니다. 예를 들면 다음과 같습니다.

   <configuration ...>
      <core ...>
         ...
         <address-settings>
            ...
            <address-setting match="stocks">
               ...
               <expiry-address>ExpiryAddress</expiry-address>
               <expiry-delay>10</expiry-delay>
               ...
            </address-setting>
            ...
         <address-settings>
   <configuration ...>

   Copy to Clipboard Toggle word wrap

   expiry-address

   일치하는 주소 또는 주소에 대한 만료 주소입니다. 이전 예에서 브로커는 자재 주소에 대한 만료된 메시지를 ExpiryAddress 라는 만료 주소로 보냅니다.

   expiry-delay

   브로커가 기본 만료 시간을 사용하는 메시지에 적용되는 만료 시간(밀리초)입니다. 기본적으로 메시지는 만료 시간이 0 이며, 이는 만료되지 않습니다. 기본값보다 만료 시간이 긴 메시지의 경우 expiration -delay 는 적용되지 않습니다.

   예를 들어 앞의 예제와 같이 주소의 expiration -delay 를 10 으로 설정했다고 가정합니다. 기본 만료 시간이 0 인 메시지가 이 주소에서 큐에 도달하면 브로커는 메시지의 만료 시간을 0 에서 10 으로 변경합니다. 그러나 만료 시간을 사용 중인 다른 메시지가 20 개의 도달한 경우 만료 시간은 변경되지 않습니다. expiration-delay를 -1 로 설정하면 이 기능이 비활성화됩니다. 기본적으로 expiration -delay 는 -1 로 설정됩니다.

4. 또는 expiration -delay의 값을 지정하는 대신 최소 및 최대 만료 지연 값을 지정할 수 있습니다. 예를 들면 다음과 같습니다.

   <configuration ...>
      <core ...>
         ...
         <address-settings>
            ...
            <address-setting match="stocks">
               ...
               <expiry-address>ExpiryAddress</expiry-address>
               <min-expiry-delay>10</min-expiry-delay>
               <max-expiry-delay>100</max-expiry-delay>
               ...
            </address-setting>
            ...
         <address-settings>
   <configuration ...>

   Copy to Clipboard Toggle word wrap

   min-expiry-delay

   브로커가 메시지에 적용되는 최소 만료 시간(밀리초)입니다.

   max-expiry-delay

   브로커가 메시지에 적용되는 최대 만료 시간(밀리초)입니다.

   브로커는 다음과 같이 min-expiry-delay 및 max-expiry-delay 값을 적용합니다.

   • 기본 만료 시간이 0 인 메시지의 경우 브로커는 만료 시간을 max-expiry-delay 의 지정된 값으로 설정합니다. max-expiry-delay 의 값을 지정하지 않은 경우 브로커는 만료 시간을 min-expiry-delay 의 지정된 값으로 설정합니다. min-expiry-delay 의 값을 지정하지 않은 경우 브로커는 메시지의 만료 시간을 변경하지 않습니다.
   • max-expiry-delay 값을 초과하는 만료 시간이 있는 메시지의 경우 브로커는 만료 시간을 지정된 max-expiry-delay 값으로 설정합니다.
   • min-expiry-delay 값이 있는 만료 시간이 있는 메시지의 경우 브로커는 만료 시간을 min-expiry-delay 의 지정된 값으로 설정합니다.
   • min-expiry-delay 및 max-expiry-delay 값 사이의 만료가 있는 메시지의 경우 브로커는 메시지의 만료 시간을 변경하지 않습니다.
   • expiration -delay (기본값 -1)에 대한 값을 지정하면 min-expiry-delay 및 max-expiry-delay 에 대해 지정한 값을 덮어씁니다.
   • min-expiry-delay 및 max-expiry-delay 의 기본값은 -1 입니다(즉, 비활성화됨).

5. 구성 파일의 address 요소에서 이전에 지정한 address를 expiration -address에 대해 구성합니다. 이 주소에 큐를 정의합니다. 예를 들면 다음과 같습니다.

   <addresses>
       ...
       <address name="ExpiryAddress">
           <anycast>
               <queue name="ExpiryQueue"/>
           </anycast>
       </address>
       ...
   </addresses>

   Copy to Clipboard Toggle word wrap

   앞의 예제 구성은 만료 큐인 ExpiryQueue 를 만료 주소 ExpiryAddress 와 연결합니다.

절차

1. &lt ;broker_instance_dir> /etc/broker.xml 구성 파일을 엽니다.

2. 구성 파일에 이전에 추가한 & lt;address-setting > 요소를 찾아 일치하는 주소 또는 주소 집합에 대한 만료 주소를 정의합니다. 예를 들면 다음과 같습니다.

   <configuration ...>
   
      <core ...>
         ...
         <address-settings>
            ...
            <address-setting match="stocks">
               ...
               <expiry-address>ExpiryAddress</expiry-address>
               ...
            </address-setting>
            ...
         <address-settings>
   <configuration ...>

   Copy to Clipboard Toggle word wrap

3. < address-setting > 요소에서 브로커가 만료 리소스(즉, 주소 및 대기열)를 자동으로 생성하도록 지시하는 구성 항목과 이러한 리소스의 이름을 지정하는 방법을 추가합니다. 예를 들면 다음과 같습니다.

   <configuration ...>
      <core ...>
         ...
         <address-settings>
            ...
            <address-setting match="stocks">
               ...
               <expiry-address>ExpiryAddress</expiry-address>
               <auto-create-expiry-resources>true</auto-create-expiry-resources>
               <expiry-queue-prefix>EXP.</expiry-queue-prefix>
               <expiry-queue-suffix></expiry-queue-suffix>
               ...
            </address-setting>
            ...
         <address-settings>
   <configuration ...>

   Copy to Clipboard Toggle word wrap

   auto-create-expiry-resources

   브로커가 만료된 메시지를 수신하기 위해 만료 주소 및 큐를 자동으로 생성하는지 여부를 지정합니다. 기본값은 false입니다.

   매개변수 값이 true 로 설정되면 브로커는 만료 주소와 관련 만료 큐를 정의하는 <address> 요소를 자동으로 생성합니다. 자동 생성 < address> 요소의 name 값은 에 <expiry-address> 지정된 name 값과 일치합니다.

   자동 생성된 만료 큐에는 멀티 캐스트 라우팅 유형이 있습니다. 기본적으로 브로커 이름은 만료된 메시지가 원래 전송된 주소와 일치하도록 만료 큐의 이름을 지정합니다(예: 스포 지 ).

   브로커는 _AMQ_ORIG_ADDRESS 속성을 사용하는 만료 큐에 대한 필터도 정의합니다. 이 필터를 사용하면 만료 큐가 해당 원래 주소로 전송된 메시지만 수신합니다.

   expiry-queue-prefix

   브로커가 자동으로 생성된 만료 큐의 이름에 적용되는 접두사입니다. 기본값은 EXP입니다.

   접두사 값을 정의하거나 기본값을 유지하는 경우 만료 큐의 이름은 접두사와 원래 주소(예: EXP.>-<s )의 연결입니다.

   expiry-queue-suffix

   브로커가 자동으로 생성된 만료 큐의 이름에 적용되는 접미사입니다. 기본값은 정의되지 않습니다(즉 브로커는 접미사를 적용하지 않음).

절차

1. &lt ;broker_instance_dir> /etc/broker.xml 구성 파일을 엽니다.

2. 큐 이름과 일치하는 < address-setting > 요소에서 dead letter address name 및 최대 전달 시도 수를 설정합니다. 예를 들면 다음과 같습니다.

   <configuration ...>
      <core ...>
         ...
         <address-settings>
            ...
            <address-setting match="exampleQueue">
               <dead-letter-address>DLA</dead-letter-address>
               <max-delivery-attempts>3</max-delivery-attempts>
            </address-setting>
         ...
         <address-settings>
   <configuration ...>

   Copy to Clipboard Toggle word wrap

   match

   브로커가 이 address-setting 섹션의 구성을 적용하는 주소입니다. < address-setting > 요소의 match 속성에 와일드카드 표현식을 지정할 수 있습니다. 와일드카드 표현식을 사용하면 < address-setting > 요소에서 구성된 dead letter 설정을 일치하는 주소 세트 와 연결하려는 경우 유용합니다.

   dead-letter-address

   dead letter 주소의 이름입니다. 이 예제에서 브로커는 큐 예제Queue 에서 전달되지 않은 메시지를 dead letter 주소 DLA 로 이동합니다.

   max-delivery-attempts

   브로커가 구성된 배달되지 않은 메시지를 구성된 dead letter 주소로 이동하기 전에 최대 전달 시도 횟수입니다. 이 예에서 브로커는 실패한 전달 시도에 세 번 실패한 후 배달되지 않은 메시지를 배달 못 한 편지 주소로 이동합니다. 기본값은 10 입니다. 브로커가 무제한의 재전송 시도 횟수를 만들려면 값 -1 을 지정합니다.

3. addresses 섹션에서 dead letter 주소에 대한 address 요소 DLA 를 추가합니다. 배달 못 한 큐를 배달 못 한 편지 주소와 연결하려면 큐 의 이름 값을 지정합니다. 예를 들면 다음과 같습니다.

   <configuration ...>
      <core ...>
         ...
         <addresses>
            <address name="DLA">
               <anycast>
                  <queue name="DLQ" />
               </anycast>
            </address>
         ...
         </addresses>
      </core>
   </configuration>

   Copy to Clipboard Toggle word wrap

절차

1. &lt ;broker_instance_dir> /etc/broker.xml 구성 파일을 엽니다.

2. 일치하는 큐 또는 큐 집합에 대한 dead letter 주소를 정의하기 위해 이전에 추가한 <address-setting > 요소를 찾습니다. 예를 들면 다음과 같습니다.

   <configuration ...>
      <core ...>
         ...
         <address-settings>
            ...
            <address-setting match="exampleQueue">
               <dead-letter-address>DLA</dead-letter-address>
               <max-delivery-attempts>3</max-delivery-attempts>
            </address-setting>
         ...
         <address-settings>
   <configuration ...>

   Copy to Clipboard Toggle word wrap

3. < address-setting > 요소에서 브로커가 종료된 문자 리소스(즉, 주소 및 대기열) 및 이러한 리소스의 이름을 지정하는 방법을 자동으로 생성하도록 지시하는 구성 항목을 추가합니다. 예를 들면 다음과 같습니다.

   <configuration ...>
      <core ...>
         ...
         <address-settings>
            ...
            <address-setting match="exampleQueue">
               <dead-letter-address>DLA</dead-letter-address>
               <max-delivery-attempts>3</max-delivery-attempts>
               <auto-create-dead-letter-resources>true</auto-create-dead-letter-resources>
               <dead-letter-queue-prefix>DLQ.</dead-letter-queue-prefix>
               <dead-letter-queue-suffix></dead-letter-queue-suffix>
            </address-setting>
         ...
         <address-settings>
   <configuration ...>

   Copy to Clipboard Toggle word wrap

   auto-create-dead-letter-resources

   브로커가 배달되지 않은 메시지를 수신하기 위해 배달 못 한 주소와 큐를 자동으로 생성하는지 여부를 지정합니다. 기본값은 false입니다.

   auto-create-dead-letter-resources 가 true 로 설정된 경우 브로커는 배달 못 한 주소와 연관된 dead letter 큐를 정의하는 <address> 요소를 자동으로 생성합니다. 자동 생성 된 < address > 요소의 이름은 < dead-letter-address>에 대해 지정한 name 값과 일치합니다.

   브로커가 자동으로 생성된 < address > 요소에 정의하는 dead letter 큐는 멀티캐스트 라우팅 유형이 있습니다. 기본적으로 브로커는 배달되지 않은 메시지의 원래 주소와 일치하도록 dead letter 큐의 이름을 지정합니다(예: 스포지 트 ).

   브로커는 _AMQ_ORIG_ADDRESS 속성을 사용하는 dead letter 큐에 대한 필터도 정의합니다. 이 필터는 배달 못 한 큐가 해당 원래 주소로 전송된 메시지만 수신하도록 합니다.

   dead-letter-queue-prefix

   브로커가 자동으로 생성된 dead letter 큐의 이름에 적용되는 접두사입니다. 기본값은 DLQ입니다.

   접두사 값을 정의하거나 기본값을 유지하는 경우 dead letter 큐의 이름은 접두사와 원래 주소(예: DLQ.>-<s )의 연결입니다.

   dead-letter-queue-suffix

   브로커가 자동 생성된 dead letter 큐에 적용되는 접미사입니다. 기본값은 정의되지 않습니다(즉 브로커는 접미사를 적용하지 않음).

절차

1. &lt ;broker_instance_dir> /etc/broker.xml 구성 파일을 엽니다.

2. 지정된 큐에 대해 전용 키를 추가합니다. 값을 true 로 설정합니다.

   <configuration ...>
     <core ...>
       ...
       <address name="my.address">
         <multicast>
           <queue name="orders1" exclusive="true"/>
         </multicast>
       </address>
     </core>
   </configuration>

   Copy to Clipboard Toggle word wrap

1. &lt ;broker_instance_dir> /etc/broker.xml 구성 파일을 엽니다.

2. address-setting 요소에서 일치하는 주소에 대해 default-exclusive-queue 키를 추가합니다. 값을 true 로 설정합니다.

   <address-setting match="myAddress">
       <default-exclusive-queue>true</default-exclusive-queue>
   </address-setting>

   Copy to Clipboard Toggle word wrap

   앞의 구성에 따라 myAddress 주소와 연결된 모든 대기열은 배타적입니다. 기본적으로 default-exclusive-queue 의 값은 false 입니다.

3. 주소 집합에 대해 배타적 대기열을 구성하려면 주소 와일드카드를 지정할 수 있습니다. 예를 들면 다음과 같습니다.

   <address-setting match="myAddress.*">
       <default-exclusive-queue>true</default-exclusive-queue>
   </address-setting>

   Copy to Clipboard Toggle word wrap

절차

1. &lt ;broker_instance_dir> /etc/broker.xml 구성 파일을 엽니다.

2. 명시적 링 크기 세트가 없는 일치하는 주소의 모든 큐에 대한 기본 링 크기를 정의하려면 address-setting 요소에서 default-ring-size 의 값을 지정합니다. 예를 들면 다음과 같습니다.

   <address-settings>
      <address-setting match="ring.#">
         <default-ring-size>3</default-ring-size>
      </address-setting>
   </address-settings>

   Copy to Clipboard Toggle word wrap

   default-ring-size 매개변수는 자동 생성된 대기열의 기본 크기를 정의하는 데 특히 유용합니다. default-ring-size 의 기본값은 -1 입니다(즉, 크기 제한 없음).

3. 특정 큐에서 링 크기를 정의하려면 queue 요소에 ring-size 키를 추가합니다. 값을 지정합니다. 예를 들면 다음과 같습니다.

   <addresses>
      <address name="myRing">
         <anycast>
            <queue name="myRing" ring-size="5" />
         </anycast>
      </address>
   </addresses>

   Copy to Clipboard Toggle word wrap

1. 생산자는 ring-size="3" 로 구성된 링 큐에 세 개의 메시지를 보냅니다.

2. 모든 메시지는 즉시 소비자에게 전달됩니다.

   이 시점에서 messageCount= 3 및 deliveringCount= 3 입니다.

3. 생산자는 또 다른 메시지를 큐에 보냅니다. 그런 다음 메시지가 소비자에게 전달됩니다.

   이제 messageCount = 4 및 deliveringCount = 4 입니다. 4 의 메시지 수는 구성된 링 크기 3 보다 큽니다. 그러나 브로커는 큐에서 전달 중인 메시지를 제거할 수 없기 때문에 이러한 상황을 허용할 수 있습니다.

4. 이제 소비자가 메시지를 승인하지 않고 닫히고 있다고 가정합니다.

   이 경우 인증되지 않은 4개의 메시지가 브로커에 다시 취소되고 사용된 반대 순서로 큐 헤드에 추가됩니다. 이 작업은 구성된 링 크기에 큐를 둡니다. 링 대기열은 헤드의 메시지 위에 있는 큐의 tail의 메시지를 선호하므로 대기열은 대기열의 헤드에 다시 추가된 마지막 메시지가기 때문에 큐에서 보낸 첫 번째 메시지를 삭제합니다. 트랜잭션 또는 코어 세션 롤백은 동일한 방식으로 처리됩니다.

1. 12:00에서 생산자는 ring-size="3" 로 구성된 링 큐에 A 라는 메시지를 보냅니다. 메시지가 12:05에 대해 예정되어 있습니다.

   이 시점에서 messageCount= 1 및 scheduledCount= 1.

2. 12:01에서 생산자는 메시지 B 를 동일한 링 대기열에 보냅니다.

   이제 messageCount= 2 및 scheduledCount= 1 입니다.

3. 12:02에서 생산자는 C 메시지를 동일한 링 대기열에 보냅니다.

   이제 messageCount= 3 및 scheduledCount= 1 입니다.

4. 12:03에서 생산자는 메시지를 동일한 링 대기열에 보냅니다.

   이제 messageCount= 4 및 scheduledCount= 1 입니다.

   큐의 메시지 수는 이제 구성된 링 크기인 3 개보다 1개 큰 4 입니다. 그러나 예약된 메시지는 아직 큐에 기술적으로 표시되지 않습니다(즉, 브로커에 있으며 대기열에 배치되도록 예약됨). 예약된 제공 시간인 12:05에서 브로커는 큐의 헤드에 메시지를 넣습니다. 그러나 링 큐가 이미 구성된 크기에 도달했기 때문에 예약된 메시지 A 가 즉시 제거됩니다.

절차

1. &lt ;broker_instance_dir> /etc/broker.xml 구성 파일을 엽니다.

2. < federation> 요소를 포함하는 새 < federations > 요소를 추가합니다. 예를 들면 다음과 같습니다.

   <federations>
     <federation name="eu-north-1" user="federation_username" password="32a10275cf4ab4e9">
     </federation>
   </federations>

   Copy to Clipboard Toggle word wrap

   name

   페더레이션 구성의 이름입니다. 이 예에서 name은 로컬 브로커의 이름에 해당합니다.

   user

   업스트림 브로커에 연결하기 위한 공유 사용자 이름입니다.

   암호

   업스트림 브로커에 연결하기 위한 공유 암호입니다.

   참고

   원격 브로커에 대해 사용자 및 암호 인증 정보가 다른 경우 구성에 추가할 때 해당 브로커의 인증 정보를 별도로 지정할 수 있습니다. 이 내용은 이 절차의 뒷부분에서 설명합니다.

3. 페더레이션 요소 내에서 < address-policy> 요소를 추가합니다. 예를 들면 다음과 같습니다.

   <federations>
       <federation name="eu-north-1" user="federation_username" password="32a10275cf4ab4e9">
   
           <address-policy name="news-address-federation" auto-delete="true" auto-delete-delay="300000" auto-delete-message-count="-1" enable-divert-bindings="false" max-hops="1" transformer-ref="news-transformer">
           </address-policy>
   
       </federation>
   </federations>

   Copy to Clipboard Toggle word wrap

   name

   주소 정책의 이름입니다. 브로커에 구성된 모든 주소 정책에는 고유한 이름이 있어야 합니다.

   auto-delete

   주소 페더레이션 중에 로컬 브로커는 원격 주소에 내재된 큐를 동적으로 생성합니다. 자동 삭제 속성 값은 로컬 브로커의 연결을 끊고 auto-delete - delay 및 auto-delete-message- count 속성의 값도 연결되면 원격 큐를 삭제해야 하는지 여부를 지정합니다. 동적으로 생성된 대기열의 정리를 자동화하려는 경우 유용한 옵션입니다. 로컬 브로커가 오랫동안 연결이 끊어진 경우 원격 브로커의 메시지 빌드를 방지하려는 경우에도 유용한 옵션입니다. 그러나 연결이 끊긴 동안 메시지가 항상 로컬 브로커에 대해 대기 상태로 유지되도록 하려면 이 옵션을 false 로 설정하여 로컬 브로커에서 메시지 손실을 방지할 수 있습니다.

   auto-delete-delay

   로컬 브로커의 연결이 끊어지면 이 속성의 값은 동적으로 생성된 원격 대기열을 자동으로 삭제할 수 있기 전에 시간(밀리초)을 지정합니다.

   auto-delete-message-count

   로컬 브로커의 연결이 끊어진 후 이 속성의 값은 해당 큐가 자동으로 삭제되기 전에 동적으로 생성된 원격 큐에 계속 있을 수 있는 최대 메시지 수를 지정합니다.

   enable-divert-bindings

   이 속성을 true 로 설정하면 요청 발생 시 바인딩을 수신 대기할 수 있습니다. 주소 정책의 포함된 주소와 일치하는 주소가 있는 중단 바인딩이 있는 경우 변환 주소의 전달 주소와 일치하는 모든 큐 바인딩이 수요가 생성됩니다. 기본값은 false입니다.

   max-hops

   페더레이션 중에 메시지가 만들 수 있는 최대 홉 수입니다. 특정 토폴로지에는 이 속성에 대한 특정 값이 필요합니다. 이러한 요구 사항에 대한 자세한 내용은 4.22.2절. “주소 페더레이션의 일반적인 토폴로지” 을 참조하십시오.

   transformer-ref

   변환기 구성의 이름입니다. 페더레이션 메시지 전송 중에 메시지를 변환하려면 변환기 구성을 추가할 수 있습니다. Transformer 구성은 이 절차의 뒷부분에서 설명합니다.

4. &lt ;address-policy > 요소 내에 주소를 포함 및 제외할 address-matching 패턴을 추가합니다. 예를 들면 다음과 같습니다.

   <federations>
       <federation name="eu-north-1" user="federation_username" password="32a10275cf4ab4e9">
   
           <address-policy name="news-address-federation" auto-delete="true" auto-delete-delay="300000" auto-delete-message-count="-1" enable-divert-bindings="false" max-hops="1" transformer-ref="news-transformer">
   
               <include address-match="queue.bbc.new" />
               <include address-match="queue.usatoday" />
               <include address-match="queue.news.#" />
   
               <exclude address-match="queue.news.sport.#" />
           </address-policy>
   
       </federation>
   </federations>

   Copy to Clipboard Toggle word wrap

   include

   이 요소의 address-match 속성 값은 주소 정책에 포함할 주소를 지정합니다. 정확한 주소를 지정할 수 있습니다(예: queue.bbc.new 또는 queue.usatoday ). 또는 와일드카드 표현식을 사용하여 일치하는 주소 집합을 지정할 수 있습니다. 이전 예에서 주소 정책에는 문자열 queue.news 로 시작하는 모든 주소 이름도 포함됩니다.

   exclude

   이 요소의 address-match 속성 값은 주소 정책에서 제외할 주소를 지정합니다. 정확한 주소 이름을 지정하거나 와일드카드 표현식을 사용하여 일치하는 주소 집합을 지정할 수 있습니다. 이전 예에서 address 정책은 queue.news.sport 문자열로 시작하는 모든 주소 이름을 제외합니다.

5. (선택 사항) 페더레이션 요소에서 사용자 지정 변환기 구현을 참조하는 변환자 요소를 추가합니다. 예를 들면 다음과 같습니다.

   <federations>
       <federation name="eu-north-1" user="federation_username" password="32a10275cf4ab4e9">
   
           <address-policy name="news-address-federation" auto-delete="true" auto-delete-delay="300000" auto-delete-message-count="-1" enable-divert-bindings="false" max-hops="1" transformer-ref="news-transformer">
   
               <include address-match="queue.bbc.new" />
               <include address-match="queue.usatoday" />
               <include address-match="queue.news.#" />
   
               <exclude address-match="queue.news.sport.#" />
           </address-policy>
   
           <transformer name="news-transformer">
               <class-name>org.myorg.NewsTransformer</class-name>
               <property key="key1" value="value1"/>
               <property key="key2" value="value2"/>
           </transformer>
   
       </federation>
   </federations>

   Copy to Clipboard Toggle word wrap

   name

   변환기 구성의 이름입니다. 이 이름은 로컬 브로커에서 고유해야 합니다. 주소 정책의 transformer-ref 속성 값으로 지정하는 이름입니다.

   class-name

   org.apache.activemq.artemis.core.server.transformer 인터페이스를 구현하는 사용자 정의 클래스의 이름입니다.

   변환기의 transform() 메서드는 메시지가 전송되기 전에 메시지와 함께 호출됩니다. 이렇게 하면 메시지 헤더 또는 본문이 페더레이션되기 전에 변환될 수 있습니다.

   속성

   특정 변환기 구성에 대해 키-값 쌍을 보유하는 데 사용됩니다.

6. 페더레이션 요소 내에서 하나 이상의 업스트림 요소를 추가합니다. 각 업스트림 요소는 원격 브로커에 대한 연결을 정의하고 해당 연결에 적용할 정책을 정의합니다. 예를 들면 다음과 같습니다.

   <federations>
       <federation name="eu-north-1" user="federation_username" password="32a10275cf4ab4e9">
   
           <upstream name="eu-east-1">
               <static-connectors>
                   <connector-ref>eu-east-connector1</connector-ref>
               </static-connectors>
               <policy ref="news-address-federation"/>
           </upstream>
   
           <upstream name="eu-west-1" >
               <static-connectors>
                   <connector-ref>eu-west-connector1</connector-ref>
               </static-connectors>
               <policy ref="news-address-federation"/>
           </upstream>
   
           <address-policy name="news-address-federation" auto-delete="true" auto-delete-delay="300000" auto-delete-message-count="-1" enable-divert-bindings="false" max-hops="1" transformer-ref="news-transformer">
   
               <include address-match="queue.bbc.new" />
               <include address-match="queue.usatoday" />
               <include address-match="queue.news.#" />
   
               <exclude address-match="queue.news.sport.#" />
           </address-policy>
   
           <transformer name="news-transformer">
               <class-name>org.myorg.NewsTransformer</class-name>
               <property key="key1" value="value1"/>
               <property key="key2" value="value2"/>
           </transformer>
   
       </federation>
   </federations>

   Copy to Clipboard Toggle word wrap

   static-connectors

   로컬 브로커의 broker.xml 구성 파일의 다른 위치에서 정의된 커넥터 요소를 참조하는 connector -ref 요소 목록이 포함되어 있습니다. 커넥터는 발신 연결에 사용할 전송(TCP, SSL, HTTP 등) 및 서버 연결 매개 변수(호스트, 포트 등)를 정의합니다. 이 절차의 다음 단계에서는 static-connectors 요소에서 참조되는 커넥터를 추가하는 방법을 보여줍니다.

   policy-ref

   업스트림 브로커에 적용되는 다운스트림 브로커에 구성된 주소 정책의 이름입니다.

   업스트림 요소에 대해 지정할 수 있는 추가 옵션은 다음과 같습니다.

   name

   업스트림 브로커 구성의 이름입니다. 이 예에서 이름은 eu-east-1 및 eu-west-1 이라는 업스트림 브로커에 해당합니다.

   user

   업스트림 브로커에 대한 연결을 생성할 때 사용할 사용자 이름입니다. 지정하지 않으면 페더레이션 요소의 구성에 지정된 공유 사용자 이름이 사용됩니다.

   암호

   업스트림 브로커에 대한 연결을 생성할 때 사용할 암호입니다. 지정하지 않으면 페더레이션 요소의 구성에 지정된 공유 암호가 사용됩니다.

   call-failover-timeout

   call-timeout 과 유사하지만 페일오버 시도 중에 호출이 수행될 때 사용됩니다. 기본값은 -1 이며, 이는 시간 초과가 비활성화되어 있음을 의미합니다.

   call-timeout

   페더레이션 연결은 원격 브로커에서 차단 호출인 패킷을 전송할 때 응답을 대기하는 시간(밀리초)입니다. 이 시간이 지나면 연결이 예외를 발생시킵니다. 기본값은 30000 입니다.

   check-period

   로컬 브로커가 원격 브로커에 전송하여 페더레이션 연결 상태를 확인하기 위해 연속 "유지 관리" 메시지 사이의 기간(밀리초)입니다. 페더레이션 연결이 정상이면 원격 브로커는 각 keep-alive 메시지에 응답합니다. 연결이 비정상적인 경우 다운스트림 브로커가 업스트림 브로커로부터 응답을 수신하지 못하면 회로 차단기 라는 메커니즘을 사용하여 페더레이션 소비자를 차단합니다. 자세한 내용은 circuit-breaker-timeout 매개변수 설명을 참조하십시오. check-period 매개변수의 기본값은 30000 입니다.

   circuit-breaker-timeout

   다운스트림과 업스트림 브로커 간의 단일 연결은 많은 페더레이션 대기열과 주소 소비자에 의해 공유될 수 있습니다. 브로커 간의 연결이 손실되면 페더레이션된 각 소비자가 동시에 다시 연결을 시도할 수 있습니다. 이를 방지하기 위해 회로 차단기 라는 메커니즘은 소비자를 차단합니다. 지정된 타임아웃 값이 경과하면 회로 차단기에서 연결을 다시 연결합니다. 성공하면 소비자가 차단 해제됩니다. 그렇지 않으면 회로 차단기가 다시 적용됩니다.

   connection-ttl

   원격 브로커에서 메시지 수신을 중지하면 페더레이션 연결이 활성 상태로 유지됩니다. 기본값은 60000 입니다.

   discovery-group-ref

   업스트림 브로커 연결에 대해 정적 커넥터를 정의하는 대신 이 요소를 사용하여 broker.xml 구성 파일의 다른 위치에서 이미 구성된 검색 그룹을 지정할 수 있습니다. 특히 기존 검색 그룹을 이 요소의 discovery-group-name 속성 값으로 지정합니다. 검색 그룹에 대한 자세한 내용은 14.1.6절. “브로커 검색 방법” 을 참조하십시오.

   ha

   업스트림 브로커에 대한 연결에 high availability가 활성화되어 있는지 여부를 지정합니다. 이 매개변수의 값이 true 로 설정된 경우 로컬 브로커는 업스트림 클러스터에서 사용 가능한 모든 브로커에 연결하고 라이브 업스트림 브로커가 종료되면 백업 브로커로 자동 실패할 수 있습니다. 기본값은 false입니다.

   initial-connect-attempts

   다운스트림 브로커가 업스트림 브로커에 연결하기 위해 수행할 초기 시도 횟수입니다. 연결이 설정되지 않은 경우 업스트림 브로커는 영구적으로 오프라인으로 간주됩니다. 다운스트림 브로커는 더 이상 메시지를 업스트림 브로커로 라우팅하지 않습니다. 기본값은 -1 이며 이는 제한이 없음을 의미합니다.

   max-retry-interval

   원격 브로커에 연결할 때 후속 재연결 시도 사이에 최대 시간(밀리초)입니다. 기본값은 2000 입니다.

   reconnect-attempts

   연결이 실패하면 다운스트림 브로커가 업스트림 브로커에 다시 연결하는 횟수입니다. 연결을 다시 설정하지 않고 이 값에 도달하면 업스트림 브로커는 영구적으로 오프라인으로 간주됩니다. 다운스트림 브로커는 더 이상 메시지를 업스트림 브로커로 라우팅하지 않습니다. 기본값은 -1 이며 이는 제한이 없음을 의미합니다.

   retry-interval

   원격 브로커 연결에 실패한 경우 후속 재연결 시도 사이에 마침표(밀리초)입니다. 기본값은 500 입니다.

   retry-interval-multiplier

   retry-interval 매개변수 값에 적용되는 요인을 곱합니다. 기본값은 1 입니다.

   share-connection

   동일한 브로커에 대해 다운스트림 및 업스트림 연결이 모두 구성된 경우 다운스트림 및 업스트림 구성 모두 이 매개변수 값을 true 로 설정하는 한 동일한 연결이 공유됩니다. 기본값은 false입니다.

7. 로컬 브로커에서 원격 브로커에 커넥터를 추가합니다. 이러한 커넥터는 페더레이션 주소 구성의 정적 연결 요소에서 참조됩니다. 예를 들면 다음과 같습니다.

   <connectors>
      <connector name="eu-west-1-connector">tcp://localhost:61616</connector>
      <connector name="eu-east-1-connector">tcp://localhost:61617</connector>
   </connectors>

   Copy to Clipboard Toggle word wrap

절차

1. 로컬 브로커에서 < broker_instance_dir> /etc/broker.xml 구성 파일을 엽니다.

2. < federation> 요소를 포함하는 < federations > 요소를 추가합니다. 예를 들면 다음과 같습니다.

   <federations>
       <federation name="eu-north-1" user="federation_username" password="32a10275cf4ab4e9">
       </federation>
   </federations>

   Copy to Clipboard Toggle word wrap

3. 주소 정책 구성을 추가합니다. 예를 들면 다음과 같습니다.

   <federations>
       ...
       <federation name="eu-north-1" user="federation_username" password="32a10275cf4ab4e9">
   
           <address-policy name="news-address-federation" max-hops="1" auto-delete="true" auto-delete-delay="300000" auto-delete-message-count="-1" transformer-ref="news-transformer">
   
               <include address-match="queue.bbc.new" />
               <include address-match="queue.usatoday" />
               <include address-match="queue.news.#" />
   
               <exclude address-match="queue.news.sport.#" />
           </address-policy>
   
       </federation>
     ...
   </federations>

   Copy to Clipboard Toggle word wrap

4. 전송 전에 메시지를 변환하려면 변환기 구성을 추가합니다. 예를 들면 다음과 같습니다.

   <federations>
       ...
       <federation name="eu-north-1" user="federation_username" password="32a10275cf4ab4e9">
   
           <address-policy name="news-address-federation" max-hops="1" auto-delete="true" auto-delete-delay="300000" auto-delete-message-count="-1" transformer-ref="news-transformer">
   
               <include address-match="queue.bbc.new" />
               <include address-match="queue.usatoday" />
               <include address-match="queue.news.#" />
   
               <exclude address-match="queue.news.sport.#" />
           </address-policy>
   
           <transformer name="news-transformer">
               <class-name>org.myorg.NewsTransformer</class-name>
               <property key="key1" value="value1"/>
               <property key="key2" value="value2"/>
           </transformer>
   
       </federation>
     ...
   </federations>

   Copy to Clipboard Toggle word wrap

5. 각 원격 브로커에 대해 downstream 요소를 추가합니다. 예를 들면 다음과 같습니다.

   <federations>
       ...
       <federation name="eu-north-1" user="federation_username" password="32a10275cf4ab4e9">
   
           <downstream name="eu-east-1">
                   <static-connectors>
                       <connector-ref>eu-east-connector1</connector-ref>
                   </static-connectors>
                   <upstream-connector-ref>netty-connector</upstream-connector-ref>
                   <policy ref="news-address-federation"/>
           </downstream>
   
           <downstream name="eu-west-1" >
                   <static-connectors>
                       <connector-ref>eu-west-connector1</connector-ref>
                   </static-connectors>
                   <upstream-connector-ref>netty-connector</upstream-connector-ref>
                   <policy ref="news-address-federation"/>
           </downstream>
   
           <address-policy name="news-address-federation" max-hops="1" auto-delete="true" auto-delete-delay="300000" auto-delete-message-count="-1" transformer-ref="news-transformer">
               <include address-match="queue.bbc.new" />
               <include address-match="queue.usatoday" />
               <include address-match="queue.news.#" />
   
               <exclude address-match="queue.news.sport.#" />
           </address-policy>
   
           <transformer name="news-transformer">
               <class-name>org.myorg.NewsTransformer</class-name>
               <property key="key1" value="value1"/>
               <property key="key2" value="value2"/>
           </transformer>
   
       </federation>
     ...
   </federations>

   Copy to Clipboard Toggle word wrap

   이전 구성에 표시된 대로 원격 브로커는 이제 로컬 브로커의 다운스트림으로 간주됩니다. 다운스트림 브로커는 구성의 연결 정보를 사용하여 로컬(즉, 업스트림) 브로커에 다시 연결합니다.

6. 로컬 브로커에서 로컬 및 원격 브로커가 사용하는 커넥터 및 어셉터를 추가하여 페더레이션 연결을 설정합니다. 예를 들면 다음과 같습니다.

   <connectors>
      <connector name="netty-connector">tcp://localhost:61616</connector>
      <connector name="eu-west-1-connector">tcp://localhost:61616</connector>
      <connector name="eu-east-1-connector">tcp://localhost:61617</connector>
   </connectors>
   
   <acceptors>
      <acceptor name="netty-acceptor">tcp://localhost:61616</acceptor>
   </acceptors>

   Copy to Clipboard Toggle word wrap

   connector name="netty-connector"

   로컬 브로커가 원격 브로커에 전송하는 커넥터 구성입니다. 원격 브로커는 이 구성을 사용하여 로컬 브로커에 다시 연결합니다.

   connector name="eu-west-1-connector", connector name="eu-east-1-connector"

   원격 브로커에 대한 커넥터입니다. 로컬 브로커는 이러한 커넥터를 사용하여 원격 브로커에 연결하고 원격 브로커가 로컬 브로커에 다시 연결해야 하는 구성을 공유합니다.

   acceptor name="netty-acceptor"

   로컬 브로커의 어셉터는 원격 브로커가 로컬 브로커에 다시 연결하는 데 사용하는 커넥터에 해당합니다.

절차

1. &lt ;broker_instance_dir> /etc/broker.xml 구성 파일을 엽니다.

2. 새 < federations > 요소 내에서 < federation> 요소를 추가합니다. 예를 들면 다음과 같습니다.

   <federations>
     <federation name="eu-north-1" user="federation_username" password="32a10275cf4ab4e9">
     </federation>
   </federations>

   Copy to Clipboard Toggle word wrap

   name

   페더레이션 구성의 이름입니다. 이 예에서 name은 다운스트림 브로커의 이름에 해당합니다.

   user

   업스트림 브로커에 연결하기 위한 공유 사용자 이름입니다.

   암호

   업스트림 브로커에 연결하기 위한 공유 암호입니다.

   참고
   • 사용자 및 암호 인증 정보가 업스트림 브로커에 대해 다른 경우 구성에 추가할 때 해당 브로커의 인증 정보를 별도로 지정할 수 있습니다. 이 내용은 이 절차의 뒷부분에서 설명합니다.

3. 페더레이션 요소 내에 < queue-policy> 요소를 추가합니다. < queue-policy&gt; 요소의 속성 값을 지정합니다. 예를 들면 다음과 같습니다.

   <federations>
       <federation name="eu-north-1" user="federation_username" password="32a10275cf4ab4e9">
   
           <queue-policy name="news-queue-federation" include-federated="true" priority-adjustment="-5" transformer-ref="news-transformer">
           </queue-policy>
   
       </federation>
   </federations>

   Copy to Clipboard Toggle word wrap

   name

   대기열 정책의 이름입니다. 브로커에 구성된 모든 큐 정책에는 고유한 이름이 있어야 합니다.

   include-federated

   이 속성의 값을 false 로 설정하면 구성이 이미 손상된 소비자(즉, 페더레이션 큐의 소비자)를 다시 페더레이션하지 않습니다. 따라서 대칭 또는 클로즈 루프 토폴로지에서는 페더레이션되지 않은 소비자가 없으며 메시지가 시스템 전체에서 무한대로 순환되는 상황을 방지할 수 있습니다.

   closed-loop 토폴로지가 없는 경우 이 속성의 값을 true 로 설정할 수 있습니다. 예를 들어 BrokerA,BrokerB 및 BrokerC 의 생산자와 BrokerC의 생산자와 함께 세 개의 브로커, BrokerA, BrokerC 의 체인이 있다고 가정합니다. 이 경우 BrokerB 에서 BrokerA 에 소비자를 다시 주도록 합니다.

   priority-adjustment

   소비자가 큐에 연결하면 업스트림(즉 페더레이션된) 소비자가 생성될 때 우선순위가 사용됩니다. 페더레이션 소비자의 우선 순위는 priority-adjustment 속성의 값으로 조정됩니다. 이 속성의 기본값은 -1 이며, 로드 밸런싱 중에 로컬 소비자가 페더레이션 소비자보다 우선 순위를 지정할 수 있습니다. 그러나 필요에 따라 우선순위 조정 값을 변경할 수 있습니다.

절차

1. &lt ;broker_instance_dir> /etc/broker.xml 구성 파일을 엽니다.

2. < federation> 요소를 포함하는 < federations > 요소를 추가합니다. 예를 들면 다음과 같습니다.

   <federations>
     <federation name="eu-north-1" user="federation_username" password="32a10275cf4ab4e9">
     </federation>
   </federations>

   Copy to Clipboard Toggle word wrap

3. 큐 정책 구성을 추가합니다. 예를 들면 다음과 같습니다.

   <federations>
       ...
       <federation name="eu-north-1" user="federation_username" password="32a10275cf4ab4e9">
   
           <queue-policy name="news-queue-federation" priority-adjustment="-5" include-federated="true" transformer-ref="new-transformer">
   
               <include queue-match="#" address-match="queue.bbc.new" />
               <include queue-match="#" address-match="queue.usatoday" />
               <include queue-match="#" address-match="queue.news.#" />
   
               <exclude queue-match="#.local" address-match="#" />
   
           </queue-policy>
   
       </federation>
     ...
   </federations>

   Copy to Clipboard Toggle word wrap

4. 전송 전에 메시지를 변환하려면 변환기 구성을 추가합니다. 예를 들면 다음과 같습니다.

   <federations>
       ...
       <federation name="eu-north-1" user="federation_username" password="32a10275cf4ab4e9">
   
           <queue-policy name="news-queue-federation" priority-adjustment="-5" include-federated="true" transformer-ref="news-transformer">
   
               <include queue-match="#" address-match="queue.bbc.new" />
               <include queue-match="#" address-match="queue.usatoday" />
               <include queue-match="#" address-match="queue.news.#" />
   
               <exclude queue-match="#.local" address-match="#" />
   
           </queue-policy>
   
           <transformer name="news-transformer">
               <class-name>org.myorg.NewsTransformer</class-name>
               <property key="key1" value="value1"/>
               <property key="key2" value="value2"/>
           </transformer>
   
       </federation>
     ...
   </federations>

   Copy to Clipboard Toggle word wrap

5. 각 원격 브로커에 대해 downstream 요소를 추가합니다. 예를 들면 다음과 같습니다.

   <federations>
       ...
       <federation name="eu-north-1" user="federation_username" password="32a10275cf4ab4e9">
   
           <downstream name="eu-east-1">
               <static-connectors>
                   <connector-ref>eu-east-connector1</connector-ref>
               </static-connectors>
               <upstream-connector-ref>netty-connector</upstream-connector-ref>
               <policy ref="news-address-federation"/>
           </downstream>
   
           <downstream name="eu-west-1" >
               <static-connectors>
                   <connector-ref>eu-west-connector1</connector-ref>
               </static-connectors>
               <upstream-connector-ref>netty-connector</upstream-connector-ref>
               <policy ref="news-address-federation"/>
           </downstream>
   
           <queue-policy name="news-queue-federation" priority-adjustment="-5" include-federated="true" transformer-ref="new-transformer">
   
               <include queue-match="#" address-match="queue.bbc.new" />
               <include queue-match="#" address-match="queue.usatoday" />
               <include queue-match="#" address-match="queue.news.#" />
   
               <exclude queue-match="#.local" address-match="#" />
   
           </queue-policy>
   
           <transformer name="news-transformer">
               <class-name>org.myorg.NewsTransformer</class-name>
               <property key="key1" value="value1"/>
               <property key="key2" value="value2"/>
           </transformer>
   
       </federation>
     ...
   </federations>

   Copy to Clipboard Toggle word wrap

   이전 구성에 표시된 대로 원격 브로커는 이제 로컬 브로커의 다운스트림으로 간주됩니다. 다운스트림 브로커는 구성의 연결 정보를 사용하여 로컬(즉, 업스트림) 브로커에 다시 연결합니다.

6. 로컬 브로커에서 로컬 및 원격 브로커가 사용하는 커넥터 및 어셉터를 추가하여 페더레이션 연결을 설정합니다. 예를 들면 다음과 같습니다.

   <connectors>
      <connector name="netty-connector">tcp://localhost:61616</connector>
      <connector name="eu-west-1-connector">tcp://localhost:61616</connector>
      <connector name="eu-east-1-connector">tcp://localhost:61617</connector>
   </connectors>
   
   <acceptors>
      <acceptor name="netty-acceptor">tcp://localhost:61616</acceptor>
   </acceptors>

   Copy to Clipboard Toggle word wrap

   connector name="netty-connector"

   로컬 브로커가 원격 브로커에 전송하는 커넥터 구성입니다. 원격 브로커는 이 구성을 사용하여 로컬 브로커에 다시 연결합니다.

   connector name="eu-west-1-connector" , connector name="eu-east-1-connector"

   원격 브로커에 대한 커넥터입니다. 로컬 브로커는 이러한 커넥터를 사용하여 원격 브로커에 연결하고 원격 브로커가 로컬 브로커에 다시 연결해야 하는 구성을 공유합니다.

   acceptor name="netty-acceptor"

   로컬 브로커의 어셉터는 원격 브로커가 로컬 브로커에 다시 연결하는 데 사용하는 커넥터에 해당합니다.

1. &lt ;broker_instance_dir> /etc/broker.xml 구성 파일을 엽니다.

2. 지정된 acceptor에 sslEnabled 키를 추가하고 값을 true 로 설정합니다. 또한 keyStorePath 및 keyStorePassword 키를 추가합니다. 브로커 키 저장소에 해당하는 값을 설정합니다. 예를 들면 다음과 같습니다.

   <acceptor name="artemis">tcp://0.0.0.0:61616?sslEnabled=true;keyStorePath=../etc/broker.keystore;keyStorePassword=1234!</acceptor>

   Copy to Clipboard Toggle word wrap

절차

1. &lt ;broker_instance_dir> /etc/broker.xml 구성 파일을 엽니다.

2. 이전에 단방향 TLS용으로 구성한 acceptor의 경우 needClientAuth 키를 추가합니다. 값을 true 로 설정합니다. 예를 들면 다음과 같습니다.

   <acceptor name="artemis">tcp://0.0.0.0:61616?sslEnabled=true;keyStorePath=../etc/broker.keystore;keyStorePassword=1234!;needClientAuth=true</acceptor>

   Copy to Clipboard Toggle word wrap

3. 이전 단계의 구성은 클라이언트의 인증서가 신뢰할 수 있는 공급자가 서명했다고 가정합니다. 클라이언트의 인증서가 신뢰할 수 있는 공급자(예: 자체 서명)에서 서명 하지 않은 경우 브로커는 클라이언트의 인증서를 신뢰 저장소로 가져와야 합니다. 이 경우 trustStorePath 및 trustStorePassword 키를 추가합니다. 브로커 신뢰 저장소에 해당하는 값을 설정합니다. 예를 들면 다음과 같습니다.

   <acceptor name="artemis">tcp://0.0.0.0:61616?sslEnabled=true;keyStorePath=../etc/broker.keystore;keyStorePassword=1234!;needClientAuth=true;trustStorePath=../etc/client.truststore;trustStorePassword=5678!</acceptor>

   Copy to Clipboard Toggle word wrap