chat

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

@@ -34,7 +34,7 @@ public class SseController {
     @GetMapping(path = "/sse", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
     @NoAPIResponse
     public SseEmitter handleSse(@RequestParam("token") String token) throws IOException {
-        SseEmitter sseEmitter = new SseEmitter(300 * 1000L); // 设置超时时间
+        SseEmitter sseEmitter = new SseEmitter(0L); // 设置超时时间
         sseService.monitor(token, sseEmitter);
         sseEmitter.send(SseEmitter.event().name("hello").data("hello"));
         return sseEmitter;
@@ -52,6 +52,7 @@ public class SseController {
             kimiChatService.create(kimiChat);
         });
         sseEmitter.send(SseEmitter.event().name("hello").data("你好"));
+        seEmitter.send(SseEmitter.event().name("hello").data("hello"));
         return sseEmitter;
     }