[java] ActiveMQ와 메시지 보내기 예약

28 Nov 2023

java

이번 글에서는 Java 언어를 사용하여 ActiveMQ를 통해 메시지를 보내는 방법을 예약하는 방법에 대해 알아보겠습니다.

1. ActiveMQ 설정

먼저, ActiveMQ를 설치하고 설정해야 합니다. 설치 방법은 ActiveMQ 공식 웹사이트에서 확인할 수 있습니다. 설치가 완료되면 ActiveMQ에 대한 설정을 진행해야 합니다.

2. Java 프로젝트 설정

ActiveMQ를 사용하기 위해 Java 프로젝트에 해당 라이브러리를 추가해야 합니다. Maven을 사용한다면 pom.xml 파일에 다음과 같은 의존성을 추가합니다.

<dependency>
    <groupId>org.apache.activemq</groupId>
    <artifactId>activemq-all</artifactId>
    <version>5.16.1</version>
</dependency>

Gradle을 사용한다면 build.gradle 파일에 다음과 같은 의존성을 추가합니다.

implementation 'org.apache.activemq:activemq-all:5.16.1'

의존성을 추가한 후, Java 클래스 파일을 작성하여 ActiveMQ에 메시지를 보내는 예약을 구현할 수 있습니다.

3. 메시지 보내기 예약 구현

다음은 메시지를 보내기 위한 예약 클래스의 예제 코드입니다.

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

public class MessageScheduler {

    public static void main(String[] args) throws Exception {
        // ActiveMQ 연결 설정
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
        Connection connection = connectionFactory.createConnection();
        connection.start();

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

        // 메시지 큐 생성
        Queue queue = session.createQueue("message_queue");

        // 예약 메시지 전송
        MessageProducer producer = session.createProducer(queue);
        TextMessage message = session.createTextMessage("Hello, ActiveMQ!");
        long delay = 5000; // 5초 후에 메시지가 전송됨
        producer.setDeliveryDelay(delay);
        producer.send(message);

        // 연결 종료
        session.close();
        connection.close();
    }
}

위의 예제 코드에서는 ActiveMQ에 대한 연결 설정을 시작으로 메시지 큐를 생성하고, 예약 메시지를 보내는 과정을 나타냅니다. delay 변수 값을 조정하여 메시지를 전송할 시간을 지정할 수 있습니다.

이제 Java 프로젝트를 빌드하고 실행하면 ActiveMQ에 메시지를 예약하여 보낼 수 있습니다.

마무리

이번 글에서는 ActiveMQ를 통해 Java 언어를 사용하여 메시지를 보내는 예약 방법에 대해 알아보았습니다. ActiveMQ를 사용하면 메시지 기반 아키텍처를 구현하고, 다양한 기능과 편의성을 제공할 수 있습니다. ActiveMQ에 대한 더 자세한 정보는 ActiveMQ 공식 웹사이트를 참고하시기 바랍니다.