修改client和server部分日志输出

Author: “â黄可欣

framework/fel/java/plugins/tool-mcp-client/src/main/java/modelengine/fel/tool/mcp/client/support/DefaultMcpStreamableClient.java

@@ -115,19 +115,19 @@ public List<Tool> getTools() {
         try {
             McpSchema.ListToolsResult result = this.mcpSyncClient.listTools();
             if (result == null || result.tools() == null) {
-                log.warn("Failed to get tools: result is null. [clientId={}]", clientId);
-                throw new IllegalStateException("Failed to get tools from MCP server: result is null.");
+                log.warn("Failed to get tools list: result is null. [clientId={}]", clientId);
+                throw new IllegalStateException("Failed to get tools list from MCP server: result is null.");
             }
 
             List<Tool> tools = result.tools().stream().map(this::convertToFelTool).collect(Collectors.toList());
 
-            log.info("Successfully retrieved tools. [clientId={}, count={}]", clientId, tools.size());
+            log.info("Successfully retrieved tools list. [clientId={}, count={}]", clientId, tools.size());
             tools.forEach(tool -> log.debug("Tool information. [name={}, description={}]",
                     tool.getName(),
                     tool.getDescription()));
             return tools;
         } catch (Exception e) {
-            log.error("Failed to get tools. [clientId={}, error={}]", clientId, e.getMessage());
+            log.error("Failed to get tools list. [clientId={}, error={}]", clientId, e.getMessage());
             throw new IllegalStateException("Failed to get tools from MCP server. [error=" + e.getMessage() + "]", e);
         }
     }
@@ -251,7 +251,7 @@ private Tool convertToFelTool(McpSchema.Tool mcpTool) {
      */
     private void ensureNotClosed() {
         if (this.closed) {
-            throw new IllegalStateException("The MCP client is closed. [clientId=" + clientId + "]");
+            throw new IllegalStateException("The MCP client is already closed. [clientId=" + clientId + "]");
         }
     }
 
@@ -264,7 +264,7 @@ private void ensureReady() {
         ensureNotClosed();
         if (!this.initialized) {
             throw new IllegalStateException(
-                    "MCP client is not initialized. Please wait a moment. [clientId=" + clientId + "]");
+                    "MCP client is not initialized. [clientId=" + clientId + "]");
         }
     }
 

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

@@ -204,7 +204,7 @@ public Object handleGet(HttpClassicServerRequest request, HttpClassicServerRespo
         }
         String sessionId = request.headers().first(HttpHeaders.MCP_SESSION_ID).orElse("");
         McpStreamableServerSession session = this.sessions.get(sessionId);
-        logger.info("[GET] Handling GET request for session: {}", sessionId);
+        logger.info("[GET] Receiving GET request from session: {}", sessionId);
 
         McpTransportContext transportContext = this.contextExtractor.extract(request);
         try {
@@ -392,7 +392,7 @@ private void handleReplaySseRequest(HttpClassicServerRequest request, McpTranspo
             String sessionId, McpStreamableServerSession session, FitStreamableMcpSessionTransport sessionTransport,
             Emitter<TextEvent> emitter) {
         String lastId = request.headers().first(HttpHeaders.LAST_EVENT_ID).orElse("0");
-        logger.info("[GET] Receiving replay request from session: {}", sessionId);
+        logger.info("[GET] Handling replay request from session: {}", sessionId);
 
         try {
             session.replay(lastId)
@@ -426,7 +426,7 @@ private void handleReplaySseRequest(HttpClassicServerRequest request, McpTranspo
      */
     private void handleEstablishSseRequest(String sessionId, McpStreamableServerSession session,
             FitStreamableMcpSessionTransport sessionTransport, Emitter<TextEvent> emitter) {
-        logger.info("[GET] Receiving Get request to establish new SSE for session: {}", sessionId);
+        logger.info("[GET] Handling Get request to establish new SSE for session: {}", sessionId);
         McpStreamableServerSession.McpStreamableServerSessionStream listeningStream =
                 session.listeningStream(sessionTransport);
 
@@ -643,7 +643,7 @@ private class FitStreamableMcpSessionTransport implements McpStreamableServerTra
             this.sessionId = sessionId;
             this.emitter = emitter;
             this.response = response;
-            logger.info("[SSE] Building SSE for session: {} ", sessionId);
+            logger.info("[SSE] Building SSE emitter for session: {} ", sessionId);
         }
 
         /**