opt

src/main/java/com/knowledge/base/infrastructure/south/llm/AnythingLLMServiceImpl.java

@@ -64,7 +64,10 @@ public class AnythingLLMServiceImpl implements LLMService {
 
             String line;
             while ((line = reader.readLine()) != null) {
-                writer.writeLine(line); // 已是 SSE 格式
+                if (line.startsWith("data:")) {
+                    line = line.substring(5).trim();
+                }
+                writer.writeJsonLine(line);
             }
         }
     }

src/main/java/com/knowledge/base/infrastructure/util/http/SseOutputAdapter.java

@@ -19,4 +19,9 @@ public class SseOutputAdapter implements WriterAdapter {
             emitter.send(SseEmitter.event().data(line));
         }
     }
+
+    @Override
+    public void writeJsonLine(String json) throws IOException {
+        emitter.send(SseEmitter.event().data(json));
+    }
 }

src/main/java/com/knowledge/base/infrastructure/util/http/WriterAdapter.java

@@ -4,5 +4,7 @@ import java.io.IOException;
 
 public interface WriterAdapter {
     void writeLine(String line) throws IOException;
+
+    void writeJsonLine(String line)  throws IOException ;
 }