feat : 하트비트 로직 구현

Author: EpicFn

src/main/java/org/tuna/zoopzoop/backend/BackendApplication.java

@@ -3,9 +3,11 @@
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.data.jpa.repository.config.EnableJpaAuditing;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 @SpringBootApplication
 @EnableJpaAuditing
+@EnableScheduling
 public class BackendApplication {
     public static void main(String[] args) {
         SpringApplication.run(BackendApplication.class, args);

src/main/java/org/tuna/zoopzoop/backend/domain/SSE/service/EmitterService.java

@@ -1,5 +1,6 @@
 package org.tuna.zoopzoop.backend.domain.SSE.service;
 
+import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Service;
 import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
 
@@ -53,4 +54,22 @@ public void sendNotification(Long memberId, String eventName, Object data) {
             }
         }
     }
+
+    /**
+     * 20초마다 모든 Emitter에 하트비트 전송
+     * 클라이언트와의 연결 유지를 위해 주기적으로 빈 이벤트를 전송
+     */
+    @Scheduled(fixedRate = 20000)
+    public void sendHeartbeat() {
+        // 모든 Emitter에 하트비트 전송
+        emitters.forEach((userId, emitter) -> {
+            try {
+                // SSE 주석(comment)을 사용하여 클라이언트에서 별도 이벤트를 발생시키지 않음
+                emitter.send(SseEmitter.event().comment("keep-alive"));
+            } catch (IOException e) {
+                // 전송 실패 시, 클라이언트 연결이 끊어진 것으로 간주하고 Map에서 제거
+                emitters.remove(userId);
+            }
+        });
+    }
 }