4.22. 주소 및 큐 처리

프로세스

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

2. < amqp-connection> 요소를 포함하는 <broker connections > 요소를 추가합니다. &lt ;amqp-connection > 요소에서 원격 브로커의 연결 세부 정보를 지정하고 페더레이션 구성에 이름을 할당합니다. 예를 들면 다음과 같습니다.

   <broker-connections>
     <amqp-connection uri="tcp://<__HOST__>:<__PORT__>" user="federation_user" password="federation_pwd" name="queue-federation-example">
     </amqp-connection>
   </broker-connections>

3. &lt ;federation&gt; 요소를 추가하고 다음 중 하나 또는 둘 다를 포함합니다.

   • 원격 브로커에서 로컬 브로커로 메시지를 통합하는 <local-address-policy > 요소입니다.
   • 로컬 브로커에서 원격 브로커로 메시지를 통합하는 <remote-address-policy > 요소입니다.

   다음 예제에서는 로컬 및 원격 주소 정책이 모두 있는 페더레이션 요소를 보여줍니다.

   <broker-connections>
     <amqp-connection uri="tcp://<__HOST__>:<__PORT__>" user="federation_user" password="federation_pwd" name="queue-federation-example">
       <federation>
         <local-address-policy name="example-local-address-policy" auto-delete="true" auto-delete-delay="1" auto-delete-message-count="2" max-hops="1" enable-divert-bindings="true">
           <include address-match="queue.news.#" />
   	    <include address-match="queue.bbc.news" />
           <exclude address-match="queue.news.sport.#" />
          </local-address-policy>
          <remote-address-policy name="example-remote-address-policy">
            <include address-match="queue.usatoday" />
          </remote-address-policy>
       </federation>
     </amqp-connection>
   </broker-connections>

   동일한 매개변수는 로컬 및 원격 주소 정책 모두에서 구성할 수 있습니다. 유효한 매개변수는 다음과 같습니다.

   name

   주소 정책의 이름입니다. 모든 주소 정책 이름은 < broker-connections > 요소의 < federation > 요소 내에서 고유해야 합니다.

   max-hops

   페더레이션 중에 메시지가 만들 수 있는 최대 홉 수입니다. 기본값은 대부분의 간단한 페더레이션 배포에 적합합니다. 그러나 특정 토폴로지에서는 메시지가 루프되지 않도록 하는 데 더 큰 값이 필요할 수 있습니다.

   자동 삭제

   주소 페더레이션의 경우 메시지가 페인딩되는 브로커에 생성됩니다. 시작 브로커의 연결이 끊어지고 지연 및 메시지 수 매개변수가 충족되면 자동 삭제 대기열을 표시하려면 이 매개변수를 true로 설정합니다. 동적으로 생성된 큐의 정리를 자동화하려는 경우 이 옵션이 유용합니다. 기본값은 false 이므로 큐가 자동으로 삭제되지 않습니다.

   auto-delete-delay

   브로커 시작 연결이 끊어진 후 생성된 큐를 자동으로 삭제할 수 있는 시간(밀리초)입니다. 기본값은 0입니다.

   auto-delete-message-count

   큐의 메시지 수가 큐를 자동으로 삭제하기 전에 큐보다 작거나 같아야 합니다. 기본값은 0입니다.

   enable-divert-bindings

   true 로 설정하면 필요에 따라 다양한 바인딩을 청취할 수 있습니다. 주소가 있는 다양한 바인딩이 주소 정책에 대한 포함된 주소와 일치하는 경우 다이버트의 전달 주소와 일치하는 모든 큐 바인딩이 수요를 생성합니다. 기본값은 false입니다.

   포함

   정책에 포함할 주소와 일치하는 주소와 일치하는 패턴입니다. 여러 패턴을 지정할 수 있습니다. 패턴을 지정하지 않으면 모든 주소가 정책에 포함됩니다.

   정확한 주소를 지정할 수 있습니다(예: queue.bbc.news ). 또는 숫자 기호(#) 와일드카드 문자를 사용하여 일치하는 주소 집합을 지정할 수 있습니다. 이전 예에서 로컬 주소 정책에는 queue.news 문자열로 시작하는 모든 주소도 포함됩니다.

   exclude

   정책에서 제외할 주소와 일치하는 주소와 일치하는 패턴입니다. 여러 패턴을 지정할 수 있습니다. 패턴을 지정하지 않으면 주소가 정책에서 제외되지 않습니다.

   정확한 주소를 지정할 수 있습니다(예: queue.bbc.news ). 또는 숫자 기호(#) 와일드카드 문자를 사용하여 일치하는 주소 집합을 지정할 수 있습니다. 이전 예에서 로컬 주소 정책은 queue.news.sport 문자열로 시작하는 모든 주소를 제외합니다.

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

2. < amqp-connection> 요소를 포함하는 <broker connections > 요소를 추가합니다. &lt ;amqp-connection > 요소에서 원격 브로커의 연결 세부 정보를 지정하고 페더레이션 구성에 이름을 할당합니다. 예를 들면 다음과 같습니다.

   <broker-connections>
     <amqp-connection uri="tcp://<__HOST__>:<__PORT__>" user="federation_user" password="federation_pwd" name="queue-federation-example">
     </amqp-connection>
   </broker-connections>

3. &lt ;federation&gt; 요소를 추가하고 다음 중 하나 또는 둘 다를 포함합니다.

   • 원격 브로커에서 로컬 브로커로 메시지를 통합하는 <local-queue-policy > 요소입니다.
   • 로컬 브로커에서 원격 브로커로 메시지를 통합하는 <remote-queue-policy > 요소입니다.

   다음 예제에서는 로컬 큐 정책을 포함하는 페더레이션 요소를 보여줍니다.

   <broker-connections>
     <amqp-connection uri="tcp://HOST:PORT" name="federation-example">
       <federation>
         <local-queue-policy name="example-local-queue-policy">
           <include address-match="#" queue-match="#.remote" />
           <exclude address-match="#" queue-match="#.local" />
         </local-queue-policy>
       </federation>
     </amqp-connection>
   </broker-connections>

   name

   큐 정책의 이름입니다. 모든 큐 정책 이름은 < broker-connections > 요소의 < federation > 요소 내에서 고유해야 합니다.

   포함

   정책에 포함되기 위해 해당 주소의 특정 큐와 일치하는 주소 일치 패턴 및 큐 일치 패턴입니다. address-match 매개변수와 마찬가지로 queue-match 매개변수에 대한 정확한 이름을 지정하거나 와일드카드 표현식을 사용하여 대기열 세트를 지정할 수 있습니다. 위 예제에서는 주소 일치 값 # 임을 나타내는 모든 주소의 .remote 문자열과 일치하는 큐가 포함됩니다.

   exclude

   정책을 제외하기 위해 해당 주소의 특정 큐와 일치하는 주소 일치 패턴 및 큐 일치 패턴입니다. address-match 매개변수와 마찬가지로 queue-match 매개변수에 대한 정확한 이름을 지정하거나 와일드카드 표현식을 사용하여 대기열 세트를 지정할 수 있습니다. 이전 예에서 주소 일치 값 # 로 표시되는 모든 주소의 .local 문자열과 일치하는 큐는 제외됩니다.

   priority-adjustment

   통합 소비자의 값을 조정하여 동일한 큐에 있는 다른 로컬 소비자보다 우선 순위가 낮은지 확인합니다. 기본값은 -1 로, 로컬 소비자가 페더레이션 소비자보다 우선 순위를 지정하도록 합니다.

   include-federated

   이 매개 변수의 값이 false 로 설정되면 구성이 이미 제공된 소비자(즉, 페더레이션 대기열의 소비자)를 다시 제공하지 않습니다. 이렇게 하면 대칭 또는 폐쇄 루프 토폴로지에서 제공되지 않는 소비자와 메시지가 시스템 전체에서 끝없이 흐름되는 상황을 방지할 수 있습니다.

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

프로세스

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

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

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

   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>

   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& gt; 요소 내에서 주소 일치 패턴을 추가하여 주소 정책에서 주소를 포함 및 제외합니다. 예를 들면 다음과 같습니다.

   <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>

   포함

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

   exclude

   이 요소의 address-match 속성 값은 주소 정책에서 제외할 주소를 지정합니다. 정확한 주소 이름을 지정하거나 와일드카드 표현식을 사용하여 일치하는 주소 집합 을 지정할 수 있습니다. 이전 예에서 주소 정책은 문자열 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>

   name

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

   class-name

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

   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>

   static-connectors

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

   policy-ref

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

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

   name

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

   user

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

   암호

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

   call-failover-timeout

   call-timeout 과 유사하지만 장애 조치(failover) 시도 중에 호출이 수행될 때 사용됩니다. 기본값은 -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

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

   initial-connect-attempts

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

   max-retry-interval

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

   재연결-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>

프로세스

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

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

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

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>

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>

5. 각 원격 브로커에 대한 다운스트림 요소를 추가합니다. 예를 들면 다음과 같습니다.

   <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>

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

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>

   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>

   name

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

   user

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

   암호

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

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

3. federation 요소 내에서 < 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>

   name

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

   include-federated

   이 속성의 값이 false 로 설정되면 구성이 이미 제공된 소비자(즉, 페더레이션 대기열의 소비자)를 다시 제공하지 않습니다. 이렇게 하면 대칭 또는 closed-loop 토폴로지에서 공급되지 않은 소비자가 없고 메시지가 시스템 전체에서 지속적으로 전달되는 상황을 방지할 수 있습니다.

   closed-loop 토폴로지가 없는 경우 이 속성의 값을 true 로 설정할 수 있습니다. 예를 들어 BrokerA,BrokerB 및 BrokerC 의 세 가지 브로커 체인과 BrokerA 의 생산자와 BrokerC 의 소비자가 있다고 가정합니다. 이 경우 BrokerB 가 소비자를 BrokerA 에 다시 공급하기를 원할 것입니다.

   priority-adjustment

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

   우선 순위 조정이 너무 많은 메시지가 페더레이션 소비자로 이동하는 것을 방지하기에 불충분하여 브로커 간에 메시지를 이동할 수 있는 경우 페더레이션 소비자로 이동하는 메시지 배치 크기를 제한할 수 있습니다. 배치 크기를 제한하려면 페더레이션 소비자의 연결 URI에서 consumerWindowSize 값을 0 으로 설정합니다.

   tcp://<host>:<port>?consumerWindowSize=0

   consumerWindowSize 값을 0 으로 설정하면 AMQ Broker는 일치하는 주소에 대한 주소 설정에 defaultConsumerWindowSize 매개변수 값을 사용하여 브로커 간에 이동할 수 있는 메시지의 배치 크기를 결정합니다. defaultConsumerWindowSize 속성의 기본값은 1048576 바이트입니다.

   Transformer-ref

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

4. &lt ;queue-policy > 요소 내에서 큐 정책에서 주소를 포함 및 제외하기 위해 주소 일치 패턴을 추가합니다. 예를 들면 다음과 같습니다.

   <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">
   
               <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>

   포함

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

   address-match 속성과 함께 queue-match 속성을 사용하여 큐 정책의 해당 주소에 특정 큐를 포함할 수 있습니다. address-match 속성과 마찬가지로 정확한 큐 이름을 지정하거나 와일드카드 표현식을 사용하여 큐 집합 을 지정할 수 있습니다. 이전 예에서 숫자 기호(#) 와일드카드 문자는 각 주소의 모든 큐 또는 주소 집합의 모든 큐가 큐 정책에 포함되어 있음을 나타냅니다.

   exclude

   이 요소의 address-match 속성 값은 큐 정책에서 제외할 주소를 지정합니다. 정확한 주소를 지정하거나 와일드카드 표현식을 사용하여 일치하는 주소 집합 을 지정할 수 있습니다. 이전 예에서 숫자 기호(#) 와일드카드 문자는 모든 주소의 queue-match 속성과 일치하는 모든 큐가 제외됨을 의미합니다. 이 경우 .local 문자열로 끝나는 모든 큐가 제외됩니다. 이는 특정 대기열이 페더레이션이 아닌 로컬 큐로 유지됨을 나타냅니다.

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

   <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">
   
               <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>

   name

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

   class-name

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

   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-queue-federation"/>
           </upstream>
   
           <upstream name="eu-west-1" >
               <static-connectors>
                   <connector-ref>eu-west-connector1</connector-ref>
               </static-connectors>
               <policy ref="news-queue-federation"/>
           </upstream>
   
           <queue-policy name="news-queue-federation" include-federated="true" priority-adjustment="-5" 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>

   static-connectors

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

   policy-ref

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

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

   name

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

   user

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

   암호

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

   call-failover-timeout

   call-timeout 과 유사하지만 장애 조치(failover) 시도 중에 호출이 수행될 때 사용됩니다. 기본값은 -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

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

   initial-connect-attempts

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

   max-retry-interval

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

   재연결-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>

   참고

   대용량 메시지가 페더레이션 연결을 통과하도록 하려면 페더레이션 연결에 사용되는 커넥터에서 consumerWindowSize 매개변수를 -1로 설정합니다. consumerWindowSize 매개변수를 -1로 설정하면 이 매개변수에 대한 제한이 설정되어 있지 않으므로 대규모 메시지가 연결을 통과할 수 있습니다. 예를 들면 다음과 같습니다.

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

   대규모 메시지에 대한 자세한 내용은 8장. 대용량 메시지 처리 을 참조하십시오.

프로세스

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

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

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

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>

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>

5. 각 원격 브로커에 대한 다운스트림 요소를 추가합니다. 예를 들면 다음과 같습니다.

   <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>

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

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>

   connector name="netty-connector"

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

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

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

   acceptor name="netty-acceptor"

   원격 브로커가 로컬 브로커에 다시 연결하는 데 사용하는 커넥터에 해당하는 로컬 브로커의 수락자.

   참고

   페더레이션 연결을 통해 많은 메시지가 전송되도록 하려면 페더레이션 연결에 사용되는 커넥터에서 consumerWindowSize 매개변수를 -1로 설정합니다. consumerWindowSize 매개변수를 -1로 설정하면 이 매개변수에 대한 제한이 설정되어 있지 않으므로 대규모 메시지가 연결을 통과할 수 있습니다. 예를 들면 다음과 같습니다.

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

   대규모 메시지에 대한 자세한 내용은 8장. 대용량 메시지 처리 을 참조하십시오.