RabbitMQ 일시 중지된 대기열 동기화 문제 해결

Amazon MQ 콘솔에 로그인합니다.

왼쪽 탐색 창에서 Brokers(브로커)를 선택합니다.

브로커 목록에서 새 정책을 적용할 브로커의 이름을 선택합니다.

브로커 페이지의 Connections(연결) 섹션에서 RabbitMQ 웹 콘솔 URL을 선택합니다. RabbitMQ 웹 콘솔이 새 브라우저 탭 또는 창에 열립니다.

브로커 관리자 로그인 보안 인증 정보를 사용하여 RabbitMQ 웹 콘솔에 로그인합니다.

RabbitMQ 웹 콘솔의 페이지 상단에서 Admin(관리자)을 선택합니다.

Admin(관리자) 페이지의 오른쪽 탐색 창에서 Policies(정책)를 선택합니다.

Policies(정책) 페이지에서 브로커의 현재 User policies(사용자 정책) 목록을 볼 수 있습니다. User policies(사용자 정책) 아래에서 Add / update a policy(정책 추가/업데이트)를 확장합니다.

새 브로커 정책을 생성하려면 Add / update a policy(정책 추가/업데이트)에서 다음을 수행합니다.

1. Name(이름)에 정책의 이름을 입력합니다(예: batch-size-policy).

2. Pattern(패턴)에 regexp 패턴 .*를 입력합니다. 이 경우 정책이 브로커의 모든 대기열과 일치합니다.

3. Apply to(적용 대상)의 드롭다운 목록에서 Exchanges and queues(교환 및 대기열)를 선택합니다.

4. Priority(우선 순위)에 vhost에 적용된 다른 모든 정책보다 큰 정수를 입력합니다. 지정된 시간에 RabbitMQ 대기열 및 교환에 정확히 하나의 정책 정의 집합을 적용할 수 있습니다. RabbitMQ는 가장 높은 우선 순위 값과 일치하는 정책을 선택합니다. 정책 우선 순위 및 정책을 결합하는 방법에 대한 자세한 내용은 RabbitMQ Server 설명서에서 정책을 참조하세요.

5. Definition(정의)에 다음 키-값 페어를 추가합니다.

   • ha-sync-batch-size=100. 드롭다운 목록에서 Number(숫자)를 선택합니다.

     참고

     대기열에 있는 동기화되지 않은 메시지 수와 크기를 기준으로 ha-sync-batch-size 값을 조정하고 보정해야 할 수 있습니다.

   • ha-mode=all. 드롭다운 목록에서 String(문자열)을 선택합니다.

     중요

     ha-mode 정의는 모든 HA 관련 정책에 필요합니다. 생략하면 검증이 실패합니다.

   • ha-sync-mode=automatic. 드롭다운 목록에서 String(문자열)을 선택합니다.

     참고

     ha-sync-mode 정의는 모든 사용자 지정 정책에 필요합니다. 생략하면 Amazon MQ가 자동으로 정의를 추가합니다.

6. Add / update policy(정책 추가/업데이트)를 선택합니다.

새 정책이 User policies(사용자 정책)의 목록에 표시되는지 확인합니다.

Amazon MQ 콘솔에 로그인합니다.

왼쪽 탐색 창에서 Brokers(브로커)를 선택합니다.

브로커 목록에서 새 정책을 적용할 브로커의 이름을 선택합니다.

브로커 페이지의 Connections(연결) 섹션에서 RabbitMQ 웹 콘솔 URL을 기록합니다. 이는 HTTP 요청에서 사용하는 브로커 엔드포인트입니다.

새 터미널 또는 원하는 명령줄 창을 엽니다.

새 브로커 정책을 생성하려면 다음 curl 명령을 입력합니다. 이 명령에서는 대기열이 %2F로 인코딩된 기본 / vhost에 있다고 가정합니다.

curl -i -u username:password -H "content-type:application/json" -XPUT \
-d '{"pattern":".*", "priority":1, "definition":{"ha-sync-batch-size":100, "ha-mode":"all", "ha-sync-mode":"automatic"}}' \
https://b-589c045f-f8ln-4ab0-a89c-co62e1c32ef8.mq.us-west-2.amazonaws.com/api/policies/%2F/batch-size-policy
                

브로커의 사용자 정책에 새 정책이 추가되었는지 확인하려면 다음 curl 명령을 입력하여 모든 브로커 정책을 나열합니다.

curl -i -u username:password https://b-589c045f-f8ln-4ab0-a89c-co62e1c32ef8.mq.us-west-2.amazonaws.com/api/policies

RabbitMQ 웹 콘솔의 페이지 상단에서 Queues(대기열)를 선택합니다.

Queues(대기열) 페이지의 All queues(모든 대기열)에서 일시 중지된 대기열을 찾습니다. Features(기능) 열에서 생성한 새 정책의 이름(예:batch-size-policy)이 대기열에 표시되어야 합니다.

줄어든 배치 크기로 동기화 프로세스를 다시 시작하려면 Restart sync(동기화 다시 시작)를 선택합니다.