[java] JMS를 사용하여 분산 시스템 간 통신 구현 방법

16 Nov 2023

java

Java Message Service (JMS)는 Java 애플리케이션들 사이에서 비동기적으로 메시지를 교환하기 위한 API이다. JMS는 분산 시스템에서 효과적으로 통신할 수 있는 방법을 제공하는데, 이를 통해 여러 시스템 간의 메시지 교환과 이벤트 통지를 쉽게 구현할 수 있다. 이 문서에서는 JMS를 사용하여 분산 시스템 간 통신을 구현하는 방법에 대해 알아본다.

JMS의 주요 구성 요소

JMS는 다음과 같은 주요 구성 요소로 구성된다.

메시지 브로커 (Message Broker): JMS 메시지를 보내고 받는 역할을 수행하는 중간 계층 서버이다. 가장 대표적인 예로 Apache ActiveMQ, RabbitMQ 등이 있다.
프로듀서 (Producer): JMS 메시지를 생성하고 메시지 브로커로 전송하는 역할을 수행한다.
컨슈머 (Consumer): 메시지 브로커로부터 메시지를 받아 처리하는 역할을 수행한다.

JMS 사용하기

먼저, JMS를 사용하기 위해서는 다음과 같은 단계를 따라야 한다.

JMS Provider에 연결하기: JMS Provider에 연결하여 세션을 생성한다. 세션은 JMS 메시지를 생성하고 송수신하기 위한 핵심 객체이다.
목적지(Destination) 생성하기: 메시지를 보낼 대상 혹은 메시지를 받을 대상으로 목적지를 생성한다.
프로듀서 역할 수행하기: 메시지를 생성하고 목적지로 전송한다.
컨슈머 역할 수행하기: 목적지에서 메시지를 받아 처리한다.

다음은 JMS를 사용하여 간단한 예제 코드를 작성한 것이다.

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

public class JMSExample {
    public static void main(String[] args) throws JMSException {
        // 1. JMS Provider에 연결하기
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
        Connection connection = connectionFactory.createConnection();
        connection.start();
        
        // 2. 목적지 생성하기
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        Destination destination = session.createQueue("myQueue");
        
        // 3. 프로듀서 역할 수행하기
        MessageProducer producer = session.createProducer(destination);
        TextMessage message = session.createTextMessage("Hello, JMS!");
        producer.send(message);
        
        // 4. 컨슈머 역할 수행하기
        MessageConsumer consumer = session.createConsumer(destination);
        Message receivedMessage = consumer.receive();
        if (receivedMessage instanceof TextMessage) {
            TextMessage textMessage = (TextMessage) receivedMessage;
            System.out.println("Received message: " + textMessage.getText());
        }
        
        // 연결 종료하기
        session.close();
        connection.close();
    }
}

위 예제는 ActiveMQ를 JMS Provider로 사용하는 예제이다. ActiveMQ의 주소를 tcp://localhost:61616로 설정하고, myQueue라는 이름의 목적지를 생성하여 메시지를 주고받는다. 프로듀서는 “Hello, JMS!”라는 메시지를 생성하여 전송하고, 컨슈머는 목적지에서 메시지를 받아 출력한다.

결론

JMS는 분산 시스템 간의 효과적인 통신을 구현하기 위해 사용되는 강력한 도구이다. JMS Provider와의 연결, 목적지 설정, 프로듀서 및 컨슈머 역할을 수행하는 단계를 통해 JMS를 사용할 수 있다. 위 예제 코드를 참고하여 실제 프로젝트에서 JMS를 활용해보자.