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인 새 메시지가 도착하기 전에 이전 메시지가 3,000개 이상 의 메시지가 도착하면 브로커가 중복을 감지할 수 없습니다. 그러면 브로커가 두 메시지를 모두 처리하게 됩니다.persist-id-cache-
이 속성의 값을
true로 설정하면 브로커가 수신된 대로 ID를 디스크에 유지합니다. 기본값은true입니다. 위의 예에서 값을false로 설정하여 지속성을 비활성화합니다.
추가 리소스
- AMQ Core Protocol JMS 클라이언트를 사용하여 중복 ID 메시지 속성을 설정하는 방법을 알아보려면 AMQ Core Protocol JMS 클라이언트 설명서에서 중복된 메시지 탐지 사용을 참조하십시오.
