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

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

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 가 즉시 제거됩니다.