修改transport类null返回值

Author: relat-ivity

framework/fel/java/plugins/tool-mcp-server/README.md

@@ -3,10 +3,9 @@
 ## 文档概述
 
 本文档用于记录 `FitMcpStreamableServerTransportProvider` 类的设计、实现细节以及维护更新指南。该类是基于 MCP SDK 中的
-`WebMvcStreamableServerTransportProvider` 类改造而来，用于在 FIT 框架中提供 MCP（Model Context Protocol）服务端的传输层实现。
+`HttpServletStreamableServerTransportProvider` 类改造而来，用于在 FIT 框架中提供 MCP（Model Context Protocol）服务端的传输层实现。
 
-**原始参考类**: MCP SDK 中的 `WebMvcStreamableServerTransportProvider` (或
-`HttpServletStreamableServerTransportProvider`)
+**原始参考类**: MCP SDK 中的 `HttpServletStreamableServerTransportProvider`
 
 **创建时间**: 2025-11-04
 
@@ -86,7 +85,7 @@
 
 ## SDK 原始逻辑
 
-以下是从 MCP SDK 的 `WebMvcStreamableServerTransportProvider` 类保留的原始逻辑：
+以下是从 MCP SDK 的 `HttpServletStreamableServerTransportProvider` 类保留的原始逻辑：
 
 ### 1. 会话管理核心逻辑
 
@@ -181,7 +180,7 @@ public Mono<Void> closeGracefully() {
 
 ### 2. SSE 实现改造（核心改造）
 
-**原始 SDK (Spring MVC)**:
+**原始 SDK**:
 
 ```java
 SseEmitter sseEmitter = new SseEmitter();

framework/fel/java/plugins/tool-mcp-server/src/main/java/modelengine/fel/tool/mcp/server/transport/FitMcpStreamableServerTransportProvider.java

@@ -46,7 +46,8 @@
 
 /**
  * The default implementation of {@link McpStreamableServerTransportProvider}.
- * The FIT transport provider for MCP Server, according to {@code WebMvcStreamableServerTransportProvider} in MCP SDK.
+ * The FIT transport provider for MCP Server, according to {@code HttpServletStreamableServerTransportProvider} in MCP
+ * SDK.
  *
  * @author 黄可欣
  * @since 2025-09-30
@@ -143,7 +144,7 @@ public Mono<Void> notifyClients(String method, Object params) {
                 try {
                     session.sendNotification(method, params).block();
                 } catch (Exception e) {
-                    logger.error("Failed to send message to session {}: {}", session.getId(), e.getMessage());
+                    logger.error("Failed to send message to session {}: {}", session.getId(), e.getMessage(), e);
                 }
             });
         });
@@ -164,7 +165,7 @@ public Mono<Void> closeGracefully() {
                 try {
                     session.closeGracefully().block();
                 } catch (Exception e) {
-                    logger.error("Failed to close session {}: {}", session.getId(), e.getMessage());
+                    logger.error("Failed to close session {}: {}", session.getId(), e.getMessage(), e);
                 }
             });
 
@@ -219,7 +220,7 @@ public Object handleGet(HttpClassicServerRequest request, HttpClassicServerRespo
                 }
             });
         } catch (Exception e) {
-            logger.error("Failed to handle GET request for session {}: {}", sessionId, e.getMessage());
+            logger.error("Failed to handle GET request for session {}: {}", sessionId, e.getMessage(), e);
             response.statusCode(HttpResponseStatus.INTERNAL_SERVER_ERROR.statusCode());
             return null;
         }
@@ -266,9 +267,11 @@ public Object handlePost(HttpClassicServerRequest request, HttpClassicServerResp
 
             // Handle JSONRPCMessage
             if (message instanceof McpSchema.JSONRPCResponse jsonrpcResponse) {
-                return handleJsonRpcResponse(jsonrpcResponse, session, transportContext, response);
+                handleJsonRpcResponse(jsonrpcResponse, session, transportContext, response);
+                return null;
             } else if (message instanceof McpSchema.JSONRPCNotification jsonrpcNotification) {
-                return handleJsonRpcNotification(jsonrpcNotification, session, transportContext, response);
+                handleJsonRpcNotification(jsonrpcNotification, session, transportContext, response);
+                return null;
             } else if (message instanceof McpSchema.JSONRPCRequest jsonrpcRequest) {
                 return handleJsonRpcRequest(jsonrpcRequest, session, sessionId, transportContext, response);
             } else {
@@ -277,12 +280,12 @@ public Object handlePost(HttpClassicServerRequest request, HttpClassicServerResp
                         McpError.builder(McpSchema.ErrorCodes.INTERNAL_ERROR).message("Unknown message type").build());
             }
         } catch (IllegalArgumentException | IOException e) {
-            logger.error("Failed to deserialize message: {}", e.getMessage());
+            logger.error("Failed to deserialize message: {}", e.getMessage(), e);
             response.statusCode(HttpResponseStatus.BAD_REQUEST.statusCode());
             return Entity.createObject(response,
                     McpError.builder(McpSchema.ErrorCodes.PARSE_ERROR).message("Invalid message format").build());
         } catch (Exception e) {
-            logger.error("Error handling message: {}", e.getMessage());
+            logger.error("Error handling message: {}", e.getMessage(), e);
             response.statusCode(HttpResponseStatus.INTERNAL_SERVER_ERROR.statusCode());
             return Entity.createObject(response,
                     McpError.builder(McpSchema.ErrorCodes.INTERNAL_ERROR).message(e.getMessage()).build());
@@ -323,7 +326,7 @@ public Object handleDelete(HttpClassicServerRequest request, HttpClassicServerRe
             response.statusCode(HttpResponseStatus.OK.statusCode());
             return null;
         } catch (Exception e) {
-            logger.error("Failed to delete session {}: {}", sessionId, e.getMessage());
+            logger.error("Failed to delete session {}: {}", sessionId, e.getMessage(), e);
             response.statusCode(HttpResponseStatus.INTERNAL_SERVER_ERROR.statusCode());
             return Entity.createObject(response,
                     McpError.builder(McpSchema.ErrorCodes.INTERNAL_ERROR).message(e.getMessage()).build());
@@ -423,12 +426,12 @@ private void handleReplaySseRequest(HttpClassicServerRequest request, McpTranspo
                                     .contextWrite(ctx -> ctx.put(McpTransportContext.KEY, transportContext))
                                     .block();
                         } catch (Exception e) {
-                            logger.error("Failed to replay message: {}", e.getMessage());
+                            logger.error("Failed to replay message: {}", e.getMessage(), e);
                             emitter.fail(e);
                         }
                     });
         } catch (Exception e) {
-            logger.error("Failed to replay messages: {}", e.getMessage());
+            logger.error("Failed to replay messages: {}", e.getMessage(), e);
             emitter.fail(e);
         }
     }
@@ -507,7 +510,7 @@ private Object handleInitializeRequest(HttpClassicServerRequest request, HttpCla
             return Entity.createObject(response,
                     new McpSchema.JSONRPCResponse(McpSchema.JSONRPC_VERSION, jsonrpcRequest.id(), initResult, null));
         } catch (Exception e) {
-            logger.error("Failed to initialize session: {}", e.getMessage());
+            logger.error("Failed to initialize session: {}", e.getMessage(), e);
             response.statusCode(HttpResponseStatus.INTERNAL_SERVER_ERROR.statusCode());
             return Entity.createObject(response,
                     McpError.builder(McpSchema.ErrorCodes.INTERNAL_ERROR).message(e.getMessage()).build());
@@ -523,13 +526,11 @@ private Object handleInitializeRequest(HttpClassicServerRequest request, HttpCla
      * @param session The {@link McpStreamableServerSession} to accept the response
      * @param transportContext The {@link McpTransportContext} for request context propagation
      * @param response The {@link HttpClassicServerResponse} to set the status code
-     * @return {@code null} as the response status is set to {@code 202 Accepted}
      */
-    private Object handleJsonRpcResponse(McpSchema.JSONRPCResponse jsonrpcResponse, McpStreamableServerSession session,
+    private void handleJsonRpcResponse(McpSchema.JSONRPCResponse jsonrpcResponse, McpStreamableServerSession session,
             McpTransportContext transportContext, HttpClassicServerResponse response) {
         session.accept(jsonrpcResponse).contextWrite(ctx -> ctx.put(McpTransportContext.KEY, transportContext)).block();
         response.statusCode(HttpResponseStatus.ACCEPTED.statusCode());
-        return null;
     }
 
     /**
@@ -541,16 +542,14 @@ private Object handleJsonRpcResponse(McpSchema.JSONRPCResponse jsonrpcResponse,
      * @param session The {@link McpStreamableServerSession} to accept the notification
      * @param transportContext The {@link McpTransportContext} for request context propagation
      * @param response The {@link HttpClassicServerResponse} to set the status code
-     * @return {@code null} as the response status is set to {@code 202 Accepted}
      */
-    private Object handleJsonRpcNotification(McpSchema.JSONRPCNotification jsonrpcNotification,
+    private void handleJsonRpcNotification(McpSchema.JSONRPCNotification jsonrpcNotification,
             McpStreamableServerSession session, McpTransportContext transportContext,
             HttpClassicServerResponse response) {
         session.accept(jsonrpcNotification)
                 .contextWrite(ctx -> ctx.put(McpTransportContext.KEY, transportContext))
                 .block();
         response.statusCode(HttpResponseStatus.ACCEPTED.statusCode());
-        return null;
     }
 
     /**
@@ -593,7 +592,7 @@ public void onFailed(Exception e) {
                         .contextWrite(ctx -> ctx.put(McpTransportContext.KEY, transportContext))
                         .block();
             } catch (Exception e) {
-                logger.error("Failed to handle request stream: {}", e.getMessage());
+                logger.error("Failed to handle request stream: {}", e.getMessage(), e);
                 emitter.fail(e);
             }
         });
@@ -681,13 +680,14 @@ public Mono<Void> sendMessage(McpSchema.JSONRPCMessage message, String messageId
 
                     logger.info("[SSE] Sending message to session {}: {}", this.sessionId, jsonText);
                 } catch (Exception e) {
-                    logger.error("Failed to send message to session {}: {}", this.sessionId, e.getMessage());
+                    logger.error("Failed to send message to session {}: {}", this.sessionId, e.getMessage(), e);
                     try {
                         this.emitter.fail(e);
                     } catch (Exception errorException) {
                         logger.error("Failed to send error to SSE builder for session {}: {}",
                                 this.sessionId,
-                                errorException.getMessage());
+                                errorException.getMessage(),
+                                errorException);
                     }
                 } finally {
                     this.lock.unlock();

framework/fel/java/plugins/tool-mcp-server/src/main/resources/application.yml

@@ -6,4 +6,4 @@ fit:
 mcp:
   server:
     request:
-      timeout-seconds: 10
+      timeout-seconds: 60