14.5. 클러스터형 메시지 그룹화 구성

프로세스

1. 클러스터의 한 브로커에 로컬 처리기를 구성합니다.

   고가용성을 사용하는 경우 마스터 브로커여야 합니다.

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

   2. < core&gt; 요소 내에서 로컬 처리기를 추가합니다.

      로컬 처리기는 원격 처리기의 중재자 역할을 합니다. 라우팅 정보를 저장하고 다른 브로커와 통신합니다.

      <configuration>
          <core>
              ...
              <grouping-handler name="my-grouping-handler">
                  <type>LOCAL</type>
                  <timeout>10000</timeout>
              </grouping-handler>
              ...
          </core>
      </configuration>

      grouping-handler

      name 속성을 사용하여 그룹화 처리기의 고유한 이름을 지정합니다.

      type

      이를 LOCAL 로 설정합니다.

      timeout

      메시지를 라우팅할 위치에 대한 결정을 내릴 때까지 대기하는 시간(밀리초)입니다. 기본값은 5000밀리초입니다. 라우팅 결정이 이루어지기 전에 시간 초과에 도달하면 예외가 발생하여 엄격한 메시지 순서가 보장됩니다.

      브로커가 그룹 ID가 있는 메시지를 수신하면 소비자가 연결된 큐의 경로를 제안합니다. 클러스터의 다른 브로커에서 경로를 그룹화하여 경로를 수락하면 경로가 설정됩니다. 클러스터의 모든 브로커는 이 그룹 ID가 있는 메시지를 해당 큐로 전달합니다. 브로커의 경로 제안이 거부되면 경로가 수락될 때까지 프로세스를 반복하여 대체 경로를 제안합니다.

2. 고가용성을 사용하는 경우 로컬 처리기 구성을 마스터 브로커의 슬레이브 브로커에 복사합니다.

   로컬 처리기 구성을 슬레이브 브로커에 복사하면 로컬 처리기의 단일 장애 지점을 방지할 수 있습니다.

3. 클러스터의 나머지 각 브로커에서 원격 처리기를 구성합니다.

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

   2. < core&gt; 요소 내에서 원격 처리기를 추가합니다.

      <configuration>
          <core>
              ...
              <grouping-handler name="my-grouping-handler">
                  <type>REMOTE</type>
                  <timeout>5000</timeout>
              </grouping-handler>
              ...
          </core>
      </configuration>

      grouping-handler

      name 속성을 사용하여 그룹화 처리기의 고유한 이름을 지정합니다.

      type

      이를 REMOTE 로 설정합니다.

      timeout

      메시지를 라우팅할 위치에 대한 결정을 내릴 때까지 대기하는 시간(밀리초)입니다. 기본값은 5000밀리초입니다. 이 값을 로컬 처리기 값의 절반 이상으로 설정합니다.