Spring自定义MCP sse-endpoint配置指南

/**
 * @className: MyMcpServerConfig
 * @author: huajie
 * @date: 2025/4/29
 * @Description:
 **/
@Configuration
public class MyMcpServerConfig {
    @Bean
    @Primary
    public WebMvcSseServerTransportProvider webMvcSseServerTransportProvider(
            ObjectProvider<ObjectMapper> objectMapperProvider, McpServerProperties serverProperties) {
        ObjectMapper objectMapper = objectMapperProvider.getIfAvailable(ObjectMapper::new);
        return new WebMvcSseServerTransportProvider(objectMapper, serverProperties.getSseMessageEndpoint(),
                serverProperties.getSseEndpoint());
    }
    @Bean
    public RouterFunction<ServerResponse> mvcMcpRouterFunction(WebMvcSseServerTransportProvider transportProvider) {
        return transportProvider.getRouterFunction();
    }
}

@Configuration
public class MyMcpSseConfig {
    private final SseClientProperties sseClientProperties;
    public MyMcpSseConfig(SseClientProperties sseClientProperties) {
        this.sseClientProperties = sseClientProperties;
    }
    @Bean
//    @Primary
    public List<NamedClientMcpTransport> mcpHttpClientTransports(SseClientProperties sseProperties,
                                                                 ObjectProvider<ObjectMapper> objectMapperProvider) {
        ObjectMapper objectMapper = objectMapperProvider.getIfAvailable(ObjectMapper::new);
        List<NamedClientMcpTransport> sseTransports = new ArrayList<>();
        for (Map.Entry<String, SseClientProperties.Connection> serverParameters : sseProperties.getConnections().entrySet()) {
            String url = serverParameters.getValue().getUrl();
            String sseEndpoint = serverParameters.getValue().getSseEndpoint();
            var transport = new HttpClientSseClientTransport(HttpClient.newBuilder(), url,
                    sseEndpoint, objectMapper);
            sseTransports.add(new NamedClientMcpTransport(serverParameters.getKey(), transport));
        }
        return sseTransports;
    }
}