fix: 핀으로 등록한 과목의 여석 정보가 SSE로 전달되는 속도가 일정은 문제 해결

src/main/java/kr/allcll/seatfinder/seat/SeatService.java

@@ -24,9 +24,9 @@
 public class SeatService {
 
     private static final String NON_MAJOR_SEATS_EVENT_NAME = "nonMajorSeats";
-    private static final int NON_MAJOR_SUBJECT_QUERY_LIMIT = 20;
     private static final String PIN_EVENT_NAME = "pinSeats";
-    private static final int TASK_DURATION = 2000;
+    private static final int NON_MAJOR_SUBJECT_QUERY_LIMIT = 20;
+    private static final int TASK_DURATION = 1000;
     private static final int TASK_PERIOD = 60000;
 
     private final SseService sseService;
@@ -48,20 +48,12 @@ public void sendPinSeatsInformation(String token) {
         }
 
         Runnable task = () -> {
-            long start = System.currentTimeMillis();
             List<Pin> pins = pinRepository.findAllByToken(token);
-            log.info("token: {}ms - {}: 핀 조회 결과 {}개 조회", System.currentTimeMillis() - start, token, pins.size());
-            start = System.currentTimeMillis();
             List<Subject> subjects = pins.stream()
                 .map(Pin::getSubject)
                 .toList();
-            log.info("token: {}ms - {}: 과목 조회 결과 {}개 조회", System.currentTimeMillis() - start, token, subjects.size());
-            start = System.currentTimeMillis();
             List<Seat> pinSeats = seatStorage.getSeats(subjects);
-            log.info("token: {}ms - {}: 좌석 조회 결과 {}개 조회", System.currentTimeMillis() - start, token, pinSeats.size());
-            start = System.currentTimeMillis();
-            sseService.propagate(PIN_EVENT_NAME, PinSeatsResponse.from(pinSeats));
-            log.info("token: {}ms - {}: SSE 전송 완료", System.currentTimeMillis() - start, token);
+            sseService.propagate(token, PIN_EVENT_NAME, PinSeatsResponse.from(pinSeats));
         };
 
         ScheduledFuture<?> scheduledFuture = scheduler.scheduleAtFixedRate(task, Duration.ofMillis(TASK_DURATION));

src/main/java/kr/allcll/seatfinder/sse/SseApi.java

@@ -19,8 +19,8 @@ public class SseApi {
     @GetMapping(value = "/api/connect", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
     public ResponseEntity<SseEmitter> getServerSentEventConnection() {
         String token = ThreadLocalHolder.SHARED_TOKEN.get();
-        seatService.sendPinSeatsInformation(token);
         SseEmitter emitter = sseService.connect(token);
+        seatService.sendPinSeatsInformation(token);
         return ResponseEntity.ok()
             .header("X-Accel-Buffering", "no")
             .body(emitter);

src/main/java/kr/allcll/seatfinder/sse/SseEmitterStorage.java

@@ -2,6 +2,7 @@
 
 import java.util.List;
 import java.util.Map;
+import java.util.Optional;
 import java.util.concurrent.ConcurrentHashMap;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
@@ -43,6 +44,11 @@ public List<SseEmitter> getEmitters() {
         return emitters.values().stream().toList();
     }
 
+    public Optional<SseEmitter> getEmitter(String token) {
+        SseEmitter emitter = emitters.get(token);
+        return Optional.ofNullable(emitter);
+    }
+
     public List<String> getUserTokens() {
         return emitters.keySet().stream().toList();
     }

src/main/java/kr/allcll/seatfinder/sse/SseService.java

@@ -33,6 +33,13 @@ public void propagate(String eventName, Object data) {
         });
     }
 
+    public void propagate(String token, String eventName, Object data) {
+        sseEmitterStorage.getEmitter(token).ifPresent(emitter -> {
+            SseEventBuilder eventBuilder = SseEventBuilderFactory.create(eventName, data);
+            sendEvent(emitter, eventBuilder);
+        });
+    }
+
     private void sendEvent(SseEmitter sseEmitter, SseEventBuilder eventBuilder) {
         try {
             sseEmitter.send(eventBuilder);