feat: sse 관련 지표 Bean 주입

Author: hyeonseong0917

thefirsttake/src/main/java/com/thefirsttake/app/chat/service/SSEConnectionService.java

@@ -67,6 +67,9 @@ public SseEmitter initializeConnection(String connectionId, SseEmitter emitter,
             // 연결 메트릭 증가
             sseConnectionCounter.increment();
 
+            // 활성 연결 수 증가
+            com.thefirsttake.app.config.MetricsConfig.getGlobalActiveConnections().incrementAndGet();
+            
             log.info("SSE 연결 초기화 완료: connectionId={}, roomId={}", connectionId, finalRoomId);
 
         } catch (IOException e) {
@@ -201,6 +204,9 @@ public void completeConnection(String connectionId, SseEmitter emitter, AtomicBo
 
                 // 연결 해제 메트릭 증가
                 sseDisconnectionCounter.increment();
+                
+                // 활성 연결 수 감소
+                com.thefirsttake.app.config.MetricsConfig.getGlobalActiveConnections().decrementAndGet();
             } else {
                 log.warn("SSE 연결이 이미 종료됨: connectionId={}", connectionId);
             }

thefirsttake/src/main/java/com/thefirsttake/app/chat/sse/SseInitializer.java

@@ -49,6 +49,10 @@ public Result initialize(SseTrackingHooks hooks) {
         Timer.Sample totalResponseTimer = Timer.start();
 
         sseConnectionCounter.increment();
+        
+        // 활성 연결 수 증가
+        com.thefirsttake.app.config.MetricsConfig.getGlobalActiveConnections().incrementAndGet();
+        
         Timer.Sample connectionTimer = Timer.start();
 
         CompletableFuture.delayedExecutor(120, TimeUnit.SECONDS).execute(() -> {
@@ -59,6 +63,8 @@ public Result initialize(SseTrackingHooks hooks) {
                     connectionTimer.stop(sseConnectionDurationTimer);
                     totalResponseTimer.stop(sseApiTotalResponseTimer);
                     sseDisconnectionCounter.increment();
+                    // 활성 연결 수 감소
+                    com.thefirsttake.app.config.MetricsConfig.getGlobalActiveConnections().decrementAndGet();
                     hooks.onEnd(connectionCreationTimer, connectionLifetimeTimer, "force_timeout", connectionId);
                 }
                 try { emitter.complete(); } catch (Exception e) { log.warn("강제 종료 중 오류: {}", e.getMessage()); }
@@ -71,6 +77,8 @@ public Result initialize(SseTrackingHooks hooks) {
                 connectionTimer.stop(sseConnectionDurationTimer);
                 totalResponseTimer.stop(sseApiTotalResponseTimer);
                 sseDisconnectionCounter.increment();
+                // 활성 연결 수 감소
+                com.thefirsttake.app.config.MetricsConfig.getGlobalActiveConnections().decrementAndGet();
                 hooks.onEnd(connectionCreationTimer, connectionLifetimeTimer, "completion", connectionId);
             }
         });
@@ -80,6 +88,8 @@ public Result initialize(SseTrackingHooks hooks) {
                 connectionTimer.stop(sseConnectionDurationTimer);
                 totalResponseTimer.stop(sseApiTotalResponseTimer);
                 sseDisconnectionCounter.increment();
+                // 활성 연결 수 감소
+                com.thefirsttake.app.config.MetricsConfig.getGlobalActiveConnections().decrementAndGet();
                 hooks.onEnd(connectionCreationTimer, connectionLifetimeTimer, "timeout", connectionId);
             }
         });
@@ -89,6 +99,8 @@ public Result initialize(SseTrackingHooks hooks) {
                 connectionTimer.stop(sseConnectionDurationTimer);
                 totalResponseTimer.stop(sseApiTotalResponseTimer);
                 sseDisconnectionCounter.increment();
+                // 활성 연결 수 감소
+                com.thefirsttake.app.config.MetricsConfig.getGlobalActiveConnections().decrementAndGet();
                 hooks.onEnd(connectionCreationTimer, connectionLifetimeTimer, "error", connectionId);
             }
         });

thefirsttake/src/main/java/com/thefirsttake/app/config/MetricsConfig.java

@@ -174,13 +174,15 @@ public Counter llmApiRetryCounter(MeterRegistry meterRegistry) {
     // ===== SSE API 전체 응답 시간 메트릭 =====
 
     @Bean
+    @Qualifier("sseApiTotalResponseTimer")
     public Timer sseApiTotalResponseTimer(MeterRegistry meterRegistry) {
         return Timer.builder("sse_api_total_response_duration")
                 .description("Total SSE API response time from start to complete")
                 .register(meterRegistry);
     }
 
     @Bean
+    @Qualifier("sseApiTotalCounter")
     public Counter sseApiTotalCounter(MeterRegistry meterRegistry) {
         return Counter.builder("sse_api_total_requests")
                 .description("Total number of SSE API requests")