chat

src/main/java/com/sxtvs/open/api/review/controller/SseController.java

@@ -36,9 +36,7 @@ public class SseController {
     public SseEmitter handleSse(@RequestParam("token") String token) throws IOException {
         SseEmitter sseEmitter = new SseEmitter(300 * 1000L); // 设置超时时间
         sseService.monitor(token, sseEmitter);
-        for (int i = 0; i < 100; i++) {
-            sseEmitter.send("data");
-        }
+        sseEmitter.send(SseEmitter.event().name("hello").data("hello"));
         return sseEmitter;
     }
 
@@ -51,7 +49,7 @@ public class SseController {
         SseEmitter sseEmitter = new SseEmitter(0L); // 设置超时时间
         sseService.monitor(kimiChat.getGroupId(), sseEmitter);
         kimiChatService.create(kimiChat);
-        sseEmitter.send("data");
+        sseEmitter.send(SseEmitter.event().name("hello").data("你好"));
         return sseEmitter;
     }