How to start Apache Camel

Apache Camel 은 무엇인🍊?

Apache Camel은 통합 프레임워크로, 여러 시스템 간의 메시지 라우팅 및 처리 로직을 정의하고 실행하기 위해 사용된다.

서로 다른 시스템 간 데이터를 통합하고 처리할 수 있도록 Component 와 Java APIs 들의 집합으로 구성되어 있다. 즉, Camel 은 서로 다른 애플리케이션을 연결하는 매게체 역할을 한다.

약 320개 이상의 Component 를 제공하며 이를 통해 웹 서비스, 파일 읽기 및 쓰기, 타 앱과 상호작용 등이 가능하다. Camel은 Java 용 파이프라인을 생성할 수 있는 도구라고 비유할 수 있다. 특정 지점에서 데이터를 가져와 다른 지점으로 연결하며, 그 과정에서 데이터를 변경 및 변환하거나 또 다른 파이프를 통해 전송할 수도 있다.

어떤 상황에서 사용되는가?

데이터를 A에서 B로 이동해야 하는 거의 모든 경우에 Camel이 사용될 수 있다. 가령 다음과 같은 예시가 있다.

FTP 서버에서 문서를 가져와 특정 부서로 이메일 보내기
디스크 폴더에서 파일을 가져와 Google Drive 같은 특정 저장소에 적재하기
메시지 큐에서 메시지를 가져와 웹 서비스로 보내기
DB에서 특정 데이터를 검색할 수 있는 웹 서비스 만들기

APIM(API 관리) 솔루션에 조금 더 초점을 맞추자면 다음과 같은 예시가 있다.

메시지 라우팅: 클라이언트 요청을 적절한 서비스(애플리케이션)
로 전달
로깅 및 모니터링: API 호출 추적
보안 처리: 인증 및 권한 부여
데이터 변환: JSON ↔ XML 변환 등

Camel 파이프라인

다음 다이어그램은 Camel의 핵심 개념 중 일부를 보여준다.

주요 키워드

Camel Context : 라우트가 동작하는 컨테이너
Route: 데이터 흐름을 정의하는 경로입니다. Camel DSL을 사용해 정의합니다.
Endpoint : 메시지를 송수신하는 지점
EIP (Enterprise Integration Patterns): 메시지 라우팅과 변환을 다루는 설계 패턴.
- Camel은 소프트웨어 통합에 관한 서적인 Enterprise Integration Patterns 에서 영감을 많이 받아, 재사용 가능한 패턴을 차용해 개발되었다. 시스템 간 메시지 라우팅 및 처리를 다루는 디자인 패턴의 모음이다.
Component: 외부 시스템과의 통신을 처리하는 Camel의 플러그인.
- 예: HTTP, FTP, JMS, Kafka 등.
Processor & Transformer: 메시지 처리 및 변환 역할을 합니다.

Route : 데이터가 이동하는 경로를 정의

Camel의 가장 기본적인 개념은 Route 이다. Camel을 구성하는 객체로, 데이터를 A에서 B로 이동시킬 수 있다. 이때, 각 지점인 A, B를 Endpoint 이라 지칭한다. Route는 각 Endpoint 경로를 정의할 때 사용된다. Java 또는 Xml 구문을 통해 Route를 생성할 수 있다.

from("sourceEndpoint")
    .to("destinationEndpoint");

다음은 이전 폴더에 위치한 파일들을 특정 폴더로 이동시키는 예제코드이다.

from("file:home/customers/new")
    .to("file:home/customers/old");

Producer & Consumer (생산자와 소비자)
Route, Endpoint, Component에서 Producer와 Consumer 개념이 사용된다.

Producer

데이터를 보내는 역할 (to() 메서드로 지정)
엔드포인트 관점에서, 메시지가 전달되는 목적지
컴포넌트 관점에서, 디스크의 파일에 쓰거나 메시지 대기열에 적재하는 등 무언가를 작성하도록 구성된 컴포넌트이다.

Consumer

데이터를 받는 역할 (from() 메서드로 지정)
엔드포인트 관점에서, 메시지가 들어오는 시작점
컴포넌트 관점에서, 디스크에서 파일을 읽거나 REST 요청을 수신하는 등 무언가를 읽도록 구성된 컴포넌트이다.

DSL

Apache Camel은 다양한 형태의 DSL(Domain Specific Language)을 이용해서 라우트들을 정의한다. Spring 애플리케이션에서 DSL의 주요 두 가지 형식은 Java DSL과 Spring XML DSL로 정의된다. 다음은 RouteBuilder 클래스를 사용하는 Java DSL로 정의된 라우트 예제이다.

RouteBuilder builder = new RouteBuilder(){
	@Override
	public void configure() throws Exception{
		// Route Definition in Java DSL for
		// moving file from jms queue to file system.
		from("jms:queue:mySQueue").to("file://mysrc");
	}
}

Endpoint : 외부 시스템과 상호작용하는 지점

Endpoint는 Camel 이 다른 시스템과 메시지를 교환하는 인터페이스 이다. 라우트에서 이동하는 단계이다.(?)
여러 방법으로 엔드포인트를 선언할 수 있찌만, 가장 대표적인 방법은 다음과 같이 URI 처럼 보이는 구문을 사용해 선언한다.

URI 형식: <component>:<specific-uri-options>

component : 엔드포인트가 참조
options : 엔드포인트가 필요로 하는 설정

예제

prefix:mainpart?option1=xxx&option2=xxx...
file:inputFolder (파일 디렉토리)
http://example.com (HTTP 요청)
jms:queue:orders (JMS 큐)

from("timer:foo?period=1000") // 1초마다 타이머 이벤트 생성
    .setBody(constant("Hello, Camel"))
    .to("log:info"); // 로그 출력

Component : 엔드포인트를 만들기 위한 도구

Component는 특정 프로토콜이나 기술을 다루기 위해 Camel에 플러그인처럼 추가되는 모듈입니다. 엔드포인트를 생성할 수 있도록 컴포넌트 라이브러리를 제공한다. 컴포넌트는 디스크에 있는 파일, 사서함, Dropbox나 트위터 같은 앱 등 외부 시스템과의 통신(연결)할 수 있는 플러그와 같은 역할이다.

예를들어, 애플리케이션에 데이터를 저장하거나 가져오는 작업이 필요하다고 가정하자. Component는 이미 이러한 작업을 대신 해주는 기능을 제공한다. 따라서 파일을 읽거나 웹 서비스를 호출하기 위해 직접 코드를 작성하여 구현하는데 시간을 소모할 필요가 없다. 단지, 적절한 컴포넌트를 찾아서 사용하면 된다. 가장 일반적인 컴포넌트들은 다음과 같다.

Component	목적	Endpoint URI
HTTP	HTTP 요청 처리	http:
File	파일 읽기 및 쓰기	file:
REST	RESTful 서비스 구현	rest:
JMS	메시지 큐와의 통신 (예: ActiveMQ, RabbitMQ)	jms:
Direct	for joining your Camel routes together	direct:
Salesforce	for getting data in and out of Salesforce	salesforce:

from("file:inputFolder")
    .to("http://example.com/api/upload");

EIP : 시스템 간 메시지 라우팅 및 처리

앞서 언급한 엔터프라이즈 통합 패턴이라는 책에 정의된 패턴에 따라 메시지를 처리한다. 메시지에서 변환, 분할 및 로깅과 같은 몇 가지 일반적인 작업을 수행하려는 경우 EIP를 사용한다. 다음은 Camel의 몇 가지 일반적인 EIP이다.

EIP	역할	Java 문법
Splitter	Splits a message into multiple parts	.split()
Aggregator	Combines several messages into one message	.aggregate()
Log	Writes a simple log message	.log()
Marshal	Converts an object into a text or binary format	.marshal()
From*	Receives a message from an endpoint	.from()
To*	Sends a message to an endpoint	.to()

예제

Content-Based Routing: 메시지 내용에 따라 다른 라우트를 선택

from("direct:start")
    .choice()
      .when(simple("${body} contains 'urgent'"))
        .to("jms:queue:urgent")
      .otherwise()
        .to("jms:queue:normal");

Message Transformation: 메시지 변환

from("direct:start")
    .transform().simple("Modified: ${body}");

Split/Aggregate: 메시지를 분할하거나 합침

from("file:inputFolder")
    .split(body().tokenize("\n"))
    .to("direct:processLine");

Processor & Transformer

Processor

메시지의 내용을 직접적으로 처리하여 비지니스로직을 구현할 수 있는 인터페이스이다.
메시지가 Camel 라우트를 통해 이동할 때, 중간 단계에서 Processor를 처리하여 메시지를 변환하거나 조작을 할 수 있다.

processor의 역할

메시지 내용 변경 : 메시지의 본문, 헤더 또는 기타 속성을 변경할 수 있다.
비지니스 로직 추가 : 라우팅 중간에 특정 비지니스 로직을 추가하여 메시지를 변환하거나 필터링할 수 있습니다.

Processor 또한 RouterBuilder처럼 클래스에서 상속을 받아 사용하며 apiCreator의 경우 apiService에서 제공하는 기능들 별로 processor를 상속하여 기능들을 구현하였다.
ex) parsingProcessor, convertProcessor

Transformer

Camel Context : 컨테이너

모든 Camel 생성자의 런타임 컨테이너이며, 라우팅 규칙에 따라 수행된다.

종합 정리

주요 구성 요소들을 종합적으로 정리하자면, Camel의 키워드들은 아래와 같은 관계로 동작한다.

Route는 메시지의 이동 경로를 정의하며, Endpoint를 통해 데이터를 송수신한다.
Component는 다양한 시스템과의 통신을 지원하며, EIP를 통해 메시지 처리 로직을 설계합니다.
모든 작업은 Camel Context에 의해 관리됩니다.

참고 링크

초보자를 위한 카멜 튜토리얼

Demo 프로젝트 만들어보기

RouteBuilder

public class CustomRouter extends RouteBuilder {

route 구축을 위해 RouteBuilder를 상속받는다.

dev_Hyun

공룡, 다람쥐 그리고 돌고래!

이전 포스트