[java] JMS를 사용하여 메시지 재시도 기능 구현 방법

16 Nov 2023

java

JMS(Java Message Service)는 자바 기반의 메시징 시스템을 구현할 때 사용되는 API입니다. JMS를 사용하면 메시지를 안정적으로 전달하고 처리할 수 있으며, 장애 상황에서도 메시지를 보장할 수 있습니다. 이번 글에서는 JMS를 사용하여 메시지 재시도 기능을 구현하는 방법에 대해 알아보겠습니다.

1. JMS와 메시지 재시도

메시지 재시도는 메시지를 전송한 후, 실패한 경우 다시 전송하는 기능입니다. 이는 네트워크 문제, 대상 시스템의 장애 등으로 인해 메시지가 정상적으로 처리되지 않을 경우에 유용합니다. JMS는 여러 가지 방법으로 메시지 재시도를 구현할 수 있지만, 일반적으로 다음과 같은 방법들을 사용합니다.

Redelivery 기능: JMS 컨테이너에서 제공하는 기능으로, 메시지 전송에 실패한 경우 일정 횟수 동안 재시도합니다.
DLQ(Destination Learning Queue): 재시도를 여러 번 해도 처리가 되지 않는 경우, 재시도된 메시지는 대기 큐(DLQ)로 이동되어 따로 처리할 수 있도록 합니다.

2. JMS에서의 메시지 재시도 구현 방법

2.1. Redelivery 기능 사용

JMS 컨테이너에서 제공하는 Redelivery 기능을 사용하여 메시지 재시도를 구현할 수 있습니다. Redelivery가 가능한 경우에는 일정 횟수 동안 재시도하고, 재시도 횟수를 넘어선 경우에는 대기 큐(DLQ)로 이동시키는 방식입니다. 아래는 Redelivery 기능을 사용한 메시지 재시도 구현 예시입니다.

// JMS 컨테이너로부터 ConnectionFactory 및 Destination 객체를 가져온다.
ConnectionFactory factory = new ActiveMQConnectionFactory();
Connection connection = factory.createConnection();
connection.start();

// Session 객체를 생성한다.
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

// MessageConsumer를 생성하고 Destination에 연결한다.
Destination destination = session.createQueue("queueName");
MessageConsumer consumer = session.createConsumer(destination);

// 메시지를 수신한다.
Message message = consumer.receive();

try {
    // 메시지 처리 로직을 수행한다.
    processMessage(message);
} catch (Exception e) {
    // 예외가 발생한 경우 메시지를 다시 재시도하기 위해 Rollback을 수행한다.
    session.rollback();
} finally {
    // 세션 및 커넥션을 종료한다.
    session.close();
    connection.close();
}

2.2. DLQ(Destination Learning Queue) 사용

DLQ(Destination Learning Queue)는 재시도를 여러 번 해도 처리할 수 없는 경우, 메시지를 따로 대기 큐로 이동시키는 기능입니다. JMS에서 DLQ를 사용하기 위해서는 다음과 같이 설정해주어야 합니다.

JMS 컨테이너 설정에서 DLQ를 사용할 수 있도록 활성화합니다.
대상 시스템에서 메시지를 처리할 수 없는 경우, DLQ로 이동시킬 수 있는 설정을 적용합니다.
DLQ에서 메시지를 처리하는 로직을 별도로 구현합니다.

이를테면, ActiveMQ를 사용하는 경우 다음과 같이 설정 파일을 수정하여 DLQ를 사용할 수 있습니다.

<broker>
    <!-- ... -->
    <destinationPolicy>
        <policyMap>
            <policyEntries>
                <policyEntry topic=">" queue=">" >
                    <!-- ... -->
                    <deadLetterStrategy>
                        <!-- DLQ로 이동할지 여부 -->
                        <sharedDeadLetterStrategy processExpired="false" />
                    </deadLetterStrategy>
                </policyEntry>
            </policyEntries>
        </policyMap>
    </destinationPolicy>
    <!-- ... -->
</broker>

위 예시 코드에서 processExpired="false" 설정은 메시지가 재시도를 여러 번 해도 처리할 수 없는 경우에만 DLQ로 이동시키도록 설정한 것입니다.

3. 결론

메시지 재시도 기능은 JMS를 사용하는 시스템에서 안정적인 메시지 처리를 위해 필수적입니다. JMS에서는 Redelivery 기능과 DLQ를 사용하여 메시지 재시도를 구현할 수 있으며, 장애 상황에서도 메시지를 보장할 수 있습니다. 따라서 JMS를 사용하는 시스템에서는 메시지 재시도 기능을 적절하게 구현하여 안정적인 메시지 전달을 보장해야 합니다.

참고 문서: