[java] ActiveMQ 연결 설정하기

28 Nov 2023

java

ActiveMQ는 오픈 소스 메시지 브로커로, 메시지 기반의 애플리케이션을 만들 때 사용됩니다. 이 글에서는 자바를 사용하여 ActiveMQ에 연결하는 방법을 알아보겠습니다.

1. Maven 종속성 추가하기

ActiveMQ를 사용하기 위해 먼저 Maven 종속성을 추가해야 합니다. 아래의 코드를 pom.xml 파일에 추가하세요.

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

위의 종속성은 ActiveMQ의 모든 기능을 포함하고 있습니다.

2. ActiveMQ에 연결하기

ActiveMQ에 연결하기 위해 ConnectionFactory 객체를 생성해야 합니다. 아래의 코드를 참고하여 Connection 객체를 생성하세요.

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

public class ActiveMQExample {

    public static void main(String[] args) {
        try {
            // ActiveMQ에 연결하기 위한 ConnectionFactory 생성
            ConnectionFactory connectionFactory = 
                    new ActiveMQConnectionFactory("tcp://localhost:61616");
            
            // ConnectionFactory를 사용하여 Connection 생성
            Connection connection = connectionFactory.createConnection();
            
            // 연결 시작
            connection.start();
            
            // 연결 종료
            connection.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

위의 코드에서 "tcp://localhost:61616"은 ActiveMQ의 기본 연결 주소입니다. 필요에 따라 해당 주소를 변경할 수 있습니다.

3. 연결 설정하기

ActiveMQ에 연결할 때 추가적인 설정을 할 수 있습니다. 예를 들어, 사용자 이름과 비밀번호를 사용하여 연결할 수 있습니다.

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

public class ActiveMQExample {

    public static void main(String[] args) {
        try {
            // ActiveMQ에 연결하기 위한 ConnectionFactory 생성
            ConnectionFactory connectionFactory = 
                    new ActiveMQConnectionFactory("tcp://localhost:61616");
            
            // 사용자 이름과 비밀번호 설정
            ((ActiveMQConnectionFactory) connectionFactory).setUserName("username");
            ((ActiveMQConnectionFactory) connectionFactory).setPassword("password");
            
            // ConnectionFactory를 사용하여 Connection 생성
            Connection connection = connectionFactory.createConnection();
            
            // 연결 시작
            connection.start();
            
            // 연결 종료
            connection.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

위의 코드에서 "username"과 "password"는 실제 사용자 이름과 비밀번호로 변경되어야 합니다. 이렇게 연결 설정을 추가로 할 수 있습니다.

ActiveMQ 연결 설정하기와 관련된 자세한 내용은 공식 문서를 참고하세요.

이제 ActiveMQ에 연결하는 방법을 알게 되었습니다. 여러분의 메시지 기반 애플리케이션을 만들 때 이를 활용해보세요!