Categories: Camel프레임워크

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

운영 중인 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: 처리량 통계

zerg96

Share
Published by
zerg96

Recent Posts

정보보안기사 필기 핵심 개념, 접근통제·인증 8문제로 정리

필기 시험의 접근통제 영역은 용어 하나만 알아도 풀리는 문제와 개념을 뒤집어 묻는 문제가 섞여 나옵니다.…

3시간 ago

유튜브 AI 영상 범람, 진짜 크리에이터는 어떻게 살아남나

유튜브에 AI 자동 생성 영상이 넘쳐납니다. 진짜 크리에이터들은 어떻게 살아남아야 할까요? AI와 경쟁하는 3가지 생존…

5시간 ago

코스피 사이드카 이틀 만에 또 발동, 올해만 27번째…5분간 멈추는 건 ‘프로그램 매도’뿐입니다

이틀 전에 사이드카가 걸렸을 때만 해도 "한 번 놀란 장"으로 끝날 줄 알았는데요. 15일 아침…

5시간 ago

코스피 낙폭 7%로 확대, 외국인 1.7조 순매도: 10월 15일 오전 10시 시황

오전 시황 글에 이어 장중 후속 정리입니다. 코스피는 개장 직후 5%대였던 낙폭이 오전 10시 전후에…

8시간 ago

코스피 5.59% 급락 출발, 개장 7분 만에 매도 사이드카: 10월 15일 오전 시황

10월 15일 목요일 아침, 코스피가 전날 종가보다 5.59% 낮은 5,673.01로 출발했습니다. 장 시작 7분 만에…

9시간 ago

삼성 갤럭시 AI, 솔직히 기대 이하였다 — 실망스러운 이유 TOP 5

삼성 갤럭시 AI, 써보니 실망스러웠다. 온디바이스 한계, 지역 제한, 낮은 일상 활용도 등 현실적인 문제점…

10시간 ago