快捷導(dǎo)航

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

更新時(shí)間：2025年09月11日 10:16:01 作者：Gwanda

本文給大家介紹Spring自定義MCP sse-endpoint配置指南,本文結(jié)合實(shí)例代碼給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友參考下吧

前言

最近調(diào)研了MCP的相關(guān)內(nèi)容，嘗試自定義MCP server的端點(diǎn)，并在MCP client里配置自定義的server 端點(diǎn)，發(fā)現(xiàn)官方的文檔缺失了一部分，且無法通過yaml直接自定義。經(jīng)過翻看源碼后，成功修改了配置，以下是一些記錄。

一、MCP server配置自定義sse-endpoint

首先，根據(jù)SpringAI官方文檔，在yaml文件中，spring.ai.mcp.server.sse-endpoint為自定義端點(diǎn)

但是，經(jīng)過驗(yàn)證，只配置該選項(xiàng)，啟動(dòng)正常，通過postman調(diào)用新配置的sse-endpoint ：“http://localhost:8080/demo/sse”，會(huì)提示404 not found。
通過斷點(diǎn)，發(fā)現(xiàn)項(xiàng)目啟動(dòng)時(shí)，框架通過McpWebMvcServerAutoConfiguration來進(jìn)行自動(dòng)配置

通過源碼，發(fā)現(xiàn)配置的sse-endpoint，并沒有在配置類里引用，無論配置什么地址，都是使用默認(rèn)的/sse作為端點(diǎn)。
而springboot是可以通過自己編寫配置類，來實(shí)現(xiàn)對(duì)jar包內(nèi)的配置類的補(bǔ)充和覆蓋，所以第一時(shí)間就想到了，自己編寫一個(gè)config，實(shí)現(xiàn)獲取yaml里的配置內(nèi)容，代碼如下

/**
 * @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();
    }
}

重新啟動(dòng)，可以通過postman訪問自定義的地址了

二、MCP client配置

在server端配置完成后，client也需要同步配置，不然啟動(dòng)會(huì)提示404，找不到server的地址，但在翻閱文檔后，發(fā)現(xiàn)spring提供的client相關(guān)jar，并沒有配置自定義sse-endpoint的方式??，沒有辦法，又需要自定義相關(guān)配置類了，首先，先在yaml里增加對(duì)應(yīng)key

翻看源碼和斷點(diǎn)，找到client端的自動(dòng)配置class

按照server端的經(jīng)驗(yàn)，編寫自定義config，此處需要注意，因?yàn)閥aml里并不存在sseEndpoint這個(gè)key，我們需要先自定義一個(gè)SseClientProperties，替換源碼里的McpSseClientProperties

@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;
    }
}

源碼里的McpSseClientProperties：

編寫完成后啟動(dòng)，此時(shí)console報(bào)錯(cuò)，提示

詢問模型后，發(fā)現(xiàn)是因?yàn)镾pring Boot 中，同名的 Bean 不能重復(fù)注冊(cè)， mcpHttpClientTransports 這個(gè) Bean，在兩個(gè)地方都被定義了： 1個(gè)在官方自動(dòng)配置 SseHttpClientTransportAutoConfiguration， 1個(gè)在自己的配置類 MyMcpSseConfig
通過修改啟動(dòng)類，排除官方自動(dòng)配置的class
@SpringBootApplication(exclude = {SseHttpClientTransportAutoConfiguration.class})
再次啟動(dòng)，此時(shí)console沒有報(bào)錯(cuò)了，通過postman調(diào)用client的接口，也可以正常調(diào)用server里編寫的tools