[java] JMS를 사용하여 배치 처리 시스템 개발 방법

16 Nov 2023

java

개요

JMS(Java Message Service)는 자바 플랫폼에서 메시지 기반 통신을 제공하는 API로, 비동기식 메시지 패턴을 사용하여 시스템 간 통신을 용이하게 합니다. 이 글에서는 JMS를 사용하여 배치 처리 시스템을 개발하는 방법에 대해 알아보겠습니다.

1. JMS 구성 요소

JMS는 크게 다음과 같은 구성 요소로 이루어져 있습니다.

Producer(생산자): 메시지를 생성하고 전송합니다.
Consumer(소비자): 메시지를 수신하고 처리합니다.
Message: 비즈니스 데이터를 포함하는 인터페이스입니다.
Queue(대기열): 송신자가 메시지를 보내는 곳입니다.
Topic(주제): 메시지를 받을 수신자들의 그룹을 정의하는 곳입니다.

2. JMS 배치 처리 시스템 개발 방법

JMS를 사용하여 배치 처리 시스템을 개발하는 방법은 다음과 같습니다.

2.1. Queue 생성

처리할 배치 작업을 위한 Queue를 생성합니다. 이 Queue는 Producer가 작업을 생성하여 보낼 때 사용됩니다.

2.2. Producer 개발

Producer는 배치 작업을 생성하고 Queue에 메시지를 보내는 역할을 합니다. 아래는 Producer의 예시 코드입니다.

import javax.jms.*;
import javax.naming.*;
 
public class BatchProducer {
   public static void main(String[] args) throws JMSException, NamingException {
      Context jndiContext = new InitialContext();
      ConnectionFactory connectionFactory = (ConnectionFactory) jndiContext.lookup("ConnectionFactory");
      Destination destination = (Destination) jndiContext.lookup("queue/MyQueue");
 
      Connection connection = connectionFactory.createConnection();
      Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
      MessageProducer producer = session.createProducer(destination);
 
      TextMessage message = session.createTextMessage();
      message.setText("Batch job 1");
 
      producer.send(message);
      System.out.println("Message sent successfully!");
 
      connection.close();
   }
}

2.3. Consumer 개발

Consumer는 Queue에서 메시지를 받아와 작업을 수행하는 역할을 합니다. 아래는 Consumer의 예시 코드입니다.

import javax.jms.*;
import javax.naming.*;
 
public class BatchConsumer {
   public static void main(String[] args) throws JMSException, NamingException {
      Context jndiContext = new InitialContext();
      ConnectionFactory connectionFactory = (ConnectionFactory) jndiContext.lookup("ConnectionFactory");
      Destination destination = (Destination) jndiContext.lookup("queue/MyQueue");
 
      Connection connection = connectionFactory.createConnection();
      Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
      MessageConsumer consumer = session.createConsumer(destination);
 
      connection.start();
 
      Message message = consumer.receive();
      if (message instanceof TextMessage) {
         TextMessage textMessage = (TextMessage) message;
         System.out.println("Received message: " + textMessage.getText());
      }
 
      connection.close();
   }
}

3. JMS 배치 처리 시스템 실행

위에서 개발한 Producer와 Consumer를 실행하여 JMS를 사용한 배치 처리 시스템을 실행할 수 있습니다. Producer가 작업을 생성하고 Queue에 메시지를 보내면, Consumer가 해당 메시지를 받아와 작업을 수행하게 됩니다.

결론

JMS를 사용하여 배치 처리 시스템을 개발하는 방법을 알아보았습니다. JMS는 비동기식 메시지 패턴을 사용하기 때문에 다양한 시스템 간 통신에 유용하게 사용될 수 있습니다.

참고 자료

Java Message Service API Specification