[FEAT/#447] 커스텀 대시보드·메트릭 및 request-id 로깅 추가

src/main/java/com/assu/server/domain/certification/controller/GroupCertificationController.java

@@ -14,6 +14,8 @@
 import com.assu.server.domain.certification.service.CertificationService;
 import com.assu.server.global.util.PrincipalDetails;
 
+import io.micrometer.core.instrument.MeterRegistry;
+import io.micrometer.core.instrument.Timer;
 import io.swagger.v3.oas.annotations.Operation;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -26,6 +28,7 @@
 public class GroupCertificationController {
 
 	private final CertificationService certificationService;
+	private final MeterRegistry meterRegistry;
 
 	@MessageMapping("/certify")
 	@Operation(
@@ -44,15 +47,21 @@ public CertificationProgressResponseDTO certifyGroup(@Payload GroupSessionReques
 			UsernamePasswordAuthenticationToken auth = (UsernamePasswordAuthenticationToken)principal;
 			PrincipalDetails principalDetails = (PrincipalDetails)auth.getPrincipal();
 
+			Timer.Sample sample = Timer.start(meterRegistry);
 			try {
 				log.info("### SUCCESS ### 인증 요청 메시지 수신 - user: {}, adminId: {}, sessionId: {}",
 					principalDetails.getUsername(), dto.adminId(), dto.sessionId());
 
 				if (principalDetails != null) {
-					return certificationService.handleCertification(dto, principalDetails.getMember());
+					CertificationProgressResponseDTO result = certificationService.handleCertification(dto, principalDetails.getMember());
+					meterRegistry.counter("certification.group.result", "result", "success").increment();
+					return result;
 				}
 			} catch (Exception e) {
 				log.error("### ERROR ### 인증 처리 중 오류 발생: {}", e.getMessage(), e);
+				meterRegistry.counter("certification.group.result", "result", "failure").increment();
+			} finally {
+				sample.stop(meterRegistry.timer("certification.group.duration"));
 			}
 		}
 		return null;

src/main/java/com/assu/server/domain/chat/service/ChatServiceImpl.java

@@ -21,6 +21,7 @@
 import com.assu.server.global.exception.DatabaseException;
 import com.assu.server.global.exception.GeneralException;
 import com.assu.server.global.util.PresenceTracker;
+import io.micrometer.core.instrument.MeterRegistry;
 import jakarta.transaction.Transactional;
 import org.springframework.dao.DataIntegrityViolationException;
 import lombok.RequiredArgsConstructor;
@@ -45,6 +46,7 @@ public class ChatServiceImpl implements ChatService {
     private final NotificationCommandService notificationCommandService;
     private final PresenceTracker presenceTracker;
     private final BlockRepository blockRepository;
+    private final MeterRegistry meterRegistry;
 
 
     @Override
@@ -115,6 +117,7 @@ public MessageHandlingResult handleMessage(ChatRequestDTO.ChatMessageRequestDTO
         // 3. 메시지 저장 (기존 로직)
         Message message = Message.toMessageEntity(request, room, sender, receiver, unreadForSender);
         Message saved = messageRepository.saveAndFlush(message);
+        meterRegistry.counter("chat.message.sent").increment();
         log.info("saved message id={}, roomId={}, senderId={}, receiverId={}",
                 saved.getId(), room.getId(), sender.getId(), receiver.getId());
 

src/main/java/com/assu/server/domain/notification/service/NotificationListener.java

@@ -8,6 +8,7 @@
 import com.assu.server.domain.notification.dto.NotificationMessageDTO;
 import com.google.firebase.messaging.FirebaseMessagingException;
 import com.rabbitmq.client.Channel;
+import io.micrometer.core.instrument.MeterRegistry;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.rabbit.annotation.RabbitListener;
@@ -28,6 +29,7 @@ public class NotificationListener {
     private final FcmClient fcmClient;
     private final OutboxStatusService outboxStatus;
     private final ApplicationEventPublisher eventPublisher;
+    private final MeterRegistry meterRegistry;
 
     @RabbitListener(queues = AmqpConfig.QUEUE, ackMode = "MANUAL")
     public void onMessage(@Payload NotificationMessageDTO notificationMessageDTO,
@@ -67,11 +69,17 @@ private void sendNotification(NotificationMessageDTO dto, Long outboxId)
 
         if (outboxId != null) outboxStatus.markSent(outboxId);
 
+        meterRegistry.counter("notification.fcm.send", "result", "success").increment(result.successCount());
+        if (result.failureCount() > 0) {
+            meterRegistry.counter("notification.fcm.send", "result", "failure").increment(result.failureCount());
+        }
+
         log.info("[Notify] sent outboxId={} memberId={} success={} fail={} invalidTokens={}",
                 outboxId, dto.receiverId(), result.successCount(), result.failureCount(), result.invalidTokens());
     }
 
     private void handleException(Exception e, Long outboxId, Long memberId) {
+        meterRegistry.counter("notification.fcm.send", "result", "exception").increment();
         if (outboxId != null) {
             outboxStatus.markFailed(outboxId);
 

src/main/java/com/assu/server/domain/notification/service/OutboxAfterCommitPublisher.java

@@ -6,6 +6,7 @@
 import com.assu.server.domain.notification.event.NotificationFailedEvent;
 import com.assu.server.infra.messaging.AmqpConfig;
 import com.assu.server.infra.messaging.ConditionalOnRabbitEnabled;
+import io.micrometer.core.instrument.MeterRegistry;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
@@ -24,6 +25,7 @@ public class OutboxAfterCommitPublisher {
     private final RabbitTemplate rabbit;
     private final OutboxStatusService outboxStatus;
     private final ApplicationEventPublisher eventPublisher;
+    private final MeterRegistry meterRegistry;
 
     @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
     public void onOutboxCreated(OutboxCreatedEvent e) {
@@ -44,8 +46,10 @@ public void onOutboxCreated(OutboxCreatedEvent e) {
             rabbit.convertAndSend(AmqpConfig.EXCHANGE, AmqpConfig.ROUTING_KEY, dto);
             log.info("[Outbox] Message sent to queue for outboxId={}", e.getOutboxId());
             outboxStatus.markDispatched(e.getOutboxId());
+            meterRegistry.counter("notification.outbox.publish", "result", "success").increment();
         } catch (Exception ex) {
             log.error("[Outbox] Failed to send message for outboxId={}", e.getOutboxId(), ex);
+            meterRegistry.counter("notification.outbox.publish", "result", "failure").increment();
             // 큐 전송 실패 시 재시도 이벤트 발행
             eventPublisher.publishEvent(new NotificationFailedEvent(e.getOutboxId(), 0));
         }

src/main/java/com/assu/server/domain/notification/service/OutboxRetryProcessor.java

@@ -4,6 +4,7 @@
 import com.assu.server.domain.notification.entity.OutboxCreatedEvent;
 import com.assu.server.domain.notification.event.NotificationFailedEvent;
 import com.assu.server.domain.notification.repository.NotificationOutboxRepository;
+import io.micrometer.core.instrument.MeterRegistry;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.context.ApplicationEventPublisher;
@@ -19,9 +20,11 @@ public class OutboxRetryProcessor {
 
     private final NotificationOutboxRepository outboxRepository;
     private final ApplicationEventPublisher eventPublisher;
-
+    private final MeterRegistry meterRegistry;
+
     @Transactional(propagation = Propagation.REQUIRES_NEW)
     public void processRetry(NotificationOutbox outbox) {
+        meterRegistry.counter("notification.outbox.retry").increment();
         try {
             outbox.incrementRetryCount();
             outboxRepository.save(outbox);

src/main/java/com/assu/server/global/filter/RequestIdFilter.java

@@ -0,0 +1,38 @@
+package com.assu.server.global.filter;
+
+import jakarta.servlet.FilterChain;
+import jakarta.servlet.ServletException;
+import jakarta.servlet.http.HttpServletRequest;
+import jakarta.servlet.http.HttpServletResponse;
+import org.slf4j.MDC;
+import org.springframework.core.Ordered;
+import org.springframework.core.annotation.Order;
+import org.springframework.stereotype.Component;
+import org.springframework.web.filter.OncePerRequestFilter;
+
+import java.io.IOException;
+import java.util.UUID;
+
+@Component
+@Order(Ordered.HIGHEST_PRECEDENCE)
+public class RequestIdFilter extends OncePerRequestFilter {
+
+    public static final String REQUEST_ID_HEADER = "X-Request-Id";
+    public static final String MDC_KEY = "requestId";
+
+    @Override
+    protected void doFilterInternal(
+            HttpServletRequest request,
+            HttpServletResponse response,
+            FilterChain filterChain)
+            throws ServletException, IOException {
+        String requestId = UUID.randomUUID().toString();
+        MDC.put(MDC_KEY, requestId);
+        response.setHeader(REQUEST_ID_HEADER, requestId);
+        try {
+            filterChain.doFilter(request, response);
+        } finally {
+            MDC.remove(MDC_KEY);
+        }
+    }
+}

src/main/java/com/assu/server/global/util/PresenceTracker.java

@@ -1,5 +1,7 @@
 package com.assu.server.global.util;
 
+import io.micrometer.core.instrument.Gauge;
+import io.micrometer.core.instrument.MeterRegistry;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.context.event.EventListener;
 import org.springframework.messaging.simp.stomp.StompHeaderAccessor;
@@ -22,6 +24,11 @@ public class PresenceTracker {
     // "sessionId:subscriptionId" -> roomId: 특정 구독 해제 시 어느 방인지 추적
     private final Map<String, Long> subToRoom = new ConcurrentHashMap<>();
 
+    public PresenceTracker(MeterRegistry meterRegistry) {
+        Gauge.builder("chat.active.sessions", sessionToMember, Map::size)
+                .register(meterRegistry);
+    }
+
     private Long parseRoomId(String dest) { // "/sub/chat/26" -> 26
         if (dest == null) return null;
         String[] p = dest.split("/");

src/main/resources/application.yml

@@ -47,6 +47,10 @@ spring:
 server:
   shutdown: graceful
 
+logging:
+  pattern:
+    console: "%clr(%d{yyyy-MM-dd'T'HH:mm:ss.SSSXXX}){faint} %clr(${LOG_LEVEL_PATTERN:-%5p}) %clr(${PID:- }){magenta} %clr(---){faint} %clr([%15.15t]){faint} %clr(%-40.40logger{39}){cyan} %clr(:){faint} [reqId=%X{requestId}] %m%n${LOG_EXCEPTION_CONVERSION_WORD:-%wEx}"
+
 management:
   endpoints:
     web:
@@ -56,3 +60,9 @@ management:
     health:
       probes:
         enabled: true
+  metrics:
+    tags:
+      application: ${spring.application.name}
+    distribution:
+      percentiles-histogram:
+        http.server.requests: true