support streamable http

Author: alexcheng1982

pom.xml

@@ -21,7 +21,7 @@
     <maven.compiler.source>21</maven.compiler.source>
     <maven.compiler.target>21</maven.compiler.target>
     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-    <spring-ai.version>1.1.0</spring-ai.version>
+    <spring-ai.version>1.1.1</spring-ai.version>
     <chat-agent-ui.version>0.14.0</chat-agent-ui.version>
     <llm-agent-spec.version>0.4.0</llm-agent-spec.version>
   </properties>
@@ -73,7 +73,7 @@
       <dependency>
         <groupId>io.modelcontextprotocol.sdk</groupId>
         <artifactId>mcp-bom</artifactId>
-        <version>0.16.0</version>
+        <version>0.17.0</version>
         <type>pom</type>
         <scope>import</scope>
       </dependency>

src/main/java/com/javaaidev/easymcpclient/client/McpClientService.java

@@ -3,8 +3,10 @@
 import com.javaaidev.easymcpclient.config.mcp.NamedMcpServer;
 import com.javaaidev.easymcpclient.config.mcp.SseServer;
 import com.javaaidev.easymcpclient.config.mcp.StdioServer;
+import com.javaaidev.easymcpclient.config.mcp.StreamableServer;
 import io.modelcontextprotocol.client.McpClient;
 import io.modelcontextprotocol.client.transport.HttpClientSseClientTransport;
+import io.modelcontextprotocol.client.transport.HttpClientStreamableHttpTransport;
 import io.modelcontextprotocol.client.transport.ServerParameters;
 import io.modelcontextprotocol.client.transport.StdioClientTransport;
 import io.modelcontextprotocol.json.McpJsonMapper;
@@ -42,6 +44,8 @@ public List<NamedMcpSyncClient> connect(Collection<NamedMcpServer> servers) {
         return connect(name, stdioServer);
       } else if (server instanceof SseServer sseServer) {
         return connect(name, sseServer);
+      } else if (server instanceof StreamableServer streamableServer) {
+        return connect(name, streamableServer);
       }
       return Optional.<NamedMcpSyncClient>empty();
     }).flatMap(Optional::stream).toList();
@@ -51,6 +55,11 @@ private Optional<NamedMcpSyncClient> connect(String name, SseServer server) {
     return doConnect(name, HttpClientSseClientTransport.builder(server.url()).build());
   }
 
+  private Optional<NamedMcpSyncClient> connect(String name, StreamableServer server) {
+    return doConnect(name, HttpClientStreamableHttpTransport.builder(server.url()).build());
+  }
+
+
   private Optional<NamedMcpSyncClient> connect(String name, StdioServer server) {
     return doConnect(name, new StdioClientTransport(
         ServerParameters.builder(server.command())

src/main/java/com/javaaidev/easymcpclient/config/mcp/McpServer.java

@@ -6,14 +6,18 @@
 @JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY, property = "type")
 @JsonSubTypes({
     @JsonSubTypes.Type(value = SseServer.class, name = "sse"),
-    @JsonSubTypes.Type(value = StdioServer.class, name = "stdio")})
-public sealed interface McpServer permits SseServer, StdioServer {
+    @JsonSubTypes.Type(value = StdioServer.class, name = "stdio"),
+    @JsonSubTypes.Type(value = StreamableServer.class, name = "streamable"),
+})
+public sealed interface McpServer permits SseServer, StdioServer, StreamableServer {
 
   default String type() {
     if (this instanceof SseServer) {
       return "sse";
     } else if (this instanceof StdioServer) {
       return "stdio";
+    } else if (this instanceof StreamableServer) {
+      return "streamable";
     }
     throw new IllegalArgumentException("Unknown server type: " + this);
   }

src/main/java/com/javaaidev/easymcpclient/config/mcp/StreamableServer.java

@@ -0,0 +1,5 @@
+package com.javaaidev.easymcpclient.config.mcp;
+
+public record StreamableServer(String url) implements McpServer {
+
+}