Java アプリケーション向け New Relic APM 設定ガイド ​

import com.newrelic.api.agent.NewRelic;
import com.newrelic.api.agent.Trace;

@Service
public class OrderService {
    
    @Trace(dispatcher = true)
    public void processOrder(Order order) {
        // ビジネスロジック
        NewRelic.recordMetric("Custom/OrderProcessed", 1);
    }
}

import com.newrelic.api.agent.NewRelic;

public class PaymentProcessor {
    public void processPayment(Payment payment) {
        long startTime = System.currentTimeMillis();
        try {
            // 支払い処理
            NewRelic.recordMetric("Custom/PaymentSuccess", 1);
        } catch (Exception e) {
            NewRelic.noticeError(e);
            NewRelic.recordMetric("Custom/PaymentError", 1);
        } finally {
            long duration = System.currentTimeMillis() - startTime;
            NewRelic.recordResponseTimeMetric("Custom/PaymentDuration", duration);
        }
    }
}

@Component
public class AdvancedErrorHandler {
    private static final Logger logger = LoggerFactory.getLogger(AdvancedErrorHandler.class);
    
    @EventListener
    @Trace
    public void handleApplicationError(ApplicationErrorEvent event) {
        Map<String, Object> attributes = new HashMap<>();
        attributes.put("error.severity", event.getSeverity().name());
        attributes.put("error.module", event.getModuleName());
        attributes.put("error.user_id", event.getUserId());
        attributes.put("error.request_id", event.getRequestId());
        
        // エラーカテゴリ別の分類
        if (event.getException() instanceof ValidationException) {
            attributes.put("error.category", "validation");
            NewRelic.recordMetric("Errors/Validation", 1);
        } else if (event.getException() instanceof DataAccessException) {
            attributes.put("error.category", "database");
            NewRelic.recordMetric("Errors/Database", 1);
        } else if (event.getException() instanceof ServiceUnavailableException) {
            attributes.put("error.category", "external_service");
            NewRelic.recordMetric("Errors/ExternalService", 1);
        }
        
        // New Relicへのエラー報告
        NewRelic.noticeError(event.getException(), attributes);
        
        // 重要度に応じたアラート
        if (event.getSeverity() == ErrorSeverity.CRITICAL) {
            NewRelic.recordMetric("Errors/Critical", 1);
            // 緊急アラートトリガー
            triggerCriticalAlert(event);
        }
    }
    
    @Trace
    private void triggerCriticalAlert(ApplicationErrorEvent event) {
        // アラート送信ロジック
        logger.error("Critical error detected: {}", event.getException().getMessage());
    }
}

@Service
public class BusinessMetricsService {
    
    @EventListener
    @Trace
    public void onOrderCompleted(OrderCompletedEvent event) {
        Map<String, Object> attributes = new HashMap<>();
        attributes.put("order.value", event.getOrderValue());
        attributes.put("customer.segment", event.getCustomerSegment());
        attributes.put("product.category", event.getProductCategory());
        attributes.put("payment.method", event.getPaymentMethod());
        
        // 売上メトリクス
        NewRelic.recordMetric("Business/Revenue/Total", event.getOrderValue());
        NewRelic.recordMetric("Business/Orders/Completed", 1);
        
        // カテゴリ別売上
        String categoryMetric = "Business/Revenue/Category/" + event.getProductCategory();
        NewRelic.recordMetric(categoryMetric, event.getOrderValue());
        
        // カスタムイベントの送信
        NewRelic.recordCustomEvent("OrderCompleted", attributes);
    }
    
    @Scheduled(fixedRate = 60000) // 1分間隔
    @Trace
    public void collectActiveUsers() {
        int activeUsers = userSessionService.getActiveUserCount();
        NewRelic.recordMetric("Business/Users/Active", activeUsers);
        
        // ユーザーセグメント別の集計
        Map<String, Integer> segmentCounts = userSessionService.getActiveUsersBySegment();
        segmentCounts.forEach((segment, count) -> {
            String metricName = "Business/Users/Active/Segment/" + segment;
            NewRelic.recordMetric(metricName, count);
        });
    }
    
    @EventListener
    @Trace
    public void onUserRegistration(UserRegistrationEvent event) {
        Map<String, Object> attributes = new HashMap<>();
        attributes.put("user.source", event.getRegistrationSource());
        attributes.put("user.plan", event.getSubscriptionPlan());
        attributes.put("user.country", event.getCountry());
        
        NewRelic.recordMetric("Business/Users/Registered", 1);
        NewRelic.recordCustomEvent("UserRegistered", attributes);
        
        // 獲得チャネル別の追跡
        String sourceMetric = "Business/Users/Acquisition/" + event.getRegistrationSource();
        NewRelic.recordMetric(sourceMetric, 1);
    }
}