本项目实现了一个支持WebSocket实时数据更新的MCP(模型上下文协议)服务器。它允许客户端发送标准MCP请求,还能让客户端通过WebSocket订阅新数据,在有新数据可用时接收推送通知。
本项目的MCP服务器可处理客户端的标准MCP请求,WebSocket服务器支持客户端订阅实时更新,当有新数据时会向订阅客户端推送通知,且采用asyncio实现异步架构,进行高效的非阻塞操作。
asyncio进行高效的非阻塞操作。git clone https://github.com/your-repo/mcp-websocket-server.git
cd mcp-websocket-server
pip install websockets mcp-sdk # 使用实际的MCP SDK包名替换
运行以下命令以启动MCP和WebSocket服务器:
python server.py
客户端可以连接到WebSocket服务器(ws://localhost:8765),并通过发送以下内容订阅更新:
{"action": "subscribe"}
MCP客户端可以向MCP服务器(http://localhost:8080)发送请求,带有如下负载:
{"method": "get_data"}
服务器将响应:
{"result": "这是你的数据!"}
此项目根据MIT许可证发布。
欢迎提交拉取请求!对于主要更改,请先打开一个问题来讨论您想更改的内容。
如有问题或建议,请通过 virajsharma@sharmaviraj.com 联系。