Micrometer — 스프링의 메트릭 추상화와 Prometheus 연동

// build.gradle
implementation 'org.springframework.boot:spring-boot-starter-actuator'
implementation 'io.micrometer:micrometer-registry-prometheus'

# application.yml
management:
  endpoints:
    web:
      exposure:
        include: health, info, prometheus, metrics
  metrics:
    tags:
      application: my-service  # 모든 메트릭에 공통 태그 추가
    distribution:
      percentiles-histogram:
        http.server.requests: true  # 히스토그램 활성화
      percentiles:
        http.server.requests: [0.5, 0.95, 0.99]  # 백분위 수

@Service
@RequiredArgsConstructor
public class OrderService {
    private final MeterRegistry meterRegistry;

    public Order createOrder(OrderRequest request) {
        try {
            Order order = processOrder(request);

            // 주문 성공 카운터 증가
            meterRegistry.counter("orders.created",
                "type", request.getType(),
                "region", request.getRegion()
            ).increment();

            return order;
        } catch (Exception e) {
            // 주문 실패 카운터 증가
            meterRegistry.counter("orders.failed",
                "reason", e.getClass().getSimpleName()
            ).increment();
            throw e;
        }
    }
}

@Configuration
public class MetricsConfig {

    @Bean
    public MeterBinder queueSizeGauge(TaskQueue taskQueue) {
        return registry -> Gauge.builder("task.queue.size",
                taskQueue, TaskQueue::size)
            .description("현재 대기 중인 작업 수")
            .register(registry);
    }

    @Bean
    public MeterBinder activeUsersGauge(SessionStore sessionStore) {
        return registry -> Gauge.builder("users.active",
                sessionStore, SessionStore::getActiveCount)
            .description("현재 활성 사용자 수")
            .register(registry);
    }
}

@Service
@RequiredArgsConstructor
public class PaymentService {
    private final MeterRegistry meterRegistry;

    public PaymentResult processPayment(PaymentRequest request) {
        // Timer로 소요 시간 측정
        return Timer.builder("payment.process")
            .tag("gateway", request.getGateway())
            .tag("currency", request.getCurrency())
            .description("결제 처리 소요 시간")
            .register(meterRegistry)
            .record(() -> {
                // 실제 결제 처리 로직
                return paymentGateway.charge(request);
            });
    }
}

public void complexOperation() {
    Timer.Sample sample = Timer.start(meterRegistry);

    try {
        // 복잡한 작업...
        step1();
        step2();
        step3();

        sample.stop(Timer.builder("complex.operation")
            .tag("result", "success")
            .register(meterRegistry));
    } catch (Exception e) {
        sample.stop(Timer.builder("complex.operation")
            .tag("result", "failure")
            .register(meterRegistry));
        throw e;
    }
}

DistributionSummary summary = DistributionSummary.builder("http.request.size")
    .baseUnit("bytes")
    .publishPercentiles(0.5, 0.95, 0.99)
    .register(meterRegistry);

summary.record(request.getContentLength());

@Bean
public TimedAspect timedAspect(MeterRegistry registry) {
    return new TimedAspect(registry);  // AOP 기반 @Timed 활성화
}

@Service
public class ProductService {

    @Timed(
        value = "product.search",
        description = "상품 검색 소요 시간",
        extraTags = { "layer", "service" }
    )
    public List<Product> search(String keyword) {
        return productRepository.findByKeyword(keyword);
    }
}

# prometheus.yml
scrape_configs:
  - job_name: 'spring-app'
    metrics_path: '/actuator/prometheus'
    scrape_interval: 15s
    static_configs:
      - targets: ['host.docker.internal:8080']
        labels:
          environment: 'production'

# 초당 요청 수 (1분 평균)
rate(http_server_requests_seconds_count[1m])

# 95백분위 응답 시간
histogram_quantile(0.95, rate(http_server_requests_seconds_bucket[5m]))

# 에러율
rate(http_server_requests_seconds_count{status=~"5.."}[5m])
/ rate(http_server_requests_seconds_count[5m])

# HikariCP 대기 중인 요청
hikaricp_connections_pending{pool="HikariPool-1"}

# Grafana Alerting Rule 예시
# 5분간 에러율이 5%를 초과하면 알림
expr: |
  rate(http_server_requests_seconds_count{status=~"5.."}[5m])
  / rate(http_server_requests_seconds_count[5m]) > 0.05

도메인.동작.단위
예: orders.created.total, payment.process.seconds

// 좋은 태그: 카디널리티가 낮은 값
counter.increment("method", "POST", "status", "200");

// 나쁜 태그: 카디널리티가 높은 값 (사용자 ID, 타임스탬프 등)
counter.increment("userId", userId);  // 사용자 수만큼 시계열 생성 → 메모리 폭발