4.19. 링 대기열 구성

프로세스

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>

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

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

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

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

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

   이 시점에서 messageCount= 3 을 제공하고Count= 3 을 제공합니다.

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

   이제 messageCount = 4 를 제공하고Count = 4 를 제공합니다. 메시지 수 4 는 구성된 링 크기 3 보다 큽니다. 그러나 브로커는 큐에서 전송 중 메시지를 제거할 수 없기 때문에 이 상황을 허용할 의무가 있습니다.

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

   이 경우 승인되지 않은 네 개의 메시지가 브로커에 다시 취소되고 사용된 역순으로 큐의 헤드에 추가됩니다. 이 작업을 수행하면 큐가 구성된 링 크기에 도달합니다. 링 대기열은 헤드의 메시지에 따라 대기열의 메시지를 선호하기 때문에 대기열은 대기열의 헤드에 다시 추가된 마지막 메시지였기 때문에 생산자가 보낸 첫 번째 메시지를 삭제합니다. 트랜잭션 또는 코어 세션 롤백은 동일한 방식으로 처리됩니다.

1. 12:00에 생산자는 ring-size="3" 로 구성된 링 큐로 메시지를 전송합니다. 이 메시지는 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에서 생산자는 메시지 D 를 동일한 링 큐로 보냅니다.

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

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