ai流程编排流式输出报错

[coloforlia]

版本号：

3.9.0

分支：

main

问题描述：

千问模型 , 直接回复->流式输出会报错, 提示emitter已完成 2025-12-03 09:16:45.766 [OkHttp https://dashscope.aliyuncs.com/...] ERROR d.l.service.AiServiceStreamingResponseHandler:241 - While handling the following error... java.lang.IllegalStateException: ResponseBodyEmitter has already completed at org.springframework.util.Assert.state(Assert.java:101) at org.springframework.web.servlet.mvc.method.annotation.ResponseBodyEmitter.send(ResponseBodyEmitter.java:215) at org.springframework.web.servlet.mvc.method.annotation.SseEmitter.send(SseEmitter.java:134) at org.jeecg.modules.airag.flow.component.f.a(ReplyNode.java:171) at org.jeecg.modules.airag.flow.component.f$1.a(ReplyNode.java:110) at org.jeecg.modules.airag.flow.b.b.a(FlowMsgChannel.java:65) at org.jeecg.modules.airag.flow.component.e.a(LlmNode.java:137) at dev.langchain4j.service.AiServiceStreamingResponseHandler.onPartialResponse(AiServiceStreamingResponseHandler.java:108) at dev.langchain4j.model.chat.StreamingChatModel$1.onPartialResponse(StreamingChatModel.java:52) at dev.langchain4j.community.model.dashscope.QwenStreamingChatModel$1.onEvent(QwenStreamingChatModel.java:154) at dev.langchain4j.community.model.dashscope.QwenStreamingChatModel$1.onEvent(QwenStreamingChatModel.java:148) at com.alibaba.dashscope.aigc.generation.Generation$2.onEvent(Generation.java:166) at com.alibaba.dashscope.aigc.generation.Generation$2.onEvent(Generation.java:163) at com.alibaba.dashscope.protocol.okhttp.OkHttpHttpClient$3.onEvent(OkHttpHttpClient.java:428) at okhttp3.internal.sse.RealEventSource.onEvent(RealEventSource.kt:101) at okhttp3.internal.sse.ServerSentEventReader.completeEvent(ServerSentEventReader.kt:108) at okhttp3.internal.sse.ServerSentEventReader.processNextEvent(ServerSentEventReader.kt:52) at okhttp3.internal.sse.RealEventSource.processResponse(RealEventSource.kt:75) at okhttp3.internal.sse.RealEventSource.onResponse(RealEventSource.kt:46) at okhttp3.internal.connection.RealCall$AsyncCall.run(RealCall.kt:504) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at java.base/java.lang.Thread.run(Thread.java:840)

错误截图：

友情提示：

• 未按格式要求发帖、描述过于简单的，会被直接删掉;
• 描述问题请图文并茂，方便我们理解并快速定位问题;
• 如果使用的不是master，请说明你使用的分支;