Merge branch 'develop'

# Conflicts:
#	backend/src/test/java/com/WEB4_5_GPT_BE/unihub/domain/enrollment/controller/EnrollmentControllerTest.java
#	backend/src/test/java/com/WEB4_5_GPT_BE/unihub/domain/enrollment/service/EnrollmentQueueServiceTest.java

Author: TheGreatKang

backend/src/main/java/com/WEB4_5_GPT_BE/unihub/domain/enrollment/controller/EnrollmentEventController.java

@@ -1,8 +1,12 @@
 package com.WEB4_5_GPT_BE.unihub.domain.enrollment.controller;
 
+import org.springframework.security.core.annotation.AuthenticationPrincipal;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
 import com.WEB4_5_GPT_BE.unihub.domain.enrollment.dto.QueueStatusDto;
 import com.WEB4_5_GPT_BE.unihub.domain.enrollment.service.EnrollmentQueueService;
-import com.WEB4_5_GPT_BE.unihub.domain.enrollment.service.SseEmitterService;
 import com.WEB4_5_GPT_BE.unihub.global.exception.UnihubException;
 import com.WEB4_5_GPT_BE.unihub.global.response.Empty;
 import com.WEB4_5_GPT_BE.unihub.global.response.RsData;
@@ -13,13 +17,6 @@
 import io.swagger.v3.oas.annotations.tags.Tag;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
-import org.springframework.http.MediaType;
-import org.springframework.security.core.annotation.AuthenticationPrincipal;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
 
 @Tag(name = "Enrollment", description = "수강신청 관련 API (대기열 관리, 이벤트 스트림 등)")
 @Slf4j
@@ -28,31 +25,9 @@
 @RequiredArgsConstructor
 public class EnrollmentEventController {
 
-    private final SseEmitterService sseEmitterService;
     private final EnrollmentQueueService enrollmentQueueService;
 
-    @Operation(summary = "SSE 연결", description = "수강신청 과정에서 실시간 이벤트를 받기 위한 SSE 연결을 설정합니다.")
-    @ApiResponses(value = {
-            @ApiResponse(responseCode = "200", description = "SSE 연결 성공"),
-            @ApiResponse(responseCode = "401", description = "인증되지 않은 사용자")
-    })
-    @GetMapping(value = "/events", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
-    public SseEmitter subscribeToEvents(@AuthenticationPrincipal SecurityUser securityUser) {
-        // 인증된 사용자 정보가 없는 경우 예외 처리
-        if (securityUser == null) {
-            log.warn("인증되지 않은 SSE 연결 시도");
-            throw new UnihubException("401", "인증되지 않은 요청입니다.");
-        }
-
-        String memberId = String.valueOf(securityUser.getId());
-        log.info("SSE 연결 요청: {}", memberId);
-
-        // 초기 상태 가져오기
-        QueueStatusDto initialStatus = enrollmentQueueService.getQueueStatus(memberId);
-
-        // 초기 상태와 함께 SSE 이미터 생성
-        return sseEmitterService.createEmitterWithInitialStatus(memberId, initialStatus);
-    }
+    // SSE 관련 코드 제거
 
     @Operation(summary = "대기열 참여", description = "수강신청 대기열에 사용자를 추가합니다.")
     @ApiResponses(value = {

backend/src/main/java/com/WEB4_5_GPT_BE/unihub/domain/enrollment/scheduler/SseHeartbeatScheduler.java

@@ -21,15 +21,8 @@ public class EnrollmentQueueService {
     private static final int MAX_CONCURRENT_USERS = 3;
     private static final Duration SESSION_TIMEOUT = Duration.ofMinutes(10);
     private final StringRedisTemplate redisTemplate;
-    private final SseEmitterService sseEmitterService;
-    // 대기열 상태 메시지 전송 주기 (5초)
-    private static final long QUEUE_MESSAGE_INTERVAL = 5000;
-    // 업데이트 오프셋 (일정 수 이상 변경이 있을 때 업데이트)
-    private static final int QUEUE_MESSAGE_BATCH_SIZE = 5;
-    // 마지막으로 대기열 상태 메시지를 전송한 시간
-    private long lastQueueMessageTime = 0;
-    // 최근 처리된 사용자 수 (배치 처리용)
-    private int processedUserCount = 0;
+
+    // 구현 제거: SSE 관련 필드 및 메시지 배치 전송 코드 제거
 
     /**
      * 대기열에 사용자 추가
@@ -38,18 +31,14 @@ public QueueStatusDto addToQueue(String memberId) {
         // 이미 활성 세션이 있는지 확인
         Boolean hasSession = redisTemplate.hasKey(SESSION_PREFIX + memberId);
         if (Boolean.TRUE.equals(hasSession)) {
-            QueueStatusDto status = new QueueStatusDto(true, 0, 0);
-            sseEmitterService.sendQueueStatus(memberId, status);
-            return status;
+            return new QueueStatusDto(true, 0, 0);
         }
 
         // 이미 대기열에 있는지 확인
         if (isUserInQueue(memberId)) {
             int position = getPositionInQueue(memberId);
             int waitTime = position * 60 * 5; // 사용자당 5분 소요 가정
-            QueueStatusDto status = new QueueStatusDto(false, position, waitTime);
-            sseEmitterService.sendQueueStatus(memberId, status);
-            return status;
+            return new QueueStatusDto(false, position, waitTime);
         }
 
         // 현재 활성 사용자 수 확인
@@ -59,10 +48,7 @@ public QueueStatusDto addToQueue(String memberId) {
         if (activeUsers < MAX_CONCURRENT_USERS) {
             redisTemplate.opsForValue().set(SESSION_PREFIX + memberId, "active", SESSION_TIMEOUT);
             log.info("사용자 {} 즉시 접속 허용", memberId);
-
-            QueueStatusDto status = new QueueStatusDto(true, 0, 0);
-            sseEmitterService.sendQueueStatus(memberId, status);
-            return status;
+            return new QueueStatusDto(true, 0, 0);
         }
 
         // 대기열에 추가
@@ -71,9 +57,7 @@ public QueueStatusDto addToQueue(String memberId) {
         int waitTime = position * 60 * 5; // 사용자당 5분 소요 가정
 
         log.info("사용자 {} 대기열 추가, 위치: {}, 예상 대기시간: {}초", memberId, position, waitTime);
-        QueueStatusDto status = new QueueStatusDto(false, position, waitTime);
-        sseEmitterService.sendQueueStatus(memberId, status);
-        return status;
+        return new QueueStatusDto(false, position, waitTime);
     }
 
     /**
@@ -124,49 +108,19 @@ public void processNextInQueue() {
             // 대기열에서 다음 사용자 가져오기 (leftPop 사용) - Redis 대기열 실시간 업데이트
             String nextMemberId = redisTemplate.opsForList().leftPop(WAITING_QUEUE_KEY);
 
+            // 대기열이 비어있는 경우 처리
+            if (nextMemberId == null) {
+                log.info("대기열에 사용자가 없습니다.");
+                return;
+            }
+
             // 세션 활성화
             redisTemplate.opsForValue().set(SESSION_PREFIX + nextMemberId, "active", SESSION_TIMEOUT);
-
-            // 사용자에게 접속 허용 알림 (SSE 이벤트 전송)
-            QueueStatusDto status = new QueueStatusDto(true, 0, 0);
-            sseEmitterService.sendQueueStatus(nextMemberId, status);
             log.info("사용자 {} 대기열에서 접속 허용", nextMemberId);
-
-            // 처리된 사용자 카운트 증가
-            processedUserCount++;
-
-            // 대기열 상태 메시지 배치 전송 조건 확인
-            long currentTime = System.currentTimeMillis();
-            boolean timeBasedUpdate = (currentTime - lastQueueMessageTime) > QUEUE_MESSAGE_INTERVAL;
-            boolean countBasedUpdate = processedUserCount >= QUEUE_MESSAGE_BATCH_SIZE;
-
-            if (timeBasedUpdate || countBasedUpdate) {
-                // 대기열 상태 메시지만 배치로 전송 (Redis 대기열 업데이트는 이미 위에서 실시간으로 이루어짐)
-                sendQueueStatusMessages();
-                lastQueueMessageTime = currentTime;
-                processedUserCount = 0;
-                log.info("대기열 사용자에게 상태 메시지 전송 - {} 기준", timeBasedUpdate ? "시간" : "처리량");
-            }
         }
     }
 
-    /**
-     * 대기열에 있는 모든 사용자에게 상태 메시지만 전송 (Redis 데이터 업데이트 없이 메시지만 전송)
-     */
-    private void sendQueueStatusMessages() {
-        // 현재 대기열 상태 조회 (Redis 대기열은 변경하지 않고 읽기만 함)
-        List<String> queueMembers = redisTemplate.opsForList().range(WAITING_QUEUE_KEY, 0, -1);
 
-        // 대기열에 있는 모든 사용자에게 상태 메시지 전송
-        for (int i = 0; i < queueMembers.size(); i++) {
-            String memberId = queueMembers.get(i);
-            int position = i + 1; // 1부터 시작하는 위치
-            int waitTime = position * 30; // 사용자당 30초 소요 가정
-
-            QueueStatusDto status = new QueueStatusDto(false, position, waitTime);
-            sseEmitterService.sendQueueStatus(memberId, status);
-        }
-    }
 
     /**
      * 대기열에 사용자가 있는지 확인