chat

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

@@ -41,7 +41,7 @@ public class SseController {
         SseEmitter sseEmitter = new SseEmitter(0L); // 设置超时时间
         sseService.monitor(kimiChat.getGroupId(), sseEmitter);
         kimiChatService.create(kimiChat);
-        sseEmitter.send(SseEmitter.event().name("data").data("hello"));
+        sseEmitter.send(SseEmitter.event().name("hello").data("hello"));
 
         return sseEmitter;
     }
@@ -52,11 +52,11 @@ public class SseController {
         SseEmitter sseEmitter = new SseEmitter(0L); // 设置超时时间
         sseService.monitor(kimiChat.getGroupId(), sseEmitter);
 
-        sseEmitter.send(SseEmitter.event().name("data").data("hello"));
+        sseEmitter.send(SseEmitter.event().name("hello").data("hello"));
         new Thread(() -> {
             try {
-                sseEmitter.send(SseEmitter.event().name("data").data("你好"));
-                sseEmitter.send(SseEmitter.event().name("message").data("你好ya"));
+                sseEmitter.send(SseEmitter.event().name("hello").data("你好"));
+                sseEmitter.send(SseEmitter.event().name("data").data("你好ya"));
             } catch (IOException e) {
                 e.printStackTrace();
             }