[java] 자바 메시지 브로커와의 통합을 위한 Camel 사용법

23 Nov 2023

java

Camel은 Java 기반의 오픈 소스 통합 프레임워크로, 다양한 시스템 간의 통합을 쉽게 구현할 수 있도록 도와줍니다. 이번 블로그에서는 Camel을 사용하여 자바 메시지 브로커와의 통합을 어떻게 할 수 있는지에 대해 알아보겠습니다.

Camel 설치

Camel을 사용하기 위해서는 먼저 Maven 빌드 도구를 설치해야 합니다. 다음과 같이 Maven을 사용하여 Camel 의존성을 추가합니다.

<dependencies>
    <dependency>
        <groupId>org.apache.camel</groupId>
        <artifactId>camel-core</artifactId>
        <version>3.7.1</version>
    </dependency>
    <dependency>
        <groupId>org.apache.camel</groupId>
        <artifactId>camel-jms</artifactId>
        <version>3.7.1</version>
    </dependency>
</dependencies>

Camel 설정

Camel을 사용하기 위해선 CamelContext를 생성하고 라우트를 정의해야 합니다. 다음은 자바 메시지 브로커와의 통합을 위해 Camel의 JMS 컴포넌트를 사용하는 예제입니다.

import org.apache.camel.CamelContext;
import org.apache.camel.impl.DefaultCamelContext;

public class JmsIntegrationExample {
    public static void main(String[] args) throws Exception {
        CamelContext context = new DefaultCamelContext();

        context.addRoutes(new RouteBuilder() {
            public void configure() {
                from("jms:queue:inputQueue")
                    .to("jms:queue:outputQueue");
            }
        });

        context.start();

        Thread.sleep(5000);

        context.stop();
    }
}

위의 예제에서는 from("jms:queue:inputQueue")로 메시지를 inputQueue에서 수신하고, to("jms:queue:outputQueue")로 메시지를 outputQueue로 전송하는 라우트를 정의하고 있습니다.

Camel과 메시지 브로커의 연동

Camel은 다양한 메시지 브로커와의 통합을 지원합니다. 메시지 브로커에 따라 Camel의 컴포넌트를 적절히 설정하여 사용할 수 있습니다. 예를 들어, Apache ActiveMQ 메시지 브로커와의 통합을 위해선 다음과 같이 Camel 컴포넌트를 설정합니다.

import org.apache.camel.CamelContext;
import org.apache.camel.RoutesBuilder;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.jms.JmsComponent;
import org.apache.camel.impl.DefaultCamelContext;

public class ActiveMQIntegrationExample {
    public static void main(String[] args) throws Exception {
        CamelContext context = new DefaultCamelContext();

        // 메시지 브로커 연결을 위한 Camel JMS 컴포넌트 설정
        JmsComponent jmsComponent = JmsComponent.jmsComponent();
        jmsComponent.setConnectionFactory(new ActiveMQConnectionFactory("tcp://localhost:61616"));
        context.addComponent("jms", jmsComponent);

        context.addRoutes(new RouteBuilder() {
            public void configure() {
                from("jms:queue:inputQueue")
                    .to("jms:queue:outputQueue");
            }
        });

        context.start();

        Thread.sleep(5000);

        context.stop();
    }
}

위의 예제에서는 ActiveMQConnectionFactory("tcp://localhost:61616")로 ActiveMQ 메시지 브로커의 연결을 설정하고 있습니다.

결론

Camel을 사용하여 자바 메시지 브로커와의 통합을 구현하는 방법에 대해 알아보았습니다. Camel은 다양한 컴포넌트를 제공하여 다른 시스템과의 통합을 간편하게 할 수 있도록 도와줍니다.

더 자세한 내용은 Apache Camel 공식 문서를 참조하시기 바랍니다.

Apache Camel 공식 문서: https://camel.apache.org/documentation.html