[java] JMS를 사용하여 메시지 간 관계를 설정하는 방법

17 Nov 2023

java

Java Message Service(JMS)는 애플리케이션 간에 비동기적으로 메시지를 교환하기 위한 API입니다. JMS를 사용하면 메시지를 보내고 받는 애플리케이션 간에 강력한 관계를 설정할 수 있습니다. 이 글에서는 JMS를 사용하여 메시지 간 관계를 설정하는 방법에 대해 알아보겠습니다.

1. JMS Provider 설정

첫 번째 단계는 JMS Provider를 설정하는 것입니다. JMS Provider는 JMS를 구현한 메시징 시스템입니다. 다양한 JMS Provider가 있지만, 대표적인 예로 Apache ActiveMQ나 IBM WebSphere MQ를 사용할 수 있습니다.

JMS Provider를 설정하기 위해서는 해당 Provider의 라이브러리를 애플리케이션의 classpath에 추가해야 합니다. 또한, JMS Provider에 대한 초기화 및 연결 설정을 구성해야 합니다.

2. Connection Factory 생성

두 번째 단계는 Connection Factory를 생성하는 것입니다. Connection Factory는 JMS Provider와 애플리케이션 간의 연결을 관리합니다. Connection Factory는 JMS Provider의 특정 구현체에 따라 다를 수 있습니다.

Connection Factory를 생성하려면 JMS Provider에서 제공하는 클래스를 사용해야 합니다. 일반적으로 javax.jms.ConnectionFactory 인터페이스를 구현한 클래스를 사용합니다.

import javax.jms.ConnectionFactory;
import org.apache.activemq.ActiveMQConnectionFactory;

// Connection Factory 생성
ConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");

위의 예제는 ActiveMQ를 JMS Provider로 사용하는 경우의 Connection Factory 생성 방법입니다.

3. Connection 생성

세 번째 단계는 Connection을 생성하는 것입니다. Connection은 실제 메시지 교환을 위한 세션을 생성하는 데 사용됩니다.

import javax.jms.Connection;
import javax.jms.JMSException;

// Connection 생성
Connection connection = null;
try {
    connection = factory.createConnection();
} catch (JMSException e) {
    e.printStackTrace();
}

위의 예제에서는 Connection Factory를 사용하여 Connection을 생성하고 있습니다.

4. Session 생성

네 번째 단계는 Session을 생성하는 것입니다. Session은 실제 메시지 교환을 담당하는 객체입니다. Session은 javax.jms.Session 인터페이스를 구현한 클래스를 사용하여 생성합니다.

import javax.jms.Session;
import javax.jms.JMSException;

// Session 생성
Session session = null;
try {
    session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
} catch (JMSException e) {
    e.printStackTrace();
}

위의 예제에서는 Connection을 사용하여 Session을 생성하고 있습니다.

5. Message Producer 생성

다섯 번째 단계는 Message Producer를 생성하는 것입니다. Message Producer는 메시지를 생성하고 송신하는 역할을 담당합니다.

import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.JMSException;

// Message Producer 생성
MessageProducer producer = null;
try {
    Queue queue = session.createQueue("myQueue");
    producer = session.createProducer(queue);
} catch (JMSException e) {
    e.printStackTrace();
}

위의 예제에서는 Session을 사용하여 Message Producer를 생성하고 있습니다. 이 예제에서는 Queue를 대상으로 메시지를 전송하는 Message Producer를 생성하고 있습니다.

6. Message Consumer 생성

여섯 번째 단계는 Message Consumer를 생성하는 것입니다. Message Consumer는 메시지를 수신하고 처리하는 역할을 담당합니다.

import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.TextMessage;
import javax.jms.JMSException;

// Message Consumer 생성
MessageConsumer consumer = null;
try {
    Queue queue = session.createQueue("myQueue");
    consumer = session.createConsumer(queue);

    consumer.setMessageListener(new MessageListener() {
        public void onMessage(javax.jms.Message message) {
            if (message instanceof TextMessage) {
                try {
                    TextMessage textMessage = (TextMessage) message;
                    System.out.println("Received message: " + textMessage.getText());
                } catch (JMSException e) {
                    e.printStackTrace();
                }
            }
        }
    });
} catch (JMSException e) {
    e.printStackTrace();
}

위의 예제에서는 Session을 사용하여 Message Consumer를 생성하고 있습니다. 이 예제에서는 Queue로부터 메시지를 수신하고, 수신된 메시지를 처리하는 Message Consumer를 생성하고 있습니다.

7. 메시지 전송과 수신

이제 모든 준비가 완료되었으므로 메시지를 전송하고 수신할 수 있습니다.

import javax.jms.TextMessage;
import javax.jms.Message;
import javax.jms.JMSException;

// 메시지 전송
try {
    TextMessage message = session.createTextMessage("Hello, World!");
    producer.send(message);
} catch (JMSException e) {
    e.printStackTrace();
}

// 메시지 수신은 Message Consumer의 MessageListener를 통해 이루어집니다.

위의 예제에서는 TextMessage를 생성하고 Message Producer를 통해 메시지를 전송하는 방법을 보여주고 있습니다. 메시지 수신은 Message Consumer의 MessageListener를 통해 이루어집니다.

이제 JMS를 사용하여 메시지 간 관계를 설정하는 방법에 대해 알아보았습니다. JMS를 통해 애플리케이션 간에 느슨한 결합을 구현하고 비동기적으로 메시지를 교환할 수 있습니다.

더 자세한 정보를 알고 싶다면, JMS Provider의 공식 문서를 참조하시기 바랍니다.

참고 자료

주의: 이 예제는 설명을 위한 단순화된 코드이며, 실제 구현에서는 에러 처리 및 예외 상황 처리 등을 고려해야 합니다.