[feat/#279] 로깅 인프라 구축 - Logback MDC 설정 및 파일 롤링 정책 적용

.gitignore

@@ -52,6 +52,9 @@ stop-dev-tunnel.sh
 /CLAUDE.md
 /.claude
 
+### logs ###
+logs/
+
 ### env ###
 .env
 

src/main/java/com/techfork/domain/recommendation/config/RecommendationConfig.java

@@ -0,0 +1,30 @@
+package com.techfork.domain.recommendation.config;
+
+import com.techfork.global.filter.MdcTaskDecorator;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
+
+import java.util.concurrent.Executor;
+
+@Configuration
+public class RecommendationConfig {
+
+    /**
+     * 추천 생성 전용 executor.
+     * 검색(SearchConfig)과 스레드풀을 분리하여 추천 배치 작업이 실시간 검색에 영향을 주지 않도록 한다.
+     */
+    @Bean(name = "recommendationAsyncExecutor")
+    public Executor recommendationAsyncExecutor() {
+        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+        executor.setCorePoolSize(4);
+        executor.setMaxPoolSize(8);
+        executor.setQueueCapacity(20);
+        executor.setThreadNamePrefix("recommendation-");
+        executor.setTaskDecorator(new MdcTaskDecorator());
+        executor.setWaitForTasksToCompleteOnShutdown(true);
+        executor.setAwaitTerminationSeconds(30);
+        executor.initialize();
+        return executor;
+    }
+}

src/main/java/com/techfork/domain/recommendation/service/LlmRecommendationService.java

@@ -25,6 +25,7 @@
 import com.techfork.global.util.VectorUtil;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.context.annotation.Primary;
 import org.springframework.data.domain.PageRequest;
 import org.springframework.stereotype.Service;
@@ -33,6 +34,7 @@
 import java.io.IOException;
 import java.util.*;
 import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.Executor;
 import java.util.stream.Collectors;
 
 /**
@@ -55,6 +57,8 @@ public class LlmRecommendationService implements RecommendationService {
     private final TimeDecayStrategy timeDecayStrategy;
     private final RecommendationProperties properties;
     private final VectorQueryBuilder vectorQueryBuilder;
+    @Qualifier("recommendationAsyncExecutor")
+    private final Executor recommendationAsyncExecutor;
 
     private static final String POSTS_INDEX = "posts";
     private static final String TITLE_EMBEDDING_FIELD = "titleEmbedding";
@@ -154,7 +158,7 @@ private List<MmrCandidate> searchCandidates(float[] userProfileVector, User user
                 log.error("kNN 검색 실패", e);
                 return Collections.emptyList();
             }
-        });
+        }, recommendationAsyncExecutor);
 
         CompletableFuture<List<Hit<PostDocument>>> keywordSearchFuture = CompletableFuture.supplyAsync(() -> {
             // 키워드가 없으면 BM25 검색 생략
@@ -178,7 +182,7 @@ private List<MmrCandidate> searchCandidates(float[] userProfileVector, User user
                 log.error("BM25 검색 실패", e);
                 return Collections.emptyList();
             }
-        });
+        }, recommendationAsyncExecutor);
 
         // 4. 두 검색 완료 대기
         CompletableFuture<Void> allSearches = CompletableFuture.allOf(vectorSearchFuture, keywordSearchFuture);

src/main/java/com/techfork/global/config/SearchConfig.java → src/main/java/com/techfork/domain/search/config/SearchConfig.java

@@ -1,24 +1,25 @@
-package com.techfork.global.config;
+package com.techfork.domain.search.config;
 
-import java.util.concurrent.Executor;
-import java.util.concurrent.ThreadPoolExecutor;
+import com.techfork.global.filter.MdcTaskDecorator;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 
+import java.util.concurrent.Executor;
+import java.util.concurrent.ThreadPoolExecutor;
+
 @Configuration
 public class SearchConfig {
 
     @Bean(name = "searchAsyncExecutor")
     public Executor searchAsyncExecutor() {
         ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
-
         executor.setCorePoolSize(20);
         executor.setMaxPoolSize(50);
         executor.setQueueCapacity(100);
+        executor.setTaskDecorator(new MdcTaskDecorator());
         executor.setThreadNamePrefix("SearchExec-");
         executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
-
         return executor;
     }
-}
+}

src/main/java/com/techfork/domain/source/config/RssCrawlingJobConfig.java

@@ -8,6 +8,7 @@
 import com.techfork.domain.source.batch.RssToPostProcessor;
 import com.techfork.domain.source.dto.RssFeedItem;
 import com.techfork.domain.source.listener.RssCrawlingJobListener;
+import com.techfork.global.filter.MdcTaskDecorator;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.batch.core.Job;
@@ -168,6 +169,7 @@ public TaskExecutor summaryTaskExecutor() {
         executor.setMaxPoolSize(2);
         executor.setQueueCapacity(10);
         executor.setThreadNamePrefix("summary-");
+        executor.setTaskDecorator(new MdcTaskDecorator());
         executor.setWaitForTasksToCompleteOnShutdown(true);
         executor.setAwaitTerminationSeconds(60);
         executor.initialize();
@@ -181,6 +183,7 @@ public TaskExecutor embeddingTaskExecutor() {
         executor.setMaxPoolSize(20);
         executor.setQueueCapacity(50);
         executor.setThreadNamePrefix("embedding-");
+        executor.setTaskDecorator(new MdcTaskDecorator());
         executor.setWaitForTasksToCompleteOnShutdown(true);
         executor.setAwaitTerminationSeconds(60);
         executor.initialize();

src/main/java/com/techfork/domain/source/listener/RssCrawlingJobListener.java

@@ -1,8 +1,10 @@
 package com.techfork.domain.source.listener;
 
 import com.techfork.domain.source.service.WebhookNotificationService;
+import com.techfork.global.constant.MdcKey;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.slf4j.MDC;
 import org.springframework.batch.core.BatchStatus;
 import org.springframework.batch.core.JobExecution;
 import org.springframework.batch.core.JobExecutionListener;
@@ -30,9 +32,10 @@ public class RssCrawlingJobListener implements JobExecutionListener {
 
     @Override
     public void beforeJob(JobExecution jobExecution) {
-        Long jobExecutionId = jobExecution.getId();
+        MDC.put(MdcKey.REQUEST_ID, "batch-" + jobExecution.getId());
+        MDC.put(MdcKey.USER_ID, "system");
         log.info("RSS crawling job started: jobExecutionId={}, startTime={}",
-                jobExecutionId, jobExecution.getStartTime());
+                jobExecution.getId(), jobExecution.getStartTime());
     }
 
     @Override
@@ -44,6 +47,7 @@ public void afterJob(JobExecution jobExecution) {
         } else {
             handleJobFailure(jobExecution, "Job failed with status: " + batchStatus);
         }
+        MDC.clear();
     }
 
     /**

src/main/java/com/techfork/global/config/AsyncConfig.java

@@ -0,0 +1,32 @@
+package com.techfork.global.config;
+
+import com.techfork.global.filter.MdcTaskDecorator;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.EnableAsync;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
+
+import java.util.concurrent.Executor;
+
+@Configuration
+@EnableAsync
+public class AsyncConfig {
+
+    /**
+     * @Async 기본 executor.
+     * MdcTaskDecorator로 부모 스레드의 MDC 컨텍스트를 자식 스레드에 복사한다.
+     */
+    @Bean(name = "taskExecutor")
+    public Executor taskExecutor() {
+        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+        executor.setCorePoolSize(4);
+        executor.setMaxPoolSize(8);
+        executor.setQueueCapacity(50);
+        executor.setThreadNamePrefix("async-");
+        executor.setTaskDecorator(new MdcTaskDecorator());
+        executor.setWaitForTasksToCompleteOnShutdown(true);
+        executor.setAwaitTerminationSeconds(30);
+        executor.initialize();
+        return executor;
+    }
+}

src/main/java/com/techfork/global/constant/MdcKey.java

@@ -0,0 +1,11 @@
+package com.techfork.global.constant;
+
+public final class MdcKey {
+    private MdcKey() {}
+
+    public static final String REQUEST_ID = "requestId";
+    public static final String USER_ID = "userId";
+    public static final String METHOD = "method";
+    public static final String URI = "uri";
+    public static final String CLIENT_IP = "clientIp";
+}

src/main/java/com/techfork/global/filter/MdcLoggingFilter.java

@@ -0,0 +1,72 @@
+package com.techfork.global.filter;
+
+import com.techfork.global.constant.MdcKey;
+import jakarta.servlet.FilterChain;
+import lombok.extern.slf4j.Slf4j;
+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;
+
+/**
+ * HTTP 요청마다 MDC에 트레이싱 컨텍스트를 설정하는 필터.
+ * 요청 종료 시 MDC를 정리하여 스레드 풀 재사용 시 누수를 방지한다.
+ * <p>
+ * MDC 필드:
+ * - requestId: 요청 단위 고유 ID (UUID)
+ * - userId: 인증된 사용자 ID (비인증 요청은 "anonymous")
+ * - method: HTTP 메서드
+ * - uri: 요청 URI
+ * - clientIp: 클라이언트 IP (X-Forwarded-For 우선)
+ */
+@Slf4j
+@Component
+@Order(Ordered.HIGHEST_PRECEDENCE)
+public class MdcLoggingFilter extends OncePerRequestFilter {
+
+    @Override
+    protected void doFilterInternal(HttpServletRequest request, HttpServletResponse response, FilterChain filterChain)
+            throws ServletException, IOException {
+        long startTime = System.currentTimeMillis();
+        try {
+            MDC.put(MdcKey.REQUEST_ID, UUID.randomUUID().toString().replace("-", "").substring(0, 12));
+            MDC.put(MdcKey.METHOD, request.getMethod());
+            MDC.put(MdcKey.URI, request.getRequestURI());
+            MDC.put(MdcKey.CLIENT_IP, resolveClientIp(request));
+            MDC.put(MdcKey.USER_ID, "anonymous");
+
+            filterChain.doFilter(request, response);
+
+            log.info("{} {} {} {}ms",
+                    request.getMethod(),
+                    request.getRequestURI(),
+                    response.getStatus(),
+                    System.currentTimeMillis() - startTime);
+        } finally {
+            MDC.clear();
+        }
+    }
+
+    private String resolveClientIp(HttpServletRequest request) {
+        String ip = request.getHeader("X-Forwarded-For");
+        if (isValid(ip)) {
+            return ip.split(",")[0].trim();
+        }
+        ip = request.getHeader("X-Real-IP");
+        if (isValid(ip)) {
+            return ip;
+        }
+        return request.getRemoteAddr();
+    }
+
+    private boolean isValid(String ip) {
+        return ip != null && !ip.isBlank() && !"unknown".equalsIgnoreCase(ip);
+    }
+}

src/main/java/com/techfork/global/filter/MdcTaskDecorator.java

@@ -0,0 +1,28 @@
+package com.techfork.global.filter;
+
+import org.slf4j.MDC;
+import org.springframework.core.task.TaskDecorator;
+
+import java.util.Map;
+
+/**
+ * 부모 스레드의 MDC 컨텍스트를 자식 스레드로 복사하는 TaskDecorator.
+ * ThreadPoolTaskExecutor에 등록하여 @Async, AsyncItemProcessor 등에서 MDC가 전파되도록 한다.
+ */
+public class MdcTaskDecorator implements TaskDecorator {
+
+    @Override
+    public Runnable decorate(Runnable runnable) {
+        Map<String, String> mdcContext = MDC.getCopyOfContextMap();
+        return () -> {
+            try {
+                if (mdcContext != null) {
+                    MDC.setContextMap(mdcContext);
+                }
+                runnable.run();
+            } finally {
+                MDC.clear();
+            }
+        };
+    }
+}

src/main/java/com/techfork/global/security/filter/JwtAuthenticationFilter.java

@@ -4,6 +4,7 @@
 import com.techfork.domain.user.entity.User;
 import com.techfork.domain.user.repository.UserRepository;
 import com.techfork.global.constant.Constants;
+import com.techfork.global.constant.MdcKey;
 import com.techfork.global.exception.GeneralException;
 import com.techfork.global.security.jwt.JwtUtil;
 import com.techfork.global.security.oauth.UserPrincipal;
@@ -14,6 +15,7 @@
 import jakarta.servlet.http.HttpServletResponse;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.slf4j.MDC;
 import org.springframework.security.authentication.UsernamePasswordAuthenticationToken;
 import org.springframework.security.core.context.SecurityContext;
 import org.springframework.security.core.context.SecurityContextHolder;
@@ -66,6 +68,7 @@ protected void doFilterInternal(HttpServletRequest request, HttpServletResponse
                 securityContext.setAuthentication(authentication);
                 SecurityContextHolder.setContext(securityContext);
 
+                MDC.put(MdcKey.USER_ID, String.valueOf(userId));
                 log.debug("Set authentication for user: {}", userId);
             }
         } catch (Exception e) {

src/main/resources/application-dev.yml

@@ -38,11 +38,8 @@ spring:
     uris: http://elasticsearch:9200
 
 logging:
-  level:
-    com.techfork: INFO
-    org.springframework.batch: INFO
-    org.hibernate.SQL: INFO
-    org.hibernate.type.descriptor.sql.BasicBinder: WARN
+  file:
+    path: /app/logs
 
 apple:
   private-key-path: /app/keys/AuthKey_${APPLE_KEY_ID}.p8

src/main/resources/application-local.yml

@@ -37,13 +37,6 @@ spring:
   elasticsearch:
     uris: http://elasticsearch:9200
 
-logging:
-  level:
-    com.techfork: DEBUG
-    org.springframework.batch: INFO
-    org.hibernate.SQL: DEBUG
-    org.hibernate.type.descriptor.sql.BasicBinder: TRACE
-
 # Actuator 설정 - Resilience4j 모니터링
 management:
   endpoints: