[java] JMS 메시지를 선택하여 수신하는 방법

16 Nov 2023

java

Java Messaging Service (JMS)는 분산 환경에서 메시지를 교환하는 애플리케이션 간의 통신을 위한 표준 API입니다. JMS를 사용하면 메시지를 생성하고, 송수신자 간에 안정적으로 전송하고, 필요한 메시지를 선택하여 수신할 수 있습니다. 이번 블로그 포스트에서는 JMS를 사용하여 메시지를 선택적으로 수신하는 방법에 대해 알아보겠습니다.

1. JMS Consumer 생성

JMS 메시지를 수신하려면 JMS Consumer를 생성해야 합니다. 아래의 코드는 JMS Consumer를 생성하는 예제입니다.

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;

public class JMSConsumer {
    public static void main(String[] args) {
        try {
            // JNDI를 사용하여 ConnectionFactory 및 Destination을 검색합니다.
            Context initialContext = new InitialContext();
            ConnectionFactory connectionFactory = (ConnectionFactory) initialContext.lookup("jms/ConnectionFactory");
            Destination destination = (Destination) initialContext.lookup("jms/Queue");

            // Connection을 생성합니다.
            Connection connection = connectionFactory.createConnection();

            // Session을 생성합니다.
            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

            // 메시지를 수신할 MessageConsumer를 생성합니다.
            MessageConsumer consumer = session.createConsumer(destination);

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

            // 수신한 메시지를 처리합니다.
            if (message instanceof TextMessage) {
                TextMessage textMessage = (TextMessage) message;
                String text = textMessage.getText();
                System.out.println("Received message: " + text);
            }

            // 연결을 종료합니다.
            connection.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

위의 코드에서는 JMSConsumer 클래스를 정의하고 main 메서드에서 JMS Consumer를 생성하고 메시지를 수신하는 로직을 작성했습니다.

2. 선택적으로 메시지 수신하기

JMS를 사용하여 선택적으로 메시지를 수신하려면 MessageConsumer 객체의 receive 메서드를 사용하면 됩니다. 이 메서드는 매개변수 없이 호출되면 기본적으로 가장 오래된 메시지를 수신하게 됩니다.

Message message = consumer.receive();

메시지를 선택적으로 수신하려면 receive 메서드 호출 전에 MessageConsumer 객체의 setMessageSelector 메서드를 사용하여 선택자를 설정해야 합니다. 선택자는 메시지 속성과 비교하여 메시지를 필터링하는 데 사용됩니다.

consumer.setMessageSelector("color = 'red'");
Message message = consumer.receive();

위의 코드는 color 속성이 'red'인 메시지만을 수신하는 예제입니다.

결론

JMS를 사용하여 메시지를 선택적으로 수신하는 방법에 대해 알아보았습니다. JMS Consumer를 생성하고 receive 메서드를 사용하여 선택적으로 메시지를 수신할 수 있습니다. 메시지 선택자를 사용하면 원하는 메시지만을 필터링하여 수신할 수 있습니다.

더 자세한 정보는 Oracle의 JMS 문서를 참조하세요.