使用spring-ai-starter-mcp-client sse方式连接mcp server，重启mcp server后，以前的client不会自动重连。

[hymmyh]

1.0.0-M7 版本：
client 采用sse 方式连接上 mcp server，可以正常运行；这个时候重启 mcp server， client 端就不会重连 mcp server，导致一直报错
reactor.core.Exceptions$ReactiveException: java.util.concurrent.TimeoutException: Did not observe any item or terminal signal within 20000ms in 'source(MonoCreate)' (and no fallback has been configured)
at reactor.core.Exceptions.propagate(Exceptions.java:410)
at reactor.core.publisher.BlockingSingleSubscriber.blockingGet(BlockingSingleSubscriber.java:102)

怎么设置重连mcp server？

[Forest-Fairy]

应该只能重新创建一个mcpclient对象 或者重新实现一个client可以重连的

[lyxfn]

I also encountered this problem. Every time I restarted mcp-server, I needed to restart the client to recover. If I only restarted mcp-server, a 404 error would appear. I didn't see any reconnection configuration in the official documentation.

org.springframework.web.reactive.function.client.WebClientResponseException$NotFound: 404 Not Found from POST http://localhost:9080/mcp/message
at org.springframework.web.reactive.function.client.WebClientResponseException.create(WebClientResponseException.java:324) ~[spring-webflux-6.1.14.jar:6.1.14]
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Error has been observed at the following site(s):
*__checkpoint ⇢ 404 NOT_FOUND from POST http://localhost:9080/mcp/message [DefaultWebClient]

[SuperWuYou]

这都不用等服务器重启，我连着高德的MCP，等个几分钟就断开了，然后他就不连了.... 怎么办？？？

[hymmyh]

这都不用等服务器重启，我连着高德的MCP，等个几分钟就断开了，然后他就不连了.... 怎么办？？？

目前可以不用autoconfigure，自己在代码中实现 mcpClient 的初始化，用mcpClient.ping() 来判断是否正常，不正常重新实例化一个新的mcpClient。

[zhouwenjun-hub]

这都不用等服务器重启，我连着高德的MCP，等个几分钟就断开了，然后他就不连了.... 怎么办？？？

目前可以不用autoconfigure，自己在代码中实现 mcpClient 的初始化，用mcpClient.ping() 来判断是否正常，不正常重新实例化一个新的mcpClient。

大佬，请问有示例代码么？我尝试这个方案还是有问题，重新实例化时，mcp server会报错： session is null

[SuperWuYou]

@zhouwenjun-hub 去看看autoconfigure包是怎么写的你就会了。

[dyrnq]

stare

[luojinggit]

这都不用等服务器重启，我连着高德的MCP，等个几分钟就断开了，然后他就不连了.... 怎么办？？？

目前可以不用autoconfigure，自己在代码中实现 mcpClient 的初始化，用mcpClient.ping() 来判断是否正常，不正常重新实例化一个新的mcpClient。

麻烦您能不能贴一下关键代码，我也遇到这个问题，我重新调用mcpSyncClient.initialize(); 方法还是无法重连。

[15185640400]

这都不用等服务器重启，我连着高德的MCP，等个几分钟就断开了，然后他就不连了....怎么办？？？

目前可以不用autoconfigure，自己在代码中实现 mcpClient 的初始化，用mcpClient.ping（） 来判断是否正常，不正常重新实例化一个新的mcpClient。

麻烦您能不能贴一下关键代码，我也遇到这个问题，我重新调用mcpSyncClient.initialize（）;方法还是无法重连。

您好，请问一下，您解决了吗

[hymmyh]

@configuration
@EnableConfigurationProperties
public class McpConfig {
private static final Logger LOGGER = LoggerFactory.getLogger(McpConfig.class);
private McpSyncClient mcpClient;
private List toolCallbacks;

/**
 * MCP客户端的URL地址，用于建立与MCP服务器的连接。
 */
@Value("${spring.ai.mcp.client.sse.connections.server1.url}")
private String mcpServerUrl;

/**
 * 创建或重建MCP客户端。该方法会关闭旧客户端实例（如果存在），并初始化新的MCP客户端及关联的工具回调。
 * <p>
 * 同步方法确保客户端创建过程的线程安全。
 */
private synchronized void createMcpClient() {
    // 关闭旧的MCP客户端（如果存在）
    if (mcpClient != null) {
        try {
            mcpClient.close();
        } catch (final Exception e) {
            LOGGER.error("关闭旧客户端失败", e);
        }
    }

    // 创建并配置新的MCP客户端传输层
    final WebClient.Builder builder = WebClient.builder().baseUrl(mcpServerUrl);
    final WebFluxSseClientTransport transport = new WebFluxSseClientTransport(builder);
    final McpSyncClient newClient = McpClient.sync(transport).build();

    // 初始化新客户端并记录结果
    final McpSchema.InitializeResult init = newClient.initialize();
    LOGGER.info("<---------------->MCP Initialized: {}", init);

    // 更新MCP客户端引用和工具回调
    mcpClient = newClient;
    toolCallbacks = List.of(new SyncMcpToolCallbackProvider(mcpClient).getToolCallbacks());
}


/**
 * 获取工具回调列表。该方法会确保MCP客户端处于有效连接状态，若连接异常则自动重建客户端。
 * @return 已配置的工具回调列表
 */
public List<ToolCallback> getToolCallback() {
    if (mcpClient == null) {
        // 如果MCP客户端未初始化，则创建并直接返回回调列表
        createMcpClient();
        return toolCallbacks;
    }
    try {
        // 检查与服务端的连接状态
        mcpClient.ping();
    } catch (final Exception e) {
        // 捕获连接异常，记录错误日志并重建客户端
        LOGGER.error("<---------------->MCP ping error: {}", e.getLocalizedMessage());
        createMcpClient();
    }
    return toolCallbacks;
}

/**
 * 在Bean初始化时创建MCP客户端。
 */
@PostConstruct
public void init() {
    createMcpClient(); // 在Bean初始化时强制执行
}

}

[luojinggit]

这个方法可行，在这个代码基础上，我把自动配置chatClient改成自己配置，并且设定一个定时任务，定时ping mcp server，断开就尝试重新初始化chatClient，主要是这个chatClient 的tools每次都是增量添加，导致我断开一次后再添加会报错 tool 重复，所以只能每次重新初始化chatClient

[15185640400]

private static final Logger LOGGER = LoggerFactory.getLogger（McpConfig.class）;
private McpSyncClient mcpClient;
private List toolCallbacks;

666啊兄弟，收下我的膝盖

[15185640400]

这个方法可行，在这个代码基础上，我把自动配置chatClient改成自己配置，并且设定一个定时任务，定时ping mcp server，断开就尝试重新初始化chatClient，主要是这个chatClient的tools每次都是增量添加，导致我断开一次后再添加会报错 tool 重复，所以只能每次重新初始化chatClient

可以附一下代码吗兄弟？不，义父0.0