SSE方式接入高德MCP报错

[chiefleo]

Bug description
SSE方式接入高德MCP报错，同样的SSE配置在cursor里面运行是没有问题的
高德SSE参考文档：https://lbs.amap.com/api/mcp-server/gettingstarted#s2

application.properties配置：
spring.ai.mcp.client.enabled=true
spring.ai.mcp.client.request-timeout=20s
spring.ai.mcp.client.sse.connections.server1.url=https://mcp.amap.com/sse?key=xxx

报错信息：
[alsc.sales_data_center^^A47F9B75ACA3410330606ECA34F91A86|1744771227656][1] -2025-04-16 10:40:27.656 ERROR 16815 --- [HttpClient-1-Worker-2] i.m.c.t.WebFluxSseClientTransport : Fatal SSE error, not retrying: 200 OK from GET https://mcp.amap.com/sse, but response failed with cause: java.io.IOException: http1_0 content, bytes received: 81,[traceId:]
[alsc.sales_data_center^^A47F9B75ACA3410330606ECA34F91A86|1744771227656][1] -2025-04-16 10:40:27.659 ERROR 16815 --- [HttpClient-1-Worker-2] reactor.core.publisher.Operators : Operator called default onErrorDropped
reactor.core.Exceptions$ErrorCallbackNotImplemented: org.springframework.web.reactive.function.client.WebClientResponseException: 200 OK from GET https://mcp.amap.com/sse, but response failed with cause: java.io.IOException: http1_0 content, bytes received: 81
Caused by: org.springframework.web.reactive.function.client.WebClientResponseException: 200 OK from GET https://mcp.amap.com/sse, but response failed with cause: java.io.IOException: http1_0 content, bytes received: 81
at org.springframework.web.reactive.function.client.WebClientResponseException.create(WebClientResponseException.java:337) ~[spring-webflux-6.2.5.jar:6.2.5]
at org.springframework.web.reactive.function.client.DefaultClientResponse.lambda$createException$1(DefaultClientResponse.java:214) ~[spring-webflux-6.2.5.jar:6.2.5]
Caused by: java.io.IOException: http1_0 content, bytes received: 81
at java.net.http/jdk.internal.net.http.common.Utils.wrapWithExtraDetail(Utils.java:391) ~[java.net.http:na]
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Error has been observed at the following site(s):
*__checkpoint ⇢ Body from GET https://mcp.amap.com/sse [DefaultClientResponse]
Original Stack Trace:
at java.net.http/jdk.internal.net.http.common.Utils.wrapWithExtraDetail(Utils.java:391) ~[java.net.http:na]
at java.net.http/jdk.internal.net.http.Http1Response$BodyReader.onReadError(Http1Response.java:676) ~[java.net.http:na]
at java.net.http/jdk.internal.net.http.Http1AsyncReceiver.checkForErrors(Http1AsyncReceiver.java:302) ~[java.net.http:na]
at java.net.http/jdk.internal.net.http.Http1AsyncReceiver.flush(Http1AsyncReceiver.java:268) ~[java.net.http:na]
at java.net.http/jdk.internal.net.http.common.SequentialScheduler$LockingRestartableTask.run(SequentialScheduler.java:182) ~[java.net.http:na]
at java.net.http/jdk.internal.net.http.common.SequentialScheduler$CompleteRestartableTask.run(SequentialScheduler.java:149) ~[java.net.http:na]
at java.net.http/jdk.internal.net.http.common.SequentialScheduler$SchedulableTask.run(SequentialScheduler.java:207) ~[java.net.http:na]
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[na:na]
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[na:na]
at java.base/java.lang.Thread.run(Thread.java:1583) ~[na:na]
Caused by: java.net.SocketException: Connection reset
at java.base/sun.nio.ch.SocketChannelImpl.throwConnectionReset(SocketChannelImpl.java:401) ~[na:na]
at java.base/sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:434) ~[na:na]

[leadhow]

是有这个问题，我换了stdio方式配置才能正常运行。

[SuperWuYou]

你自己用官方demo写一个mcp server 然后使用mcp client连接 ，启动时是好的 过两分钟一样。现在急着用的话就自己初始化那个客户端，用完关了 ，下一次请求来了继续初始化 用完继续关

[luckygqx]

@leadhow 高德的mcp服务，可以用stdio模式？

[luckygqx]

@leadhow 我一直理解stdio为本地模式，是如何可以链接到高德这种外部mcp服务的？

[chiefleo]

嗯嗯 stdio模式我在本地环境跑通了；但是部署到预发/生产服务器上，还需要装npx，服务器上没法这样自由，还是sse方式更方便点。

[luckygqx]

@chiefleo 能方便描述下是如何部署本地高德mcp服务吗（stdio协议的）？我在想，即便部署在本地了，那需要把地址转换为经纬度时，难道部署的mcp服务内部会再去访问高德api吗？

[dyrnq]

stare

[chiefleo]

本地挺简单的，只要mcp-servers-config.json配置一下下面内容，然后先命令行执行下npx -y @amap/amap-maps-mcp-server ，然后启动Application就好了。
{
"mcpServers": {
"amap-maps": {
"command": "npx",
"args": [
"-y",
"@amap/amap-maps-mcp-server"
],
"env": {
"AMAP_MAPS_API_KEY": "你的key"
}
}
}
}

@chiefleo 能方便描述下是如何部署本地高德mcp服务吗（stdio协议的）？我在想，即便部署在本地了，那需要把地址转换为经纬度时，难道部署的mcp服务内部会再去访问高德api吗？

[luckygqx]

本地挺简单的，只要mcp-servers-config.json配置一下下面内容，然后先命令行执行下npx -y @amap/amap-maps-mcp-server ，然后启动Application就好了。 { "mcpServers": { "amap-maps": { "command": "npx", "args": [ "-y", "@amap/amap-maps-mcp-server" ], "env": { "AMAP_MAPS_API_KEY": "你的key" } } } }

@chiefleo 能方便描述下是如何部署本地高德mcp服务吗（stdio协议的）？我在想，即便部署在本地了，那需要把地址转换为经纬度时，难道部署的mcp服务内部会再去访问高德api吗？

谢谢～

[seethefruture]

官网的sample上面只有stdio的，怎么都没有sse的？照着那个配置做的sse的好像有问题，是这个模块还在孵化阶段吗？
The official website's sample only has stdio, and there's nothing about SSE. I followed that configuration for SSE, but it seems to have issues. Is this module still in the incubation stage?

[spring-ai-demo] [onPool-worker-1] i.m.c.t.HttpClientSseClientTransport     : Error sending message: 404
Caused by: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'mcpSyncClients' defined in class path resource [org/springframework/ai/mcp/client/autoconfigure/McpClientAutoConfiguration.class]: Failed to instantiate [java.util.List]: Factory method 'mcpSyncClients' threw exception with message: java.util.concurrent.TimeoutException: Did not observe any item or terminal signal within 3000ms in 'source(MonoCreate)' (and no fallback has been configured)

[Danny0802]

官网的样本上面只有stdio的，怎么都没有sse的？照着那个配置做的sse的好像有问题，这个模块还在孵化阶段吗？官网的 样本只有stdio，没有SSE的东西。我遵循了 SSE 的配置，但它似乎有问题。这个模块还处于孵化阶段吗？

[spring-ai-demo] [onPool-worker-1] i.m.c.t.HttpClientSseClientTransport : Error sending message: 404
Caused by: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'mcpSyncClients' defined in class path resource [org/springframework/ai/mcp/client/autoconfigure/McpClientAutoConfiguration.class]: Failed to instantiate [java.util.List]: Factory method 'mcpSyncClients' threw exception with message: java.util.concurrent.TimeoutException: Did not observe any item or terminal signal within 3000ms in 'source(MonoCreate)' (and no fallback has been configured)

请问这个问题解了吗？

[seethefruture]

官网的样本上面只有stdio的，怎么都没有sse的？照着那个配置做的sse的好像有问题，这个模块还在孵化阶段吗？官网的 样本只有stdio，没有SSE的东西。我遵循了 SSE 的配置，但它似乎有问题。这个模块还处于孵化阶段吗？
[spring-ai-demo] [onPool-worker-1] i.m.c.t.HttpClientSseClientTransport : Error sending message: 404
Caused by: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'mcpSyncClients' defined in class path resource [org/springframework/ai/mcp/client/autoconfigure/McpClientAutoConfiguration.class]: Failed to instantiate [java.util.List]: Factory method 'mcpSyncClients' threw exception with message: java.util.concurrent.TimeoutException: Did not observe any item or terminal signal within 3000ms in 'source(MonoCreate)' (and no fallback has been configured)

请问这个问题解了吗？

解决了，但是会出现另一个issus(2740)里面的另一个问题，每两分钟就会断连，可能需要自己处理client和保持连接吧
resloved，but here's will be another problem refer(issue 2740), lost connect every 2m, maybe we need use manual config and handle the client's connection ourself

[Danny0802]

官网的样本上面只有stdio的，怎么都没有sse的？照着那个配置做的sse的好像有问题，这个模块还在孵化阶段吗？官网的 样本只有stdio，没有SSE的东西。我遵循了 SSE 的配置，但它似乎有问题。这个模块还处于孵化阶段吗？
[spring-ai-demo] [onPool-worker-1] i.m.c.t.HttpClientSseClientTransport : Error sending message: 404
Caused by: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'mcpSyncClients' defined in class path resource [org/springframework/ai/mcp/client/autoconfigure/McpClientAutoConfiguration.class]: Failed to instantiate [java.util.List]: Factory method 'mcpSyncClients' threw exception with message: java.util.concurrent.TimeoutException: Did not observe any item or terminal signal within 3000ms in 'source(MonoCreate)' (and no fallback has been configured)

请问这个问题解了吗？

解决了，但是会出现另一个issus(2740)里面的另一个问题，每两分钟就会断连，可能需要自己处理client和保持连接吧 resloved，but here's will be another problem refer(issue 2740), lost connect every 2m, maybe we need use manual config and handle the client's connection ourself

请问如何解决的呢，我的工程启动时，也会报同样的错误

[ReloadingPeace]

一样，我使用spring ai的mcp server实现了高德的api，集成到mcp client，目前没啥问题。

直接对接官方的sse，SYNC模式我没成功过。ASYNC模式一开始正常，但是运行段时间就挂了。

编程式sync是可以的，yml形式我没成功过
McpClientTransport transport = HttpClientSseClientTransport
.builder("https://mcp.amap.com")
.sseEndpoint("/sse?key=xxxxxx")
.objectMapper(objectMapper)
.build();

[seethefruture]

一样，我使用spring ai的mcp server实现了高德的api，集成到mcp client，目前没啥问题。
直接对接官方的sse，SYNC模式我没成功过。ASYNC模式一开始正常，但是运行段时间就挂了。

编程式sync是可以的，yml形式我没成功过 McpClientTransport transport = HttpClientSseClientTransport .builder("https://mcp.amap.com") .sseEndpoint("/sse?key=xxxxxx") .objectMapper(objectMapper) .build();

yml的引入后我排查到是在建立连接时的url不正确，我猜测可能是目前yml的配置方式不支持这种，使用目前只能手动写。另外高德的链接使用endpoint建立后会在2分钟左右断连，spring没有做自动切换恢复。可能国外的sse跟高德的不太一样？先自己实现吧，可以做心跳重连，但是目前的心跳好像没有比较好的方法，试试看有没有什么断开回调吧，不行就只能每次使用都是实例化sseclient了