{"id":35329,"date":"2025-05-04T10:50:49","date_gmt":"2025-05-04T02:50:49","guid":{"rendered":"https:\/\/www.wsisp.com\/helps\/35329.html"},"modified":"2025-05-04T10:50:49","modified_gmt":"2025-05-04T02:50:49","slug":"%e3%80%90mcp-node-js-sdk-%e5%85%a8%e6%a0%88%e8%bf%9b%e9%98%b6%e6%8c%87%e5%8d%97%e3%80%91%e9%ab%98%e7%ba%a7%e7%af%87%ef%bc%881%ef%bc%89%ef%bc%9amcp%e5%a4%9a%e6%9c%8d%e5%8a%a1%e5%99%a8%e5%8d%8f%e4%bd%9c","status":"publish","type":"post","link":"https:\/\/www.wsisp.com\/helps\/35329.html","title":{"rendered":"\u3010MCP Node.js SDK \u5168\u6808\u8fdb\u9636\u6307\u5357\u3011\u9ad8\u7ea7\u7bc7\uff081\uff09\uff1aMCP\u591a\u670d\u52a1\u5668\u534f\u4f5c\u67b6\u6784"},"content":{"rendered":"

\u968f\u7740\u4e1a\u52a1\u89c4\u6a21\u7684\u4e0d\u65ad\u6269\u5927\u548c\u7cfb\u7edf\u590d\u6742\u5ea6\u7684\u63d0\u5347\uff0c\u5355\u4e00\u670d\u52a1\u5668\u67b6\u6784\u5f80\u5f80\u65e0\u6cd5\u6ee1\u8db3\u9ad8\u5e76\u53d1\u3001\u9ad8\u53ef\u7528\u6027\u548c\u5f39\u6027\u6269\u5c55\u7684\u9700\u6c42\u3002\u5728MCP\u751f\u6001\u7cfb\u7edf\u4e2d\uff0c\u591a\u670d\u52a1\u5668\u534f\u4f5c\u67b6\u6784\u6210\u4e3a\u6784\u5efa\u5927\u89c4\u6a21\u5e94\u7528\u7684\u5fc5\u7136\u9009\u62e9\u3002\u672c\u6587\u5c06\u6df1\u5165\u63a2\u8ba8MCP TypeScript-SDK\u5728\u591a\u670d\u52a1\u5668\u73af\u5883\u4e0b\u7684\u90e8\u7f72\u3001\u534f\u4f5c\u548c\u7ba1\u7406\uff0c\u4ee5\u53ca\u5982\u4f55\u6784\u5efa\u9ad8\u53ef\u7528\u3001\u9ad8\u6027\u80fd\u3001\u6613\u6269\u5c55\u7684\u5206\u5e03\u5f0fMCP\u5e94\u7528\u3002<\/p>\n

\u76ee\u5f55<\/h3>\n
  • \n

    \u591a\u670d\u52a1\u5668\u67b6\u6784\u57fa\u7840 1.1 MCP\u591a\u670d\u52a1\u5668\u67b6\u6784\u6982\u8ff0 1.2 \u5206\u5e03\u5f0f\u7cfb\u7edf\u7684\u6311\u6218\u4e0e\u89e3\u51b3\u65b9\u6848 1.3 MCP\u670d\u52a1\u5668\u5206\u7c7b\u4e0e\u804c\u8d23\u5212\u5206 1.4 \u591a\u670d\u52a1\u5668\u67b6\u6784\u7684\u5e38\u89c1\u6a21\u5f0f<\/p>\n<\/li>\n

  • \n

    \u670d\u52a1\u53d1\u73b0\u4e0e\u8def\u7531 2.1 \u670d\u52a1\u6ce8\u518c\u4e0e\u53d1\u73b0\u673a\u5236 2.2 \u57fa\u4e8eDNS\u7684\u670d\u52a1\u53d1\u73b0 2.3 \u52a8\u6001\u8def\u7531\u4e0e\u8d1f\u8f7d\u5747\u8861 2.4 \u670d\u52a1\u5065\u5eb7\u68c0\u67e5\u4e0e\u81ea\u52a8\u6062\u590d<\/p>\n<\/li>\n

  • \n

    \u72b6\u6001\u540c\u6b65\u4e0e\u4e00\u81f4\u6027 3.1 \u5206\u5e03\u5f0f\u72b6\u6001\u7ba1\u7406\u7b56\u7565 3.2 \u4e8b\u4ef6\u9a71\u52a8\u7684\u72b6\u6001\u540c\u6b65 3.3 \u5b9e\u73b0\u6700\u7ec8\u4e00\u81f4\u6027 3.4 \u6570\u636e\u5206\u533a\u4e0e\u51b2\u7a81\u89e3\u51b3<\/p>\n<\/li>\n

  • \n

    \u8d1f\u8f7d\u5747\u8861\u4e0e\u5bb9\u9519\u8bbe\u8ba1 4.1 \u8d1f\u8f7d\u5747\u8861\u7b56\u7565\u4e0e\u5b9e\u73b0 4.2 \u6545\u969c\u68c0\u6d4b\u4e0e\u81ea\u52a8\u6062\u590d 4.3 \u4f18\u96c5\u964d\u7ea7\u4e0e\u7194\u65ad\u673a\u5236 4.4 \u6784\u5efa\u9ad8\u53ef\u7528MCP\u96c6\u7fa4<\/p>\n<\/li>\n

    1. \u591a\u670d\u52a1\u5668\u67b6\u6784\u57fa\u7840<\/h3>\n

    \u5728\u6df1\u5165\u63a2\u8ba8MCP\u591a\u670d\u52a1\u5668\u534f\u4f5c\u4e4b\u524d\uff0c\u6211\u4eec\u9700\u8981\u5148\u4e86\u89e3\u591a\u670d\u52a1\u5668\u67b6\u6784\u7684\u6838\u5fc3\u6982\u5ff5\u3001\u6311\u6218\u4ee5\u53caMCP SDK\u63d0\u4f9b\u7684\u89e3\u51b3\u65b9\u6848\u3002<\/p>\n

    1.1 MCP\u591a\u670d\u52a1\u5668\u67b6\u6784\u6982\u8ff0<\/h4>\n

    MCP\uff08Model Context Protocol\uff09\u4f5c\u4e3a\u4e00\u79cd\u4e3a\u5927\u578b\u8bed\u8a00\u6a21\u578b\uff08LLM\uff09\u4ea4\u4e92\u8bbe\u8ba1\u7684\u534f\u8bae\uff0c\u5176\u670d\u52a1\u67b6\u6784\u9700\u8981\u9002\u5e94\u590d\u6742\u591a\u53d8\u7684\u4e1a\u52a1\u573a\u666f\u548c\u8d1f\u8f7d\u6a21\u5f0f\u3002\u591a\u670d\u52a1\u5668MCP\u67b6\u6784\u662f\u6307\u5c06MCP\u670d\u52a1\u5206\u5e03\u5728\u591a\u4e2a\u7269\u7406\u6216\u865a\u62df\u670d\u52a1\u5668\u4e0a\uff0c\u901a\u8fc7\u534f\u4f5c\u65b9\u5f0f\u63d0\u4f9b\u7edf\u4e00\u7684\u670d\u52a1\u80fd\u529b\u3002<\/p>\n

    \/\/ MCP\u670d\u52a1\u5668\u5b9e\u4f8b\u7c7b\u578b<\/span>
    \ninterface<\/span> McpServerInstance<\/span> {
    \n <\/span>
    \n id:<\/span> string<\/span>;<\/span> \/\/ \u670d\u52a1\u5668\u552f\u4e00\u6807\u8bc6<\/span>
    \n host:<\/span> string<\/span>;<\/span> \/\/ \u4e3b\u673a\u5730\u5740<\/span>
    \n port:<\/span> number<\/span>;<\/span> \/\/ \u7aef\u53e3\u53f7<\/span>
    \n role:<\/span> \\’master\\’<\/span> |<\/span> \\’worker\\’<\/span> |<\/span> \\’specialized\\’<\/span>;<\/span> \/\/ \u670d\u52a1\u5668\u89d2\u8272<\/span>
    \n status:<\/span> \\’online\\’<\/span> |<\/span> \\’offline\\’<\/span> |<\/span> \\’degraded\\’<\/span>;<\/span> \/\/ \u670d\u52a1\u5668\u72b6\u6001<\/span>
    \n capacity:<\/span> {
    \n <\/span> \/\/ \u670d\u52a1\u5668\u5bb9\u91cf\u4fe1\u606f<\/span>
    \n maxConcurrentRequests:<\/span> number<\/span>;<\/span>
    \n currentLoad:<\/span> number<\/span>;<\/span>
    \n }<\/span>;<\/span>
    \n features:<\/span> string<\/span>[<\/span>]<\/span>;<\/span> \/\/ \u652f\u6301\u7684\u7279\u6027<\/span>
    \n startTime:<\/span> Date;<\/span> \/\/ \u542f\u52a8\u65f6\u95f4<\/span>
    \n}<\/span><\/p>\n

    \/\/ \u591a\u670d\u52a1\u5668\u96c6\u7fa4\u914d\u7f6e<\/span>
    \ninterface<\/span> McpClusterConfig<\/span> {
    \n <\/span>
    \n serviceName:<\/span> string<\/span>;<\/span> \/\/ \u670d\u52a1\u540d\u79f0<\/span>
    \n serviceVersion:<\/span> string<\/span>;<\/span>\/\/ \u670d\u52a1\u7248\u672c<\/span>
    \n discoveryMethod:<\/span> \\’static\\’<\/span> |<\/span> \\’dns\\’<\/span> |<\/span> \\’registry\\’<\/span>;<\/span> \/\/ \u670d\u52a1\u53d1\u73b0\u65b9\u5f0f<\/span>
    \n heartbeatInterval:<\/span> number<\/span>;<\/span> \/\/ \u5fc3\u8df3\u95f4\u9694<\/span>
    \n syncStrategy:<\/span> \\’event-based\\’<\/span> |<\/span> \\’polling\\’<\/span> |<\/span> \\’hybrid\\’<\/span>;<\/span> \/\/ \u540c\u6b65\u7b56\u7565<\/span>
    \n loadBalanceStrategy:<\/span> \\’round-robin\\’<\/span> |<\/span> \\’least-connections\\’<\/span> |<\/span> \\’consistent-hash\\’<\/span>;<\/span> \/\/ \u8d1f\u8f7d\u5747\u8861\u7b56\u7565<\/span>
    \n failoverPolicy:<\/span> {
    \n <\/span> \/\/ \u6545\u969c\u8f6c\u79fb\u7b56\u7565<\/span>
    \n retryAttempts:<\/span> number<\/span>;<\/span>
    \n retryDelay:<\/span> number<\/span>;<\/span>
    \n circuitBreakerThreshold:<\/span> number<\/span>;<\/span>
    \n }<\/span>;<\/span>
    \n}<\/span><\/p>\n

    \u591a\u670d\u52a1\u5668MCP\u67b6\u6784\u5177\u6709\u4ee5\u4e0b\u51e0\u4e2a\u6838\u5fc3\u7279\u70b9\uff1a<\/p>\n

  • \u6c34\u5e73\u6269\u5c55\u6027\uff1a\u901a\u8fc7\u589e\u52a0\u670d\u52a1\u5668\u6570\u91cf\u6765\u7ebf\u6027\u63d0\u5347\u7cfb\u7edf\u6574\u4f53\u5904\u7406\u80fd\u529b<\/li>\n
  • \u9ad8\u53ef\u7528\u6027\uff1a\u5373\u4f7f\u90e8\u5206\u670d\u52a1\u5668\u6545\u969c\uff0c\u7cfb\u7edf\u6574\u4f53\u4ecd\u53ef\u6301\u7eed\u63d0\u4f9b\u670d\u52a1<\/li>\n
  • \u8d1f\u8f7d\u5206\u6563\uff1a\u5c06\u8bf7\u6c42\u8d1f\u8f7d\u5206\u6563\u5230\u591a\u4e2a\u670d\u52a1\u5668\uff0c\u907f\u514d\u5355\u70b9\u538b\u529b\u8fc7\u5927<\/li>\n
  • \u8d44\u6e90\u9694\u79bb\uff1a\u53ef\u6309\u4e1a\u52a1\u529f\u80fd\u6216\u5ba2\u6237\u9700\u6c42\u9694\u79bb\u8d44\u6e90\uff0c\u63d0\u9ad8\u5b89\u5168\u6027\u548c\u7a33\u5b9a\u6027<\/li>\n
  • \u7075\u6d3b\u90e8\u7f72\uff1a\u652f\u6301\u6df7\u5408\u4e91\u3001\u591a\u533a\u57df\u3001\u8fb9\u7f18\u8ba1\u7b97\u7b49\u591a\u6837\u5316\u90e8\u7f72\u6a21\u5f0f<\/li>\n

    1.2 \u5206\u5e03\u5f0f\u7cfb\u7edf\u7684\u6311\u6218\u4e0e\u89e3\u51b3\u65b9\u6848<\/h4>\n

    \u6784\u5efa\u5206\u5e03\u5f0fMCP\u670d\u52a1\u9762\u4e34\u4e00\u7cfb\u5217\u6311\u6218\uff0cMCP TypeScript-SDK\u9488\u5bf9\u8fd9\u4e9b\u6311\u6218\u63d0\u4f9b\u4e86\u76f8\u5e94\u7684\u89e3\u51b3\u65b9\u6848\uff1a<\/p>\n\n\n \u6311\u6218
    \n \u8868\u73b0
    \n MCP SDK\u89e3\u51b3\u65b9\u6848
    \n <\/tr>\n\n\n\n\n\n\n
    \u7f51\u7edc\u4e0d\u53ef\u9760<\/td>\n\u7f51\u7edc\u5ef6\u8fdf\u3001\u5206\u533a\u3001\u4e22\u5305<\/td>\n\u91cd\u8bd5\u673a\u5236\u3001\u5f02\u6b65\u901a\u4fe1\u3001\u65ad\u7ebf\u91cd\u8fde<\/td>\n<\/tr>\n
    \u4e00\u81f4\u6027\u95ee\u9898<\/td>\n\u6570\u636e\u4e0d\u4e00\u81f4\u3001\u51b2\u7a81<\/td>\n\u4e8b\u4ef6\u9a71\u52a8\u540c\u6b65\u3001\u7248\u672c\u63a7\u5236\u3001\u51b2\u7a81\u89e3\u51b3\u7b56\u7565<\/td>\n<\/tr>\n
    \u670d\u52a1\u534f\u8c03<\/td>\n\u670d\u52a1\u53d1\u73b0\u3001\u8def\u7531<\/td>\n\u670d\u52a1\u6ce8\u518c\u8868\u3001\u670d\u52a1\u5065\u5eb7\u68c0\u67e5\u3001\u52a8\u6001\u8def\u7531<\/td>\n<\/tr>\n
    \u6545\u969c\u5904\u7406<\/td>\n\u8282\u70b9\u6545\u969c\u3001\u670d\u52a1\u964d\u7ea7<\/td>\n\u6545\u969c\u68c0\u6d4b\u3001\u81ea\u52a8\u6062\u590d\u3001\u7194\u65ad\u673a\u5236<\/td>\n<\/tr>\n
    \u6027\u80fd\u74f6\u9888<\/td>\n\u8bf7\u6c42\u62e5\u585e\u3001\u8d44\u6e90\u7ade\u4e89<\/td>\n\u8d1f\u8f7d\u5747\u8861\u3001\u8bf7\u6c42\u9650\u6d41\u3001\u8d44\u6e90\u9694\u79bb<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n

    \/\/ MCP\u670d\u52a1\u5668\u6545\u969c\u5904\u7406\u914d\u7f6e<\/span>
    \ninterface<\/span> McpFailoverConfig<\/span> {
    \n <\/span>
    \n detection:<\/span> {
    \n <\/span>
    \n method:<\/span> \\’heartbeat\\’<\/span> |<\/span> \\’ping\\’<\/span> |<\/span> \\’health-endpoint\\’<\/span>;<\/span>
    \n interval:<\/span> number<\/span>;<\/span> \/\/ \u68c0\u6d4b\u95f4\u9694<\/span>
    \n timeout:<\/span> number<\/span>;<\/span> \/\/ \u8d85\u65f6\u65f6\u95f4<\/span>
    \n thresholds:<\/span> {
    \n <\/span>
    \n warning:<\/span> number<\/span>;<\/span> \/\/ \u8b66\u544a\u9608\u503c<\/span>
    \n critical:<\/span> number<\/span>;<\/span> \/\/ \u4e34\u754c\u9608\u503c<\/span>
    \n }<\/span>
    \n }<\/span>;<\/span>
    \n recovery:<\/span> {
    \n <\/span>
    \n strategy:<\/span> \\’restart\\’<\/span> |<\/span> \\’replace\\’<\/span> |<\/span> \\’redirect\\’<\/span>;<\/span>
    \n cooldownPeriod:<\/span> number<\/span>;<\/span> \/\/ \u51b7\u5374\u65f6\u95f4<\/span>
    \n maxAttempts:<\/span> number<\/span>;<\/span> \/\/ \u6700\u5927\u5c1d\u8bd5\u6b21\u6570<\/span>
    \n }<\/span>;<\/span>
    \n notification:<\/span> {
    \n <\/span>
    \n channels:<\/span> string<\/span>[<\/span>]<\/span>;<\/span> \/\/ \u901a\u77e5\u6e20\u9053<\/span>
    \n templates:<\/span> Record<<\/span>string<\/span>,<\/span> string<\/span>><\/span>;<\/span> \/\/ \u901a\u77e5\u6a21\u677f<\/span>
    \n }<\/span>
    \n}<\/span><\/p>\n

    1.3 MCP\u670d\u52a1\u5668\u5206\u7c7b\u4e0e\u804c\u8d23\u5212\u5206<\/h4>\n

    \u5728\u591a\u670d\u52a1\u5668\u67b6\u6784\u4e2d\uff0c\u4e0d\u540c\u7684MCP\u670d\u52a1\u5668\u53ef\u4ee5\u627f\u62c5\u4e0d\u540c\u7684\u89d2\u8272\u548c\u804c\u8d23\uff0c\u5b9e\u73b0\u529f\u80fd\u5206\u79bb\u548c\u4e13\u4e1a\u5316\uff1a<\/p>\n

    1.3.1 \u6309\u89d2\u8272\u5206\u7c7b<\/h5>\n
  • \n

    \u4e3b\u670d\u52a1\u5668\uff08Master\uff09\uff1a<\/p>\n

      \n
    • \u7ba1\u7406\u96c6\u7fa4\u72b6\u6001\u548c\u914d\u7f6e<\/li>\n
    • \u534f\u8c03\u8de8\u670d\u52a1\u5668\u7684\u8d44\u6e90\u5206\u914d<\/li>\n
    • \u76d1\u63a7\u96c6\u7fa4\u5065\u5eb7\u72b6\u6001<\/li>\n
    • \u901a\u5e38\u90e8\u7f72\u8f83\u5c11\u6570\u91cf\uff0c\u914d\u7f6e\u8f83\u9ad8<\/li>\n<\/ul>\n<\/li>\n
    • \n

      \u5de5\u4f5c\u670d\u52a1\u5668\uff08Worker\uff09\uff1a<\/p>\n

        \n
      • \u5904\u7406\u5ba2\u6237\u7aef\u7684\u5b9e\u9645\u8bf7\u6c42<\/li>\n
      • \u6267\u884cMCP\u8d44\u6e90\u8bbf\u95ee\u548c\u5de5\u5177\u8c03\u7528<\/li>\n
      • \u53ef\u5927\u89c4\u6a21\u90e8\u7f72\uff0c\u6784\u6210\u7cfb\u7edf\u5904\u7406\u80fd\u529b\u7684\u4e3b\u4f53<\/li>\n
      • \u901a\u5e38\u662f\u65e0\u72b6\u6001\u7684\uff0c\u4fbf\u4e8e\u6a2a\u5411\u6269\u5c55<\/li>\n<\/ul>\n<\/li>\n
      • \n

        \u4e13\u7528\u670d\u52a1\u5668\uff08Specialized\uff09\uff1a<\/p>\n

          \n
        • \u4e13\u6ce8\u4e8e\u7279\u5b9a\u529f\u80fd\u6216\u4e1a\u52a1\u573a\u666f<\/li>\n
        • \u4f8b\u5982\uff1aAI\u63a8\u7406\u670d\u52a1\u5668\u3001\u6570\u636e\u5904\u7406\u670d\u52a1\u5668\u7b49<\/li>\n
        • \u53ef\u6839\u636e\u9700\u6c42\u5b9a\u5236\u5316\u914d\u7f6e<\/li>\n
        • \u9002\u5408\u8d44\u6e90\u5bc6\u96c6\u578b\u6216\u5b89\u5168\u654f\u611f\u578b\u4e1a\u52a1<\/li>\n<\/ul>\n<\/li>\n

          \/\/ MCP\u670d\u52a1\u5668\u89d2\u8272\u5b9a\u4e49\u548c\u804c\u8d23\u914d\u7f6e<\/span>
          \nimport<\/span> {
          \n <\/span> McpServer }<\/span> from<\/span> \\’@modelcontextprotocol\/sdk\\’<\/span>;<\/span><\/p>\n

          \/\/ \u4e3b\u670d\u52a1\u5668\u914d\u7f6e<\/span>
          \nconst<\/span> masterConfig =<\/span> {
          \n <\/span>
          \n name:<\/span> \\”mcp-master-server\\”<\/span>,<\/span>
          \n description:<\/span> \\”MCP\u96c6\u7fa4\u4e3b\u670d\u52a1\u5668\\”<\/span>,<\/span>
          \n version:<\/span> \\”1.0.0\\”<\/span>,<\/span>
          \n cluster:<\/span> {
          \n <\/span>
          \n role:<\/span> \\”master\\”<\/span>,<\/span>
          \n workers:<\/span> [<\/span>\\”worker-1\\”<\/span>,<\/span> \\”worker-2\\”<\/span>,<\/span> \\”worker-3\\”<\/span>]<\/span>,<\/span>
          \n electionStrategy:<\/span> \\”fixed\\”<\/span>,<\/span> \/\/ \u56fa\u5b9a\u4e3b\u670d\u52a1\u5668<\/span>
          \n stateSync:<\/span> {
          \n <\/span>
          \n method:<\/span> \\”push\\”<\/span>,<\/span>
          \n interval:<\/span> 5000<\/span>
          \n }<\/span>
          \n }<\/span>
          \n}<\/span>;<\/span><\/p>\n

          \/\/ \u5de5\u4f5c\u670d\u52a1\u5668\u914d\u7f6e<\/span>
          \nconst<\/span> workerConfig =<\/span> {
          \n <\/span>
          \n name:<\/span> \\”mcp-worker-server\\”<\/span>,<\/span>
          \n description:<\/span> \\”MCP\u96c6\u7fa4\u5de5\u4f5c\u670d\u52a1\u5668\\”<\/span>,<\/span>
          \n version:<\/span> \\”1.0.0\\”<\/span>,<\/span>
          \n cluster:<\/span> {
          \n <\/span>
          \n role:<\/span> \\”worker\\”<\/span>,<\/span>
          \n masterId:<\/span> \\”master-1\\”<\/span>,<\/span>
          \n maxConcurrentRequests:<\/span> 1000<\/span>,<\/span>
          \n resourceCacheSize:<\/span> 500<\/span>,<\/span>
          \n reportInterval:<\/span> 2000<\/span>
          \n }<\/span>
          \n}<\/span>;<\/span><\/p>\n

          \/\/ \u4e13\u7528\u670d\u52a1\u5668\u914d\u7f6e<\/span>
          \nconst<\/span> specializedConfig =<\/span> {
          \n <\/span>
          \n name:<\/span> \\”mcp-specialized-server\\”<\/span>,<\/span>
          \n description:<\/span> \\”MCP\u56fe\u50cf\u5904\u7406\u4e13\u7528\u670d\u52a1\u5668\\”<\/span>,<\/span>
          \n version:<\/span> \\”1.0.0\\”<\/span>,<\/span>
          \n cluster:<\/span> {
          \n <\/span>
          \n role:<\/span> \\”specialized\\”<\/span>,<\/span>
          \n serviceType:<\/span> \\”image-processing\\”<\/span>,<\/span>
          \n supportedOperations:<\/span> [<\/span>\\”resize\\”<\/span>,<\/span> \\”filter\\”<\/span>,<\/span> \\”recognize\\”<\/span>]<\/span>,<\/span>
          \n resourceRequirements:<\/span> {
          \n <\/span>
          \n gpu:<\/span> true<\/span>,<\/span>
          \n minMemory:<\/span> \\”16G\\”<\/span>,<\/span>
          \n cpuCores:<\/span> 8<\/span>
          \n }<\/span>
          \n }<\/span>
          \n}<\/span>;<\/span><\/p>\n

          1.3.2 \u6309\u529f\u80fd\u5206\u7c7b<\/h5>\n
        • \n

          API\u7f51\u5173\u670d\u52a1\u5668\uff1a<\/p>\n

            \n
          • \u8bf7\u6c42\u8def\u7531\u548c\u8d1f\u8f7d\u5747\u8861<\/li>\n
          • \u8ba4\u8bc1\u548c\u6388\u6743\u5904\u7406<\/li>\n
          • \u8bf7\u6c42\u9650\u6d41\u548c\u7f13\u5b58<\/li>\n
          • \u8bf7\u6c42\/\u54cd\u5e94\u8f6c\u6362<\/li>\n<\/ul>\n<\/li>\n
          • \n

            \u8d44\u6e90\u670d\u52a1\u5668\uff1a<\/p>\n

              \n
            • \u7ba1\u7406MCP\u8d44\u6e90\u6a21\u677f<\/li>\n
            • \u5904\u7406\u8d44\u6e90\u8bbf\u95ee\u8bf7\u6c42<\/li>\n
            • \u8d44\u6e90\u7f13\u5b58\u548c\u4f18\u5316<\/li>\n
            • \u8d44\u6e90\u7248\u672c\u63a7\u5236<\/li>\n<\/ul>\n<\/li>\n
            • \n

              \u5de5\u5177\u670d\u52a1\u5668\uff1a<\/p>\n

                \n
              • \u6258\u7ba1\u548c\u6267\u884cMCP\u5de5\u5177<\/li>\n
              • \u5de5\u5177\u4f9d\u8d56\u7ba1\u7406<\/li>\n
              • \u5de5\u5177\u6267\u884c\u73af\u5883\u9694\u79bb<\/li>\n
              • \u5de5\u5177\u6027\u80fd\u76d1\u63a7<\/li>\n<\/ul>\n<\/li>\n
              • \n

                \u72b6\u6001\u540c\u6b65\u670d\u52a1\u5668\uff1a<\/p>\n

                  \n
                • \u7ef4\u62a4\u5168\u5c40\u72b6\u6001<\/li>\n
                • \u534f\u8c03\u8de8\u670d\u52a1\u5668\u72b6\u6001\u540c\u6b65<\/li>\n
                • \u5904\u7406\u5206\u5e03\u5f0f\u4e8b\u52a1<\/li>\n
                • \u89e3\u51b3\u6570\u636e\u51b2\u7a81<\/li>\n<\/ul>\n<\/li>\n

                  \/\/ \u6309\u529f\u80fd\u5212\u5206\u7684MCP\u670d\u52a1\u5668\u5b9e\u73b0\u793a\u4f8b<\/span>
                  \nimport<\/span> {
                  \n <\/span> McpServer }<\/span> from<\/span> \\’@modelcontextprotocol\/sdk\\’<\/span>;<\/span>
                  \nimport<\/span> express from<\/span> \\’express\\’<\/span>;<\/span>
                  \nimport<\/span> {
                  \n <\/span> createProxyMiddleware }<\/span> from<\/span> \\’http-proxy-middleware\\’<\/span>;<\/span><\/p>\n

                  \/\/ API\u7f51\u5173\u670d\u52a1\u5668<\/span>
                  \nconst<\/span> apiGatewayApp =<\/span> express<\/span>(<\/span>)<\/span>;<\/span>
                  \nconst<\/span> apiGatewayServer =<\/span> new<\/span> McpServer<\/span>(<\/span>{
                  \n <\/span>
                  \n name:<\/span> \\”mcp-api-gateway\\”<\/span>,<\/span>
                  \n description:<\/span> \\”MCP API\u7f51\u5173\u670d\u52a1\u5668\\”<\/span>,<\/span>
                  \n version:<\/span> \\”1.0.0\\”<\/span>
                  \n}<\/span>)<\/span>;<\/span><\/p>\n

                  \/\/ \u8def\u7531\u914d\u7f6e<\/span>
                  \nconst<\/span> routeConfig =<\/span> {
                  \n <\/span>
                  \n \\’\/api\/resources\\’<\/span>:<\/span> {
                  \n <\/span> target:<\/span> \\’http:\/\/resource-server:3001\\’<\/span>,<\/span> pathRewrite:<\/span> {
                  \n <\/span>\\’^\/api\\’<\/span>:<\/span> \\’\\’<\/span>}<\/span> }<\/span>,<\/span>
                  \n \\’\/api\/tools\\’<\/span>:<\/span> {
                  \n <\/span> target:<\/span> \\’http:\/\/tool-server:3002\\’<\/span>,<\/span> pathRewrite:<\/span> {
                  \n <\/span>\\’^\/api\\’<\/span>:<\/span> \\’\\’<\/span>}<\/span> }<\/span>
                  \n}<\/span>;<\/span><\/p>\n

                  \/\/ \u8bbe\u7f6eAPI\u4ee3\u7406<\/span>
                  \nObject.<\/span>entries<\/span>(<\/span>routeConfig)<\/span>.<\/span>forEach<\/span>(<\/span>(<\/span>[<\/span>path,<\/span> config]<\/span>)<\/span> =><\/span> {
                  \n <\/span>
                  \n apiGatewayApp.<\/span>use<\/span>(<\/span>path,<\/span> createProxyMiddleware<\/span>(<\/span>config)<\/span>)<\/span>;<\/span>
                  \n}<\/span>)<\/span>;<\/span><\/p>\n

                  \/\/ \u8d44\u6e90\u670d\u52a1\u5668<\/span>
                  \nconst<\/span> resourceServer =<\/span> new<\/span> McpServer<\/span>(<\/span>{
                  \n <\/span>
                  \n name:<\/span> \\”mcp-resource-server\\”<\/span>,<\/span>
                  \n description:<\/span> \\”MCP\u8d44\u6e90\u670d\u52a1\u5668\\”<\/span>,<\/span>
                  \n version:<\/span> \\”1.0.0\\”<\/span>
                  \n}<\/span>)<\/span>;<\/span><\/p>\n

                  \/\/ \u6ce8\u518c\u8d44\u6e90\u6a21\u677f<\/span>
                  \nresourceServer.<\/span>registerResourceTemplate<\/span>(<\/span>{
                  \n <\/span>
                  \n name:<\/span> \\”users\\”<\/span>,<\/span>
                  \n description:<\/span> \\”\u7528\u6237\u8d44\u6e90\\”<\/span>,<\/span>
                  \n schema:<\/span> userSchema
                  \n}<\/span>)<\/span>;<\/span><\/p>\n

                  \/\/ \u5de5\u5177\u670d\u52a1\u5668<\/span>
                  \nconst<\/span> toolServer =<\/span> new<\/span> McpServer<\/span>(<\/span>{
                  \n <\/span>
                  \n name:<\/span> \\”mcp-tool-server\\”<\/span>,<\/span>
                  \n description:<\/span> \\”MCP\u5de5\u5177\u670d\u52a1\u5668\\”<\/span>,<\/span>
                  \n version:<\/span> \\”1.0.0\\”<\/span>
                  \n}<\/span>)<\/span>;<\/span><\/p>\n

                  \/\/ \u6ce8\u518c\u5de5\u5177<\/span>
                  \ntoolServer.<\/span>registerTool<\/span>(<\/span>{
                  \n <\/span>
                  \n name:<\/span> \\”calculator\\”<\/span>,<\/span>
                  \n description:<\/span> \\”\u8ba1\u7b97\u5de5\u5177\\”<\/span>,<\/span>
                  \n parameters:<\/span> calculatorSchema,<\/span>
                  \n execute<\/span>:<\/span> async<\/span> (<\/span>params)<\/span> =><\/span> {
                  \n <\/span>
                  \n \/\/ \u8ba1\u7b97\u903b\u8f91<\/span>
                  \n return<\/span> {
                  \n <\/span> result:<\/span> calculateExpression<\/span>(<\/span>params.<\/span>expression)<\/span> }<\/span>;<\/span>
                  \n }<\/span>
                  \n}<\/span>)<\/span>;<\/span><\/p>\n

                  1.4 \u591a\u670d\u52a1\u5668\u67b6\u6784\u7684\u5e38\u89c1\u6a21\u5f0f<\/h4>\n

                  \u5728\u5b9e\u9645\u5e94\u7528\u4e2d\uff0cMCP\u591a\u670d\u52a1\u5668\u67b6\u6784\u53ef\u4ee5\u91c7\u7528\u591a\u79cd\u6a21\u5f0f\uff0c\u6839\u636e\u4e1a\u52a1\u9700\u6c42\u548c\u8d44\u6e90\u6761\u4ef6\u7075\u6d3b\u9009\u62e9\uff1a<\/p>\n

                  1.4.1 \u4e3b\u4ece\u6a21\u5f0f\uff08Master-Slave\uff09<\/h5>\n

                  \u6700\u5e38\u89c1\u7684\u5206\u5e03\u5f0f\u67b6\u6784\u6a21\u5f0f\uff0c\u4e00\u4e2a\u4e3b\u670d\u52a1\u5668\u534f\u8c03\u591a\u4e2a\u4ece\u670d\u52a1\u5668\u7684\u5de5\u4f5c\u3002<\/p>\n

                  \u250c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2510 \u250c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2510
                  \n\u2502 \u2502 \u2502 \u2502
                  \n\u2502 Master \u2502\u25c4\u2500\u2500\u2500\u2500\u25ba\u2502 Slave 1 \u2502
                  \n\u2502 \u2502 \u2502 \u2502
                  \n\u2514\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2518 \u2514\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2518
                  \n \u25b2
                  \n \u2502
                  \n \u25bc
                  \n\u250c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2510 \u250c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2510
                  \n\u2502 \u2502 \u2502 \u2502
                  \n\u2502 Slave 2 \u2502\u25c4\u2500\u2500\u2500\u2500\u25ba\u2502 Slave 3 \u2502
                  \n\u2502 \u2502 \u2502 \u2502
                  \n\u2514\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2518 \u2514\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2518<\/p>\n

                  \/\/ \u4e3b\u4ece\u6a21\u5f0f\u5b9e\u73b0\u793a\u4f8b<\/span>
                  \nimport<\/span> {
                  \n <\/span> McpServer,<\/span> EventEmitter }<\/span> from<\/span> \\’@modelcontextprotocol\/sdk\\’<\/span>;<\/span>
                  \nimport<\/span> {
                  \n <\/span> createClient }<\/span> from<\/span> \\’redis\\’<\/span>;<\/span><\/p>\n

                  \/\/ \u521b\u5efaRedis\u5ba2\u6237\u7aef\u7528\u4e8e\u670d\u52a1\u5668\u95f4\u901a\u4fe1<\/span>
                  \nconst<\/span> pubClient =<\/span> createClient<\/span>(<\/span>{
                  \n <\/span> url:<\/span> process.<\/span>env.<\/span>REDIS_URL<\/span> }<\/span>)<\/span>;<\/span>
                  \nconst<\/span> subClient =<\/span> pubClient.<\/span>duplicate<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

                  \/\/ \u4e3b\u670d\u52a1\u5668\u5b9e\u73b0<\/span>
                  \nclass<\/span> MasterMcpServer<\/span> extends<\/span> McpServer<\/span> {
                  \n <\/span>
                  \n private<\/span> slaves:<\/span> Map<<\/span>string<\/span>,<\/span> SlaveInfo><\/span> =<\/span> new<\/span> Map<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

                  constructor<\/span>(<\/span>config)<\/span> {
                  \n <\/span>
                  \n super<\/span>(<\/span>config)<\/span>;<\/span><\/p>\n

                  \/\/ \u8ba2\u9605\u4ece\u670d\u52a1\u5668\u72b6\u6001\u66f4\u65b0<\/span>
                  \n subClient.<\/span>subscribe<\/span>(<\/span>\\’slave-status\\’<\/span>,<\/span> (<\/span>message)<\/span> =><\/span> {
                  \n <\/span>
                  \n const<\/span> slaveStatus =<\/span> JSON<\/span>.<\/span>parse<\/span>(<\/span>message)<\/span>;<\/span>
                  \n this<\/span>.<\/span>updateSlaveStatus<\/span>(<\/span>slaveStatus)<\/span>;<\/span>
                  \n }<\/span>)<\/span>;<\/span><\/p>\n

                  \/\/ \u5b9a\u671f\u68c0\u67e5\u4ece\u670d\u52a1\u5668\u5065\u5eb7\u72b6\u6001<\/span>
                  \n setInterval<\/span>(<\/span>(<\/span>)<\/span> =><\/span> this<\/span>.<\/span>checkSlavesHealth<\/span>(<\/span>)<\/span>,<\/span> 10000<\/span>)<\/span>;<\/span>
                  \n }<\/span><\/p>\n

                  \/\/ \u6ce8\u518c\u4ece\u670d\u52a1\u5668<\/span>
                  \n registerSlave<\/span>(<\/span>slaveId:<\/span> string<\/span>,<\/span> info:<\/span> SlaveInfo)<\/span> {
                  \n <\/span>
                  \n this<\/span>.<\/span>slaves.<\/span>set<\/span>(<\/span>slaveId,<\/span> {
                  \n <\/span> …<\/span>info,<\/span> lastHeartbeat:<\/span> Date.<\/span>now<\/span>(<\/span>)<\/span> }<\/span>)<\/span>;<\/span>
                  \n this<\/span>.<\/span>emit<\/span>(<\/span>\\’slave-registered\\’<\/span>,<\/span> {
                  \n <\/span> slaveId,<\/span> info }<\/span>)<\/span>;<\/span>
                  \n }<\/span><\/p>\n

                  \/\/ \u66f4\u65b0\u4ece\u670d\u52a1\u5668\u72b6\u6001<\/span>
                  \n updateSlaveStatus<\/span>(<\/span>status:<\/span> SlaveStatus)<\/span> {
                  \n <\/span>
                  \n const<\/span> slave =<\/span> this<\/span>.<\/span>slaves.<\/span>get<\/span>(<\/span>status.<\/span>slaveId)<\/span>;<\/span>
                  \n if<\/span> (<\/span>slave)<\/span> {
                  \n <\/span>
                  \n this<\/span>.<\/span>slaves.<\/span>set<\/span>(<\/span>status.<\/span>slaveId,<\/span> {
                  \n <\/span>
                  \n …<\/span>slave,<\/span>
                  \n …<\/span>status,<\/span>
                  \n lastHeartbeat:<\/span> Date.<\/span>now<\/span>(<\/span>)<\/span>
                  \n }<\/span>)<\/span>;<\/span>
                  \n }<\/span>
                  \n }<\/span><\/p>\n

                  \/\/ \u68c0\u67e5\u4ece\u670d\u52a1\u5668\u5065\u5eb7\u72b6\u6001<\/span>
                  \n checkSlavesHealth<\/span>(<\/span>)<\/span> {
                  \n <\/span>
                  \n const<\/span> now =<\/span> Date.<\/span>now<\/span>(<\/span>)<\/span>;<\/span>
                  \n for<\/span> (<\/span>const<\/span> [<\/span>slaveId,<\/span> info]<\/span> of<\/span> this<\/span>.<\/span>slaves.<\/span>entries<\/span>(<\/span>)<\/span>)<\/span> {
                  \n <\/span>
                  \n if<\/span> (<\/span>now –<\/span> info.<\/span>lastHeartbeat ><\/span> 30000<\/span>)<\/span> {
                  \n <\/span> \/\/ 30\u79d2\u65e0\u5fc3\u8df3<\/span>
                  \n this<\/span>.<\/span>emit<\/span>(<\/span>\\’slave-offline\\’<\/span>,<\/span> {
                  \n <\/span> slaveId }<\/span>)<\/span>;<\/span>
                  \n this<\/span>.<\/span>slaves.<\/span>delete<\/span>(<\/span>slaveId)<\/span>;<\/span>
                  \n }<\/span>
                  \n }<\/span>
                  \n }<\/span>
                  \n}<\/span><\/p>\n

                  \/\/ \u4ece\u670d\u52a1\u5668\u5b9e\u73b0<\/span>
                  \nclass<\/span> SlaveMcpServer<\/span> extends<\/span> McpServer<\/span> {
                  \n <\/span>
                  \n private<\/span> masterId:<\/span> string<\/span>;<\/span><\/p>\n

                  constructor<\/span>(<\/span>config)<\/span> {
                  \n <\/span>
                  \n super<\/span>(<\/span>config)<\/span>;<\/span>
                  \n this<\/span>.<\/span>masterId =<\/span> config.<\/span>masterId;<\/span><\/p>\n

                  \/\/ \u5b9a\u671f\u5411\u4e3b\u670d\u52a1\u5668\u53d1\u9001\u5fc3\u8df3<\/span>
                  \n setInterval<\/span>(<\/span>(<\/span>)<\/span> =><\/span> this<\/span>.<\/span>sendHeartbeat<\/span>(<\/span>)<\/span>,<\/span> 5000<\/span>)<\/span>;<\/span><\/p>\n

                  \/\/ \u8ba2\u9605\u4e3b\u670d\u52a1\u5668\u6307\u4ee4<\/span>
                  \n subClient.<\/span>subscribe<\/span>(<\/span>`<\/span>slave-command:<\/span>${
                  \n <\/span>this<\/span>.<\/span>id}<\/span><\/span>`<\/span><\/span>,<\/span> (<\/span>message)<\/span> =><\/span> {
                  \n <\/span>
                  \n this<\/span>.<\/span>handleMasterCommand<\/span>(<\/span>JSON<\/span>.<\/span>parse<\/span>(<\/span>message)<\/span>)<\/span>;<\/span>
                  \n }<\/span>)<\/span>;<\/span>
                  \n }<\/span><\/p>\n

                  \/\/ \u53d1\u9001\u5fc3\u8df3<\/span>
                  \n sendHeartbeat<\/span>(<\/span>)<\/span> {
                  \n <\/span>
                  \n const<\/span> status =<\/span> {
                  \n <\/span>
                  \n slaveId:<\/span> this<\/span>.<\/span>id,<\/span>
                  \n load:<\/span> this<\/span>.<\/span>getCurrentLoad<\/span>(<\/span>)<\/span>,<\/span>
                  \n memory:<\/span> process.<\/span>memoryUsage<\/span>(<\/span>)<\/span>,<\/span>
                  \n status:<\/span> \\’online\\’<\/span>
                  \n }<\/span>;<\/span><\/p>\n

                  pubClient.<\/span>publish<\/span>(<\/span>\\’slave-status\\’<\/span>,<\/span> JSON<\/span>.<\/span>stringify<\/span>(<\/span>status)<\/span>)<\/span>;<\/span>
                  \n }<\/span><\/p>\n

                  \/\/ \u5904\u7406\u4e3b\u670d\u52a1\u5668\u6307\u4ee4<\/span>
                  \n handleMasterCommand<\/span>(<\/span>command)<\/span> {
                  \n <\/span>
                  \n switch<\/span> (<\/span>command.<\/span>type<\/span>)<\/span> {
                  \n <\/span>
                  \n case<\/span> \\’restart\\’<\/span>:<\/span>
                  \n this<\/span>.<\/span>restart<\/span>(<\/span>)<\/span>;<\/span>
                  \n break<\/span>;<\/span>
                  \n case<\/span> \\’update-config\\’<\/span>:<\/span>
                  \n this<\/span>.<\/span>updateConfig<\/span>(<\/span>command.<\/span>config)<\/span>;<\/span>
                  \n break<\/span>;<\/span>
                  \n \/\/ \u5176\u4ed6\u6307\u4ee4\u5904\u7406…<\/span>
                  \n }<\/span>
                  \n }<\/span>
                  \n}<\/span><\/p>\n

                  1.4.2 \u53bb\u4e2d\u5fc3\u5316\u6a21\u5f0f\uff08Peer-to-Peer\uff09<\/h5>\n

                  \u6240\u6709\u670d\u52a1\u5668\u5730\u4f4d\u5e73\u7b49\uff0c\u901a\u8fc7\u534f\u4f5c\u63d0\u4f9b\u670d\u52a1\uff0c\u65e0\u5355\u70b9\u6545\u969c\u98ce\u9669\u3002<\/p>\n

                  \u250c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2510 \u250c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2510
                  \n\u2502 \u2502\u25c4\u2500\u2500\u2500\u2500\u25ba\u2502 \u2502
                  \n\u2502 Node 1 \u2502 \u2502 Node 2 \u2502
                  \n\u2502 \u2502\u25c4\u2500\u2500\u2500\u2500\u25ba\u2502 \u2502
                  \n\u2514\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2518 \u2514\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2518
                  \n \u25b2 \u25b2 \u25b2
                  \n \u2502 \u2514\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2510 \u250c\u2500\u2500\u2500\u2518
                  \n \u2502 \u25bc \u25bc
                  \n\u250c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2510 \u250c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2510
                  \n\u2502 \u2502\u25c4\u2500\u2500\u2500\u2500\u25ba\u2502 \u2502
                  \n\u2502 Node 3 \u2502 \u2502 Node 4 \u2502
                  \n\u2502 \u2502\u25c4\u2500\u2500\u2500\u2500\u25ba\u2502 \u2502
                  \n\u2514\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2518 \u2514\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2518<\/p>\n

                  \/\/ \u53bb\u4e2d\u5fc3\u5316\u6a21\u5f0f\u5b9e\u73b0\u793a\u4f8b<\/span>
                  \nimport<\/span> {
                  \n <\/span> McpServer }<\/span> from<\/span> \\’@modelcontextprotocol\/sdk\\’<\/span>;<\/span>
                  \nimport<\/span> *<\/span> as<\/span> IPFS<\/span> from<\/span> \\’ipfs-core\\’<\/span>;<\/span>
                  \nimport<\/span> {
                  \n <\/span> v4 as<\/span> uuidv4 }<\/span> from<\/span> \\’uuid\\’<\/span>;<\/span><\/p>\n

                  \/\/ P2P MCP\u670d\u52a1\u5668<\/span>
                  \nclass<\/span> P2PMcpServer<\/span> extends<\/span> McpServer<\/span> {
                  \n <\/span>
                  \n private<\/span> ipfs;<\/span>
                  \n private<\/span> peerId:<\/span> string<\/span>;<\/span>
                  \n private<\/span> peers:<\/span> Map<<\/span>string<\/span>,<\/span> PeerInfo><\/span> =<\/span> new<\/span> Map<\/span>(<\/span>)<\/span>;<\/span>
                  \n private<\/span> eventTopic =<\/span> \\’mcp-p2p-events\\’<\/span>;<\/span><\/p>\n

                  constructor<\/span>(<\/span>config)<\/span> {
                  \n <\/span>
                  \n super<\/span>(<\/span>config)<\/span>;<\/span>
                  \n this<\/span>.<\/span>peerId =<\/span> uuidv4<\/span>(<\/span>)<\/span>;<\/span>
                  \n this<\/span>.<\/span>initializeP2P<\/span>(<\/span>)<\/span>;<\/span>
                  \n }<\/span><\/p>\n

                  \/\/ \u521d\u59cb\u5316P2P\u7f51\u7edc<\/span>
                  \n async<\/span> initializeP2P<\/span>(<\/span>)<\/span> {
                  \n <\/span>
                  \n \/\/ \u521b\u5efaIPFS\u8282\u70b9<\/span>
                  \n this<\/span>.<\/span>ipfs =<\/span> await<\/span> IPFS<\/span>.<\/span>create<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

                  \/\/ \u83b7\u53d6\u672c\u8282\u70b9ID<\/span>
                  \n const<\/span> nodeInfo =<\/span> await<\/span> this<\/span>.<\/span>ipfs.<\/span>id<\/span>(<\/span>)<\/span>;<\/span>
                  \n console<\/span>.<\/span>log<\/span>(<\/span>`<\/span>P2P\u8282\u70b9ID: <\/span>${
                  \n <\/span>nodeInfo.<\/span>id}<\/span><\/span>`<\/span><\/span>)<\/span>;<\/span><\/p>\n

                  \/\/ \u8ba2\u9605\u4e8b\u4ef6\u4e3b\u9898<\/span>
                  \n await<\/span> this<\/span>.<\/span>ipfs.<\/span>pubsub.<\/span>subscribe<\/span>(<\/span>this<\/span>.<\/span>eventTopic,<\/span> (<\/span>msg)<\/span> =><\/span> {
                  \n <\/span>
                  \n this<\/span>.<\/span>handleP2PEvent<\/span>(<\/span>msg)<\/span>;<\/span>
                  \n }<\/span>)<\/span>;<\/span><\/p>\n

                  \/\/ \u5b9a\u671f\u53d1\u5e03\u72b6\u6001<\/span>
                  \n setInterval<\/span>(<\/span>(<\/span>)<\/span> =><\/span> this<\/span>.<\/span>broadcastStatus<\/span>(<\/span>)<\/span>,<\/span> 5000<\/span>)<\/span>;<\/span><\/p>\n

                  \/\/ \u53d1\u5e03\u4e0a\u7ebf\u4e8b\u4ef6<\/span>
                  \n this<\/span>.<\/span>broadcastEvent<\/span>(<\/span>{
                  \n <\/span>
                  \n type<\/span>:<\/span> \\’node-online\\’<\/span>,<\/span>
                  \n peerId:<\/span> this<\/span>.<\/span>peerId,<\/span>
                  \n timestamp:<\/span> Date.<\/span>now<\/span>(<\/span>)<\/span>,<\/span>
                  \n info:<\/span> {
                  \n <\/span>
                  \n resources:<\/span> this<\/span>.<\/span>getResourceNames<\/span>(<\/span>)<\/span>,<\/span>
                  \n tools:<\/span> this<\/span>.<\/span>getToolNames<\/span>(<\/span>)<\/span>,<\/span>
                  \n capacity:<\/span> this<\/span>.<\/span>getCapacity<\/span>(<\/span>)<\/span>
                  \n }<\/span>
                  \n }<\/span>)<\/span>;<\/span>
                  \n }<\/span><\/p>\n

                  \/\/ \u5904\u7406P2P\u4e8b\u4ef6<\/span>
                  \n handleP2PEvent<\/span>(<\/span>message)<\/span> {
                  \n <\/span>
                  \n try<\/span> {
                  \n <\/span>
                  \n const<\/span> event =<\/span> JSON<\/span>.<\/span>parse<\/span>(<\/span>message.<\/span>data.<\/span>toString<\/span>(<\/span>)<\/span>)<\/span>;<\/span><\/p>\n

                  \/\/ \u5ffd\u7565\u81ea\u5df1\u53d1\u51fa\u7684\u6d88\u606f<\/span>
                  \n if<\/span> (<\/span>event.<\/span>peerId ===<\/span> this<\/span>.<\/span>peerId)<\/span> return<\/span>;<\/span><\/p>\n

                  switch<\/span> (<\/span>event.<\/span>type<\/span>)<\/span> {
                  \n <\/span>
                  \n case<\/span> \\’node-online\\’<\/span>:<\/span>
                  \n this<\/span>.<\/span>addPeer<\/span>(<\/span>event.<\/span>peerId,<\/span> event.<\/span>info)<\/span>;<\/span>
                  \n \/\/ \u5411\u65b0\u8282\u70b9\u53d1\u9001\u6b22\u8fce\u6d88\u606f<\/span>
                  \n this<\/span>.<\/span>sendDirectEvent<\/span>(<\/span>event.<\/span>peerId,<\/span> {
                  \n <\/span>
                  \n type<\/span>:<\/span> \\’welcome\\’<\/span>,<\/span>
                  \n peerId:<\/span> this<\/span>.<\/span>peerId,<\/span>
                  \n timestamp:<\/span> Date.<\/span>now<\/span>(<\/span>)<\/span>
                  \n }<\/span>)<\/span>;<\/span>
                  \n break<\/span>;<\/span><\/p>\n

                  case<\/span> \\’node-offline\\’<\/span>:<\/span>
                  \n this<\/span>.<\/span>removePeer<\/span>(<\/span>event.<\/span>peerId)<\/span>;<\/span>
                  \n break<\/span>;<\/span><\/p>\n

                  case<\/span> \\’status-update\\’<\/span>:<\/span>
                  \n this<\/span>.<\/span>updatePeerStatus<\/span>(<\/span>event.<\/span>peerId,<\/span> event.<\/span>status)<\/span>;<\/span>
                  \n break<\/span>;<\/span><\/p>\n

                  case<\/span> \\’resource-request\\’<\/span>:<\/span>
                  \n this<\/span>.<\/span>handleResourceRequest<\/span>(<\/span>event)<\/span>;<\/span>
                  \n break<\/span>;<\/span><\/p>\n

                  case<\/span> \\’tool-execution\\’<\/span>:<\/span>
                  \n this<\/span>.<\/span>handleToolExecution<\/span>(<\/span>event)<\/span>;<\/span>
                  \n break<\/span>;<\/span>
                  \n }<\/span>
                  \n }<\/span> catch<\/span> (<\/span>error)<\/span> {
                  \n <\/span>
                  \n console<\/span>.<\/span>error<\/span>(<\/span>\\’\u5904\u7406P2P\u4e8b\u4ef6\u9519\u8bef:\\’<\/span>,<\/span> error)<\/span>;<\/span>
                  \n }<\/span>
                  \n }<\/span><\/p>\n

                  \/\/ \u5e7f\u64ad\u4e8b\u4ef6\u5230\u6240\u6709\u8282\u70b9<\/span>
                  \n async<\/span> broadcastEvent<\/span>(<\/span>event)<\/span> {
                  \n <\/span>
                  \n await<\/span> this<\/span>.<\/span>ipfs.<\/span>pubsub.<\/span>publish<\/span>(<\/span>
                  \n this<\/span>.<\/span>eventTopic,<\/span>
                  \n Buffer.<\/span>from<\/span>(<\/span>JSON<\/span>.<\/span>stringify<\/span>(<\/span>event)<\/span>)<\/span>
                  \n )<\/span>;<\/span>
                  \n }<\/span><\/p>\n

                  \/\/ \u53d1\u9001\u4e8b\u4ef6\u5230\u7279\u5b9a\u8282\u70b9<\/span>
                  \n async<\/span> sendDirectEvent<\/span>(<\/span>targetPeerId,<\/span> event)<\/span> {
                  \n <\/span>
                  \n const<\/span> peer =<\/span> this<\/span>.<\/span>peers.<\/span>get<\/span>(<\/span>targetPeerId)<\/span>;<\/span>
                  \n if<\/span> (<\/span>!<\/span>peer ||<\/span> !<\/span>peer.<\/span>directTopic)<\/span> return<\/span>;<\/span><\/p>\n

                  await<\/span> this<\/span>.<\/span>ipfs.<\/span>pubsub.<\/span>publish<\/span>(<\/span>
                  \n peer.<\/span>directTopic,<\/span>
                  \n Buffer.<\/span>from<\/span>(<\/span>JSON<\/span>.<\/span>stringify<\/span>(<\/span>event)<\/span>)<\/span>
                  \n )<\/span>;<\/span>
                  \n }<\/span><\/p>\n

                  \/\/ \u5b9a\u671f\u5e7f\u64ad\u72b6\u6001<\/span>
                  \n broadcastStatus<\/span>(<\/span>)<\/span> {
                  \n <\/span>
                  \n this<\/span>.<\/span>broadcastEvent<\/span>(<\/span>{
                  \n <\/span>
                  \n type<\/span>:<\/span> \\’status-update\\’<\/span>,<\/span>
                  \n peerId:<\/span> this<\/span>.<\/span>peerId,<\/span>
                  \n timestamp:<\/span> Date.<\/span>now<\/span>(<\/span>)<\/span>,<\/span>
                  \n status:<\/span> {
                  \n <\/span>
                  \n load:<\/span> this<\/span>.<\/span>getCurrentLoad<\/span>(<\/span>)<\/span>,<\/span>
                  \n memory:<\/span> process.<\/span>memoryUsage<\/span>(<\/span>)<\/span>,<\/span>
                  \n uptime:<\/span> process.<\/span>uptime<\/span>(<\/span>)<\/span>
                  \n }<\/span>
                  \n }<\/span>)<\/span>;<\/span>
                  \n }<\/span><\/p>\n

                  \/\/ \u6dfb\u52a0\u5bf9\u7b49\u8282\u70b9<\/span>
                  \n addPeer<\/span>(<\/span>peerId:<\/span> string<\/span>,<\/span> info:<\/span> any<\/span>)<\/span> {
                  \n <\/span>
                  \n this<\/span>.<\/span>peers.<\/span>set<\/span>(<\/span>peerId,<\/span> {
                  \n <\/span>
                  \n …<\/span>info,<\/span>
                  \n directTopic:<\/span> `<\/span>mcp-p2p-direct:<\/span>${
                  \n <\/span>peerId}<\/span><\/span>`<\/span><\/span>,<\/span>
                  \n lastSeen:<\/span> Date.<\/span>now<\/span>(<\/span>)<\/span>
                  \n }<\/span>)<\/span>;<\/span><\/p>\n

                  \/\/ \u8ba2\u9605\u6b64\u8282\u70b9\u7684\u76f4\u63a5\u901a\u4fe1\u4e3b\u9898<\/span>
                  \n this<\/span>.<\/span>ipfs.<\/span>pubsub.<\/span>subscribe<\/span>(<\/span>`<\/span>mcp-p2p-direct:<\/span>${
                  \n <\/span>this<\/span>.<\/span>peerId}<\/span><\/span>`<\/span><\/span>,<\/span> (<\/span>msg)<\/span> =><\/span> {
                  \n <\/span>
                  \n this<\/span>.<\/span>handleDirectMessage<\/span>(<\/span>msg)<\/span>;<\/span>
                  \n }<\/span>)<\/span>;<\/span>
                  \n }<\/span><\/p>\n

                  \/\/ \u79fb\u9664\u5bf9\u7b49\u8282\u70b9<\/span>
                  \n removePeer<\/span>(<\/span>peerId:<\/span> string<\/span>)<\/span> {
                  \n <\/span>
                  \n this<\/span>.<\/span>peers.<\/span>delete<\/span>(<\/span>peerId)<\/span>;<\/span>
                  \n }<\/span><\/p>\n

                  \/\/ \u66f4\u65b0\u5bf9\u7b49\u8282\u70b9\u72b6\u6001<\/span>
                  \n updatePeerStatus<\/span>(<\/span>peerId:<\/span> string<\/span>,<\/span> status:<\/span> any<\/span>)<\/span> {
                  \n <\/span>
                  \n const<\/span> peer =<\/span> this<\/span>.<\/span>peers.<\/span>get<\/span>(<\/span>peerId)<\/span>;<\/span>
                  \n if<\/span> (<\/span>peer)<\/span> {
                  \n <\/span>
                  \n this<\/span>.<\/span>peers.<\/span>set<\/span>(<\/span>peerId,<\/span> {
                  \n <\/span> …<\/span>peer,<\/span> …<\/span>status,<\/span> lastSeen:<\/span> Date.<\/span>now<\/span>(<\/span>)<\/span> }<\/span>)<\/span>;<\/span>
                  \n }<\/span>
                  \n }<\/span>
                  \n}<\/span><\/p>\n

                  1.4.3 \u5fae\u670d\u52a1\u6a21\u5f0f\uff08Microservices\uff09<\/h5>\n

                  \u5c06MCP\u529f\u80fd\u5206\u89e3\u4e3a\u591a\u4e2a\u72ec\u7acb\u670d\u52a1\uff0c\u6bcf\u4e2a\u670d\u52a1\u4e13\u6ce8\u4e8e\u7279\u5b9a\u529f\u80fd\u57df\u3002<\/p>\n

                  \u250c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2510
                  \n\u2502 API Gateway \u2502
                  \n\u2514\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u252c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u252c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2518
                  \n \u2502 \u2502
                  \n \u250c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u25bc\u2500\u2500\u2500\u2510 \u250c\u2500\u2500\u2500\u2500\u2500\u25bc\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2510 \u250c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2510
                  \n \u2502 Resource \u2502 \u2502 Tool \u2502 \u2502 Identity \u2502
                  \n \u2502 Service \u2502 \u2502 Service \u2502 \u2502 Service \u2502
                  \n \u2514\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2518 \u2514\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2518 \u2514\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2518
                  \n \u2502 \u2502 \u2502
                  \n \u250c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u25bc\u2500\u2500\u2500\u2510 \u250c\u2500\u2500\u2500\u2500\u2500\u25bc\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2510 \u250c\u2500\u2500\u2500\u2500\u2500\u25bc\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2510
                  \n \u2502 Storage \u2502 \u2502 Execution \u2502 \u2502 Security \u2502
                  \n \u2502 Service \u2502 \u2502 Service \u2502 \u2502 Service \u2502
                  \n \u2514\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2518 \u2514\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2518 \u2514\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2518<\/p>\n

                  \/\/ \u5fae\u670d\u52a1\u6a21\u5f0f\u5b9e\u73b0\u793a\u4f8b<\/span>
                  \nimport<\/span> {
                  \n <\/span> McpServer }<\/span> from<\/span> \\’@modelcontextprotocol\/sdk\\’<\/span>;<\/span>
                  \nimport<\/span> express from<\/span> \\’express\\’<\/span>;<\/span>
                  \nimport<\/span> axios from<\/span> \\’axios\\’<\/span>;<\/span>
                  \nimport<\/span> {
                  \n <\/span> MongoClient }<\/span> from<\/span> \\’mongodb\\’<\/span>;<\/span>
                  \nimport<\/span> {
                  \n <\/span> v4 as<\/span> uuidv4 }<\/span> from<\/span> \\’uuid\\’<\/span>;<\/span>
                  \nimport<\/span> amqp from<\/span> \\’amqplib\\’<\/span>;<\/span><\/p>\n

                  \/\/ \u670d\u52a1\u53d1\u73b0\u5ba2\u6237\u7aef<\/span>
                  \nclass<\/span> ServiceDiscovery<\/span> {
                  \n <\/span>
                  \n private<\/span> serviceRegistry:<\/span> Map<<\/span>string<\/span>,<\/span> ServiceInfo[<\/span>]<\/span>><\/span> =<\/span> new<\/span> Map<\/span>(<\/span>)<\/span>;<\/span>
                  \n private<\/span> consulUrl:<\/span> string<\/span>;<\/span><\/p>\n

                  constructor<\/span>(<\/span>consulUrl:<\/span> string<\/span>)<\/span> {
                  \n <\/span>
                  \n this<\/span>.<\/span>consulUrl =<\/span> consulUrl;<\/span>
                  \n this<\/span>.<\/span>refreshRegistry<\/span>(<\/span>)<\/span>;<\/span>
                  \n setInterval<\/span>(<\/span>(<\/span>)<\/span> =><\/span> this<\/span>.<\/span>refreshRegistry<\/span>(<\/span>)<\/span>,<\/span> 30000<\/span>)<\/span>;<\/span>
                  \n }<\/span><\/p>\n

                  \/\/ \u5237\u65b0\u670d\u52a1\u6ce8\u518c\u8868<\/span>
                  \n async<\/span> refreshRegistry<\/span>(<\/span>)<\/span> {
                  \n <\/span>
                  \n try<\/span> {
                  \n <\/span>
                  \n const<\/span> response =<\/span> await<\/span> axios.<\/span>get<\/span>(<\/span>`<\/span>${
                  \n <\/span>this<\/span>.<\/span>consulUrl}<\/span><\/span>\/v1\/catalog\/services<\/span>`<\/span><\/span>)<\/span>;<\/span>
                  \n for<\/span> (<\/span>const<\/span> [<\/span>serviceName,<\/span> tags]<\/span> of<\/span> Object.<\/span>entries<\/span>(<\/span>response.<\/span>data)<\/span>)<\/span> {
                  \n <\/span>
                  \n if<\/span> (<\/span>tags.<\/span>includes<\/span>(<\/span>\\’mcp\\’<\/span>)<\/span>)<\/span> {
                  \n <\/span>
                  \n const<\/span> instances =<\/span> await<\/span> this<\/span>.<\/span>getServiceInstances<\/span>(<\/span>serviceName)<\/span>;<\/span>
                  \n this<\/span>.<\/span>serviceRegistry.<\/span>set<\/span>(<\/span>serviceName,<\/span> instances)<\/span>;<\/span>
                  \n }<\/span>
                  \n }<\/span>
                  \n }<\/span> catch<\/span> (<\/span>error)<\/span> {
                  \n <\/span>
                  \n console<\/span>.<\/span>error<\/span>(<\/span>\\’\u5237\u65b0\u670d\u52a1\u6ce8\u518c\u8868\u5931\u8d25:\\’<\/span>,<\/span> error)<\/span>;<\/span>
                  \n }<\/span>
                  \n }<\/span><\/p>\n

                  \/\/ \u83b7\u53d6\u670d\u52a1\u5b9e\u4f8b\u5217\u8868<\/span>
                  \n async<\/span> getServiceInstances<\/span>(<\/span>serviceName:<\/span> string<\/span>)<\/span>:<\/span> Promise<\/span><<\/span>ServiceInfo[<\/span>]<\/span>><\/span> {
                  \n <\/span>
                  \n try<\/span> {
                  \n <\/span>
                  \n const<\/span> response =<\/span> await<\/span> axios.<\/span>get<\/span>(<\/span>
                  \n `<\/span>${
                  \n <\/span>this<\/span>.<\/span>consulUrl}<\/span><\/span>\/v1\/health\/service\/<\/span>${
                  \n <\/span>serviceName}<\/span><\/span>?passing=true<\/span>`<\/span><\/span>
                  \n )<\/span>;<\/span>
                  \n return<\/span> response.<\/span>data.<\/span>map<\/span>(<\/span>entry =><\/span> (<\/span>{
                  \n <\/span>
                  \n id:<\/span> entry.<\/span>Service.<\/span>ID<\/span>,<\/span>
                  \n address:<\/span> entry.<\/span>Service.<\/span>Address,<\/span>
                  \n port:<\/span> entry.<\/span>Service.<\/span>Port,<\/span>
                  \n tags:<\/span> entry.<\/span>Service.<\/span>Tags,<\/span>
                  \n meta:<\/span> entry.<\/span>Service.<\/span>Meta
                  \n }<\/span>)<\/span>)<\/span>;<\/span>
                  \n }<\/span> catch<\/span> (<\/span>error)<\/span> {
                  \n <\/span>
                  \n console<\/span>.<\/span>error<\/span>(<\/span>`<\/span>\u83b7\u53d6\u670d\u52a1<\/span>${
                  \n <\/span>serviceName}<\/span><\/span>\u5b9e\u4f8b\u5931\u8d25:<\/span>`<\/span><\/span>,<\/span> error)<\/span>;<\/span>
                  \n return<\/span> [<\/span>]<\/span>;<\/span>
                  \n }<\/span>
                  \n }<\/span><\/p>\n

                  \/\/ \u83b7\u53d6\u670d\u52a1\u5b9e\u4f8b<\/span>
                  \n getService<\/span>(<\/span>serviceName:<\/span> string<\/span>,<\/span> tags:<\/span> string<\/span>[<\/span>]<\/span> =<\/span> [<\/span>]<\/span>)<\/span>:<\/span> ServiceInfo |<\/span> null<\/span> {
                  \n <\/span>
                  \n const<\/span> instances =<\/span> this<\/span>.<\/span>serviceRegistry.<\/span>get<\/span>(<\/span>serviceName)<\/span> ||<\/span> [<\/span>]<\/span>;<\/span><\/p>\n

                  \/\/ \u7b5b\u9009\u6ee1\u8db3\u6807\u7b7e\u8981\u6c42\u7684\u5b9e\u4f8b<\/span>
                  \n const<\/span> eligibleInstances =<\/span> instances.<\/span>filter<\/span>(<\/span>instance =><\/span>
                  \n tags.<\/span>every<\/span>(<\/span>tag =><\/span> instance.<\/span>tags.<\/span>includes<\/span>(<\/span>tag)<\/span>)<\/span>
                  \n )<\/span>;<\/span><\/p>\n

                  if<\/span> (<\/span>eligibleInstances.<\/span>length ===<\/span> 0<\/span>)<\/span> return<\/span> null<\/span>;<\/span><\/p>\n

                  \/\/ \u7b80\u5355\u8d1f\u8f7d\u5747\u8861\uff1a\u968f\u673a\u9009\u62e9\u4e00\u4e2a\u5b9e\u4f8b<\/span>
                  \n const<\/span> randomIndex =<\/span> Math.<\/span>floor<\/span>(<\/span>Math.<\/span>random<\/span>(<\/span>)<\/span> *<\/span> eligibleInstances.<\/span>length)<\/span>;<\/span>
                  \n return<\/span> eligibleInstances[<\/span>randomIndex]<\/span>;<\/span>
                  \n }<\/span>
                  \n}<\/span><\/p>\n

                  \/\/ MCP\u8d44\u6e90\u670d\u52a1<\/span>
                  \nclass<\/span> ResourceMcpService<\/span> {
                  \n <\/span>
                  \n private<\/span> server:<\/span> McpServer;<\/span>
                  \n private<\/span> app =<\/span> express<\/span>(<\/span>)<\/span>;<\/span>
                  \n private<\/span> mongoClient:<\/span> MongoClient;<\/span>
                  \n private<\/span> serviceId:<\/span> string<\/span>;<\/span>
                  \n private<\/span> discovery:<\/span> ServiceDiscovery;<\/span>
                  \n private<\/span> messageBroker:<\/span> amqp.<\/span>Connection;<\/span>
                  \n private<\/span> channel:<\/span> amqp.<\/span>Channel;<\/span><\/p>\n

                  constructor<\/span>(<\/span>config)<\/span> {
                  \n <\/span>
                  \n this<\/span>.<\/span>server =<\/span> new<\/span> McpServer<\/span>(<\/span>{
                  \n <\/span>
                  \n name:<\/span> \\”mcp-resource-service\\”<\/span>,<\/span>
                  \n description:<\/span> \\”MCP\u8d44\u6e90\u5fae\u670d\u52a1\\”<\/span>,<\/span>
                  \n version:<\/span> \\”1.0.0\\”<\/span>
                  \n }<\/span>)<\/span>;<\/span><\/p>\n

                  this<\/span>.<\/span>serviceId =<\/span> uuidv4<\/span>(<\/span>)<\/span>;<\/span>
                  \n this<\/span>.<\/span>discovery =<\/span> new<\/span> ServiceDiscovery<\/span>(<\/span>config.<\/span>consulUrl)<\/span>;<\/span><\/p>\n

                  \/\/ \u521d\u59cb\u5316Express\u4e2d\u95f4\u4ef6<\/span>
                  \n this<\/span>.<\/span>initializeExpress<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

                  \/\/ \u8fde\u63a5MongoDB<\/span>
                  \n this<\/span>.<\/span>connectMongo<\/span>(<\/span>config.<\/span>mongoUrl)<\/span>;<\/span><\/p>\n

                  \/\/ \u8fde\u63a5\u6d88\u606f\u4ee3\u7406<\/span>
                  \n this<\/span>.<\/span>connectMessageBroker<\/span>(<\/span>config.<\/span>rabbitMqUrl)<\/span>;<\/span><\/p>\n

                  \/\/ \u6ce8\u518c\u670d\u52a1<\/span>
                  \n this<\/span>.<\/span>registerService<\/span>(<\/span>config.<\/span>consulUrl)<\/span>;<\/span>
                  \n }<\/span><\/p>\n

                  \/\/ \u521d\u59cb\u5316Express<\/span>
                  \n initializeExpress<\/span>(<\/span>)<\/span> {
                  \n <\/span>
                  \n this<\/span>.<\/span>app.<\/span>use<\/span>(<\/span>express.<\/span>json<\/span>(<\/span>)<\/span>)<\/span>;<\/span><\/p>\n

                  \/\/ \u8d44\u6e90API\u7aef\u70b9<\/span>
                  \n this<\/span>.<\/span>app.<\/span>get<\/span>(<\/span>\\’\/resources\/:name\\’<\/span>,<\/span> this<\/span>.<\/span>getResource<\/span>.<\/span>bind<\/span>(<\/span>this<\/span>)<\/span>)<\/span>;<\/span>
                  \n this<\/span>.<\/span>app.<\/span>post<\/span>(<\/span>\\’\/resources\/:name\\’<\/span>,<\/span> this<\/span>.<\/span>createResource<\/span>.<\/span>bind<\/span>(<\/span>this<\/span>)<\/span>)<\/span>;<\/span>
                  \n this<\/span>.<\/span>app.<\/span>put<\/span>(<\/span>\\’\/resources\/:name\/:id\\’<\/span>,<\/span> this<\/span>.<\/span>updateResource<\/span>.<\/span>bind<\/span>(<\/span>this<\/span>)<\/span>)<\/span>;<\/span>
                  \n this<\/span>.<\/span>app.<\/span>delete<\/span>(<\/span>\\’\/resources\/:name\/:id\\’<\/span>,<\/span> this<\/span>.<\/span>deleteResource<\/span>.<\/span>bind<\/span>(<\/span>this<\/span>)<\/span>)<\/span>;<\/span><\/p>\n

                  \/\/ \u5065\u5eb7\u68c0\u67e5\u7aef\u70b9<\/span>
                  \n this<\/span>.<\/span>app.<\/span>get<\/span>(<\/span>\\’\/health\\’<\/span>,<\/span> (<\/span>req,<\/span> res)<\/span> =><\/span> {
                  \n <\/span>
                  \n res.<\/span>status<\/span>(<\/span>200<\/span>)<\/span>.<\/span>json<\/span>(<\/span>{
                  \n <\/span> status:<\/span> \\’healthy\\’<\/span>,<\/span> serviceId:<\/span> this<\/span>.<\/span>serviceId }<\/span>)<\/span>;<\/span>
                  \n }<\/span>)<\/span>;<\/span><\/p>\n

                  \/\/ \u542f\u52a8\u670d\u52a1\u5668<\/span>
                  \n const<\/span> port =<\/span> process.<\/span>env.<\/span>PORT<\/span> ||<\/span> 3000<\/span>;<\/span>
                  \n this<\/span>.<\/span>app.<\/span>listen<\/span>(<\/span>port,<\/span> (<\/span>)<\/span> =><\/span> {
                  \n <\/span>
                  \n console<\/span>.<\/span>log<\/span>(<\/span>`<\/span>\u8d44\u6e90\u670d\u52a1\u8fd0\u884c\u5728\u7aef\u53e3 <\/span>${
                  \n <\/span>port}<\/span><\/span>`<\/span><\/span>)<\/span>;<\/span>
                  \n }<\/span>)<\/span>;<\/span>
                  \n }<\/span><\/p>\n

                  \/\/ \u8fde\u63a5MongoDB<\/span>
                  \n async<\/span> connectMongo<\/span>(<\/span>mongoUrl:<\/span> string<\/span>)<\/span> {
                  \n <\/span>
                  \n try<\/span> {
                  \n <\/span>
                  \n this<\/span>.<\/span>mongoClient =<\/span> new<\/span> MongoClient<\/span>(<\/span>mongoUrl)<\/span>;<\/span>
                  \n await<\/span> this<\/span>.<\/span>mongoClient.<\/span>connect<\/span>(<\/span>)<\/span>;<\/span>
                  \n console<\/span>.<\/span>log<\/span>(<\/span>\\’\u5df2\u8fde\u63a5\u5230MongoDB\\’<\/span>)<\/span>;<\/span>
                  \n }<\/span> catch<\/span> (<\/span>error)<\/span> {
                  \n <\/span>
                  \n console<\/span>.<\/span>error<\/span>(<\/span>\\’MongoDB\u8fde\u63a5\u5931\u8d25:\\’<\/span>,<\/span> error)<\/span>;<\/span>
                  \n process.<\/span>exit<\/span>(<\/span>1<\/span>)<\/span>;<\/span>
                  \n }<\/span>
                  \n }<\/span><\/p>\n

                  \/\/ \u8fde\u63a5\u6d88\u606f\u4ee3\u7406<\/span>
                  \n async<\/span> connectMessageBroker<\/span>(<\/span>rabbitMqUrl:<\/span> string<\/span>)<\/span> {
                  \n <\/span>
                  \n try<\/span> {
                  \n <\/span>
                  \n this<\/span>.<\/span>messageBroker =<\/span> await<\/span> amqp.<\/span>connect<\/span>(<\/span>rabbitMqUrl)<\/span>;<\/span>
                  \n this<\/span>.<\/span>channel =<\/span> await<\/span> this<\/span>.<\/span>messageBroker.<\/span>createChannel<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

                  \/\/ \u58f0\u660e\u4ea4\u6362\u673a\u548c\u961f\u5217<\/span>
                  \n await<\/span> this<\/span>.<\/span>channel.<\/span>assertExchange<\/span>(<\/span>\\’mcp-events\\’<\/span>,<\/span> \\’topic\\’<\/span>,<\/span> {
                  \n <\/span> durable:<\/span> true<\/span> }<\/span>)<\/span>;<\/span>
                  \n const<\/span> {
                  \n <\/span> queue }<\/span> =<\/span> await<\/span> this<\/span>.<\/span>channel.<\/span>assertQueue<\/span>(<\/span>
                  \n `<\/span>resource-service-<\/span>${
                  \n <\/span>this<\/span>.<\/span>serviceId}<\/span><\/span>`<\/span><\/span>,<\/span>
                  \n {
                  \n <\/span> exclusive:<\/span> true<\/span> }<\/span>
                  \n )<\/span>;<\/span><\/p>\n

                  \/\/ \u7ed1\u5b9a\u611f\u5174\u8da3\u7684\u4e3b\u9898<\/span>
                  \n await<\/span> this<\/span>.<\/span>channel.<\/span>bindQueue<\/span>(<\/span>queue,<\/span> \\’mcp-events\\’<\/span>,<\/span> \\’resource.*\\’<\/span>)<\/span>;<\/span><\/p>\n

                  \/\/ \u6d88\u8d39\u6d88\u606f<\/span>
                  \n this<\/span>.<\/span>channel.<\/span>consume<\/span>(<\/span>queue,<\/span> (<\/span>msg)<\/span> =><\/span> {
                  \n <\/span>
                  \n if<\/span> (<\/span>msg)<\/span> {
                  \n <\/span>
                  \n this<\/span>.<\/span>handleMessage<\/span>(<\/span>msg)<\/span>;<\/span>
                  \n this<\/span>.<\/span>channel.<\/span>ack<\/span>(<\/span>msg)<\/span>;<\/span>
                  \n }<\/span>
                  \n }<\/span>)<\/span>;<\/span><\/p>\n

                  console<\/span>.<\/span>log<\/span>(<\/span>\\’\u5df2\u8fde\u63a5\u5230\u6d88\u606f\u4ee3\u7406\\’<\/span>)<\/span>;<\/span>
                  \n }<\/span> catch<\/span> (<\/span>error)<\/span> {
                  \n <\/span>
                  \n console<\/span>.<\/span>error<\/span>(<\/span>\\’\u6d88\u606f\u4ee3\u7406\u8fde\u63a5\u5931\u8d25:\\’<\/span>,<\/span> error)<\/span>;<\/span>
                  \n }<\/span>
                  \n }<\/span><\/p>\n

                  \/\/ \u5904\u7406\u6d88\u606f<\/span>
                  \n handleMessage<\/span>(<\/span>msg:<\/span> amqp.<\/span>ConsumeMessage)<\/span> {
                  \n <\/span>
                  \n try<\/span> {
                  \n <\/span>
                  \n const<\/span> content =<\/span> JSON<\/span>.<\/span>parse<\/span>(<\/span>msg.<\/span>content.<\/span>toString<\/span>(<\/span>)<\/span>)<\/span>;<\/span>
                  \n const<\/span> routingKey =<\/span> msg.<\/span>fields.<\/span>routingKey;<\/span><\/p>\n

                  console<\/span>.<\/span>log<\/span>(<\/span>`<\/span>\u6536\u5230\u6d88\u606f: <\/span>${
                  \n <\/span>routingKey}<\/span><\/span>`<\/span><\/span>,<\/span> content)<\/span>;<\/span><\/p>\n

                  \/\/ \u6839\u636e\u8def\u7531\u952e\u5904\u7406\u4e0d\u540c\u7c7b\u578b\u7684\u6d88\u606f<\/span>
                  \n switch<\/span> (<\/span>routingKey)<\/span> {
                  \n <\/span>
                  \n case<\/span> \\’resource.created\\’<\/span>:<\/span>
                  \n this<\/span>.<\/span>handleResourceCreated<\/span>(<\/span>content)<\/span>;<\/span>
                  \n break<\/span>;<\/span><\/p>\n

                  case<\/span> \\’resource.updated\\’<\/span>:<\/span>
                  \n this<\/span>.<\/span>handleResourceUpdated<\/span>(<\/span>content)<\/span>;<\/span>
                  \n break<\/span>;<\/span><\/p>\n

                  case<\/span> \\’resource.deleted\\’<\/span>:<\/span>
                  \n this<\/span>.<\/span>handleResourceDeleted<\/span>(<\/span>content)<\/span>;<\/span>
                  \n break<\/span>;<\/span>
                  \n }<\/span>
                  \n }<\/span> catch<\/span> (<\/span>error)<\/span> {
                  \n <\/span>
                  \n console<\/span>.<\/span>error<\/span>(<\/span>\\’\u5904\u7406\u6d88\u606f\u9519\u8bef:\\’<\/span>,<\/span> error)<\/span>;<\/span>
                  \n }<\/span>
                  \n }<\/span><\/p>\n

                  \/\/ \u53d1\u5e03\u4e8b\u4ef6<\/span>
                  \n publishEvent<\/span>(<\/span>routingKey:<\/span> string<\/span>,<\/span> data:<\/span> any<\/span>)<\/span> {
                  \n <\/span>
                  \n this<\/span>.<\/span>channel.<\/span>publish<\/span>(<\/span>
                  \n \\’mcp-events\\’<\/span>,<\/span>
                  \n routingKey,<\/span>
                  \n Buffer.<\/span>from<\/span>(<\/span>JSON<\/span>.<\/span>stringify<\/span>(<\/span>{
                  \n <\/span>
                  \n …<\/span>data,<\/span>
                  \n serviceId:<\/span> this<\/span>.<\/span>serviceId,<\/span>
                  \n timestamp:<\/span> Date.<\/span>now<\/span>(<\/span>)<\/span>
                  \n }<\/span>)<\/span>)<\/span>
                  \n )<\/span>;<\/span>
                  \n }<\/span><\/p>\n

                  \/\/ API\u5904\u7406\u5668<\/span>
                  \n async<\/span> getResource<\/span>(<\/span>req,<\/span> res)<\/span> {
                  \n <\/span>
                  \n try<\/span> {
                  \n <\/span>
                  \n const<\/span> {
                  \n <\/span> name }<\/span> =<\/span> req.<\/span>params;<\/span>
                  \n const<\/span> filter =<\/span> req.<\/span>query.<\/span>filter ?<\/span> JSON<\/span>.<\/span>parse<\/span>(<\/span>req.<\/span>query.<\/span>filter)<\/span> :<\/span> {
                  \n <\/span>}<\/span>;<\/span><\/p>\n

                  const<\/span> db =<\/span> this<\/span>.<\/span>mongoClient.<\/span>db<\/span>(<\/span>\\’mcp-resources\\’<\/span>)<\/span>;<\/span>
                  \n const<\/span> collection =<\/span> db.<\/span>collection<\/span>(<\/span>name)<\/span>;<\/span><\/p>\n

                  const<\/span> resources =<\/span> await<\/span> collection.<\/span>find<\/span>(<\/span>filter)<\/span>.<\/span>toArray<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

                  res.<\/span>json<\/span>(<\/span>{
                  \n <\/span> success:<\/span> true<\/span>,<\/span> data:<\/span> resources }<\/span>)<\/span>;<\/span>
                  \n }<\/span> catch<\/span> (<\/span>error)<\/span> {
                  \n <\/span>
                  \n res.<\/span>status<\/span>(<\/span>500<\/span>)<\/span>.<\/span>json<\/span>(<\/span>{
                  \n <\/span>
                  \n success:<\/span> false<\/span>,<\/span>
                  \n error:<\/span> error.<\/span>message
                  \n }<\/span>)<\/span>;<\/span>
                  \n }<\/span>
                  \n }<\/span><\/p>\n

                  async<\/span> createResource<\/span>(<\/span>req,<\/span> res)<\/span> {
                  \n <\/span>
                  \n try<\/span> {
                  \n <\/span>
                  \n const<\/span> {
                  \n <\/span> name }<\/span> =<\/span> req.<\/span>params;<\/span>
                  \n const<\/span> resourceData =<\/span> req.<\/span>body;<\/span><\/p>\n

                  const<\/span> db =<\/span> this<\/span>.<\/span>mongoClient.<\/span>db<\/span>(<\/span>\\’mcp-resources\\’<\/span>)<\/span>;<\/span>
                  \n const<\/span> collection =<\/span> db.<\/span>collection<\/span>(<\/span>name)<\/span>;<\/span><\/p>\n

                  const<\/span> result =<\/span> await<\/span> collection.<\/span>insertOne<\/span>(<\/span>{
                  \n <\/span>
                  \n …<\/span>resourceData,<\/span>
                  \n _id:<\/span> uuidv4<\/span>(<\/span>)<\/span>,<\/span>
                  \n createdAt:<\/span> new<\/span> Date<\/span>(<\/span>)<\/span>,<\/span>
                  \n updatedAt:<\/span> new<\/span> Date<\/span>(<\/span>)<\/span>
                  \n }<\/span>)<\/span>;<\/span><\/p>\n

                  \/\/ \u53d1\u5e03\u8d44\u6e90\u521b\u5efa\u4e8b\u4ef6<\/span>
                  \n this<\/span>.<\/span>publishEvent<\/span>(<\/span>\\’resource.created\\’<\/span>,<\/span> {
                  \n <\/span>
                  \n resourceName:<\/span> name,<\/span>
                  \n resourceId:<\/span> result.<\/span>insertedId,<\/span>
                  \n data:<\/span> resourceData
                  \n }<\/span>)<\/span>;<\/span><\/p>\n

                  res.<\/span>status<\/span>(<\/span>201<\/span>)<\/span>.<\/span>json<\/span>(<\/span>{
                  \n <\/span>
                  \n success:<\/span> true<\/span>,<\/span>
                  \n data:<\/span> {
                  \n <\/span> id:<\/span> result.<\/span>insertedId }<\/span>
                  \n }<\/span>)<\/span>;<\/span>
                  \n }<\/span> catch<\/span> (<\/span>error)<\/span> {
                  \n <\/span>
                  \n res.<\/span>status<\/span>(<\/span>500<\/span>)<\/span>.<\/span>json<\/span>(<\/span>{
                  \n <\/span>
                  \n success:<\/span> false<\/span>,<\/span>
                  \n error:<\/span> error.<\/span>message
                  \n }<\/span>)<\/span>;<\/span>
                  \n }<\/span>
                  \n }<\/span><\/p>\n

                  \/\/ \u5176\u4ed6API\u5904\u7406\u5668…<\/span><\/p>\n

                  \/\/ \u6ce8\u518c\u670d\u52a1\u5230Consul<\/span>
                  \n async<\/span> registerService<\/span>(<\/span>consulUrl:<\/span> string<\/span>)<\/span> {
                  \n <\/span>
                  \n try<\/span> {
                  \n <\/span>
                  \n await<\/span> axios.<\/span>put<\/span>(<\/span>`<\/span>${
                  \n <\/span>consulUrl}<\/span><\/span>\/v1\/agent\/service\/register<\/span>`<\/span><\/span>,<\/span> {
                  \n <\/span>
                  \n ID<\/span>:<\/span> this<\/span>.<\/span>serviceId,<\/span>
                  \n Name:<\/span> \\’mcp-resource-service\\’<\/span>,<\/span>
                  \n Tags:<\/span> [<\/span>\\’mcp\\’<\/span>,<\/span> \\’resource\\’<\/span>]<\/span>,<\/span>
                  \n Address:<\/span> process.<\/span>env.<\/span>SERVICE_HOST<\/span> ||<\/span> \\’localhost\\’<\/span>,<\/span>
                  \n Port:<\/span> parseInt<\/span>(<\/span>process.<\/span>env.<\/span>PORT<\/span> ||<\/span> \\’3000\\’<\/span>)<\/span>,<\/span>
                  \n Check:<\/span> {
                  \n <\/span>
                  \n HTTP<\/span>:<\/span> `<\/span>http:\/\/<\/span>${
                  \n <\/span>process.<\/span>env.<\/span>SERVICE_HOST<\/span> ||<\/span> \\’localhost\\’<\/span>}<\/span><\/span>:<\/span>${
                  \n <\/span>process.<\/span>env.<\/span>PORT<\/span> ||<\/span> \\’3000\\’<\/span>}<\/span><\/span>\/health<\/span>`<\/span><\/span>,<\/span>
                  \n Interval:<\/span> \\’15s\\’<\/span>,<\/span>
                  \n Timeout:<\/span> \\’5s\\’<\/span>
                  \n }<\/span>
                  \n }<\/span>)<\/span>;<\/span><\/p>\n

                  console<\/span>.<\/span>log<\/span>(<\/span>`<\/span>\u670d\u52a1\u5df2\u6ce8\u518c\uff0cID: <\/span>${
                  \n <\/span>this<\/span>.<\/span>serviceId}<\/span><\/span>`<\/span><\/span>)<\/span>;<\/span><\/p>\n

                  \/\/ \u6ce8\u518c\u670d\u52a1\u6ce8\u9500\u94a9\u5b50<\/span>
                  \n process.<\/span>on<\/span>(<\/span>\\’SIGINT\\’<\/span>,<\/span> (<\/span>)<\/span> =><\/span> this<\/span>.<\/span>deregisterService<\/span>(<\/span>consulUrl)<\/span>)<\/span>;<\/span>
                  \n process.<\/span>on<\/span>(<\/span>\\’SIGTERM\\’<\/span>,<\/span> (<\/span>)<\/span> =><\/span> this<\/span>.<\/span>deregisterService<\/span>(<\/span>consulUrl)<\/span>)<\/span>;<\/span>
                  \n }<\/span> catch<\/span> (<\/span>error)<\/span> {
                  \n <\/span>
                  \n console<\/span>.<\/span>error<\/span>(<\/span>\\’\u670d\u52a1\u6ce8\u518c\u5931\u8d25:\\’<\/span>,<\/span> error)<\/span>;<\/span>
                  \n }<\/span>
                  \n }<\/span><\/p>\n

                  \/\/ \u6ce8\u9500\u670d\u52a1<\/span>
                  \n async<\/span> deregisterService<\/span>(<\/span>consulUrl:<\/span> string<\/span>)<\/span> {
                  \n <\/span>
                  \n try<\/span> {
                  \n <\/span>
                  \n await<\/span> axios.<\/span>put<\/span>(<\/span>`<\/span>${
                  \n <\/span>consulUrl}<\/span><\/span>\/v1\/agent\/service\/deregister\/<\/span>${
                  \n <\/span>this<\/span>.<\/span>serviceId}<\/span><\/span>`<\/span><\/span>)<\/span>;<\/span>
                  \n console<\/span>.<\/span>log<\/span>(<\/span>\\’\u670d\u52a1\u5df2\u6ce8\u9500\\’<\/span>)<\/span>;<\/span>
                  \n process.<\/span>exit<\/span>(<\/span>0<\/span>)<\/span>;<\/span>
                  \n }<\/span> catch<\/span> (<\/span>error)<\/span> {
                  \n <\/span>
                  \n console<\/span>.<\/span>error<\/span>(<\/span>\\’\u670d\u52a1\u6ce8\u9500\u5931\u8d25:\\’<\/span>,<\/span> error)<\/span>;<\/span>
                  \n process.<\/span>exit<\/span>(<\/span>1<\/span>)<\/span>;<\/span>
                  \n }<\/span>
                  \n }<\/span>
                  \n}<\/span><\/p>\n

                  \u591a\u670d\u52a1\u5668\u67b6\u6784\u4e3aMCP\u5e94\u7528\u63d0\u4f9b\u4e86\u66f4\u9ad8\u7684\u53ef\u7528\u6027\u3001\u53ef\u4f38\u7f29\u6027\u548c\u7075\u6d3b\u6027\uff0c\u4f46\u540c\u65f6\u4e5f\u5e26\u6765\u4e86\u7cfb\u7edf\u590d\u6742\u5ea6\u7684\u63d0\u5347\u3002\u5728\u540e\u7eed\u7ae0\u8282\u4e2d\uff0c\u6211\u4eec\u5c06\u6df1\u5165\u63a2\u8ba8\u5982\u4f55\u5e94\u5bf9\u8fd9\u4e9b\u6311\u6218\uff0c\u6784\u5efa\u7a33\u5065\u7684\u591a\u670d\u52a1\u5668MCP\u7cfb\u7edf\u3002<\/p>\n

                  2. \u670d\u52a1\u53d1\u73b0\u4e0e\u8def\u7531<\/h3>\n

                  \u5728\u591a\u670d\u52a1\u5668MCP\u67b6\u6784\u4e2d\uff0c\u670d\u52a1\u53d1\u73b0\u548c\u8def\u7531\u673a\u5236\u662f\u786e\u4fdd\u7cfb\u7edf\u9ad8\u6548\u8fd0\u884c\u7684\u5173\u952e\u7ec4\u4ef6\u3002\u5b83\u4eec\u4f7f\u5ba2\u6237\u7aef\u80fd\u591f\u52a8\u6001\u627e\u5230\u53ef\u7528\u7684\u670d\u52a1\u5b9e\u4f8b\uff0c\u5e76\u5c06\u8bf7\u6c42\u8def\u7531\u5230\u6700\u5408\u9002\u7684\u670d\u52a1\u5668\u4e0a\u3002<\/p>\n

                  2.1 \u670d\u52a1\u6ce8\u518c\u4e0e\u53d1\u73b0\u673a\u5236<\/h4>\n

                  \u670d\u52a1\u53d1\u73b0\u7684\u6838\u5fc3\u662f\u8ba9\u670d\u52a1\u6d88\u8d39\u8005\u80fd\u591f\u5728\u4e0d\u9700\u8981\u786c\u7f16\u7801\u670d\u52a1\u63d0\u4f9b\u8005\u5730\u5740\u7684\u60c5\u51b5\u4e0b\uff0c\u52a8\u6001\u627e\u5230\u5e76\u8c03\u7528\u6240\u9700\u7684\u670d\u52a1\u3002\u5728MCP\u7cfb\u7edf\u4e2d\uff0c\u670d\u52a1\u53d1\u73b0\u673a\u5236\u901a\u5e38\u6d89\u53ca\u4ee5\u4e0b\u51e0\u4e2a\u5173\u952e\u7ec4\u4ef6\uff1a<\/p>\n

                  2.1.1 \u670d\u52a1\u6ce8\u518c\u8868<\/h5>\n

                  \u670d\u52a1\u6ce8\u518c\u8868\u662f\u670d\u52a1\u53d1\u73b0\u7684\u6838\u5fc3\u6570\u636e\u5b58\u50a8\uff0c\u8bb0\u5f55\u4e86\u6240\u6709\u53ef\u7528\u670d\u52a1\u5b9e\u4f8b\u7684\u5173\u952e\u4fe1\u606f\uff1a<\/p>\n

                  \/\/ \u670d\u52a1\u6ce8\u518c\u8868\u63a5\u53e3<\/span>
                  \ninterface<\/span> ServiceRegistry<\/span> {
                  \n <\/span>
                  \n \/\/ \u6ce8\u518c\u670d\u52a1\u5b9e\u4f8b<\/span>
                  \n register<\/span>(<\/span>instance:<\/span> ServiceInstance)<\/span>:<\/span> Promise<\/span><<\/span>void<\/span>><\/span>;<\/span><\/p>\n

                  \/\/ \u6ce8\u9500\u670d\u52a1\u5b9e\u4f8b<\/span>
                  \n deregister<\/span>(<\/span>instanceId:<\/span> string<\/span>)<\/span>:<\/span> Promise<\/span><<\/span>void<\/span>><\/span>;<\/span><\/p>\n

                  \/\/ \u83b7\u53d6\u6307\u5b9a\u670d\u52a1\u7684\u6240\u6709\u5b9e\u4f8b<\/span>
                  \n getInstances<\/span>(<\/span>serviceName:<\/span> string<\/span>)<\/span>:<\/span> Promise<\/span><<\/span>ServiceInstance[<\/span>]<\/span>><\/span>;<\/span><\/p>\n

                  \/\/ \u67e5\u8be2\u7b26\u5408\u7279\u5b9a\u6761\u4ef6\u7684\u670d\u52a1\u5b9e\u4f8b<\/span>
                  \n findServices<\/span>(<\/span>query:<\/span> ServiceQuery)<\/span>:<\/span> Promise<\/span><<\/span>ServiceInstance[<\/span>]<\/span>><\/span>;<\/span><\/p>\n

                  \/\/ \u76d1\u542c\u670d\u52a1\u53d8\u66f4<\/span>
                  \n watchService<\/span>(<\/span>serviceName:<\/span> string<\/span>,<\/span> callback<\/span>:<\/span> (<\/span>instances:<\/span> ServiceInstance[<\/span>]<\/span>)<\/span> =><\/span> void<\/span>)<\/span>:<\/span> void<\/span>;<\/span>
                  \n}<\/span><\/p>\n

                  \/\/ \u670d\u52a1\u5b9e\u4f8b\u6570\u636e\u7ed3\u6784<\/span>
                  \ninterface<\/span> ServiceInstance<\/span> {
                  \n <\/span>
                  \n id:<\/span> string<\/span>;<\/span> \/\/ \u5b9e\u4f8b\u552f\u4e00\u6807\u8bc6<\/span>
                  \n serviceName:<\/span> string<\/span>;<\/span> \/\/ \u670d\u52a1\u540d\u79f0<\/span>
                  \n host:<\/span> string<\/span>;<\/span> \/\/ \u4e3b\u673a\u5730\u5740<\/span>
                  \n port:<\/span> number<\/span>;<\/span> \/\/ \u7aef\u53e3\u53f7<\/span>
                  \n status:<\/span> \\’UP\\’<\/span> |<\/span> \\’DOWN\\’<\/span> |<\/span> \\’STARTING\\’<\/span> |<\/span> \\’OUT_OF_SERVICE\\’<\/span>;<\/span> \/\/ \u5b9e\u4f8b\u72b6\u6001<\/span>
                  \n metadata:<\/span> Record<<\/span>string<\/span>,<\/span> string<\/span>><\/span>;<\/span> \/\/ \u5143\u6570\u636e\uff0c\u5982\u7248\u672c\u3001\u73af\u5883\u7b49<\/span>
                  \n healthCheckUrl?<\/span>:<\/span> string<\/span>;<\/span> \/\/ \u5065\u5eb7\u68c0\u67e5URL<\/span>
                  \n registrationTime:<\/span> number<\/span>;<\/span> \/\/ \u6ce8\u518c\u65f6\u95f4<\/span>
                  \n lastUpdateTime:<\/span> number<\/span>;<\/span> \/\/ \u6700\u540e\u66f4\u65b0\u65f6\u95f4<\/span>
                  \n}<\/span><\/p>\n

                  2.1.2 \u57fa\u4e8eMCP\u5b9e\u73b0\u7684\u5206\u5e03\u5f0f\u670d\u52a1\u6ce8\u518c\u8868<\/h5>\n

                  \u4ee5\u4e0b\u662f\u4e00\u4e2a\u4f7f\u7528MCP\u670d\u52a1\u5668\u5b9e\u73b0\u7684\u5206\u5e03\u5f0f\u670d\u52a1\u6ce8\u518c\u8868\u793a\u4f8b\uff1a<\/p>\n

                  import<\/span> {
                  \n <\/span> McpServer }<\/span> from<\/span> \\’@modelcontextprotocol\/sdk\\’<\/span>;<\/span>
                  \nimport<\/span> {
                  \n <\/span> createClient }<\/span> from<\/span> \\’redis\\’<\/span>;<\/span>
                  \nimport<\/span> express from<\/span> \\’express\\’<\/span>;<\/span><\/p>\n

                  \/\/ \u57fa\u4e8eRedis\u7684MCP\u670d\u52a1\u6ce8\u518c\u8868\u5b9e\u73b0<\/span>
                  \nclass<\/span> McpServiceRegistry<\/span> implements<\/span> ServiceRegistry<\/span> {
                  \n <\/span>
                  \n private<\/span> redisClient;<\/span>
                  \n private<\/span> readonly<\/span> KEY_PREFIX<\/span> =<\/span> \\’mcp:registry:\\’<\/span>;<\/span>
                  \n private<\/span> readonly<\/span> TTL<\/span> =<\/span> 60<\/span>;<\/span> \/\/ \u670d\u52a1\u8bb0\u5f55\u8fc7\u671f\u65f6\u95f4\uff08\u79d2\uff09<\/span><\/p>\n

                  constructor<\/span>(<\/span>redisUrl:<\/span> string<\/span>)<\/span> {
                  \n <\/span>
                  \n this<\/span>.<\/span>redisClient =<\/span> createClient<\/span>(<\/span>{
                  \n <\/span> url:<\/span> redisUrl }<\/span>)<\/span>;<\/span>
                  \n this<\/span>.<\/span>redisClient.<\/span>connect<\/span>(<\/span>)<\/span>;<\/span>
                  \n }<\/span><\/p>\n

                  \/\/ \u6ce8\u518c\u670d\u52a1\u5b9e\u4f8b<\/span>
                  \n async<\/span> register<\/span>(<\/span>instance:<\/span> ServiceInstance)<\/span>:<\/span> Promise<\/span><<\/span>void<\/span>><\/span> {
                  \n <\/span>
                  \n const<\/span> key =<\/span> `<\/span>${
                  \n <\/span>this<\/span>.<\/span>KEY_PREFIX<\/span>}<\/span><\/span>${
                  \n <\/span>instance.<\/span>serviceName}<\/span><\/span>:<\/span>${
                  \n <\/span>instance.<\/span>id}<\/span><\/span>`<\/span><\/span>;<\/span>
                  \n const<\/span> now =<\/span> Date.<\/span>now<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

                  \/\/ \u66f4\u65b0\u6ce8\u518c\u65f6\u95f4\u6216\u6700\u540e\u66f4\u65b0\u65f6\u95f4<\/span>
                  \n instance.<\/span>lastUpdateTime =<\/span> now;<\/span>
                  \n if<\/span> (<\/span>!<\/span>instance.<\/span>registrationTime)<\/span> {
                  \n <\/span>
                  \n instance.<\/span>registrationTime =<\/span> now;<\/span>
                  \n }<\/span><\/p>\n

                  \/\/ \u5c06\u670d\u52a1\u5b9e\u4f8b\u4fe1\u606f\u5b58\u50a8\u5230Redis<\/span>
                  \n await<\/span> this<\/span>.<\/span>redisClient.<\/span>set<\/span>(<\/span>key,<\/span> JSON<\/span>.<\/span>stringify<\/span>(<\/span>instance)<\/span>,<\/span> {
                  \n <\/span> EX<\/span>:<\/span> this<\/span>.<\/span>TTL<\/span> }<\/span>)<\/span>;<\/span><\/p>\n

                  \/\/ \u6dfb\u52a0\u5230\u670d\u52a1\u540d\u79f0\u96c6\u5408\u4e2d\uff0c\u65b9\u4fbf\u6309\u670d\u52a1\u540d\u67e5\u8be2<\/span>
                  \n await<\/span> this<\/span>.<\/span>redisClient.<\/span>sAdd<\/span>(<\/span>`<\/span>${
                  \n <\/span>this<\/span>.<\/span>KEY_PREFIX<\/span>}<\/span><\/span>${
                  \n <\/span>instance.<\/span>serviceName}<\/span><\/span>`<\/span><\/span>,<\/span> instance.<\/span>id)<\/span>;<\/span>
                  \n }<\/span><\/p>\n

                  \/\/ \u6ce8\u9500\u670d\u52a1\u5b9e\u4f8b<\/span>
                  \n async<\/span> deregister<\/span>(<\/span>instanceId:<\/span> string<\/span>)<\/span>:<\/span> Promise<\/span><<\/span>void<\/span>><\/span> {
                  \n <\/span>
                  \n \/\/ \u83b7\u53d6\u670d\u52a1\u5b9e\u4f8b\u4fe1\u606f<\/span>
                  \n const<\/span> pattern =<\/span> `<\/span>${
                  \n <\/span>this<\/span>.<\/span>KEY_PREFIX<\/span>}<\/span><\/span>*:<\/span>${
                  \n <\/span>instanceId}<\/span><\/span>`<\/span><\/span>;<\/span>
                  \n const<\/span> keys =<\/span> await<\/span> this<\/span>.<\/span>redisClient.<\/span>keys<\/span>(<\/span>pattern)<\/span>;<\/span><\/p>\n

                  if<\/span> (<\/span>keys.<\/span>length ><\/span> 0<\/span>)<\/span> {
                  \n <\/span>
                  \n const<\/span> key =<\/span> keys[<\/span>0<\/span>]<\/span>;<\/span>
                  \n const<\/span> serviceName =<\/span> key.<\/span>split<\/span>(<\/span>\\’:\\’<\/span>)<\/span>[<\/span>2<\/span>]<\/span>;<\/span><\/p>\n

                  \/\/ \u4eceRedis\u4e2d\u5220\u9664\u670d\u52a1\u5b9e\u4f8b<\/span>
                  \n await<\/span> this<\/span>.<\/span>redisClient.<\/span>del<\/span>(<\/span>key)<\/span>;<\/span><\/p>\n

                  \/\/ \u4ece\u670d\u52a1\u540d\u79f0\u96c6\u5408\u4e2d\u79fb\u9664<\/span>
                  \n await<\/span> this<\/span>.<\/span>redisClient.<\/span>sRem<\/span>(<\/span>`<\/span>${
                  \n <\/span>this<\/span>.<\/span>KEY_PREFIX<\/span>}<\/span><\/span>${
                  \n <\/span>serviceName}<\/span><\/span>`<\/span><\/span>,<\/span> instanceId)<\/span>;<\/span>
                  \n }<\/span>
                  \n }<\/span><\/p>\n

                  \/\/ \u83b7\u53d6\u6307\u5b9a\u670d\u52a1\u7684\u6240\u6709\u5b9e\u4f8b<\/span>
                  \n async<\/span> getInstances<\/span>(<\/span>serviceName:<\/span> string<\/span>)<\/span>:<\/span> Promise<\/span><<\/span>ServiceInstance[<\/span>]<\/span>><\/span> {
                  \n <\/span>
                  \n const<\/span> serviceKey =<\/span> `<\/span>${
                  \n <\/span>this<\/span>.<\/span>KEY_PREFIX<\/span>}<\/span><\/span>${
                  \n <\/span>serviceName}<\/span><\/span>`<\/span><\/span>;<\/span>
                  \n const<\/span> instanceIds =<\/span> await<\/span> this<\/span>.<\/span>redisClient.<\/span>sMembers<\/span>(<\/span>serviceKey)<\/span>;<\/span><\/p>\n

                  if<\/span> (<\/span>instanceIds.<\/span>length ===<\/span> 0<\/span>)<\/span> {
                  \n <\/span>
                  \n return<\/span> [<\/span>]<\/span>;<\/span>
                  \n }<\/span><\/p>\n

                  \/\/ \u6279\u91cf\u83b7\u53d6\u6240\u6709\u670d\u52a1\u5b9e\u4f8b\u4fe1\u606f<\/span>
                  \n const<\/span> keys =<\/span> instanceIds.<\/span>map<\/span>(<\/span>id =><\/span> `<\/span>${
                  \n <\/span>this<\/span>.<\/span>KEY_PREFIX<\/span>}<\/span><\/span>${
                  \n <\/span>serviceName}<\/span><\/span>:<\/span>${
                  \n <\/span>id}<\/span><\/span>`<\/span><\/span>)<\/span>;<\/span>
                  \n const<\/span> instancesData =<\/span> await<\/span> this<\/span>.<\/span>redisClient.<\/span>mGet<\/span>(<\/span>keys)<\/span>;<\/span><\/p>\n

                  \/\/ \u8fc7\u6ee4\u5e76\u89e3\u6790\u6709\u6548\u7684\u5b9e\u4f8b\u6570\u636e<\/span>
                  \n return<\/span> instancesData
                  \n .<\/span>filter<\/span>(<\/span>Boolean)<\/span>
                  \n .<\/span>map<\/span>(<\/span>data =><\/span> JSON<\/span>.<\/span>parse<\/span>(<\/span>data)<\/span>)<\/span>
                  \n .<\/span>filter<\/span>(<\/span>instance =><\/span> instance.<\/span>status !==<\/span> \\’DOWN\\’<\/span>)<\/span>;<\/span>
                  \n }<\/span><\/p>\n

                  \/\/ \u67e5\u8be2\u7b26\u5408\u7279\u5b9a\u6761\u4ef6\u7684\u670d\u52a1\u5b9e\u4f8b<\/span>
                  \n async<\/span> findServices<\/span>(<\/span>query:<\/span> ServiceQuery)<\/span>:<\/span> Promise<\/span><<\/span>ServiceInstance[<\/span>]<\/span>><\/span> {
                  \n <\/span>
                  \n const<\/span> {
                  \n <\/span> serviceName,<\/span> status,<\/span> metadata }<\/span> =<\/span> query;<\/span><\/p>\n

                  \/\/ \u83b7\u53d6\u6240\u6709\u5339\u914d\u670d\u52a1\u540d\u7684\u5b9e\u4f8b<\/span>
                  \n const<\/span> instances =<\/span> await<\/span> this<\/span>.<\/span>getInstances<\/span>(<\/span>serviceName)<\/span>;<\/span><\/p>\n

                  \/\/ \u5e94\u7528\u8fc7\u6ee4\u6761\u4ef6<\/span>
                  \n return<\/span> instances.<\/span>filter<\/span>(<\/span>instance =><\/span> {
                  \n <\/span>
                  \n \/\/ \u72b6\u6001\u8fc7\u6ee4<\/span>
                  \n if<\/span> (<\/span>status &&<\/span> instance.<\/span>status !==<\/span> status)<\/span> {
                  \n <\/span>
                  \n return<\/span> false<\/span>;<\/span>
                  \n }<\/span><\/p>\n

                  \/\/ \u5143\u6570\u636e\u8fc7\u6ee4<\/span>
                  \n if<\/span> (<\/span>metadata)<\/span> {
                  \n <\/span>
                  \n for<\/span> (<\/span>const<\/span> [<\/span>key,<\/span> value]<\/span> of<\/span> Object.<\/span>entries<\/span>(<\/span>metadata)<\/span>)<\/span> {
                  \n <\/span>
                  \n if<\/span> (<\/span>instance.<\/span>metadata[<\/span>key]<\/span> !==<\/span> value)<\/span> {
                  \n <\/span>
                  \n return<\/span> false<\/span>;<\/span>
                  \n }<\/span>
                  \n }<\/span>
                  \n }<\/span><\/p>\n

                  return<\/span> true<\/span>;<\/span>
                  \n }<\/span>)<\/span>;<\/span>
                  \n }<\/span><\/p>\n

                  \/\/ \u76d1\u542c\u670d\u52a1\u53d8\u66f4<\/span>
                  \n watchService<\/span>(<\/span>serviceName:<\/span> string<\/span>,<\/span> callback<\/span>:<\/span> (<\/span>instances:<\/span> ServiceInstance[<\/span>]<\/span>)<\/span> =><\/span> void<\/span>)<\/span>:<\/span> void<\/span> {
                  \n <\/span>
                  \n \/\/ \u521b\u5efa\u8ba2\u9605\u5ba2\u6237\u7aef<\/span>
                  \n const<\/span> subClient =<\/span> this<\/span>.<\/span>redisClient.<\/span>duplicate<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

                  \/\/ \u8ba2\u9605\u670d\u52a1\u53d8\u66f4\u4e8b\u4ef6<\/span>
                  \n subClient.<\/span>subscribe<\/span>(<\/span>`<\/span>${
                  \n <\/span>this<\/span>.<\/span>KEY_PREFIX<\/span>}<\/span><\/span>${
                  \n <\/span>serviceName}<\/span><\/span>:changes<\/span>`<\/span><\/span>,<\/span> (<\/span>message)<\/span> =><\/span> {
                  \n <\/span>
                  \n this<\/span>.<\/span>getInstances<\/span>(<\/span>serviceName)<\/span>.<\/span>then<\/span>(<\/span>callback)<\/span>;<\/span>
                  \n }<\/span>)<\/span>;<\/span>
                  \n }<\/span>
                  \n}<\/span><\/p>\n

                  \/\/ \u670d\u52a1\u6ce8\u518c\u8868API\u670d\u52a1\u5668<\/span>
                  \nfunction<\/span> createRegistryServer<\/span>(<\/span>registry:<\/span> McpServiceRegistry)<\/span>:<\/span> express.<\/span>Express {
                  \n <\/span>
                  \n const<\/span> app =<\/span> express<\/span>(<\/span>)<\/span>;<\/span>
                  \n app.<\/span>use<\/span>(<\/span>express.<\/span>json<\/span>(<\/span>)<\/span>)<\/span>;<\/span><\/p>\n

                  \/\/ \u670d\u52a1\u6ce8\u518c\u7aef\u70b9<\/span>
                  \n app.<\/span>post<\/span>(<\/span>\\’\/services\\’<\/span>,<\/span> async<\/span> (<\/span>req,<\/span> res)<\/span> =><\/span> {
                  \n <\/span>
                  \n try<\/span> {
                  \n <\/span>
                  \n const<\/span> instance =<\/span> req.<\/span>body as<\/span> ServiceInstance;<\/span>
                  \n await<\/span> registry.<\/span>register<\/span>(<\/span>instance)<\/span>;<\/span>
                  \n res.<\/span>status<\/span>(<\/span>201<\/span>)<\/span>.<\/span>json<\/span>(<\/span>{
                  \n <\/span> success:<\/span> true<\/span>,<\/span> message:<\/span> \\’\u670d\u52a1\u5b9e\u4f8b\u5df2\u6ce8\u518c\\’<\/span> }<\/span>)<\/span>;<\/span>
                  \n }<\/span> catch<\/span> (<\/span>error)<\/span> {
                  \n <\/span>
                  \n res.<\/span>status<\/span>(<\/span>500<\/span>)<\/span>.<\/span>json<\/span>(<\/span>{
                  \n <\/span> success:<\/span> false<\/span>,<\/span> error:<\/span> error.<\/span>message }<\/span>)<\/span>;<\/span>
                  \n }<\/span>
                  \n }<\/span>)<\/span>;<\/span><\/p>\n

                  \/\/ \u670d\u52a1\u6ce8\u9500\u7aef\u70b9<\/span>
                  \n app.<\/span>delete<\/span>(<\/span>\\’\/services\/:instanceId\\’<\/span>,<\/span> async<\/span> (<\/span>req,<\/span> res)<\/span> =><\/span> {
                  \n <\/span>
                  \n try<\/span> {
                  \n <\/span>
                  \n await<\/span> registry.<\/span>deregister<\/span>(<\/span>req.<\/span>params.<\/span>instanceId)<\/span>;<\/span>
                  \n res.<\/span>status<\/span>(<\/span>200<\/span>)<\/span>.<\/span>json<\/span>(<\/span>{
                  \n <\/span> success:<\/span> true<\/span>,<\/span> message:<\/span> \\’\u670d\u52a1\u5b9e\u4f8b\u5df2\u6ce8\u9500\\’<\/span> }<\/span>)<\/span>;<\/span>
                  \n }<\/span> catch<\/span> (<\/span>error)<\/span> {
                  \n <\/span>
                  \n res.<\/span>status<\/span>(<\/span>500<\/span>)<\/span>.<\/span>json<\/span>(<\/span>{
                  \n <\/span> success:<\/span> false<\/span>,<\/span> error:<\/span> error.<\/span>message }<\/span>)<\/span>;<\/span>
                  \n }<\/span>
                  \n }<\/span>)<\/span>;<\/span><\/p>\n

                  \/\/ \u83b7\u53d6\u670d\u52a1\u5b9e\u4f8b\u7aef\u70b9<\/span>
                  \n app.<\/span>get<\/span>(<\/span>\\’\/services\/:serviceName\\’<\/span>,<\/span> async<\/span> (<\/span>req,<\/span> res)<\/span> =><\/span> {
                  \n <\/span>
                  \n try<\/span> {
                  \n <\/span>
                  \n const<\/span> instances =<\/span> await<\/span> registry.<\/span>getInstances<\/span>(<\/span>req.<\/span>params.<\/span>serviceName)<\/span>;<\/span>
                  \n res.<\/span>status<\/span>(<\/span>200<\/span>)<\/span>.<\/span>json<\/span>(<\/span>{
                  \n <\/span> success:<\/span> true<\/span>,<\/span> data:<\/span> instances }<\/span>)<\/span>;<\/span>
                  \n }<\/span> catch<\/span> (<\/span>error)<\/span> {
                  \n <\/span>
                  \n res.<\/span>status<\/span>(<\/span>500<\/span>)<\/span>.<\/span>json<\/span>(<\/span>{
                  \n <\/span> success:<\/span> false<\/span>,<\/span> error:<\/span> error.<\/span>message }<\/span>)<\/span>;<\/span>
                  \n }<\/span>
                  \n }<\/span>)<\/span>;<\/span><\/p>\n

                  \/\/ \u670d\u52a1\u67e5\u8be2\u7aef\u70b9<\/span>
                  \n app.<\/span>get<\/span>(<\/span>\\’\/services\\’<\/span>,<\/span> async<\/span> (<\/span>req,<\/span> res)<\/span> =><\/span> {
                  \n <\/span>
                  \n try<\/span> {
                  \n <\/span>
                  \n const<\/span> query =<\/span> {
                  \n <\/span>
                  \n serviceName:<\/span> req.<\/span>query.<\/span>serviceName as<\/span> string<\/span>,<\/span>
                  \n status:<\/span> req.<\/span>query.<\/span>status as<\/span> \\’UP\\’<\/span> |<\/span> \\’DOWN\\’<\/span> |<\/span> \\’STARTING\\’<\/span> |<\/span> \\’OUT_OF_SERVICE\\’<\/span>,<\/span>
                  \n metadata:<\/span> req.<\/span>query.<\/span>metadata ?<\/span> JSON<\/span>.<\/span>parse<\/span>(<\/span>req.<\/span>query.<\/span>metadata as<\/span> string<\/span>)<\/span> :<\/span> undefined<\/span>
                  \n }<\/span>;<\/span><\/p>\n

                  const<\/span> instances =<\/span> await<\/span> registry.<\/span>findServices<\/span>(<\/span>query)<\/span>;<\/span>
                  \n res.<\/span>status<\/span>(<\/span>200<\/span>)<\/span>.<\/span>json<\/span>(<\/span>{
                  \n <\/span> success:<\/span> true<\/span>,<\/span> data:<\/span> instances }<\/span>)<\/span>;<\/span>
                  \n }<\/span> catch<\/span> (<\/span>error)<\/span> {
                  \n <\/span>
                  \n res.<\/span>status<\/span>(<\/span>500<\/span>)<\/span>.<\/span>json<\/span>(<\/span>{
                  \n <\/span> success:<\/span> false<\/span>,<\/span> error:<\/span> error.<\/span>message }<\/span>)<\/span>;<\/span>
                  \n }<\/span>
                  \n }<\/span>)<\/span>;<\/span><\/p>\n

                  return<\/span> app;<\/span>
                  \n}<\/span><\/p>\n

                  \/\/ \u4f7f\u7528MCP\u670d\u52a1\u5668\u5c01\u88c5\u670d\u52a1\u6ce8\u518c\u8868<\/span>
                  \nclass<\/span> McpRegistryServer<\/span> extends<\/span> McpServer<\/span> {
                  \n <\/span>
                  \n private<\/span> registry:<\/span> McpServiceRegistry;<\/span>
                  \n private<\/span> httpServer:<\/span> express.<\/span>Express;<\/span><\/p>\n

                  constructor<\/span>(<\/span>config:<\/span> {
                  \n <\/span>
                  \n name:<\/span> string<\/span>;<\/span>
                  \n description:<\/span> string<\/span>;<\/span>
                  \n version:<\/span> string<\/span>;<\/span>
                  \n redisUrl:<\/span> string<\/span>;<\/span>
                  \n port:<\/span> number<\/span>;<\/span>
                  \n }<\/span>)<\/span> {
                  \n <\/span>
                  \n super<\/span>(<\/span>{
                  \n <\/span>
                  \n name:<\/span> config.<\/span>name,<\/span>
                  \n description:<\/span> config.<\/span>description,<\/span>
                  \n version:<\/span> config.<\/span>version
                  \n }<\/span>)<\/span>;<\/span><\/p>\n

                  \/\/ \u521b\u5efa\u670d\u52a1\u6ce8\u518c\u8868<\/span>
                  \n this<\/span>.<\/span>registry =<\/span> new<\/span> McpServiceRegistry<\/span>(<\/span>config.<\/span>redisUrl)<\/span>;<\/span><\/p>\n

                  \/\/ \u521b\u5efaHTTP\u670d\u52a1\u5668<\/span>
                  \n this<\/span>.<\/span>httpServer =<\/span> createRegistryServer<\/span>(<\/span>this<\/span>.<\/span>registry)<\/span>;<\/span><\/p>\n

                  \/\/ \u542f\u52a8HTTP\u670d\u52a1\u5668<\/span>
                  \n this<\/span>.<\/span>httpServer.<\/span>listen<\/span>(<\/span>config.<\/span>port,<\/span> (<\/span>)<\/span> =><\/span> {
                  \n <\/span>
                  \n console<\/span>.<\/span>log<\/span>(<\/span>`<\/span>\u6ce8\u518c\u8868\u670d\u52a1\u5668\u8fd0\u884c\u5728\u7aef\u53e3 <\/span>${
                  \n <\/span>config.<\/span>port}<\/span><\/span>`<\/span><\/span>)<\/span>;<\/span>
                  \n }<\/span>)<\/span>;<\/span><\/p>\n

                  \/\/ \u4f5c\u4e3aMCP\u8d44\u6e90\u66b4\u9732\u670d\u52a1\u6ce8\u518c\u8868<\/span>
                  \n this<\/span>.<\/span>exposeRegistryAsResource<\/span>(<\/span>)<\/span>;<\/span>
                  \n }<\/span><\/p>\n

                  \/\/ \u5c06\u6ce8\u518c\u8868\u4f5c\u4e3aMCP\u8d44\u6e90\u66b4\u9732<\/span>
                  \n private<\/span> exposeRegistryAsResource<\/span>(<\/span>)<\/span> {
                  \n <\/span>
                  \n \/\/ \u5b9a\u4e49\u670d\u52a1\u5b9e\u4f8b\u8d44\u6e90\u6a21\u677f<\/span>
                  \n this<\/span>.<\/span>registerResourceTemplate<\/span>(<\/span>{
                  \n <\/span>
                  \n name:<\/span> \\”serviceInstances\\”<\/span>,<\/span>
                  \n description:<\/span> \\”MCP\u670d\u52a1\u5b9e\u4f8b\u8d44\u6e90\\”<\/span>,<\/span>
                  \n schema:<\/span> {
                  \n <\/span>
                  \n type<\/span>:<\/span> \\”object\\”<\/span>,<\/span>
                  \n properties:<\/span> {
                  \n <\/span>
                  \n id:<\/span> {
                  \n <\/span> type<\/span>:<\/span> \\”string\\”<\/span> }<\/span>,<\/span>
                  \n serviceName:<\/span> {
                  \n <\/span> type<\/span>:<\/span> \\”string\\”<\/span> }<\/span>,<\/span>
                  \n host:<\/span> {
                  \n <\/span> type<\/span>:<\/span> \\”string\\”<\/span> }<\/span>,<\/span>
                  \n port:<\/span> {
                  \n <\/span> type<\/span>:<\/span> \\”number\\”<\/span> }<\/span>,<\/span>
                  \n status:<\/span> {
                  \n <\/span> type<\/span>:<\/span> \\”string\\”<\/span>,<\/span> enum<\/span>:<\/span> [<\/span>\\”UP\\”<\/span>,<\/span> \\”DOWN\\”<\/span>,<\/span> \\”STARTING\\”<\/span>,<\/span> \\”OUT_OF_SERVICE\\”<\/span>]<\/span> }<\/span>,<\/span>
                  \n metadata:<\/span> {
                  \n <\/span> type<\/span>:<\/span> \\”object\\”<\/span> }<\/span>,<\/span>
                  \n healthCheckUrl:<\/span> {
                  \n <\/span> type<\/span>:<\/span> \\”string\\”<\/span> }<\/span>,<\/span>
                  \n registrationTime:<\/span> {
                  \n <\/span> type<\/span>:<\/span> \\”number\\”<\/span> }<\/span>,<\/span>
                  \n lastUpdateTime:<\/span> {
                  \n <\/span> type<\/span>:<\/span> \\”number\\”<\/span> }<\/span>
                  \n }<\/span>,<\/span>
                  \n required:<\/span> [<\/span>\\”id\\”<\/span>,<\/span> \\”serviceName\\”<\/span>,<\/span> \\”host\\”<\/span>,<\/span> <\/p>\n","protected":false},"excerpt":{"rendered":"

                  \u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb1.1k\u6b21\uff0c\u70b9\u8d5e29\u6b21\uff0c\u6536\u85cf23\u6b21\u3002\u968f\u7740\u4e1a\u52a1\u89c4\u6a21\u7684\u4e0d\u65ad\u6269\u5927\u548c\u7cfb\u7edf\u590d\u6742\u5ea6\u7684\u63d0\u5347\uff0c\u5355\u4e00\u670d\u52a1\u5668\u67b6\u6784\u5f80\u5f80\u65e0\u6cd5\u6ee1\u8db3\u9ad8\u5e76\u53d1\u3001\u9ad8\u53ef\u7528\u6027\u548c\u5f39\u6027\u6269\u5c55\u7684\u9700\u6c42\u3002\u5728MCP\u751f\u6001\u7cfb\u7edf\u4e2d\uff0c\u591a\u670d\u52a1\u5668\u534f\u4f5c\u67b6\u6784\u6210\u4e3a\u6784\u5efa\u5927\u89c4\u6a21\u5e94\u7528\u7684\u5fc5\u7136\u9009\u62e9\u3002\u672c\u6587\u5c06\u6df1\u5165\u63a2\u8ba8MCP TypeScript-SDK\u5728\u591a\u670d\u52a1\u5668\u73af\u5883\u4e0b\u7684\u90e8\u7f72\u3001\u534f\u4f5c\u548c\u7ba1\u7406\uff0c\u4ee5\u53ca\u5982\u4f55\u6784\u5efa\u9ad8\u53ef\u7528\u3001\u9ad8\u6027\u80fd\u3001\u6613\u6269\u5c55\u7684\u5206\u5e03\u5f0fMCP\u5e94\u7528\u3002\u591a\u670d\u52a1\u5668\u67b6\u6784\u57fa\u78401.1 MCP\u591a\u670d\u52a1\u5668\u67b6\u6784\u6982\u8ff01.2 \u5206\u5e03\u5f0f\u7cfb\u7edf\u7684\u6311\u6218\u4e0e\u89e3\u51b3\u65b9\u68481.3 MCP\u670d\u52a1\u5668\u5206\u7c7b\u4e0e\u804c\u8d23\u5212\u52061.4 \u591a\u670d\u52a1\u5668\u67b6\u6784\u7684\u5e38\u89c1\u6a21\u5f0f\u670d\u52a1\u53d1\u73b0\u4e0e\u8def\u75312.1 \u670d\u52a1\u6ce8\u518c\u4e0e\u53d1\u73b0\u673a\u52362.2 _\u5982\u4f55\u518dnode.js mcp\u9879\u76ee\u91cc \u5982\u4f55\u96c6\u6210\u522b\u4eba\u5f00\u53d1\u597d\u7684mcp\u670d\u52a1<\/p>\n","protected":false},"author":2,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[2623,66,73,186,50,43,188],"topic":[],"class_list":["post-35329","post","type-post","status-publish","format-standard","hentry","category-server","tag-mcp-node-js-sdk-","tag-ai","tag-mcp","tag-node-js","tag-50","tag-43","tag-188"],"yoast_head":"\n\u3010MCP Node.js SDK \u5168\u6808\u8fdb\u9636\u6307\u5357\u3011\u9ad8\u7ea7\u7bc7\uff081\uff09\uff1aMCP\u591a\u670d\u52a1\u5668\u534f\u4f5c\u67b6\u6784 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/www.wsisp.com\/helps\/35329.html\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"\u3010MCP Node.js SDK \u5168\u6808\u8fdb\u9636\u6307\u5357\u3011\u9ad8\u7ea7\u7bc7\uff081\uff09\uff1aMCP\u591a\u670d\u52a1\u5668\u534f\u4f5c\u67b6\u6784 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"og:description\" content=\"\u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb1.1k\u6b21\uff0c\u70b9\u8d5e29\u6b21\uff0c\u6536\u85cf23\u6b21\u3002\u968f\u7740\u4e1a\u52a1\u89c4\u6a21\u7684\u4e0d\u65ad\u6269\u5927\u548c\u7cfb\u7edf\u590d\u6742\u5ea6\u7684\u63d0\u5347\uff0c\u5355\u4e00\u670d\u52a1\u5668\u67b6\u6784\u5f80\u5f80\u65e0\u6cd5\u6ee1\u8db3\u9ad8\u5e76\u53d1\u3001\u9ad8\u53ef\u7528\u6027\u548c\u5f39\u6027\u6269\u5c55\u7684\u9700\u6c42\u3002\u5728MCP\u751f\u6001\u7cfb\u7edf\u4e2d\uff0c\u591a\u670d\u52a1\u5668\u534f\u4f5c\u67b6\u6784\u6210\u4e3a\u6784\u5efa\u5927\u89c4\u6a21\u5e94\u7528\u7684\u5fc5\u7136\u9009\u62e9\u3002\u672c\u6587\u5c06\u6df1\u5165\u63a2\u8ba8MCP TypeScript-SDK\u5728\u591a\u670d\u52a1\u5668\u73af\u5883\u4e0b\u7684\u90e8\u7f72\u3001\u534f\u4f5c\u548c\u7ba1\u7406\uff0c\u4ee5\u53ca\u5982\u4f55\u6784\u5efa\u9ad8\u53ef\u7528\u3001\u9ad8\u6027\u80fd\u3001\u6613\u6269\u5c55\u7684\u5206\u5e03\u5f0fMCP\u5e94\u7528\u3002\u591a\u670d\u52a1\u5668\u67b6\u6784\u57fa\u78401.1 MCP\u591a\u670d\u52a1\u5668\u67b6\u6784\u6982\u8ff01.2 \u5206\u5e03\u5f0f\u7cfb\u7edf\u7684\u6311\u6218\u4e0e\u89e3\u51b3\u65b9\u68481.3 MCP\u670d\u52a1\u5668\u5206\u7c7b\u4e0e\u804c\u8d23\u5212\u52061.4 \u591a\u670d\u52a1\u5668\u67b6\u6784\u7684\u5e38\u89c1\u6a21\u5f0f\u670d\u52a1\u53d1\u73b0\u4e0e\u8def\u75312.1 \u670d\u52a1\u6ce8\u518c\u4e0e\u53d1\u73b0\u673a\u52362.2 _\u5982\u4f55\u518dnode.js mcp\u9879\u76ee\u91cc \u5982\u4f55\u96c6\u6210\u522b\u4eba\u5f00\u53d1\u597d\u7684mcp\u670d\u52a1\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.wsisp.com\/helps\/35329.html\" \/>\n<meta property=\"og:site_name\" content=\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"article:published_time\" content=\"2025-05-04T02:50:49+00:00\" \/>\n<meta name=\"author\" content=\"admin\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"admin\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"12 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/35329.html\",\"url\":\"https:\/\/www.wsisp.com\/helps\/35329.html\",\"name\":\"\u3010MCP Node.js SDK \u5168\u6808\u8fdb\u9636\u6307\u5357\u3011\u9ad8\u7ea7\u7bc7\uff081\uff09\uff1aMCP\u591a\u670d\u52a1\u5668\u534f\u4f5c\u67b6\u6784 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"isPartOf\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\"},\"datePublished\":\"2025-05-04T02:50:49+00:00\",\"dateModified\":\"2025-05-04T02:50:49+00:00\",\"author\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/35329.html#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.wsisp.com\/helps\/35329.html\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/35329.html#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.wsisp.com\/helps\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"\u3010MCP Node.js SDK \u5168\u6808\u8fdb\u9636\u6307\u5357\u3011\u9ad8\u7ea7\u7bc7\uff081\uff09\uff1aMCP\u591a\u670d\u52a1\u5668\u534f\u4f5c\u67b6\u6784\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\",\"url\":\"https:\/\/www.wsisp.com\/helps\/\",\"name\":\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"description\":\"\u9999\u6e2f\u670d\u52a1\u5668_\u9999\u6e2f\u4e91\u670d\u52a1\u5668\u8d44\u8baf_\u670d\u52a1\u5668\u5e2e\u52a9\u6587\u6863_\u670d\u52a1\u5668\u6559\u7a0b\",\"potentialAction\":[{\"@type\":\"SearchAction\",\"target\":{\"@type\":\"EntryPoint\",\"urlTemplate\":\"https:\/\/www.wsisp.com\/helps\/?s={search_term_string}\"},\"query-input\":\"required name=search_term_string\"}],\"inLanguage\":\"zh-Hans\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\",\"name\":\"admin\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery\",\"contentUrl\":\"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery\",\"caption\":\"admin\"},\"sameAs\":[\"http:\/\/wp.wsisp.com\"],\"url\":\"https:\/\/www.wsisp.com\/helps\/author\/admin\"}]}<\/script>\n<!-- \/ Yoast SEO plugin. -->","yoast_head_json":{"title":"\u3010MCP Node.js SDK \u5168\u6808\u8fdb\u9636\u6307\u5357\u3011\u9ad8\u7ea7\u7bc7\uff081\uff09\uff1aMCP\u591a\u670d\u52a1\u5668\u534f\u4f5c\u67b6\u6784 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/www.wsisp.com\/helps\/35329.html","og_locale":"zh_CN","og_type":"article","og_title":"\u3010MCP Node.js SDK \u5168\u6808\u8fdb\u9636\u6307\u5357\u3011\u9ad8\u7ea7\u7bc7\uff081\uff09\uff1aMCP\u591a\u670d\u52a1\u5668\u534f\u4f5c\u67b6\u6784 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","og_description":"\u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb1.1k\u6b21\uff0c\u70b9\u8d5e29\u6b21\uff0c\u6536\u85cf23\u6b21\u3002\u968f\u7740\u4e1a\u52a1\u89c4\u6a21\u7684\u4e0d\u65ad\u6269\u5927\u548c\u7cfb\u7edf\u590d\u6742\u5ea6\u7684\u63d0\u5347\uff0c\u5355\u4e00\u670d\u52a1\u5668\u67b6\u6784\u5f80\u5f80\u65e0\u6cd5\u6ee1\u8db3\u9ad8\u5e76\u53d1\u3001\u9ad8\u53ef\u7528\u6027\u548c\u5f39\u6027\u6269\u5c55\u7684\u9700\u6c42\u3002\u5728MCP\u751f\u6001\u7cfb\u7edf\u4e2d\uff0c\u591a\u670d\u52a1\u5668\u534f\u4f5c\u67b6\u6784\u6210\u4e3a\u6784\u5efa\u5927\u89c4\u6a21\u5e94\u7528\u7684\u5fc5\u7136\u9009\u62e9\u3002\u672c\u6587\u5c06\u6df1\u5165\u63a2\u8ba8MCP TypeScript-SDK\u5728\u591a\u670d\u52a1\u5668\u73af\u5883\u4e0b\u7684\u90e8\u7f72\u3001\u534f\u4f5c\u548c\u7ba1\u7406\uff0c\u4ee5\u53ca\u5982\u4f55\u6784\u5efa\u9ad8\u53ef\u7528\u3001\u9ad8\u6027\u80fd\u3001\u6613\u6269\u5c55\u7684\u5206\u5e03\u5f0fMCP\u5e94\u7528\u3002\u591a\u670d\u52a1\u5668\u67b6\u6784\u57fa\u78401.1 MCP\u591a\u670d\u52a1\u5668\u67b6\u6784\u6982\u8ff01.2 \u5206\u5e03\u5f0f\u7cfb\u7edf\u7684\u6311\u6218\u4e0e\u89e3\u51b3\u65b9\u68481.3 MCP\u670d\u52a1\u5668\u5206\u7c7b\u4e0e\u804c\u8d23\u5212\u52061.4 \u591a\u670d\u52a1\u5668\u67b6\u6784\u7684\u5e38\u89c1\u6a21\u5f0f\u670d\u52a1\u53d1\u73b0\u4e0e\u8def\u75312.1 \u670d\u52a1\u6ce8\u518c\u4e0e\u53d1\u73b0\u673a\u52362.2 _\u5982\u4f55\u518dnode.js mcp\u9879\u76ee\u91cc \u5982\u4f55\u96c6\u6210\u522b\u4eba\u5f00\u53d1\u597d\u7684mcp\u670d\u52a1","og_url":"https:\/\/www.wsisp.com\/helps\/35329.html","og_site_name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","article_published_time":"2025-05-04T02:50:49+00:00","author":"admin","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"admin","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"12 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.wsisp.com\/helps\/35329.html","url":"https:\/\/www.wsisp.com\/helps\/35329.html","name":"\u3010MCP Node.js SDK \u5168\u6808\u8fdb\u9636\u6307\u5357\u3011\u9ad8\u7ea7\u7bc7\uff081\uff09\uff1aMCP\u591a\u670d\u52a1\u5668\u534f\u4f5c\u67b6\u6784 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","isPartOf":{"@id":"https:\/\/www.wsisp.com\/helps\/#website"},"datePublished":"2025-05-04T02:50:49+00:00","dateModified":"2025-05-04T02:50:49+00:00","author":{"@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41"},"breadcrumb":{"@id":"https:\/\/www.wsisp.com\/helps\/35329.html#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.wsisp.com\/helps\/35329.html"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.wsisp.com\/helps\/35329.html#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.wsisp.com\/helps"},{"@type":"ListItem","position":2,"name":"\u3010MCP Node.js SDK \u5168\u6808\u8fdb\u9636\u6307\u5357\u3011\u9ad8\u7ea7\u7bc7\uff081\uff09\uff1aMCP\u591a\u670d\u52a1\u5668\u534f\u4f5c\u67b6\u6784"}]},{"@type":"WebSite","@id":"https:\/\/www.wsisp.com\/helps\/#website","url":"https:\/\/www.wsisp.com\/helps\/","name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","description":"\u9999\u6e2f\u670d\u52a1\u5668_\u9999\u6e2f\u4e91\u670d\u52a1\u5668\u8d44\u8baf_\u670d\u52a1\u5668\u5e2e\u52a9\u6587\u6863_\u670d\u52a1\u5668\u6559\u7a0b","potentialAction":[{"@type":"SearchAction","target":{"@type":"EntryPoint","urlTemplate":"https:\/\/www.wsisp.com\/helps\/?s={search_term_string}"},"query-input":"required name=search_term_string"}],"inLanguage":"zh-Hans"},{"@type":"Person","@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41","name":"admin","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/image\/","url":"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery","contentUrl":"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery","caption":"admin"},"sameAs":["http:\/\/wp.wsisp.com"],"url":"https:\/\/www.wsisp.com\/helps\/author\/admin"}]}},"_links":{"self":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/35329","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/users\/2"}],"replies":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/comments?post=35329"}],"version-history":[{"count":0,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/35329\/revisions"}],"wp:attachment":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media?parent=35329"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/categories?post=35329"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/tags?post=35329"},{"taxonomy":"topic","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/topic?post=35329"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}