|
|
@@ -48,7 +48,9 @@ public class SseController {
|
|
|
public SseEmitter handleSsePost(@RequestBody KimiChat kimiChat) throws IOException {
|
|
|
SseEmitter sseEmitter = new SseEmitter(0L); // 设置超时时间
|
|
|
sseService.monitor(kimiChat.getGroupId(), sseEmitter);
|
|
|
- kimiChatService.create(kimiChat);
|
|
|
+ poolExecutor.execute(() -> {
|
|
|
+ kimiChatService.create(kimiChat);
|
|
|
+ });
|
|
|
sseEmitter.send(SseEmitter.event().name("hello").data("你好"));
|
|
|
return sseEmitter;
|
|
|
}
|
