[java] ActiveMQ와 메시지 이벤트 처리

28 Nov 2023

java

ActiveMQ는 오픈소스 메시지 브로커로서, 메시지 기반 이벤트 처리를 위한 강력한 도구입니다. 이 글에서는 ActiveMQ를 사용하여 메시지 이벤트를 처리하는 방법에 대해 알아보겠습니다.

1. ActiveMQ란?

ActiveMQ는 Apache Software Foundation에서 개발한 메시지 브로커입니다. 메시지 브로커는 송신자와 수신자 간에 메시지를 중계해주는 중간자 역할을 합니다. 이를 통해 데이터를 비동기적으로 전달하고, 시스템 간의 결합도를 낮추고, 확장성을 높일 수 있습니다.

2. 메시지 이벤트 처리 방법

ActiveMQ를 사용하여 메시지 이벤트를 처리하는 방법은 다음과 같습니다.

2.1. ActiveMQ 메시지 큐 생성

처음으로 해야할 일은 ActiveMQ 서버에 연결하고, 메시지 큐를 생성하는 것입니다.

import javax.jms.*;

// ActiveMQ 서버에 연결
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
Connection connection = connectionFactory.createConnection();
connection.start();

// 세션 생성
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

// 메시지 큐 생성
Destination destination = session.createQueue("myQueue");
MessageProducer producer = session.createProducer(destination);

2.2. 메시지 보내기

이제 메시지를 보내는 코드를 작성해보겠습니다.

// 텍스트 메시지 생성
TextMessage message = session.createTextMessage();
message.setText("Hello, ActiveMQ!");

// 메시지 큐에 메시지 보내기
producer.send(message);

2.3. 메시지 받기

이제 메시지를 수신하는 코드를 작성해보겠습니다.

// 메시지 큐 소비자 생성
MessageConsumer consumer = session.createConsumer(destination);

// 메시지 받기
Message receivedMessage = consumer.receive();
if (receivedMessage instanceof TextMessage) {
    TextMessage textMessage = (TextMessage) receivedMessage;
    String text = textMessage.getText();
    System.out.println("Received message: " + text);
}

2.4. 연결 닫기

메시지 이벤트 처리가 끝났다면 연결을 닫아주어야 합니다.

// 연결 닫기
producer.close();
consumer.close();
session.close();
connection.close();

3. 참고 자료

위에서는 ActiveMQ를 사용하여 메시지 이벤트를 처리하는 방법에 대해 간단히 알아보았습니다. ActiveMQ는 다양한 메시지 패턴을 지원하고, 강력한 기능을 제공하기 때문에 많은 개발자들이 선호하는 메시지 브로커입니다.