3 Commits

Author SHA1 Message Date
ageerle
afa3c78180 Merge pull request #254 from StevenJack666/v3.0.0
修复异常场景,请求链接无法关闭问题
2026-02-11 17:03:44 +08:00
zhang
91a44e1ba8 非推理模式下,大模型调用失败。连接未关闭,且没有返回错误信息 2026-02-09 15:33:11 +08:00
zhang
4a36aaa780 修复异常场景,请求链接无法关闭问题 2026-02-09 14:58:46 +08:00

View File

@@ -98,6 +98,8 @@ public abstract class AbstractStreamingChatService implements IChatService {
}
} catch (Exception e) {
SseMessageUtils.sendMessage(userId, "对话出错:" + e.getMessage());
SseMessageUtils.completeConnection(userId, tokenValue);
log.error("{}请求失败:{}", getProviderName(), e.getMessage(), e);
}
return emitter;
@@ -223,6 +225,21 @@ public abstract class AbstractStreamingChatService implements IChatService {
@Override
public void onError(Throwable error) {
log.error("{}流式响应错误: {}", getProviderName(), error.getMessage(), error);
// 发送错误消息到前端
try {
String errorMessage = String.format("模型调用失败: %s", error.getMessage());
SseMessageUtils.sendMessage(userId, errorMessage);
} catch (Exception e) {
log.error("发送错误消息失败: {}", e.getMessage(), e);
}
// 关闭SSE连接避免前端一直等待
try {
SseMessageUtils.completeConnection(userId, tokenValue);
} catch (Exception e) {
log.error("关闭SSE连接失败: {}", e.getMessage(), e);
}
}
};
}