refactor: 알림 처리 성능 개선 및 스레드풀 설정 정비 (#279)

* refactor: NotificationHandler 스레드풀 거부 정책 추가 및 반환 타입 명시 (#278)

* refactor: 스레드풀 공통 설정 buildExecutor 메서드로 분리 (#278)

* refactor: notificationExecutor 거부 정책 CallerRunsPolicy로 변경 및 공통 메서드에 handler 인자 추가 (#278)

* refactor: GroupMember에서 userId만 조회하도록 쿼리 최적화 (#278)

* fix: NotificationService에서 잘못된 커서 클래스명 사용 수정 (#278)

* refactor: markAsRead() 메서드에서 불필요한 조건문 제거 (#278)

Author: soonge2

src/main/java/com/moa/moa_server/config/AsyncConfig.java

@@ -1,6 +1,6 @@
 package com.moa.moa_server.config;
 
-import java.util.concurrent.Executor;
+import java.util.concurrent.RejectedExecutionHandler;
 import java.util.concurrent.ThreadPoolExecutor;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
@@ -14,7 +14,7 @@ public class AsyncConfig {
   // 기본 비동기 풀 (전제 @Async의 기본)
   // 명시적으로 기본 풀을 등록해 둠
   @Bean(name = "taskExecutor")
-  public Executor taskExecutor() {
+  public ThreadPoolTaskExecutor taskExecutor() {
     ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
     executor.setCorePoolSize(5);
     executor.setMaxPoolSize(10);
@@ -25,28 +25,31 @@ public Executor taskExecutor() {
   }
 
   // 댓글 롱폴링 전용 스레드풀
+  // - 특징: 대기 시간이 길 수 있고, 동시 요청이 많을 수 있음
+  // - 큐/풀 초과 시: 작업 거부 및 예외 발생시켜 클라이언트에게 즉시 실패 응답 → 재요청 유도
   @Bean(name = "commentPollingExecutor")
   public ThreadPoolTaskExecutor commentPollingExecutor() {
-    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
-    executor.setCorePoolSize(10); // 스레드풀 크기
-    executor.setMaxPoolSize(20); // 최대 스레드풀 크기
-    executor.setQueueCapacity(200); // 작업 대기 큐 용량 (초과 시 새로운 스레드 생성 또는 거부 정책 적용)
-    executor.setRejectedExecutionHandler(
-        new ThreadPoolExecutor.AbortPolicy() // 작업 거부 및 예외 발생 (FE에서 재요청 유도)
-        ); // 풀이 가득 찼을 때 대응
-    executor.setThreadNamePrefix("comment-polling-"); // 스레드 이름
-    executor.initialize();
-    return executor;
+    return buildExecutor("comment-polling-", 10, 20, 200, new ThreadPoolExecutor.AbortPolicy());
   }
 
-  // NotificationHandler 전용 스레드풀
+  // NotificationHandler (알림 비동기 처리) 전용 스레드풀
+  // - 특징: 빠르게 끝나는 경량 작업
+  // - 큐/풀 초과 시: 호출한 스레드에서 처리하여 알림 유실 방지
   @Bean(name = "notificationExecutor")
-  public Executor notificationExecutor() {
+  public ThreadPoolTaskExecutor notificationExecutor() {
+    return buildExecutor(
+        "notification-async-", 3, 6, 100, new ThreadPoolExecutor.CallerRunsPolicy());
+  }
+
+  // 공통 executor 생성 로직
+  private ThreadPoolTaskExecutor buildExecutor(
+      String name, int core, int max, int queue, RejectedExecutionHandler handler) {
     ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
-    executor.setCorePoolSize(3); // 자주 발생하지만 빠르게 끝나는 작업이므로 작게 시작
-    executor.setMaxPoolSize(6);
-    executor.setQueueCapacity(100); // 초당 수십 건 수준이면 충분
-    executor.setThreadNamePrefix("notification-async-");
+    executor.setCorePoolSize(core); // 스레드풀 크기
+    executor.setMaxPoolSize(max); // 최대 스레드풀 크기
+    executor.setQueueCapacity(queue); // 작업 대기 큐 용량
+    executor.setThreadNamePrefix(name); // 스레드 이름
+    executor.setRejectedExecutionHandler(handler); // 풀이 가득 찼을 때 대응
     executor.initialize();
     return executor;
   }

src/main/java/com/moa/moa_server/domain/group/repository/GroupMemberRepository.java

@@ -42,4 +42,8 @@ Optional<GroupMember> findByGroupAndUserIncludingDeleted(
 
   @Query("SELECT gm.group.id FROM GroupMember gm WHERE gm.user = :user")
   List<Long> findGroupIdsByUser(@Param("user") User user);
+
+  @Query("select gm.user.id from GroupMember gm where gm.group = :group and gm.user.id <> :ownerId")
+  List<Long> findUserIdsByGroupExcludingOwner(
+      @Param("group") Group group, @Param("ownerId") Long ownerId);
 }

src/main/java/com/moa/moa_server/domain/notification/application/producer/GroupNotificationProducerImpl.java

@@ -19,15 +19,12 @@ public class GroupNotificationProducerImpl implements NotificationProducer {
   public void notifyAllMembersGroupDeleted(Group group) {
     Long ownerId = group.getUser().getId();
 
-    List<Long> members =
-        groupMemberRepository.findAllByGroup(group).stream()
-            .map(GroupMember -> GroupMember.getUser().getId())
-            .filter(id -> !id.equals(ownerId)) // 그룹 소유자 제외
-            .toList();
+    List<Long> memberIds = groupMemberRepository.findUserIdsByGroupExcludingOwner(group, ownerId);
 
     String content = group.getName() + " 그룹이 삭제되었습니다.";
     NotificationEvent event =
-        NotificationEvent.forMultipleUsers(members, NotificationType.GROUP_DELETED, content, null);
+        NotificationEvent.forMultipleUsers(
+            memberIds, NotificationType.GROUP_DELETED, content, null);
     eventPublisher.publish(event);
   }
 }

src/main/java/com/moa/moa_server/domain/notification/application/service/NotificationService.java

@@ -1,6 +1,5 @@
 package com.moa.moa_server.domain.notification.application.service;
 
-import com.moa.moa_server.domain.global.cursor.CreatedAtCommentIdCursor;
 import com.moa.moa_server.domain.global.cursor.CreatedAtNotificationIdCursor;
 import com.moa.moa_server.domain.notification.dto.NotificationItem;
 import com.moa.moa_server.domain.notification.dto.NotificationListResponse;
@@ -52,7 +51,7 @@ public NotificationListResponse getNotifications(Long userId, String cursor, Int
 
     String nextCursor =
         hasNext
-            ? new CreatedAtCommentIdCursor(
+            ? new CreatedAtNotificationIdCursor(
                     notifications.getLast().getCreatedAt(), notifications.getLast().getId())
                 .encode()
             : null;

src/main/java/com/moa/moa_server/domain/notification/entity/Notification.java

@@ -36,8 +36,6 @@ public class Notification extends BaseTimeEntity {
   private String redirectUrl;
 
   public void markAsRead() {
-    if (!this.isRead) {
-      this.isRead = true;
-    }
+    this.isRead = true;
   }
 }