mirror of
https://github.com/xinnan-tech/xiaozhi-esp32-server.git
synced 2026-07-30 05:13:59 +08:00
Merge pull request #2165 from myifeng/sse-mcp-fix
优化SSE Client连接;增加SSE MCP示例
This commit is contained in:
@@ -167,14 +167,13 @@ class ServerMCPClient:
|
|||||||
|
|
||||||
# 建立SSEClient
|
# 建立SSEClient
|
||||||
elif "url" in self.config:
|
elif "url" in self.config:
|
||||||
|
headers = dict(self.config.get("headers", {}))
|
||||||
|
# TODO 兼容旧版本
|
||||||
if "API_ACCESS_TOKEN" in self.config:
|
if "API_ACCESS_TOKEN" in self.config:
|
||||||
headers = {
|
headers["Authorization"] = f"Bearer {self.config['API_ACCESS_TOKEN']}"
|
||||||
"Authorization": f"Bearer {self.config['API_ACCESS_TOKEN']}"
|
self.logger.bind(tag=TAG).warning(f"你正在使用旧过时的配置 API_ACCESS_TOKEN ,请在.mcp_server_settings.json中将API_ACCESS_TOKEN直接设置在headers中,例如 'Authorization': 'Bearer API_ACCESS_TOKEN'")
|
||||||
}
|
|
||||||
else:
|
|
||||||
headers = {}
|
|
||||||
sse_r, sse_w = await stack.enter_async_context(
|
sse_r, sse_w = await stack.enter_async_context(
|
||||||
sse_client(self.config["url"], headers=headers)
|
sse_client(self.config["url"], headers=headers, timeout=self.config.get("timeout", 5), sse_read_timeout=self.config.get("sse_read_timeout", 60 * 5))
|
||||||
)
|
)
|
||||||
read_stream, write_stream = sse_r, sse_w
|
read_stream, write_stream = sse_r, sse_w
|
||||||
|
|
||||||
|
|||||||
@@ -36,6 +36,12 @@
|
|||||||
"command": "npx",
|
"command": "npx",
|
||||||
"args": ["-y", "@simonb97/server-win-cli"],
|
"args": ["-y", "@simonb97/server-win-cli"],
|
||||||
"link": "https://github.com/SimonB97/win-cli-mcp-server"
|
"link": "https://github.com/SimonB97/win-cli-mcp-server"
|
||||||
|
},
|
||||||
|
"sse-mcp-server": {
|
||||||
|
"url": "http://localhost:8080/sse",
|
||||||
|
"headers": {
|
||||||
|
"Authorization": "Bearer YOUR TOKEN"
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user