Expected Behavior
Developers should be able to register multiple MCP servers on non-default paths, and these paths could be parametrized in a way similar to how it's done in normal controllers with @PathVariable
, or something similar in functionality.
Current Behavior
Only a single MCP server can be hosted in the app, and its path cannot be parametrized.
Context
There are tools, such as https://zapier.com/ , which seemingly allow creating customized MCP servers, with only some of their integrations available as tools.
This is also similar to how https://atlassian.com/rovo allows creating multiple agents (that is more A2A specific though) with limited sets of tools.
Comment From: piotrooo
That’s exactly what I’ve been looking and waiting for 🙏
Comment From: ivicac
+1
Comment From: shenqing-Fer
I achieved this goal through this configuration, I hope it can help you.
package org.springframework.ai.mcp.sample.server;
import com.fasterxml.jackson.databind.ObjectMapper;
import io.modelcontextprotocol.server.McpServer;
import io.modelcontextprotocol.server.McpSyncServer;
import io.modelcontextprotocol.server.transport.WebFluxSseServerTransportProvider;
import io.modelcontextprotocol.spec.McpSchema;
import org.springframework.ai.mcp.McpToolUtils;
import org.springframework.ai.tool.ToolCallbacks;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.reactive.function.server.RouterFunction;
import org.springframework.ai.tool.ToolCallback;
@Configuration
public class McpServerConfig {
@Autowired
private NewsClient newsClient;
@Autowired
private WeatherClient weatherClient;
private final ObjectMapper objectMapper = new ObjectMapper();
private McpSyncServer getMcpSyncServer(WebFluxSseServerTransportProvider provider, String name, String version, ToolCallback... toolCallbacks) {
var capabilities = McpSchema.ServerCapabilities.builder()
.tools(true)
.logging()
.build();
return McpServer.sync(provider)
.serverInfo(name, version)
.capabilities(capabilities)
.tools(McpToolUtils.toSyncToolSpecifications(toolCallbacks))
.build();
}
@Bean(name = "newsTransportProvider")
public WebFluxSseServerTransportProvider newsTransportProvider() {
return new WebFluxSseServerTransportProvider(objectMapper, "/mcp/news/message", "/mcp/news/sse");
}
@Bean
public RouterFunction<?> newsMcpRouterFunction(@Qualifier("newsTransportProvider") WebFluxSseServerTransportProvider sseServerTransportProvider) {
return sseServerTransportProvider.getRouterFunction();
}
@Bean
public McpSyncServer newsMcpServer(@Qualifier("newsTransportProvider") WebFluxSseServerTransportProvider newsTransportProvider) {
return getMcpSyncServer(newsTransportProvider, "MCP News Server", "1.0.0", ToolCallbacks.from(newsClient));
}
@Bean(name = "weatherTransportProvider")
public WebFluxSseServerTransportProvider weatherTransportProvider() {
return new WebFluxSseServerTransportProvider(objectMapper, "/mcp/weather/message", "/mcp/weather/sse");
}
@Bean
public RouterFunction<?> weatherMcpRouterFunction(@Qualifier("weatherTransportProvider") WebFluxSseServerTransportProvider sseServerTransportProvider) {
return sseServerTransportProvider.getRouterFunction();
}
@Bean
public McpSyncServer weatherMcpServer(@Qualifier("weatherTransportProvider") WebFluxSseServerTransportProvider newsTransportProvider) {
return getMcpSyncServer(newsTransportProvider, "MCP Weather Server", "1.0.0", ToolCallbacks.from(weatherClient));
}
}
Comment From: ivicac
Hi,
Is it possible to dynamically register routes, something like /mcp/news/{name}
? It is possible with a TypeScript-based MCP SDK, it seems.
Best Regards
Comment From: FishingDanDan
我通过这个配置实现了这个目标,希望对大家有所帮助。
Parameter 0 of method mcpSyncServer in org.springframework.ai.mcp.server.autoconfigure.McpServerAutoConfiguration required a single bean, but 2 were found:
Comment From: FishingDanDan
我通过这个配置实现了这个目标,希望对大家有所帮助。
Parameter 0 of method mcpSyncServer in org.springframework.ai.mcp.server.autoconfigure.McpServerAutoConfiguration required a single bean, but 2 were found:
I solved it by@SpringBootApplication(exclude = {McpServerAutoConfiguration.class}) thanks
Comment From: handicraftsman
I once asked this on an official spring livestream, they said "it's not how it is intended to work", despite the same idea being implemented in other widely used apps.
Comment From: lihuagang03
I achieved this goal through this configuration, I hope it can help you.
``` package org.springframework.ai.mcp.sample.server;
import com.fasterxml.jackson.databind.ObjectMapper; import io.modelcontextprotocol.server.McpServer; import io.modelcontextprotocol.server.McpSyncServer; import io.modelcontextprotocol.server.transport.WebFluxSseServerTransportProvider; import io.modelcontextprotocol.spec.McpSchema; import org.springframework.ai.mcp.McpToolUtils; import org.springframework.ai.tool.ToolCallbacks; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.web.reactive.function.server.RouterFunction; import org.springframework.ai.tool.ToolCallback;
@Configuration public class McpServerConfig {
@Autowired private NewsClient newsClient; @Autowired private WeatherClient weatherClient; private final ObjectMapper objectMapper = new ObjectMapper(); private McpSyncServer getMcpSyncServer(WebFluxSseServerTransportProvider provider, String name, String version, ToolCallback... toolCallbacks) { var capabilities = McpSchema.ServerCapabilities.builder() .tools(true) .logging() .build(); return McpServer.sync(provider) .serverInfo(name, version) .capabilities(capabilities) .tools(McpToolUtils.toSyncToolSpecifications(toolCallbacks)) .build(); } @Bean(name = "newsTransportProvider") public WebFluxSseServerTransportProvider newsTransportProvider() { return new WebFluxSseServerTransportProvider(objectMapper, "/mcp/news/message", "/mcp/news/sse"); } @Bean public RouterFunction<?> newsMcpRouterFunction(@Qualifier("newsTransportProvider") WebFluxSseServerTransportProvider sseServerTransportProvider) { return sseServerTransportProvider.getRouterFunction(); } @Bean public McpSyncServer newsMcpServer(@Qualifier("newsTransportProvider") WebFluxSseServerTransportProvider newsTransportProvider) { return getMcpSyncServer(newsTransportProvider, "MCP News Server", "1.0.0", ToolCallbacks.from(newsClient)); } @Bean(name = "weatherTransportProvider") public WebFluxSseServerTransportProvider weatherTransportProvider() { return new WebFluxSseServerTransportProvider(objectMapper, "/mcp/weather/message", "/mcp/weather/sse"); } @Bean public RouterFunction<?> weatherMcpRouterFunction(@Qualifier("weatherTransportProvider") WebFluxSseServerTransportProvider sseServerTransportProvider) { return sseServerTransportProvider.getRouterFunction(); } @Bean public McpSyncServer weatherMcpServer(@Qualifier("weatherTransportProvider") WebFluxSseServerTransportProvider newsTransportProvider) { return getMcpSyncServer(newsTransportProvider, "MCP Weather Server", "1.0.0", ToolCallbacks.from(weatherClient)); }
} ```
Nice work! I implement it is the same too.
Create multiple McpAsyncServer
, McpServerTransportProvider
, RouterFunction<?>
@Bean
instances, such as Map<appName, McpServerTransportProvider/McpServer>
, exclude to McpWebFluxServerAutoConfiguration
.
@shenqing-Fer