[FEL]MCP Streamable Client implement with Java MCP SDK (#361)

* MCP SDK Client first commit.

* MCP SDK Client first commit.

* 实现fit接口

* 因为jsonMapper问题暂时回退0.12.0版本

* SDK版本更新为0.15.0

* 格式化，加callTool错误日志更新

* 修改客户端默认超时时间

* 优化过长类

* 修改工厂类逻辑

* 添加测试，修改log格式

* 修改client和server部分日志输出

* 移除elicitation能力

* 恢复testcontroller

* 删除testcontroller的log依赖

* 删除service的sdk依赖

* 声明线程不安全，以及加this.

---------

Co-authored-by: 3200105739 <[email protected]>

Author: relat-ivity

framework/fel/java/plugins/tool-mcp-client/pom.xml

@@ -37,6 +37,11 @@
             <groupId>org.fitframework.fel</groupId>
             <artifactId>tool-mcp-client-service</artifactId>
         </dependency>
+        <dependency>
+            <groupId>io.modelcontextprotocol.sdk</groupId>
+            <artifactId>mcp</artifactId>
+            <version>0.15.0</version>
+        </dependency>
 
         <!-- Test -->
         <dependency>

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

@@ -6,52 +6,33 @@
 
 package modelengine.fel.tool.mcp.client.support;
 
-import static modelengine.fitframework.inspection.Validation.notNull;
-
 import modelengine.fel.tool.mcp.client.McpClient;
 import modelengine.fel.tool.mcp.client.McpClientFactory;
-import modelengine.fit.http.client.HttpClassicClient;
-import modelengine.fit.http.client.HttpClassicClientFactory;
 import modelengine.fitframework.annotation.Component;
-import modelengine.fitframework.annotation.Fit;
 import modelengine.fitframework.annotation.Value;
-import modelengine.fitframework.serialization.ObjectSerializer;
 
 /**
- * Represents a factory for creating instances of the DefaultMcpClient.
- * This class is responsible for initializing and configuring the HTTP client and JSON serializer
- * required by the DefaultMcpClient.
+ * Represents a factory for creating instances of the {@link DefaultMcpStreamableClient}.
+ * This class is responsible for initializing and configuring.
  *
  * @author 季聿阶
  * @since 2025-05-21
  */
 @Component
 public class DefaultMcpClientFactory implements McpClientFactory {
-    private final HttpClassicClient client;
-    private final ObjectSerializer jsonSerializer;
-    private final long pingInterval;
+    private final int requestTimeoutSeconds;
 
     /**
      * Constructs a new instance of the DefaultMcpClientFactory.
      *
-     * @param clientFactory The factory used to create the HTTP client.
-     * @param jsonSerializer The JSON serializer used for serialization and deserialization.
-     * @param pingInterval The interval between ping requests. Units: milliseconds.
+     * @param requestTimeoutSeconds The timeout duration of requests. Units: seconds.
      */
-    public DefaultMcpClientFactory(HttpClassicClientFactory clientFactory,
-            @Fit(alias = "json") ObjectSerializer jsonSerializer,
-            @Value("${mcp.client.ping-interval}") long pingInterval) {
-        this.client = clientFactory.create(HttpClassicClientFactory.Config.builder()
-                .connectTimeout(30_000)
-                .socketTimeout(60_000)
-                .connectionRequestTimeout(60_000)
-                .build());
-        this.jsonSerializer = notNull(jsonSerializer, "The json serializer cannot be null.");
-        this.pingInterval = pingInterval;
+    public DefaultMcpClientFactory(@Value("${mcp.client.request.timeout-seconds}") int requestTimeoutSeconds) {
+        this.requestTimeoutSeconds = requestTimeoutSeconds > 0 ? requestTimeoutSeconds : 180;
     }
 
     @Override
     public McpClient create(String baseUri, String sseEndpoint) {
-        return new DefaultMcpClient(this.jsonSerializer, this.client, baseUri, sseEndpoint, this.pingInterval);
+        return new DefaultMcpStreamableClient(baseUri, sseEndpoint, requestTimeoutSeconds);
     }
 }

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

@@ -0,0 +1,44 @@
+/*---------------------------------------------------------------------------------------------
+ *  Copyright (c) 2025 Huawei Technologies Co., Ltd. All rights reserved.
+ *  This file is a part of the ModelEngine Project.
+ *  Licensed under the MIT License. See License.txt in the project root for license information.
+ *--------------------------------------------------------------------------------------------*/
+
+package modelengine.fel.tool.mcp.client.support;
+
+import io.modelcontextprotocol.spec.McpSchema;
+import modelengine.fitframework.log.Logger;
+
+/**
+ * Handles MCP client messages received from MCP server,
+ * including logging notifications and elicitation requests.
+ *
+ * @author 黄可欣
+ * @since 2025-11-03
+ */
+public class DefaultMcpClientLogHandler {
+    private static final Logger log = Logger.get(DefaultMcpClientLogHandler.class);
+    private final String clientId;
+
+    /**
+     * Constructs a new instance of DefaultMcpClientLogHandler.
+     *
+     * @param clientId The unique identifier of the MCP client.
+     */
+    public DefaultMcpClientLogHandler(String clientId) {
+        this.clientId = clientId;
+    }
+
+    /**
+     * Handles logging messages received from the MCP server.
+     * Includes the client UUID in the log message for tracking.
+     *
+     * @param notification The {@link McpSchema.LoggingMessageNotification} containing the log level and data.
+     */
+    public void handleLoggingMessage(McpSchema.LoggingMessageNotification notification) {
+        log.info("Received logging message from MCP server. [clientId={}, level={}, data={}]",
+                this.clientId,
+                notification.level(),
+                notification.data());
+    }
+}