修改配置文件

robot-trans-manager/src/main/java/com/mortals/xhx/thread/ChatMsgRspThread.java

@@ -63,7 +63,8 @@ public class ChatMsgRspThread implements Runnable {
 
 
             log.info("快速响应线程写入数据，rsp:{}", rspJson.toJSONString());
-            context.getEmitter().next("data:"+rspJson.toJSONString());
+           // context.getEmitter().next("data:"+rspJson.toJSONString());
+            context.getEmitter().next(rspJson.toJSONString());
             reCount++;
             try {
                 Thread.sleep(1000);

robot-trans-manager/src/main/java/com/mortals/xhx/webflux/factory/FlowChatSubscriber.java

@@ -63,7 +63,7 @@ public class FlowChatSubscriber implements Subscriber<String>, Disposable {
             if (ObjectUtils.isEmpty(rsp)) {
                 this.stopFlag = true;
             }
-            rsp="data:"+rsp;
+           // rsp="data:"+rsp;
             log.info(" onNext rsp:{}", rsp);
         } catch (Exception e) {
             log.error("流式问答异常:{}", e.getMessage());