RabbitMQ: Access refused for user 'guest'

[yeseong31]

도커 이미지 적용 후 프로젝트 실행 시 접근 오류

• RabbitMQ를 Docker로 실행하는 방법을 알아보는 과정에서 RabbitMQ + STOMP plugins 도커 이미지를 발견하여 이를 프로젝트에 적용하기로 했다.

docker pull pcloud/rabbitmq-stomp

docker container run -it --name rabbitmq-stomp -p 15672:15672 -p 5672:5672 -p 61613:61613 pcloud/rabbitmq-stomp

• Dockerfile 작성자에 따르면 RabbitMQ 로그인에 admin/admin을 사용하는 것을 확인했다.
• 이에 RabbitMQ 환경 변수를 작성한 env.properties를 다음과 같이 수정했다.

RABBITMQ_USERNAME=admin
RABBITMQ_PASSWORD=admin
RABBITMQ_HOST=localhost
RABBITMQ_PORT=5672

• 하지만 다음의 오류 메시지가 터미널에 출력되면서 애플리케이션이 정상적으로 동작하지 않았다.

2023-08-27T02:00:33.558+09:00 ERROR 15212 --- [ent-scheduler-1] o.s.m.s.s.StompBrokerRelayMessageHandler : Received ERROR {message=[Bad CONNECT], content-type=[text/plain], version=[1.0,1.1,1.2], content-length=[32]} session=_system_ text/plain payload=Access refused for user 'guest'

[yeseong31]

원인 찾기

• RabbitMQ Server의 로그를 살펴보았지만 별다른 오류 로그를 확인하지 못했다.
• 일단 admin 계정으로 시도했지만 시스템 내부에서는 guest로 인식하는 것만 알고, 여러 가지 시도를 해보기로 했다.

RabbitMQ의 버전 문제인가?

• 현재 내 프로젝트에서는 RabbitMQ의 버전을 3.12.3으로 설정하고 있다.
• 그런데 Docker에서 실행 중인 RabbitMQ의 버전은 3.11.16이었다.
• Dockerfile의 내용을 확인해 보니 다음과 같이 적혀 있었다.

FROM rabbitmq:3.11.16-management
RUN rabbitmq-plugins enable rabbitmq_stomp
COPY rabbitmq.conf /etc/rabbitmq/rabbitmq.conf

• 지금의 issue는 RabbitMQ의 버전과는 상관이 없을 것으로 생각되긴 한다.
• 하지만 혹시 모를 호환성 문제를 대비하기 위해 도커 이미지가 아닌 도커 명령어를 통해 RabbitMQ를 실행하는 방법을 알아봐야겠다.

[yeseong31]

도커 명령어를 직접 입력하여 RabbitMQ 실행

• 현재의 issue는 애플리케이션이 admin/admin으로 RabbitMQ에 접근하는 과정에 문제가 있는 것이다.
• 그래서 username/password으로 계정을 다르게 하여 문제를 확인해보고자 했다.
• 우선 env.properties의 설정을 다음과 같이 수정했다.

RABBITMQ_USERNAME=username
RABBITMQ_PASSWORD=password
RABBITMQ_HOST=localhost
RABBITMQ_PORT=5672

• 그리고 도커 이미지를 직접 사용하는 방법 대힌 터미널을 열어서 다음의 도커 명령어를 실행했다.

docker run -d --name rabbitmq -p 5672:5672 -p 15672:15672 -p 61613:61613 --restart=unless-stopped -e RABBITMQ_DEFAULT_USER=username -e RABBITMQ_DEFAULT_PASS=password rabbitmq:management

• 계정을 다르게 하여 시도해봤지만 여전히 같은 문제로 인해 RabbitMQ를 정상적으로 사용할 수 없었다.

2023-08-27T03:12:33.158+09:00 ERROR 15212 --- [ent-scheduler-1] o.s.m.s.s.StompBrokerRelayMessageHandler : Received ERROR {message=[Bad CONNECT], content-type=[text/plain], version=[1.0,1.1,1.2], content-length=[32]} session=_system_ text/plain payload=Access refused for user 'guest'

[yeseong31]

문제 해결

• 오류에 대해 검색하던 와중, RabbitMQ - StompBrokerRelayMessageHandler - Received ERROR에 대해 설명하는 글을 보았다.
• 확인해 보니 StompWebSocketConfig의 설정 누락이 현재 issue의 원인이었다.
• 오류가 발생한 시점의 StompWebSocketConfig의 configureMessageBroker() 메서드는 다음과 같이 작성되어 있었다.

@Override
public void configureMessageBroker(MessageBrokerRegistry registry) {
    registry.setPathMatcher(new AntPathMatcher("."));

    registry.setApplicationDestinationPrefixes("/pub");

    // registry.enableSimpleBroker("/sub");
    registry.enableStompBrokerRelay(
                    "/queue", "/topic", "/exchange", "/amq/queue")
            .setRelayPort(STOMP_CLIENT_PORT)
            .setRelayHost(RABBITMQ_HOST)
            .setClientLogin(RABBITMQ_USERNAME)
            .setClientPasscode(RABBITMQ_PASSWORD);
}

• 위 코드에서는 시스템 로그인 부분을 설정하고 있지 않았고, 이것이 근본적인 원인이었다.
• RabbitMQ는 시스템 로그인 부분을 설정하지 않으면 자동으로 guest/guest로 로그인을 진행한다.
• 이 설정이 빠져 있었기 때문에 env.properties 설정을 변경해고, 적용되지 않았던 것이다.
• 참고로 자동으로 guest/guest를 적용하는 것은 공식 문서에도 나와 있지 않은 부분이라고 한다.
• 따라서 나는 configureMessageBroker() 메서드에 시스템 로그인 부분에 해당하는 setSystemLogin()과 setSystemPasscode()를 registry에 체인 형식으로 추가했고, 정상적으로 username/password로 로그인되는 것을 확인할 수 있었다.

@Override
public void configureMessageBroker(MessageBrokerRegistry registry) {
    registry.setPathMatcher(new AntPathMatcher("."));

    registry.setApplicationDestinationPrefixes("/pub");

    // registry.enableSimpleBroker("/sub");
    registry.enableStompBrokerRelay(
                    "/queue", "/topic", "/exchange", "/amq/queue")
            .setRelayPort(STOMP_CLIENT_PORT)
            .setRelayHost(RABBITMQ_HOST)
            .setClientLogin(RABBITMQ_USERNAME)
            .setClientPasscode(RABBITMQ_PASSWORD)
            .setSystemLogin(RABBITMQ_USERNAME)
            .setSystemPasscode(RABBITMQ_PASSWORD);
}