mcp-client: support sseEndpoint config

Signed-off-by: lambochen <[email protected]>

Author: lambochen

Diff for: auto-configurations/mcp/spring-ai-autoconfigure-mcp-client/src/main/java/org/springframework/ai/mcp/client/autoconfigure/SseHttpClientTransportAutoConfiguration.java

@@ -94,8 +94,11 @@ public List<NamedClientMcpTransport> mcpHttpClientTransports(McpSseClientPropert
 
 		for (Map.Entry<String, SseParameters> serverParameters : sseProperties.getConnections().entrySet()) {
 
-			var transport = new HttpClientSseClientTransport(HttpClient.newBuilder(), serverParameters.getValue().url(),
-					objectMapper);
+			var transport = HttpClientSseClientTransport.builder(serverParameters.getValue().url())
+				.sseEndpoint(serverParameters.getValue().sseEndpoint())
+				.clientBuilder(HttpClient.newBuilder())
+				.objectMapper(objectMapper)
+				.build();
 			sseTransports.add(new NamedClientMcpTransport(serverParameters.getKey(), transport));
 		}
 

Diff for: auto-configurations/mcp/spring-ai-autoconfigure-mcp-client/src/main/java/org/springframework/ai/mcp/client/autoconfigure/SseWebFluxTransportAutoConfiguration.java

@@ -90,7 +90,8 @@ public List<NamedClientMcpTransport> webFluxClientTransports(McpSseClientPropert
 
 		for (Map.Entry<String, SseParameters> serverParameters : sseProperties.getConnections().entrySet()) {
 			var webClientBuilder = webClientBuilderTemplate.clone().baseUrl(serverParameters.getValue().url());
-			var transport = new WebFluxSseClientTransport(webClientBuilder, objectMapper);
+			var transport = new WebFluxSseClientTransport(webClientBuilder, objectMapper,
+					serverParameters.getValue().sseEndpoint());
 			sseTransports.add(new NamedClientMcpTransport(serverParameters.getKey(), transport));
 		}
 

Diff for: auto-configurations/mcp/spring-ai-autoconfigure-mcp-client/src/main/java/org/springframework/ai/mcp/client/autoconfigure/properties/McpSseClientProperties.java

@@ -50,8 +50,12 @@ public class McpSseClientProperties {
 	 * Parameters for configuring an SSE connection to an MCP server.
 	 *
 	 * @param url the URL endpoint for SSE communication with the MCP server
+	 * @param sseEndpoint the SSE endpoint for SSE communication with the MCP server
 	 */
-	public record SseParameters(String url) {
+	public record SseParameters(String url, String sseEndpoint) {
+		public SseParameters(String url) {
+			this(url, "/sse");
+		}
 	}
 
 	/**