当前位置: 首页 > news >正文

关于MCP SSE 服务器的工作原理

模型上下文协议(Model Context Protocol,简称MCP) 是一种全新的开放协议,专门用于标准化地为大语言模型(LLMs)提供应用场景和数据背景。 你可以把MCP想象成AI领域的“USB-C接口”,它能让不同的AI模型与外部工具和数据源轻松连接

近来学习了一下,先是使用stdio的方式叫cursor做了一个,完全没有问题。但是sse的方式叫cursor 干始终不成功, 找了一轮,发现youtube的教程视频里主持,也没有搞定sse的服务器,balahblah说了一堆,就要move on ....于是研究了一下。

1. 首先MCP SSE是基于http协议的一个应用,服务器和客户端主要通过json rc的方式进行沟通。

2. MCP SSE Client会发起多个连接,但是第一个连接是http://yourhost:port/sse,  这个连接是沟通的第一步,它会使用chunked的回传数据,意思是不告诉client这个数据有多少,这样就它就可以一直连着了。 所以这个链接就是一个用来通知的链接。你现在就明白了为什么 ,就叫SSE(Server-Sent Events )。 它首先按以下格式信息给client, 然后就是定时的ping包了, 每次都只是一个chunk,估计后期server会有推送也会使用这个链接通知client.

event: 事件的名字
data:  事件的数据

      2.1 第一个event是,这个直接返回,就是给client分配一个session_id, 方便后面多个连接过来服务器可以分清谁和谁。


51
event: endpoint
data: /messages/?session_id=07aa8f90d79a49eaad802693cdd05b5b

      client收到这个,就会以http://yourhost:port/messages/?session_id=07aa8f90d79a49eaad802693cdd05b5b , 新发起一个连接去请求mcp sse server

     2.2 第二个event是event: message, 这个data 是一个json来的,就是告诉client,当前mcp server的能力,还有服务器的基本信息。

124
event: message
data: {
  "jsonrpc": "2.0",
  "id": 0,
  "result": {
    "protocolVersion": "2024-11-05",
    "capabilities": {
      "experimental": {},
      "prompts": {
        "listChanged": false
      },
      "resources": {
        "subscribe": false,
        "listChanged": false
      },
      "tools": {
        "listChanged": false
      }
    },
    "serverInfo": {
      "name": "mem0-mcp",
      "version": "1.3.0"
    }
  }
}

     2.3 第三个event也是一个message , 用来告诉client 服务器提供的tools有哪些。

{
  "jsonrpc": "2.0",
  "id": 1,
  "result": {
    "tools": [
      {
        "name": "add_coding_preference",
        "description": "Add a new coding preference to mem0. This tool stores code snippets, implementation details,\n    and coding patterns for future reference. Store every code snippet. When storing code, you should include:\n    - Complete code with all necessary imports and dependencies\n    - Language/framework version information (e.g., \"Python 3.9\", \"React 18\")\n    - Full implementation context and any required setup/configuration\n    - Detailed comments explaining the logic, especially for complex sections\n    - Example usage or test cases demonstrating the code\n    - Any known limitations, edge cases, or performance considerations\n    - Related patterns or alternative approaches\n    - Links to relevant documentation or resources\n    - Environment setup requirements (if applicable)\n    - Error handling and debugging tips\n    The preference will be indexed for semantic search and can be retrieved later using natural language queries.",
        "inputSchema": {
          "properties": {
            "text": {
              "title": "Text",
              "type": "string"
            }
          },
          "required": [
            "text"
          ],
          "title": "add_coding_preferenceArguments",
          "type": "object"
        }
      },
      {
        "name": "get_all_coding_preferences",
        "description": "Retrieve all stored coding preferences for the default user. Call this tool when you need \n    complete context of all previously stored preferences. This is useful when:\n    - You need to analyze all available code patterns\n    - You want to check all stored implementation examples\n    - You need to review the full history of stored solutions\n    - You want to ensure no relevant information is missed\n    Returns a comprehensive list of:\n    - Code snippets and implementation patterns\n    - Programming knowledge and best practices\n    - Technical documentation and examples\n    - Setup and configuration guides\n    Results are returned in JSON format with metadata.",
        "inputSchema": {
          "properties": {},
          "title": "get_all_coding_preferencesArguments",
          "type": "object"
        }
      },
      {
        "name": "search_coding_preferences",
        "description": "Search through stored coding preferences using semantic search. This tool should be called \n    for EVERY user query to find relevant code and implementation details. It helps find:\n    - Specific code implementations or patterns\n    - Solutions to programming problems\n    - Best practices and coding standards\n    - Setup and configuration guides\n    - Technical documentation and examples\n    The search uses natural language understanding to find relevant matches, so you can\n    describe what you're looking for in plain English. Always search the preferences before \n    providing answers to ensure you leverage existing knowledge.",
        "inputSchema": {
          "properties": {
            "query": {
              "title": "Query",
              "type": "string"
            }
          },
          "required": [
            "query"
          ],
          "title": "search_coding_preferencesArguments",
          "type": "object"
        }
      }
    ]
  }
}

跟着就是ping包的返回,防止client死了。


2d
: ping - 2025-03-12 08:16:23.071429+00:00

3. endpoint请求

   拿到endpont后,client 使用post的请求endpoint,  这个只处理请求,目前看 返回则在第一个http连接里。

第二个链接 请求如下:, 这个调用initialize,对应上面的第一个message的event.

第二个链接, 这个只回复202 Accepted

POST /messages/?session_id=9aa12073a4494d5580a5c30ed54c4bfd HTTP/1.1
host: 10.0.105.64:8080
connection: keep-alive
content-type: application/json
accept: */*
accept-language: *
sec-fetch-mode: cors
user-agent: node
accept-encoding: gzip, deflate
content-length: 253

{"method":"initialize","params":{"protocolVersion":"2024-11-05","capabilities":{"tools":true,"prompts":false,"resources":true,"logging":false,"roots":{"listChanged":false}},"clientInfo":{"name":"cursor-vscode","version":"1.0.0"}},"jsonrpc":"2.0","id":0}
HTTP/1.1 202 Accepted

date: Wed, 12 Mar 2025 08:08:32 GMT
server: uvicorn
content-length: 8

Accepted

第三个链接,请求如下:


第三个链接,仅回复 202 Accepted

POST /messages/?session_id=9aa12073a4494d5580a5c30ed54c4bfd HTTP/1.1
host: 10.0.105.64:8080
connection: keep-alive
content-type: application/json
accept: */*
accept-language: *
sec-fetch-mode: cors
user-agent: node
accept-encoding: gzip, deflate
content-length: 54

{"method":"notifications/initialized","jsonrpc":"2.0"}
HTTP/1.1 202 Accepted
date: Wed, 12 Mar 2025 08:08:32 GMT
server: uvicorn
content-length: 8

Accepted

第四个链接,请求如下,请求tools/list, 服务器在第一个get的链接,通过event的方式返回了这个列表给mcp sse client


第四个链接,仅加复 202 Accepted


POST /messages/?session_id=9aa12073a4494d5580a5c30ed54c4bfd HTTP/1.1
host: 10.0.105.64:8080
connection: keep-alive
content-type: application/json
accept: */*
accept-language: *
sec-fetch-mode: cors
user-agent: node
accept-encoding: gzip, deflate
content-length: 46

{"method":"tools/list","jsonrpc":"2.0","id":1}
HTTP/1.1 202 Accepted
date: Wed, 12 Mar 2025 08:08:32 GMT
server: uvicorn
content-length: 8

Accepted

1-3完成就是属于初始化完成,mcp sse的client和server 连接起来了。

然后后面使用mcp call 调用的,在cursor chat里输入

call mcp tool search_coding_preferences about StdioServerTransport

就是新起一个http短链接,post到endpoint,如下

POST /messages/?session_id=97a44bcff590415e99cf803350ffd542 HTTP/1.1
host: 10.0.105.64:8080
connection: keep-alive
content-type: application/json
accept: */*
accept-language: *
sec-fetch-mode: cors
user-agent: node
accept-encoding: gzip, deflate
content-length: 143

{"method":"tools/call","params":{"name":"search_coding_preferences","arguments":{"query":"about StdioServerTransport"}},"jsonrpc":"2.0","id":3}HTTP/1.1 202 Accepted
date: Wed, 12 Mar 2025 09:10:43 GMT
server: uvicorn
content-length: 8

HTTP/1.1 202 Accepted
date: Wed, 12 Mar 2025 09:10:43 GMT
server: uvicorn
content-length: 8

Accepted

第一个链接就是会有一个通知返回如下:

event: message
data: {"jsonrpc":"2.0","id":3,"result":{"content":[{"type":"text","text":"[]"}],"isError":false}}

相关文章:

  • 波特率、比特率、传信率、传码率......
  • 17 | 实现简洁架构的 Biz 层
  • 前端轮播图carousel案例(带详细注释)
  • 深入探索 Java Stream
  • 赶紧白P这款免费神器!
  • AGI大模型(3):大模型生成内容
  • 【ES6】在ES6中自定义数组
  • STM32 HAL库实战:高效整合DMA与ADC开发指南
  • 向智能辅助驾驶的道路车道线检测算法研究
  • Franka机器人ROS 2 发布:赋能机器人研究和行业应用
  • 职坐标IT技能提升全攻略
  • 得物,蓝禾,快手,优博讯,三七互娱,途游游戏,顺丰,oppo,游卡,汤臣倍健,康冠科技,作业帮25春招内推
  • 驾培市场与低空经济无人机融合技术详解
  • MongoDB分页实现方式对比:PageRequest vs Skip/Limit
  • 用C# Newtonsoft.Json库实现JSON数据中某个字段值的提取
  • 【Academy】XML 外部实体 (XXE) 注入 ------ XML external entity (XXE) injection
  • 13 | 实现统一的错误返回
  • 线程同步与互斥
  • 【简答题003】Java运算符简答题
  • 卷积神经网络(笔记02)
  • 西藏日喀则市拉孜县发生5.5级地震,震源深度10公里
  • 江西省司法厅厅长张强已任江西省委政法委分管日常工作副书记
  • 白宫启动“返乡计划” ,鼓励非法移民自愿离开美国
  • 拿出压箱底作品,北京交响乐团让上海观众享受音乐盛宴
  • 上海市委常委会会议暨市生态文明建设领导小组会议研究基层减负、生态环保等事项
  • 中国象棋协会坚决支持司法机关依法打击涉象棋行业的违法行为