[Camel in Action] 15-1. Camel 관리와 모니터링 – JMX와 Hawtio 대시보드

by

운영 중인 Camel을 모니터링해야 하는 이유

Camel 애플리케이션이 프로덕션에서 실행 중일 때 각 라우트의 상태, 처리량, 오류율을 실시간으로 파악해야 합니다. 문제가 발생했을 때 빠르게 원인을 찾고, 필요하면 라우트를 일시 정지하거나 재시작해야 합니다.

JMX로 Camel 관리

Camel은 기본적으로 JMX를 통해 관리 인터페이스를 노출합니다. JConsole이나 VisualVM으로 연결하면 라우트 통계를 볼 수 있습니다.

# application.properties에서 JMX 활성화
camel.springboot.jmx-enabled=true

// 코드에서 JMX로 라우트 통계 조회
ManagedCamelContext managed = context.getCamelContextExtension()
  .getContextPlugin(ManagedCamelContext.class);

ManagedRouteMBean routeMBean = managed.getManagedRoute("order-processor", ManagedRouteMBean.class);
System.out.println("처리 건수: " + routeMBean.getExchangesTotal());
System.out.println("실패 건수: " + routeMBean.getExchangesFailed());
System.out.println("평균 처리 시간: " + routeMBean.getMeanProcessingTime() + "ms");

Hawtio – Camel 전용 웹 관리 콘솔

Hawtio는 JMX 기반의 웹 관리 콘솔입니다. 브라우저에서 라우트 다이어그램을 보고, 메시지 통계를 확인하고, 라우트를 시작/중지할 수 있습니다.

<dependency>
  <groupId>io.hawt</groupId>
  <artifactId>hawtio-springboot</artifactId>
  <version>2.17.6</version>
</dependency>

의존성 추가 후 http://localhost:8080/hawtio에 접속하면 Camel 탭에서 라우트 목록, 엔드포인트, 메시지 통계를 확인할 수 있습니다.

라우트 동적 제어

운영 중에 특정 라우트를 코드 변경 없이 일시 정지하거나 재시작할 수 있습니다.

// 라우트 일시 정지 (메시지 소비 중단)
context.suspendRoute("order-processor");

// 라우트 재시작
context.resumeRoute("order-processor");

// 라우트 완전 중지
context.stopRoute("order-processor");

// 새 라우트 동적 추가
context.addRoutes(new RouteBuilder() {
  @Override
  public void configure() throws Exception {
    from("timer:new?period=1000").log("새 라우트");
  }
});

알림과 임계값 모니터링

// 에러율이 임계값 초과 시 알림
@Component
public class RouteMonitor {
  @Scheduled(fixedDelay = 60000)
  public void checkRouteHealth() {
    ManagedRouteMBean routeMBean = getManagedRoute("order-processor");
    double errorRate = (double) routeMBean.getExchangesFailed()
      / routeMBean.getExchangesTotal() * 100;

    if (errorRate > 5.0) {
      alertService.send("order-processor 에러율 " + errorRate + "% 초과");
    }
  }
}

Camel이 제공하는 주요 MBean 속성

  • ExchangesTotal: 총 처리된 Exchange 수
  • ExchangesFailed: 실패한 Exchange 수
  • MeanProcessingTime: 평균 처리 시간 (ms)
  • MaxProcessingTime: 최대 처리 시간
  • LastProcessingTime: 마지막 처리 시간
  • ThroughputStatistics: 처리량 통계

Leave a Comment