[Camel in Action] 7-1. 마이크로서비스 시대의 Apache Camel – 서비스 통합 아키텍처

마이크로서비스와 통합의 도전

마이크로서비스 아키텍처는 시스템을 작고 독립적인 서비스로 나눕니다. 하지만 서비스가 많아질수록 서비스 간 통신과 통합이 복잡해집니다. Apache Camel은 이런 복잡성을 관리하는 데 탁월한 도구입니다.

Camel이 마이크로서비스에 적합한 이유

전통적인 ESB(Enterprise Service Bus)는 중앙 집중식으로 모든 통합 로직을 처리합니다. 마이크로서비스에서는 이런 중앙화가 오히려 병목이 됩니다. Camel은 각 서비스에 내장(embedded)되어 분산 방식으로 통합을 처리합니다.

• 경량: 서비스 내부에 포함될 만큼 가볍습니다
• 다양한 프로토콜: REST, gRPC, 메시지 큐, 이벤트 스트림 모두 지원
• Spring Boot 통합: 스프링 부트 애플리케이션에 자연스럽게 녹아듦

서비스 디스커버리 패턴

마이크로서비스는 인스턴스가 동적으로 생성/삭제됩니다. Camel은 Consul, Kubernetes, Eureka 등 서비스 디스커버리 시스템과 통합해 동적으로 서비스 주소를 찾을 수 있습니다.

// Kubernetes 서비스 이름으로 자동 라우팅
from("direct:callPayment")
  .to("http4://payment-service/api/pay?bridgeEndpoint=true");

Kubernetes 환경에서는 서비스 이름이 DNS로 자동 해석되므로, IP 주소 대신 서비스 이름을 그대로 사용할 수 있습니다.

Circuit Breaker 패턴 구현

외부 서비스가 느리거나 다운됐을 때 요청이 쌓여 자체 서비스까지 망가지는 것을 막는 것이 Circuit Breaker입니다. Camel 3.x부터 Resilience4j와 통합을 지원합니다.

from("direct:callExternalService")
  .circuitBreaker()
    .to("http4://external-service/api")
  .onFallback()
    .setBody(constant("서비스 일시 중단, 나중에 다시 시도하세요"))
  .end();

Circuit Breaker는 실패 임계값을 초과하면 자동으로 “열려서” 외부 호출을 차단합니다. 일정 시간 후 다시 시도해 성공하면 “닫혀서” 정상 운영됩니다.

이벤트 드리븐 마이크로서비스

REST 호출 대신 이벤트(메시지)로 서비스 간 통신하면 더 느슨한 결합을 달성할 수 있습니다. Camel은 Kafka, RabbitMQ 등 이벤트 스트리밍 플랫폼과 쉽게 연동됩니다.

// 주문 이벤트 발행
from("direct:placeOrder")
  .marshal().json()
  .to("kafka:order-events?brokers=kafka:9092");

// 재고 서비스에서 구독
from("kafka:order-events?brokers=kafka:9092&groupId=inventory")
  .unmarshal().json(OrderEvent.class)
  .to("bean:inventoryService?method=reserve");