[java] Apache ActiveMQ의 설치 및 설정 방법

23 Nov 2023

java

Apache ActiveMQ는 대표적인 오픈 소스 메시징 브로커입니다. 이 글에서는 ActiveMQ를 설치하는 방법과 기본적인 설정에 대해 알려드리겠습니다.

1. ActiveMQ 다운로드

ActiveMQ를 사용하기 위해 먼저 Apache ActiveMQ의 공식 웹사이트에서 최신 버전을 다운로드합니다. 아래 링크를 통해 다운로드 페이지로 이동할 수 있습니다.

Apache ActiveMQ 다운로드 페이지

다운로드 페이지에서는 여러 버전 및 패키지가 제공되므로, 자신의 운영체제와 환경에 맞는 버전을 선택합니다. 일반적으로는 이진파일(zip 또는 tar.gz)을 다운로드하는 것을 권장합니다.

2. 설치

다운로드한 ActiveMQ 압축 파일을 원하는 디렉토리로 이동하고 압축을 해제합니다. 압축이 해제된 디렉토리로 이동하면 설치가 완료됩니다.

3. 활성화

ActiveMQ는 Java 가상 머신 (JVM) 위에서 실행되기 때문에, JVM이 설치되어 있어야 합니다. 설치된 JVM이 있는지 확인하기 위해 터미널 또는 명령 프롬프트에서 java -version 명령어를 실행합니다.

$ java -version

만약 JVM이 설치되어 있지 않다면, Oracle Java SE Downloads에서 JDK를 다운로드하여 설치합니다.

JVM이 설치되었다면, ActiveMQ 디렉토리로 이동한 후 bin 디렉토리로 이동하여 ActiveMQ 실행 파일을 실행합니다.

$ cd /path/to/activemq/bin
$ ./activemq start

ActiveMQ가 성공적으로 실행되면, 웹브라우저에서 http://localhost:8161/로 접속하여 ActiveMQ 관리 화면을 확인할 수 있습니다.

4. 설정

ActiveMQ는 기본적으로 conf/activemq.xml 파일을 통해 설정을 관리합니다. 이 파일을 열어서 원하는 설정을 수정할 수 있습니다. 예를 들면, 포트 번호, 인증 설정, 메시지 스토리지 위치 등을 변경할 수 있습니다.

설정 변경 후에는 ActiveMQ를 재시작해야 변경된 설정이 적용됩니다.

5. 테스트

ActiveMQ가 올바르게 설치되고 실행되었는지 확인하기 위해 간단한 테스트를 수행해보겠습니다. 아래 코드를 복사하여 Java 애플리케이션에서 실행하면 ActiveMQ에 메시지를 보낼 수 있습니다.

import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.*;

public class MessageSender {
    public static void main(String[] args) {
        try {
            // 메시지 브로커에 연결하기 위한 ConnectionFactory 생성
            ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");

            // ConnectionFactory를 이용하여 Connection 생성
            Connection connection = connectionFactory.createConnection();
            connection.start();

            // Connection에서 Session 생성
            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

            // Destination (메시지를 보낼 대상) 설정
            Destination destination = session.createQueue("testQueue");

            // MessageProducer 생성
            MessageProducer producer = session.createProducer(destination);

            // TextMessage 생성하여 메시지 설정
            TextMessage message = session.createTextMessage();
            message.setText("Hello, ActiveMQ!");

            // Producer를 이용하여 메시지 전송
            producer.send(message);
            System.out.println("메시지가 전송되었습니다.");

            // 리소스 정리
            producer.close();
            session.close();
            connection.close();
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
}

위의 코드를 실행하여 메시지를 보내면, ActiveMQ에 해당 메시지가 전달되며, 메시지를 수신하는 애플리케이션을 통해 메시지를 확인할 수 있습니다.

이제 Apache ActiveMQ를 사용하기 위해 기본적인 설치 및 설정 방법을 알게 되었습니다. 자세한 내용은 공식 문서를 참조하시기 바랍니다.

목차

1. ActiveMQ 다운로드

2. 설치

3. 활성화

4. 설정

5. 테스트