Solon AI MCP 服务端心跳机制优化与异常处理

【免费下载链接】solon-ai Java AI & MCP 应用开发框架（LLM，Function Call，RAG，Embedding，Reranking，Flow，MCP Server，Mcp Client，Mcp Proxy）。同时兼容 java8 ~ java24。也可嵌入到 SpringBoot2、jFinal、Vert.x 等框架中使用。 项目地址: https://gitcode.com/opensolon/solon-ai

问题背景

在使用 Solon AI MCP 服务端时，开发人员可能会遇到一个持续性的错误日志："java.io.IOException: writeBuffer has closed"。这个错误通常发生在服务端尝试向已关闭的客户端连接发送心跳消息时。

错误分析

该错误的完整堆栈显示，问题源于服务端在客户端连接已关闭的情况下仍然尝试通过该连接发送心跳消息。具体表现为：

1. 服务端维护的 MCP 会话未能及时检测到客户端连接已断开
2. 心跳线程继续向已关闭的连接发送数据
3. 底层网络框架 SmartHttp 检测到写入缓冲区已关闭，抛出 IOException

解决方案

Solon 团队针对此问题提出了以下改进措施：

1. 会话状态检测优化

在心跳处理逻辑中增加了连接可写性检查，当发现通道不可写时，会自动取消对应的 MCP 会话，避免持续尝试向无效连接发送数据。

2. 版本升级建议

建议升级到 3.2.1-SNAPSHOT 或更高版本，该版本包含了针对此问题的修复。开发阶段可以使用快照版本进行测试，正式发布后再切换至稳定版。

3. 架构选择建议

根据实际场景选择合适的部署模式：

• 独立端口模式：适合需要单独监听端口的场景
• 嵌入式模式：适合与其他服务共享端口的场景，可以减少端口占用

最佳实践

1. 依赖管理：确保项目中包含必要的 Reactor 依赖，这是 SSE(Server-Sent Events)功能正常运行的基础。

2. 异常处理：在客户端断开连接时，服务端应能正确识别并清理相关资源，避免内存泄漏。

3. 心跳机制：合理配置心跳间隔，平衡实时性和系统负载。

技术实现细节

Solon AI MCP 服务端的心跳机制基于以下组件协同工作：

1. WebRxSseServerTransportProvider：负责 SSE 传输层的实现
2. McpServerEndpointProvider：管理服务端点和会话生命周期
3. ScheduledThreadPoolExecutor：定时触发心跳任务

当客户端异常断开时，改进后的版本能够通过以下流程正确处理：

1. 检测到写入异常
2. 标记对应会话为无效
3. 从会话池中移除无效会话
4. 释放相关资源

总结

Solon AI MCP 服务端通过优化心跳机制和会话管理，有效解决了因客户端异常断开导致的持续错误问题。开发人员应根据实际需求选择合适的部署模式，并确保使用包含修复的版本，以获得更稳定的服务体验。

【免费下载链接】solon-ai Java AI & MCP 应用开发框架（LLM，Function Call，RAG，Embedding，Reranking，Flow，MCP Server，Mcp Client，Mcp Proxy）。同时兼容 java8 ~ java24。也可嵌入到 SpringBoot2、jFinal、Vert.x 等框架中使用。 项目地址: https://gitcode.com/opensolon/solon-ai