10장. 중복 메시지 탐지
중복 메시지를 자동으로 탐지하고 필터링하도록 브로커를 구성할 수 있습니다. 즉, 자체 중복 감지 논리를 구현할 필요가 없습니다.
중복 탐지하지 않으면 예기치 않은 연결 오류가 발생하는 경우 클라이언트가 브로커로 보낸 메시지가 수신되었는지 여부를 확인할 수 없습니다. 이 경우 클라이언트는 브로커가 메시지를 수신하지 못했다고 가정하고 다시 보낼 수 있습니다. 그러면 중복 메시지가 생성됩니다.
예를 들어 클라이언트가 브로커에 메시지를 전송한다고 가정합니다. 브로커가 메시지를 수신하고 처리하기 전에 브로커 또는 연결이 실패하면 메시지가 해당 주소에 도달하지 않습니다. 실패로 인해 클라이언트가 브로커로부터 응답을 받지 못합니다. 브로커가 메시지를 수신하고 처리한 후 브로커 또는 연결이 실패하면 메시지가 올바르게 라우팅되지만 클라이언트는 여전히 응답을 수신하지 못합니다.
또한, 트랜잭션을 사용하여 성공을 결정하는 것이 이러한 경우에 반드시 도움이 되는 것은 아닙니다. 트랜잭션 커밋을 처리하는 동안 브로커 또는 연결이 실패하면 클라이언트는 메시지를 성공적으로 전송했는지 여부를 확인할 수 없습니다.
이러한 상황에서 가정된 오류를 수정하기 위해 클라이언트는 최신 메시지를 다시 보냅니다. 결과적으로 시스템에 부정적인 영향을 미치는 중복 메시지가 표시될 수 있습니다. 예를 들어, 주문 보관 시스템에서 브로커를 사용하는 경우 중복 메시지가 구매 발주서가 두 번 처리됨을 의미할 수 있습니다.
다음 절차에서는 이러한 유형의 상황에서 보호하기 위해 중복 메시지 탐지를 구성하는 방법을 보여줍니다.
10.1. 중복 ID 캐시 구성
브로커가 중복 메시지를 감지할 수 있도록 하려면 생산자는 각 메시지를 보낼 때 메시지 속성 _AMQ_DUPL_ID 에 고유한 값을 제공해야 합니다. 브로커는 _AMQ_DUPL_ID 속성의 수신된 값의 캐시를 유지 관리합니다. 브로커가 주소에서 새 메시지를 수신하면 해당 주소에 대한 캐시를 확인하여 이 속성에 대해 동일한 값으로 메시지를 이전에 처리하지 않았는지 확인합니다.
각 주소에는 자체 캐시가 있습니다. 각 캐시는 순환 및 크기가 고정되어 있습니다. 즉, 새 항목이 캐시 공간 요구 사항으로 가장 오래된 항목을 대체합니다.
다음 절차에서는 브로커의 각 주소가 사용하는 ID 캐시를 전역적으로 구성하는 방법을 보여줍니다.
절차
-
<
;broker_instance_dir> /etc/broker.xml구성 파일을 엽니다. core요소 내에서id-cache-size및persist-id-cache속성을 추가하고 값을 지정합니다. 예를 들면 다음과 같습니다.<configuration> <core> ... <id-cache-size>5000</id-cache-size> <persist-id-cache>false</persist-id-cache> </core> </configuration>id-cache-size캐시의 개별 항목 수로 지정된 ID 캐시의 최대 크기입니다. 기본값은 20,000 항목입니다. 이 예에서 캐시 크기는 5,000개 항목으로 설정됩니다.
참고캐시의 최대 크기에 도달하면 브로커가 중복 메시지 처리를 시작할 수 있습니다. 예를 들어 캐시 크기를
3000으로 설정했다고 가정합니다. 이전 메시지가_AMQ_DUPL_ID의 새 메시지가 도달하기 전에 3000개 이상의 메시지로 도달한 경우 브로커는 중복을 감지할 수 없습니다. 이로 인해 브로커가 두 메시지를 모두 처리합니다.persist-id-cache-
이 속성의 값이
true로 설정되면 브로커는 수신되는 대로 ID를 디스크에 유지합니다. 기본값은true입니다. 위의 예에서 값을false로 설정하여 지속성을 비활성화합니다.
추가 리소스
- AMQ Core Protocol JMS 클라이언트를 사용하여 중복 ID 메시지 속성을 설정하는 방법을 알아보려면 AMQ Core Protocol JMS 클라이언트 설명서에서 중복 메시지 검색 사용을 참조하십시오.
