{"id":118408,"date":"2026-10-27T11:16:51","date_gmt":"2026-10-27T03:16:51","guid":{"rendered":"https:\/\/www.wsisp.com\/helps\/118408.html"},"modified":"2026-10-27T11:16:51","modified_gmt":"2026-10-27T03:16:51","slug":"ai%e6%99%ba%e8%83%bd%e4%bd%93%e9%a1%b9%e7%9b%ae%e5%ae%9e%e6%88%98%e8%ae%b0%e5%bd%95%ef%bc%8825%ef%bc%89%ef%bc%9a%e6%99%ba%e8%83%bd%e4%bd%93%e6%b7%bb%e5%8a%a0%e9%99%90%e6%b5%81%ef%bc%8cmcp-server","status":"publish","type":"post","link":"https:\/\/www.wsisp.com\/helps\/118408.html","title":{"rendered":"AI\u667a\u80fd\u4f53\u9879\u76ee\u5b9e\u6218\u8bb0\u5f55\uff0825\uff09\uff1a\u667a\u80fd\u4f53\u6dfb\u52a0\u9650\u6d41\uff0cMCP Server \u6dfb\u52a0\u9650\u6d41\u4e0e\u9274\u6743"},"content":{"rendered":"

\/* MD \/ \u5bcc\u6587\u672c\u4e2d\u7684 .toc\uff08\u542b\u535a\u5ba2\u56ed\u642c\u5bb6\u7b49\u5d4c\u5957\u7ed3\u6784\uff09\uff1b.toc-box \u5728\u4fa7\u680f\uff0c\u4e0d\u53d7\u5f71\u54cd *\/
\n #content_views .toc,
\n \/* \u7f16\u8f91\u5668\u5e38\u5728\u76ee\u5f55\u524d\u540e\u63d2\u5165\u7a7a p\uff08:empty \u4ecd\u5360 20px\uff09\uff0c\u4e00\u5e76\u53bb\u6389\u907f\u514d\u9876\u7a7a\u9699 *\/
\n #content_views.markdown_views > p:empty:has(+ .toc),
\n #content_views.markdown_views > .toc + p:empty,
\n \/* \u5bcc\u6587\u672c\u65e7\u7248\u76ee\u5f55\u6807\u8bb0 *\/
\n #content_views.htmledit_views #main-toc,
\n #content_views.htmledit_views #hr-toc,
\n #content_views.htmledit_views p[id*=\\”-toc\\”] {
\n display: none !important;
\n }
\n \/* \u76ee\u5f55\u53bb\u6389\u540e\uff0c\u7d27\u8ddf\u7684\u9996\u4e2a\u6807\u9898\u4e0d\u518d\u591a\u51fa\u4e00\u5757\u4e0a\u8fb9\u8ddd *\/
\n #content_views.markdown_views > .toc + h1,
\n #content_views.markdown_views > .toc + h2,
\n #content_views.markdown_views > .toc + h3,
\n #content_views.markdown_views > .toc + h4,
\n #content_views.markdown_views > .toc + p:empty + h1,
\n #content_views.markdown_views > .toc + p:empty + h2,
\n #content_views.markdown_views > .toc + p:empty + h3,
\n #content_views.markdown_views > .toc + p:empty + h4 {
\n margin-top: 0 !important;
\n }<\/p>\n

AI\u667a\u80fd\u4f53\u9879\u76ee\u5b9e\u6218\u8bb0\u5f55（25）：\u667a\u80fd\u4f53\u6dfb\u52a0\u9650\u6d41，MCP Server \u6dfb\u52a0\u9650\u6d41\u4e0e\u9274\u6743<\/h2>\n

1. \u4e3a\u4ec0\u4e48\u8981\u9650\u6d41<\/h3>\n

\u524d 24 \u7bc7\u628a\u667a\u80fd\u4f53\u80fd\u529b\u505a\u901a\u4e86：\u5bf9\u8bdd\u3001\u5b50\u667a\u80fd\u4f53\u7f16\u6392\u3001\u77e5\u8bc6\u5e93\u3001MCP Server\u3001\u684c\u9762\u5de5\u4f5c\u53f0\u63a5\u5165\u3002\u529f\u80fd\u8dd1\u901a\u4e4b\u540e，\u6210\u672c\u4e0e\u7a33\u5b9a\u6027\u5c31\u6210\u4e86\u5fc5\u987b\u5904\u7406\u7684\u95ee\u9898\u3002<\/p>\n

1.1 \u4e0d\u9650\u6d41\u4f1a\u51fa\u4ec0\u4e48\u4e8b<\/h4>\n\n\u98ce\u9669\u5177\u4f53\u8868\u73b0<\/tr>\n\n\n\n\n\n\n
\u6210\u672c\u5931\u63a7<\/td>\n\u4e00\u6b21\u5bf9\u8bdd\u4f1a\u8c03\u7528\u591a\u6b21\u5927\u6a21\u578b（\u4e3b\u7ba1\u51b3\u7b56 + \u5b50\u667a\u80fd\u4f53 + \u603b\u7ed3），\u5355\u4e2a\u7528\u6237\u5237\u4e00\u8f6e\u5c31\u53ef\u80fd\u4e0a\u4e07 token；\u63a5\u53e3\u4e00\u65e6\u88ab\u811a\u672c\u5237，\u8d26\u5355\u76f4\u63a5\u5931\u63a7<\/td>\n<\/tr>\n
\u8d44\u6e90\u6253\u6ee1<\/td>\n\u6bcf\u6b21\u4f1a\u8bdd\u90fd\u8981\u5360\u7528\u4e00\u4e2a SSE \u957f\u8fde\u63a5 + \u7ebf\u7a0b\u6c60 + \u5411\u91cf\u5e93\u8fde\u63a5；3~5 \u4e2a\u5e76\u53d1\u5c31\u8db3\u4ee5\u628a\u5355\u673a GPU\/CPU \u5403\u6ee1，\u5176\u4f59\u7528\u6237\u76f4\u63a5\u5361\u6b7b<\/td>\n<\/tr>\n
\u5355\u70b9\u96ea\u5d29<\/td>\nMilvus \/ \u5927\u6a21\u578b\u54cd\u5e94\u53d8\u6162 \u2192 \u8bf7\u6c42\u5728\u670d\u52a1\u7aef\u5806\u79ef \u2192 \u5185\u5b58\u4e0a\u6da8 \u2192 \u6574\u4e2a\u670d\u52a1\u4e0d\u53ef\u7528<\/td>\n<\/tr>\n
\u80fd\u529b\u88f8\u5954<\/td>\n\u7b2c 23 \u7bc7\u5199\u597d\u7684 MCP Server \u6ca1\u6709\u4efb\u4f55\u9274\u6743，\u8c01\u62ff\u5230\u5730\u5740\u8c01\u5c31\u80fd\u8c03\u7528\u5185\u90e8\u77e5\u8bc6\u5e93<\/td>\n<\/tr>\n
\u989d\u5ea6\u4e0d\u53ef\u63a7<\/td>\n\u5bf9\u5916\u63d0\u4f9b\u7684 MCP \u80fd\u529b\u6ca1\u6709\u7528\u91cf\u4e0a\u9650，\u4e00\u4e2a\u5ba2\u6237\u7aef\u53ef\u4ee5\u628a\u989d\u5ea6\u7528\u5149<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n

1.2 \u672c\u7bc7\u8981\u843d\u5730\u7684 5 \u4ef6\u4e8b<\/h4>\n

\u5bf9\u8bdd\u4fa7（\u672c\u9879\u76ee\u524d\u7aef \/ \u767b\u5f55\u7528\u6237）
\n \u251c\u2500 \u2460 \u540c\u4e00\u7528\u6237\u6700\u591a 3 \u4e2a\u5e76\u53d1\u4f1a\u8bdd \u2192 \u4fdd\u62a4\u670d\u52a1\u7aef\u8d44\u6e90
\n \u2514\u2500 \u2461 \u540c\u4e00\u7528\u6237\u6bcf\u5929 token \u4e0a\u9650 \u2192 \u63a7\u5236\u6210\u672c<\/p>\n

MCP \u4fa7（WorkBuddy \/ \u7b2c\u4e09\u65b9\u5ba2\u6237\u7aef）
\n \u251c\u2500 \u2462 API Key \u9274\u6743（\u65e0 key \u63d0\u793a\u5148\u83b7\u53d6） \u2192 \u9632\u6b62\u88f8\u5954
\n \u251c\u2500 \u2463 \u5e76\u53d1\u4e0a\u9650 + \u7194\u65ad \u2192 \u4fdd\u62a4\u4e0b\u6e38 Milvus \/ \u5927\u6a21\u578b
\n \u2514\u2500 \u2464 \u6bcf\u4e2a key（\u7528\u6237）\u6bcf\u5929 token \u4e0a\u9650 \u2192 \u9632\u6b62\u5355\u5ba2\u6237\u7aef\u5237\u989d\u5ea6<\/p>\n

\u8bbe\u8ba1\u539f\u5219：\u9650\u6d41\u7ec4\u4ef6\u672c\u8eab\u7edd\u4e0d\u80fd\u6210\u4e3a\u6545\u969c\u70b9\u3002\u6240\u6709 Redis \u64cd\u4f5c\u90fd\u6709\u964d\u7ea7\u8def\u5f84，\u9650\u6d41\u5224\u65ad\u5931\u8d25\u4e0d\u80fd\u963b\u65ad\u6b63\u5e38\u4e1a\u52a1\u3002<\/p>\n

\n

2. \u6574\u4f53\u7ed3\u6784<\/h3>\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\u2510
\n \u524d\u7aef\u5bf9\u8bdd \u2500\u2500\u2500\u2500\u2500\u2500\u25b6\u2502 chat_controller \u2502
\n \u2502 \u2460 session_limit_service \u2502\u2500\u2500\u25b6 Redis（\u5e76\u53d1\u8ba1\u6570，TTL \u515c\u5e95）
\n \u2502 \u2461 token_quota_service \u2502\u2500\u2500\u25b6 Redis（\u5f53\u65e5\u7528\u91cf）\u2500\u2500\u25b6 PG（ai_invoke_log \u6c47\u603b）
\n \u2514\u2500\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\u2518
\n \u25bc
\n supervisor_graph（\u4e3b\u7ba1\u7f16\u6392）
\n \u2502 \u7ed3\u675f\u65f6\u5199 ai_invoke_log
\n \u25bc
\n token_quota_service.add_tokens(chat)<\/p>\n

WorkBuddy \u2500\u2500\u2500\u2500\u25b6 knowledge_server（SSE）
\n \u251c\u2500 \u2462 API Key \u6821\u9a8c（401 \u63d0\u793a\u5148\u83b7\u53d6 key）
\n \u251c\u2500 \u2463 ConcurrencyGuard（\u5e76\u53d1 + \u7194\u65ad）
\n \u2514\u2500 \u2464 \u5de5\u5177\u5185\u6821\u9a8c MCP \u6bcf\u65e5\u989d\u5ea6
\n \u2502
\n \u25bc
\n RAGTool.run_with_usage \u2192 \u8fd4\u56de\u7b54\u6848 + token
\n \u2502
\n \u25bc
\n log_external_invoke（SKILL_ID_ = mcp:xxx）
\n \u2514\u2500\u25b6 add_tokens(mcp)<\/p>\n

\u65b0\u589e\/\u6539\u52a8\u6587\u4ef6：<\/p>\n\n\u6587\u4ef6\u4f5c\u7528<\/tr>\n\n\n\n\n\n\n\n\n\n
app\/service\/system\/session_limit_service.py<\/td>\n\u65b0\u589e：\u5e76\u53d1\u4f1a\u8bdd\u8ba1\u6570<\/td>\n<\/tr>\n
app\/service\/system\/token_quota_service.py<\/td>\n\u65b0\u589e：\u6bcf\u65e5 token \u914d\u989d<\/td>\n<\/tr>\n
app\/controller\/chat_controller.py<\/td>\n\u63a5\u5165\u4e24\u4e2a\u6821\u9a8c，\u5e76\u5728\u6d41\u7ed3\u675f\u65f6\u91ca\u653e\u540d\u989d<\/td>\n<\/tr>\n
app\/service\/system\/invoke_log_service.py<\/td>\n\u843d\u5e93\u540e\u7d2f\u52a0\u989d\u5ea6；\u65b0\u589e\u5916\u90e8\u8c03\u7528\u65e5\u5fd7<\/td>\n<\/tr>\n
app\/tools\/rag_tool.py<\/td>\n\u65b0\u589e run_with_usage，\u8fd4\u56de\u7b54\u6848\u4e0e token<\/td>\n<\/tr>\n
app\/mcp\/knowledge_server.py<\/td>\nKey \u9274\u6743 + \u5e76\u53d1\u7194\u65ad + \u6bcf\u65e5\u989d\u5ea6<\/td>\n<\/tr>\n
scripts\/test_mcp_knowledge_sse.py<\/td>\n\u652f\u6301 –key<\/td>\n<\/tr>\n
app\/config\/settings.py\u3001.env<\/td>\n\u914d\u7f6e\u9879<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n
\n

3. \u914d\u7f6e\u9879<\/h3>\n

.env：<\/p>\n

# ============ \u9650\u6d41\u4e0e\u914d\u989d ============
\n# \u540c\u4e00\u767b\u5f55\u7528\u6237\u540c\u65f6\u8fdb\u884c\u7684\u5bf9\u8bdd\u6570\u4e0a\u9650
\nCHAT_MAX_CONCURRENT_SESSIONS=3
\n# \u6bcf\u4e2a\u767b\u5f55\u7528\u6237\u6bcf\u5929\u53ef\u6d88\u8017\u7684 token \u4e0a\u9650（<=0 \u4e0d\u9650\u5236）
\nCHAT_DAILY_TOKEN_LIMIT=200000<\/p>\n

# ============ \u5bf9\u5916 MCP Server \u7684\u9274\u6743\u4e0e\u9650\u6d41 ============
\n# \u662f\u5426\u5f00\u542f API Key \u6821\u9a8c（\u751f\u4ea7\u73af\u5883\u52a1\u5fc5\u5f00\u542f）
\nMCP_AUTH_ENABLED=true
\n# API Key \u5217\u8868："key:userId,key2:userId2"；\u4e0d\u5199 userId \u65f6\u4ec5\u9274\u6743\u3001\u4e0d\u505a\u7528\u6237\u914d\u989d
\nMCP_API_KEYS="sk-mcp-demo-key:1001"
\n# MCP \u5de5\u5177\u5e76\u53d1\u6267\u884c\u4e0a\u9650
\nMCP_MAX_CONCURRENCY=3
\n# \u8fde\u7eed\u62d2\u7edd\u591a\u5c11\u6b21\u540e\u7194\u65ad
\nMCP_BREAKER_TRIP_THRESHOLD=5
\n# \u7194\u65ad\u6301\u7eed\u65f6\u95f4（\u79d2）
\nMCP_BREAKER_COOLDOWN_SECONDS=30
\n# \u6bcf\u4e2a\u7528\u6237\u6bcf\u5929\u901a\u8fc7 MCP \u8c03\u7528\u53ef\u6d88\u8017\u7684 token \u4e0a\u9650（<=0 \u4e0d\u9650\u5236）
\nMCP_DAILY_TOKEN_LIMIT=50000<\/p>\n

settings.py：<\/p>\n

# \u540c\u4e00\u767b\u5f55\u7528\u6237\u540c\u65f6\u8fdb\u884c\u7684\u5bf9\u8bdd\u6570\u4e0a\u9650（SSE \u6d41\u672a\u7ed3\u675f\u65f6\u7b97\u5360\u7528\u4e00\u4e2a）<\/span>
\n chat_max_concurrent_sessions:<\/span> int<\/span> =<\/span> 3<\/span>
\n # \u6bcf\u4e2a\u767b\u5f55\u7528\u6237\u6bcf\u5929\u53ef\u6d88\u8017\u7684 token \u4e0a\u9650（\u666e\u901a\u5bf9\u8bdd，<=0 \u8868\u793a\u4e0d\u9650\u5236）<\/span>
\n chat_daily_token_limit:<\/span> int<\/span> =<\/span> 200000<\/span>
\n # \u662f\u5426\u5f00\u542f API Key \u6821\u9a8c（\u751f\u4ea7\u73af\u5883\u52a1\u5fc5\u5f00\u542f）<\/span>
\n mcp_auth_enabled:<\/span> bool<\/span> =<\/span> True<\/span>
\n # API Key \u5217\u8868，\u683c\u5f0f "key:userId,key2:userId2"<\/span>
\n mcp_api_keys:<\/span> Optional[<\/span>str<\/span>]<\/span> =<\/span> ''<\/span>
\n # MCP \u5de5\u5177\u5e76\u53d1\u6267\u884c\u4e0a\u9650，\u8d85\u8fc7\u540e\u62d2\u7edd\u8bf7\u6c42<\/span>
\n mcp_max_concurrency:<\/span> int<\/span> =<\/span> 3<\/span>
\n # \u8fde\u7eed\u62d2\u7edd\u591a\u5c11\u6b21\u540e\u89e6\u53d1\u7194\u65ad<\/span>
\n mcp_breaker_trip_threshold:<\/span> int<\/span> =<\/span> 5<\/span>
\n # \u7194\u65ad\u6301\u7eed\u65f6\u95f4（\u79d2）<\/span>
\n mcp_breaker_cooldown_seconds:<\/span> int<\/span> =<\/span> 30<\/span>
\n # \u6bcf\u4e2a\u7528\u6237\u6bcf\u5929\u901a\u8fc7 MCP \u8c03\u7528\u53ef\u6d88\u8017\u7684 token \u4e0a\u9650（<=0 \u8868\u793a\u4e0d\u9650\u5236）<\/span>
\n mcp_daily_token_limit:<\/span> int<\/span> =<\/span> 50000<\/span><\/p>\n

\u4e24\u4e2a\u8bbe\u8ba1\u53d6\u820d：<\/p>\n

  • key:userId \u800c\u4e0d\u662f\u7eaf key：MCP \u4fa7\u7684\u989d\u5ea6\u662f\u6309\u4eba\u7b97\u7684，key \u5fc5\u987b\u80fd\u6620\u5c04\u5230\u4e00\u4e2a\u7528\u6237；<\/li>\n
  • \u4e24\u5957\u989d\u5ea6\u5206\u5f00：CHAT_DAILY_TOKEN_LIMIT \u4e0e MCP_DAILY_TOKEN_LIMIT \u4e92\u4e0d\u6324\u5360，\u907f\u514d\u684c\u9762\u5de5\u4f5c\u53f0\u7684\u8c03\u7528\u628a\u7f51\u9875\u7aef\u7684\u989d\u5ea6\u5403\u5149\u3002<\/li>\n
    \n

    4. \u5bf9\u8bdd\u4fa7\u2460：\u540c\u4e00\u7528\u6237\u6700\u591a 3 \u4e2a\u5e76\u53d1\u4f1a\u8bdd<\/h3>\n

    4.1 \u4e3a\u4ec0\u4e48\u7528"\u8ba1\u6570"\u800c\u4e0d\u662f"\u67e5\u4f1a\u8bdd\u8868"<\/h4>\n

    \u7528\u6237\u5386\u53f2\u4f1a\u8bdd\u662f\u6301\u4e45\u5316\u7684，\u6570\u91cf\u53ea\u589e\u4e0d\u51cf，\u4e0d\u80fd\u7528\u6765\u5224\u65ad"\u540c\u65f6\u8fdb\u884c"\u3002\u771f\u6b63\u8981\u9650\u5236\u7684\u662f\u6b63\u5728\u8fdb\u884c\u7684\u5bf9\u8bdd\u6d41：\u4ece\u8bf7\u6c42\u5f00\u59cb\u751f\u6210，\u5230\u6700\u540e\u4e00\u5e27 SSE \u8fd4\u56de\u4e3a\u6b62\u3002<\/p>\n

    \u6240\u4ee5\u7528\u539f\u5b50\u8ba1\u6570：\u8bf7\u6c42\u8fdb\u6765 INCR，\u6d41\u7ed3\u675f DECR，\u8d85\u8fc7\u9608\u503c\u5c31\u62d2\u7edd\u3002<\/p>\n

    4.2 \u5b9e\u73b0<\/h4>\n

    app\/service\/system\/session_limit_service.py：<\/p>\n

    _KEY_PREFIX =<\/span> "chat:running:"<\/span>
    \n_KEY_TTL_SECONDS =<\/span> 7200<\/span> # \u515c\u5e95\u8fc7\u671f，\u9632\u6b62\u8fdb\u7a0b\u5d29\u6e83\u540e\u540d\u989d\u4e0d\u91ca\u653e<\/span><\/p>\n

    def<\/span> acquire<\/span>(<\/span>user_id:<\/span> str<\/span>,<\/span> limit:<\/span> int<\/span>)<\/span> –<\/span>><\/span> bool<\/span>:<\/span>
    \n if<\/span> not<\/span> user_id or<\/span> limit <=<\/span> 0<\/span>:<\/span>
    \n return<\/span> True<\/span> # limit<=0 \u89c6\u4e3a\u4e0d\u9650\u5236<\/span>
    \n try<\/span>:<\/span>
    \n client =<\/span> redis_service.<\/span>get_client(<\/span>)<\/span>
    \n key =<\/span> _key(<\/span>user_id)<\/span>
    \n current =<\/span> client.<\/span>incr(<\/span>key)<\/span> # \u539f\u5b50\u81ea\u589e<\/span>
    \n if<\/span> current ==<\/span> 1<\/span>:<\/span>
    \n client.<\/span>expire(<\/span>key,<\/span> _KEY_TTL_SECONDS)<\/span>
    \n if<\/span> current ><\/span> limit:<\/span>
    \n client.<\/span>decr(<\/span>key)<\/span> # \u8d85\u9650\u7acb\u523b\u56de\u6eda，\u907f\u514d\u8ba1\u6570\u865a\u9ad8<\/span>
    \n logger.<\/span>warning(<\/span>f"[limit] \u7528\u6237<\/span>{<\/span>user_id}<\/span><\/span>\u5e76\u53d1\u4f1a\u8bdd\u5df2\u8fbe\u4e0a\u9650 <\/span>{<\/span>limit}<\/span><\/span>"<\/span><\/span>)<\/span>
    \n return<\/span> False<\/span>
    \n return<\/span> True<\/span>
    \n except<\/span> Exception as<\/span> e:<\/span>
    \n logger.<\/span>warning(<\/span>f"[limit] Redis \u4e0d\u53ef\u7528，\u964d\u7ea7\u4e3a\u8fdb\u7a0b\u5185\u8ba1\u6570: <\/span>{<\/span>e}<\/span><\/span>"<\/span><\/span>)<\/span>
    \n return<\/span> _acquire_local(<\/span>user_id,<\/span> limit)<\/span><\/p>\n

    release \u91cc\u6709\u4e00\u4e2a\u7ec6\u8282：decr \u53ef\u80fd\u56e0\u4e3a key \u5df2\u8fc7\u671f\u53d8\u6210\u8d1f\u6570，\u6240\u4ee5\u8981\u94b3\u5236\u5230 0\u3002<\/p>\n

    def<\/span> release<\/span>(<\/span>user_id:<\/span> str<\/span>)<\/span> –<\/span>><\/span> None<\/span>:<\/span>
    \n .<\/span>.<\/span>.<\/span>
    \n if<\/span> client.<\/span>exists(<\/span>key)<\/span>:<\/span>
    \n if<\/span> client.<\/span>decr(<\/span>key)<\/span> <<\/span> 0<\/span>:<\/span>
    \n client.<\/span>set<\/span>(<\/span>key,<\/span> 0<\/span>,<\/span> ex=<\/span>_KEY_TTL_SECONDS)<\/span><\/p>\n

    4.3 \u63a5\u5165\u5bf9\u8bdd\u63a5\u53e3<\/h4>\n

    app\/controller\/chat_controller.py：<\/p>\n

    # ———- \u9650\u6d41\u4e00：\u540c\u4e00\u7528\u6237\u5e76\u53d1\u4f1a\u8bdd\u6570 ———-<\/span>
    \n max_sessions =<\/span> int<\/span>(<\/span>setting.<\/span>chat_max_concurrent_sessions or<\/span> 0<\/span>)<\/span>
    \n slot_acquired =<\/span> False<\/span>
    \n if<\/span> max_sessions ><\/span> 0<\/span>:<\/span>
    \n slot_acquired =<\/span> await<\/span> asyncio.<\/span>to_thread(<\/span>
    \n session_limit_service.<\/span>acquire,<\/span> user_id,<\/span> max_sessions
    \n )<\/span>
    \n if<\/span> not<\/span> slot_acquired:<\/span>
    \n return<\/span> _reject_resp(<\/span>
    \n request_body,<\/span>
    \n f'\u5f53\u524d\u540c\u65f6\u8fdb\u884c\u7684\u4f1a\u8bdd\u5df2\u8fbe\u4e0a\u9650（<\/span>{<\/span>max_sessions}<\/span><\/span> \u4e2a），\u8bf7\u7ed3\u675f\u5176\u5b83\u4f1a\u8bdd\u540e\u518d\u8bd5'<\/span><\/span>,<\/span>
    \n )<\/span><\/p>\n

    \u91ca\u653e\u5fc5\u987b\u5728 finally，\u4e14\u6d41\u5f0f\u63a5\u53e3\u8981\u653e\u5230\u751f\u6210\u5668\u7684 finally \u91cc，\u56e0\u4e3a\u5ba2\u6237\u7aef\u4e2d\u9014\u65ad\u5f00\u65f6\u751f\u6210\u5668\u4f1a\u88ab\u5173\u95ed：<\/p>\n

    finally<\/span>:<\/span>
    \n # \u65e0\u8bba\u6b63\u5e38\u7ed3\u675f\u3001\u5f02\u5e38\u8fd8\u662f\u5ba2\u6237\u7aef\u65ad\u5f00，\u90fd\u8981\u5f52\u8fd8\u5e76\u53d1\u4f1a\u8bdd\u540d\u989d<\/span>
    \n if<\/span> release_user_id:<\/span>
    \n await<\/span> asyncio.<\/span>to_thread(<\/span>session_limit_service.<\/span>release,<\/span> release_user_id)<\/span><\/p>\n

    \u6d41\u5f0f\u63a5\u53e3\u7684 reject \u4e8b\u4ef6\u524d\u7aef\u5df2\u7ecf\u8ba4\u8bc6（StreamDataRespType.REJECT），\u4e0d\u9700\u8981\u6539\u524d\u7aef\u3002<\/p>\n

    \n

    5. \u5bf9\u8bdd\u4fa7\u2461：\u6bcf\u4e2a\u7528\u6237\u6bcf\u5929 token \u4e0a\u9650<\/h3>\n

    5.1 \u7edf\u8ba1\u53e3\u5f84<\/h4>\n

    token \u6570\u636e\u4e0d\u91cd\u65b0\u91c7\u96c6，\u76f4\u63a5\u590d\u7528\u7b2c 15\/19 \u7bc7\u843d\u5e93\u7684\u8c03\u7528\u65e5\u5fd7：ai_invoke_log.COST_TOKEN\u3002<\/p>\n

    SELECT<\/span> COALESCE<\/span>(<\/span>SUM<\/span>(<\/span>COST_TOKEN)<\/span>,<\/span> 0<\/span>)<\/span>
    \nFROM<\/span> ai_invoke_log
    \nWHERE<\/span> CREATE_BY_ =<\/span> :user_id
    \n AND<\/span> CREATE_TIME_ >=<\/span> :day_start
    \n AND<\/span> (<\/span>SKILL_ID_ IS<\/span> NULL<\/span> OR<\/span> SKILL_ID_ NOT<\/span> LIKE<\/span> 'mcp%'<\/span>)<\/span> — \u666e\u901a\u5bf9\u8bdd\u989d\u5ea6\u4e0d\u542b MCP \u8c03\u7528<\/span><\/p>\n

    5.2 \u4e3a\u4ec0\u4e48\u8981 Redis \u5305\u4e00\u5c42<\/h4>\n

    \u6bcf\u6b21\u5bf9\u8bdd\u524d\u90fd SUM \u4e00\u904d\u5168\u8868\u662f\u6309\u7528\u6237+\u65f6\u95f4\u626b\u7684，QPS \u4e0a\u6765\u4f1a\u5f88\u91cd\u3002\u6539\u6210 Redis \u8ba1\u6570\u5668 + \u6570\u636e\u5e93\u56de\u6e90：<\/p>\n\n\u573a\u666f\u884c\u4e3a<\/tr>\n\n\n\n\n\n
    \u6b63\u5e38\u8bfb<\/td>\n\u8bfb Redis quota:tokens:chat:{userId}:{yyyymmdd}<\/td>\n<\/tr>\n
    key \u7f3a\u5931（\u9996\u6b21 \/ Redis \u91cd\u542f）<\/td>\n\u67e5\u5e93\u6c47\u603b \u2192 \u56de\u586b Redis（TTL \u5230\u5f53\u5929\u7ed3\u675f）<\/td>\n<\/tr>\n
    \u6bcf\u6b21\u843d\u5e93\u540e<\/td>\nINCRBY \u7d2f\u52a0，\u4e0d\u518d\u67e5\u5e93<\/td>\n<\/tr>\n
    Redis \u6302\u4e86<\/td>\n\u76f4\u63a5\u67e5\u5e93，\u529f\u80fd\u4e0d\u53d7\u5f71\u54cd<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n

    app\/service\/system\/token_quota_service.py：<\/p>\n

    def<\/span> used_tokens<\/span>(<\/span>user_id:<\/span> str<\/span>,<\/span> scope:<\/span> str<\/span> =<\/span> "chat"<\/span>)<\/span> –<\/span>><\/span> int<\/span>:<\/span>
    \n key =<\/span> _key(<\/span>user_id,<\/span> scope)<\/span>
    \n try<\/span>:<\/span>
    \n client =<\/span> redis_service.<\/span>get_client(<\/span>)<\/span>
    \n value =<\/span> client.<\/span>get(<\/span>key)<\/span>
    \n if<\/span> value is<\/span> not<\/span> None<\/span>:<\/span>
    \n return<\/span> int<\/span>(<\/span>value or<\/span> 0<\/span>)<\/span>
    \n used =<\/span> _sum_from_db(<\/span>user_id,<\/span> scope)<\/span>
    \n client.<\/span>set<\/span>(<\/span>key,<\/span> used,<\/span> ex=<\/span>_ttl_seconds(<\/span>)<\/span>)<\/span>
    \n return<\/span> used
    \n except<\/span> Exception as<\/span> e:<\/span>
    \n logger.<\/span>warning(<\/span>f"[quota] Redis \u4e0d\u53ef\u7528，\u76f4\u63a5\u67e5\u5e93: <\/span>{<\/span>e}<\/span><\/span>"<\/span><\/span>)<\/span>
    \n return<\/span> _sum_from_db(<\/span>user_id,<\/span> scope)<\/span><\/p>\n

    def<\/span> add_tokens<\/span>(<\/span>user_id:<\/span> str<\/span>,<\/span> tokens:<\/span> int<\/span>,<\/span> scope:<\/span> str<\/span> =<\/span> "chat"<\/span>)<\/span> –<\/span>><\/span> None<\/span>:<\/span>
    \n .<\/span>.<\/span>.<\/span>
    \n if<\/span> not<\/span> client.<\/span>exists(<\/span>key)<\/span>:<\/span>
    \n client.<\/span>set<\/span>(<\/span>key,<\/span> _sum_from_db(<\/span>user_id,<\/span> scope)<\/span>,<\/span> ex=<\/span>_ttl_seconds(<\/span>)<\/span>)<\/span>
    \n client.<\/span>incrby(<\/span>key,<\/span> int<\/span>(<\/span>tokens)<\/span>)<\/span><\/p>\n

    add_tokens \u91cc"\u5148\u56de\u6e90\u518d\u81ea\u589e"\u5f88\u5173\u952e：Redis \u91cd\u542f\u540e key \u4e0d\u5b58\u5728，\u5982\u679c\u76f4\u63a5 INCRBY \u4f1a\u628a\u6570\u636e\u5e93\u91cc\u5df2\u6709\u7684\u7528\u91cf\u8986\u76d6\u6389，\u7b49\u4e8e\u7ed9\u7528\u6237\u91cd\u7f6e\u4e86\u989d\u5ea6\u3002<\/p>\n

    5.3 \u7d2f\u52a0\u65f6\u673a<\/h4>\n

    \u843d\u5e93\u6210\u529f\u540e\u7acb\u5373\u7d2f\u52a0，\u4fdd\u8bc1"\u5199\u65e5\u5fd7"\u4e0e"\u6263\u989d\u5ea6"\u662f\u540c\u4e00\u6b65\u53d1\u751f\u7684（invoke_log_service._do_finalize）：<\/p>\n

    logger.<\/span>info(<\/span>f"[invoke_log] \u5df2\u5199\u5165\u8c03\u7528\u65e5\u5fd7 … tokens=<\/span>{<\/span>run_log.<\/span>total_tokens}<\/span><\/span>"<\/span><\/span>)<\/span><\/p>\n

    # \u7d2f\u52a0\u5f53\u5929\u666e\u901a\u5bf9\u8bdd\u989d\u5ea6（MCP \u8c03\u7528\u5728 MCP Server \u4fa7\u5355\u72ec\u7d2f\u52a0）<\/span>
    \n token_quota_service.<\/span>add_tokens(<\/span>run_log.<\/span>user_id,<\/span> run_log.<\/span>total_tokens,<\/span> "chat"<\/span>)<\/span><\/p>\n

    5.4 \u63a5\u5165\u5bf9\u8bdd\u63a5\u53e3<\/h4>\n

    # ———- \u9650\u6d41\u4e8c：\u6bcf\u65e5 token \u914d\u989d ———-<\/span>
    \n daily_limit =<\/span> int<\/span>(<\/span>setting.<\/span>chat_daily_token_limit or<\/span> 0<\/span>)<\/span>
    \n if<\/span> daily_limit ><\/span> 0<\/span>:<\/span>
    \n allowed,<\/span> used,<\/span> quota =<\/span> await<\/span> asyncio.<\/span>to_thread(<\/span>
    \n token_quota_service.<\/span>check,<\/span> user_id,<\/span> daily_limit,<\/span> 'chat'<\/span>
    \n )<\/span>
    \n if<\/span> not<\/span> allowed:<\/span>
    \n if<\/span> slot_acquired:<\/span>
    \n await<\/span> asyncio.<\/span>to_thread(<\/span>session_limit_service.<\/span>release,<\/span> user_id)<\/span>
    \n return<\/span> _reject_resp(<\/span>
    \n request_body,<\/span>
    \n f'\u60a8\u4eca\u65e5\u7684 token \u989d\u5ea6\u5df2\u7528\u5b8c（\u5df2\u7528 <\/span>{<\/span>used}<\/span><\/span> \/ \u4e0a\u9650 <\/span>{<\/span>quota}<\/span><\/span>），\u6682\u4e0d\u53ef\u7528，\u8bf7\u660e\u5929\u518d\u8bd5'<\/span><\/span>,<\/span>
    \n )<\/span><\/p>\n

    \u6ce8\u610f\u8fd9\u91cc\u5148\u5f52\u8fd8\u5e76\u53d1\u540d\u989d\u518d\u8fd4\u56de，\u5426\u5219\u7528\u6237\u6bcf\u88ab\u989d\u5ea6\u62d2\u7edd\u4e00\u6b21\u5c31\u767d\u5360\u4e00\u4e2a\u5751\u3002<\/p>\n

    \n

    6. MCP \u4fa7\u2462：API Key \u9274\u6743<\/h3>\n

    6.1 \u73b0\u72b6：FastMCP 1.4.1 \u7684 SSE \u6ca1\u6709\u9274\u6743<\/h4>\n

    # mcp 1.4.1 \u7684 FastMCP.run_sse_async \u5185\u90e8\u5b9e\u73b0（\u8282\u9009）<\/span>
    \nasync<\/span> def<\/span> handle_sse<\/span>(<\/span>request)<\/span>:<\/span>
    \n async<\/span> with<\/span> sse.<\/span>connect_sse(<\/span>request.<\/span>scope,<\/span> request.<\/span>receive,<\/span> request.<\/span>_send)<\/span> as<\/span> streams:<\/span>
    \n await<\/span> self.<\/span>_mcp_server.<\/span>run(<\/span>.<\/span>.<\/span>.<\/span>)<\/span> # \u76f4\u63a5\u8fdb\u5165\u534f\u8bae，\u6ca1\u6709\u4efb\u4f55\u6821\u9a8c<\/span><\/p>\n

    starlette_app =<\/span> Starlette(<\/span>routes=<\/span>[<\/span>
    \n Route(<\/span>"\/sse"<\/span>,<\/span> endpoint=<\/span>handle_sse)<\/span>,<\/span>
    \n Mount(<\/span>"\/messages\/"<\/span>,<\/span> app=<\/span>sse.<\/span>handle_post_message)<\/span>,<\/span>
    \n]<\/span>)<\/span><\/p>\n

    \u5b83\u4e5f\u6ca1\u6709\u66b4\u9732 sse_app()，\u6240\u4ee5\u4e0d\u80fd\u7b80\u5355\u52a0\u4e2d\u95f4\u4ef6\u3002\u65b9\u6848：\u7167\u5b83\u7684\u7ed3\u6784\u81ea\u5df1\u642d\u4e00\u4e2a Starlette \u5e94\u7528，\u5728 handle_sse \u91cc\u5148\u6821\u9a8c key\u3002<\/p>\n

    6.2 \u6821\u9a8c\u903b\u8f91<\/h4>\n

    def<\/span> _parse_api_keys<\/span>(<\/span>raw:<\/span> str<\/span>)<\/span> –<\/span>><\/span> Dict[<\/span>str<\/span>,<\/span> str<\/span>]<\/span>:<\/span>
    \n """\u89e3\u6790 MCP_API_KEYS：'key1:userId1,key2:userId2' \u2192 {key: userId}"""<\/span>
    \n result:<\/span> Dict[<\/span>str<\/span>,<\/span> str<\/span>]<\/span> =<\/span> {<\/span>}<\/span>
    \n for<\/span> item in<\/span> (<\/span>raw or<\/span> ""<\/span>)<\/span>.<\/span>split(<\/span>","<\/span>)<\/span>:<\/span>
    \n item =<\/span> item.<\/span>strip(<\/span>)<\/span>
    \n if<\/span> not<\/span> item:<\/span>
    \n continue<\/span>
    \n key,<\/span> _,<\/span> user_id =<\/span> item.<\/span>partition(<\/span>":"<\/span>)<\/span>
    \n if<\/span> key.<\/span>strip(<\/span>)<\/span>:<\/span>
    \n result[<\/span>key.<\/span>strip(<\/span>)<\/span>]<\/span> =<\/span> user_id.<\/span>strip(<\/span>)<\/span>
    \n return<\/span> result<\/p>\n

    def<\/span> _extract_key<\/span>(<\/span>request:<\/span> Request)<\/span> –<\/span>><\/span> str<\/span>:<\/span>
    \n """\u4ece Authorization: Bearer \/ ?key= \/ X-API-Key \u4e2d\u53d6 key"""<\/span>
    \n auth =<\/span> request.<\/span>headers.<\/span>get(<\/span>"authorization"<\/span>)<\/span> or<\/span> ""<\/span>
    \n if<\/span> auth.<\/span>lower(<\/span>)<\/span>.<\/span>startswith(<\/span>"bearer "<\/span>)<\/span>:<\/span>
    \n return<\/span> auth[<\/span>7<\/span>:<\/span>]<\/span>.<\/span>strip(<\/span>)<\/span>
    \n return<\/span> (<\/span>request.<\/span>query_params.<\/span>get(<\/span>"key"<\/span>)<\/span> or<\/span> request.<\/span>headers.<\/span>get(<\/span>"x-api-key"<\/span>)<\/span> or<\/span> ""<\/span>)<\/span>.<\/span>strip(<\/span>)<\/span><\/p>\n

    def<\/span> _authenticate<\/span>(<\/span>request:<\/span> Request)<\/span> –<\/span>><\/span> Tuple[<\/span>str<\/span>,<\/span> str<\/span>]<\/span>:<\/span>
    \n if<\/span> not<\/span> setting.<\/span>mcp_auth_enabled:<\/span>
    \n return<\/span> ""<\/span>,<\/span> ""<\/span>
    \n if<\/span> not<\/span> _API_KEYS:<\/span>
    \n return<\/span> ""<\/span>,<\/span> "\u670d\u52a1\u7aef\u672a\u914d\u7f6e\u4efb\u4f55 API Key（MCP_API_KEYS），\u8bf7\u5148\u5728 .env \u4e2d\u914d\u7f6e"<\/span>
    \n key =<\/span> _extract_key(<\/span>request)<\/span>
    \n if<\/span> not<\/span> key:<\/span>
    \n return<\/span> ""<\/span>,<\/span> "\u7f3a\u5c11 API Key，\u8bf7\u5148\u83b7\u53d6 key \u540e\u518d\u8bbf\u95ee"<\/span>
    \n for<\/span> candidate,<\/span> user_id in<\/span> _API_KEYS.<\/span>items(<\/span>)<\/span>:<\/span>
    \n if<\/span> secrets.<\/span>compare_digest(<\/span>key,<\/span> candidate)<\/span>:<\/span>
    \n return<\/span> user_id,<\/span> ""<\/span>
    \n return<\/span> ""<\/span>,<\/span> "API Key \u65e0\u6548，\u8bf7\u786e\u8ba4 key \u662f\u5426\u6b63\u786e"<\/span><\/p>\n

    \u4e09\u4e2a\u7ec6\u8282：<\/p>\n

      \n
    • \u7528 secrets.compare_digest \u800c\u4e0d\u662f ==，\u907f\u514d\u65f6\u5e8f\u653b\u51fb；<\/li>\n
    • \u652f\u6301\u4e09\u79cd\u4f20\u9012\u65b9\u5f0f，\u662f\u56e0\u4e3a\u4e0d\u540c\u5ba2\u6237\u7aef\u80fd\u529b\u4e0d\u4e00\u6837：WorkBuddy \u7684 mcp.json \u91cc\u5728 URL \u4e0a\u8ffd\u52a0 ?key= \u6700\u7701\u4e8b，IDE \/ Claude Desktop \u66f4\u9002\u5408 Authorization \u5934；<\/li>\n
    • \u8fd4\u56de\u7684 userId \u5c31\u662f\u540e\u9762\u7b97\u989d\u5ea6\u7528\u7684\u8eab\u4efd\u3002<\/li>\n<\/ul>\n

      6.3 \u81ea\u5df1\u642d SSE \u5e94\u7528<\/h4>\n

      def<\/span> _build_sse_app<\/span>(<\/span>)<\/span> –<\/span>><\/span> Starlette:<\/span>
      \n sse =<\/span> SseServerTransport(<\/span>"\/messages\/"<\/span>)<\/span><\/p>\n

      async<\/span> def<\/span> handle_sse<\/span>(<\/span>request:<\/span> Request)<\/span>:<\/span>
      \n caller,<\/span> err =<\/span> _authenticate(<\/span>request)<\/span>
      \n if<\/span> err:<\/span>
      \n logger.<\/span>warning(<\/span>f"[mcp-server] \u9274\u6743\u5931\u8d25: <\/span>{<\/span>err}<\/span><\/span>"<\/span><\/span>)<\/span>
      \n return<\/span> JSONResponse(<\/span>
      \n {<\/span>"error"<\/span>:<\/span> err,<\/span> "hint"<\/span>:<\/span> "\u8bf7\u5148\u83b7\u53d6 API Key \u540e\u518d\u8fde\u63a5"<\/span>}<\/span>,<\/span>
      \n status_code=<\/span>401<\/span>,<\/span>
      \n )<\/span>
      \n if<\/span> _GUARD.<\/span>is_open(<\/span>)<\/span>:<\/span>
      \n return<\/span> JSONResponse(<\/span>{<\/span>"error"<\/span>:<\/span> "\u670d\u52a1\u7e41\u5fd9（\u7194\u65ad\u4e2d），\u8bf7\u7a0d\u540e\u91cd\u8bd5"<\/span>}<\/span>,<\/span> status_code=<\/span>503<\/span>)<\/span><\/p>\n

      # \u540c\u4e00\u6761 SSE \u8fde\u63a5\u4e0a\u7684\u6240\u6709\u5de5\u5177\u8c03\u7528\u90fd\u5f52\u5c5e\u8fd9\u4e2a\u8c03\u7528\u65b9<\/span>
      \n _caller_var.<\/span>set<\/span>(<\/span>caller)<\/span><\/p>\n

      async<\/span> with<\/span> sse.<\/span>connect_sse(<\/span>request.<\/span>scope,<\/span> request.<\/span>receive,<\/span> request.<\/span>_send)<\/span> as<\/span> streams:<\/span>
      \n await<\/span> mcp.<\/span>_mcp_server.<\/span>run(<\/span>
      \n streams[<\/span>0<\/span>]<\/span>,<\/span> streams[<\/span>1<\/span>]<\/span>,<\/span> mcp.<\/span>_mcp_server.<\/span>create_initialization_options(<\/span>)<\/span>
      \n )<\/span><\/p>\n

      return<\/span> Starlette(<\/span>
      \n debug=<\/span>mcp.<\/span>settings.<\/span>debug,<\/span>
      \n routes=<\/span>[<\/span>
      \n Route(<\/span>"\/sse"<\/span>,<\/span> endpoint=<\/span>handle_sse)<\/span>,<\/span>
      \n # \/messages \u7528 SSE \u63e1\u624b\u65f6\u4e0b\u53d1\u7684 session_id \u4f5c\u77ed\u671f\u51ed\u8bc1，\u4e0d\u518d\u91cd\u590d\u6821\u9a8c key<\/span>
      \n Mount(<\/span>"\/messages\/"<\/span>,<\/span> app=<\/span>sse.<\/span>handle_post_message)<\/span>,<\/span>
      \n ]<\/span>,<\/span>
      \n )<\/span><\/p>\n

      \u4e24\u4e2a\u5173\u952e\u70b9：<\/p>\n

    • \/messages \u4e0d\u91cd\u590d\u6821\u9a8c key：SSE \u5ba2\u6237\u7aef\u62ff\u5230 event: endpoint \u91cc\u7684 \/messages\/?session_id=xxx \u540e，POST \u65f6\u4e0d\u4f1a\u5e26 key\u3002session_id \u662f\u63e1\u624b\u65f6\u968f\u673a\u751f\u6210\u7684，\u672c\u8eab\u5c31\u662f\u4e00\u6761\u77ed\u671f\u51ed\u8bc1，\u6240\u4ee5\u53ea\u6821\u9a8c\u63e1\u624b\u5373\u53ef；<\/li>\n
    • \u8eab\u4efd\u901a\u8fc7 contextvar \u900f\u4f20：\u5de5\u5177\u662f\u5728 SSE \u8fd9\u6761\u8fde\u63a5\u7684\u4efb\u52a1\u91cc\u6267\u884c\u7684，handle_sse \u91cc set() \u7684\u503c\u80fd\u88ab\u5de5\u5177\u8bfb\u5230；\u5199\u8fdb POST \u8bf7\u6c42\u7684\u4e0a\u4e0b\u6587\u53cd\u800c\u8bfb\u4e0d\u5230（\u4e0d\u662f\u540c\u4e00\u4e2a\u4efb\u52a1）\u3002<\/li>\n

      _caller_var:<\/span> ContextVar[<\/span>str<\/span>]<\/span> =<\/span> ContextVar(<\/span>"mcp_caller"<\/span>,<\/span> default=<\/span>""<\/span>)<\/span><\/p>\n

      @mcp.<\/span>tool<\/span>(<\/span>name=<\/span>"search_knowledge_base"<\/span>,<\/span> .<\/span>.<\/span>.<\/span>)<\/span>
      \nasync<\/span> def<\/span> search_knowledge_base<\/span>(<\/span>question:<\/span> str<\/span>)<\/span> –<\/span>><\/span> str<\/span>:<\/span>
      \n caller =<\/span> _caller_var.<\/span>get(<\/span>)<\/span> # \u7531 key \u89e3\u6790\u51fa\u7684\u7528\u6237ID<\/span><\/p>\n

      6.4 \u6ca1\u6709 key \u7684\u8868\u73b0<\/h4>\n

      $ curl.exe -s -i –max-time 3 http:\/\/127.0.0.1:18766\/sse
      \nHTTP\/1.1 401 Unauthorized
      \ncontent-type: application\/json<\/p>\n

      {"error":"\u7f3a\u5c11 API Key，\u8bf7\u5148\u83b7\u53d6 key \u540e\u518d\u8bbf\u95ee","hint":"\u8bf7\u5148\u83b7\u53d6 API Key \u540e\u518d\u8fde\u63a5"}<\/p>\n

      \u5ba2\u6237\u7aef（WorkBuddy）\u4fa7\u8868\u73b0\u4e3a\u8fde\u63a5\u5931\u8d25\u3001\u8fde\u63a5\u5668\u7ea2\u70b9\u3002\u6587\u6863\u7b2c 24 \u7bc7\u7684\u63a5\u6cd5\u8981\u6539\u6210\u5e26 key：<\/p>\n

      {<\/span>
      \n "mcpServers"<\/span>:<\/span> {<\/span>
      \n "\u6d4b\u8bd5\u77e5\u8bc6\u5e93"<\/span>:<\/span> {<\/span>
      \n "type"<\/span>:<\/span> "sse"<\/span>,<\/span>
      \n "url"<\/span>:<\/span> "http:\/\/127.0.0.1:18765\/sse?key=sk-mcp-demo-key"<\/span>
      \n }<\/span>
      \n }<\/span>
      \n}<\/span><\/p>\n

      \u9879\u76ee\u5185\u6d4b\u8bd5\u811a\u672c\u540c\u6b65\u52a0\u4e86 –key：<\/p>\n

      D:\\\\anaconda3\\\\envs\\\\test01\\\\python.<\/span>exe scripts\\\\test_mcp_knowledge_sse.<\/span>py `
      \n —<\/span>url http:\/<\/span>\/<\/span>127.<\/span>0.<\/span>0.<\/span>1:18766\/sse —<\/span>key sk-mcp-demo-key `
      \n —<\/span>question "\u77e5\u8bc6\u5e93\u91cc\u6709\u6ca1\u6709\u8bb0\u5f55\u5f53\u524d\u9879\u76ee\u4f7f\u7528\u4e86\u4ec0\u4e48\u6280\u672f\u6808？"<\/span><\/p>\n

      \n

      7. MCP \u4fa7\u2463：\u5e76\u53d1\u4e0a\u9650\u4e0e\u7194\u65ad<\/h3>\n

      7.1 \u4e3a\u4ec0\u4e48\u8981"\u62d2\u7edd"\u800c\u4e0d\u662f"\u6392\u961f"<\/h4>\n

      \u6392\u961f\u770b\u8d77\u6765\u66f4\u53cb\u597d，\u4f46\u5728 Agent \u573a\u666f\u91cc\u662f\u707e\u96be：\u6bcf\u6b21\u5de5\u5177\u8c03\u7528 2~10 \u79d2，\u6392\u961f\u4f1a\u8ba9\u5ba2\u6237\u7aef\u8d85\u65f6\u3001SSE \u957f\u8fde\u63a5\u5806\u79ef，\u6700\u540e\u5185\u5b58\u88ab\u6253\u7206\u3002\u5feb\u901f\u5931\u8d25 + \u5ba2\u6237\u7aef\u7a0d\u540e\u91cd\u8bd5\u624d\u662f\u5b89\u5168\u7684\u505a\u6cd5\u3002<\/p>\n

      7.2 \u5b9e\u73b0<\/h4>\n

      class<\/span> ConcurrencyGuard<\/span>:<\/span>
      \n """
      \n – \u5e76\u53d1\u6570\u8fbe\u5230 MCP_MAX_CONCURRENCY \u65f6\u76f4\u63a5\u62d2\u7edd，\u4e0d\u6392\u961f；
      \n – \u8fde\u7eed\u88ab\u62d2\u7edd MCP_BREAKER_TRIP_THRESHOLD \u6b21\u540e\u7194\u65ad，
      \n \u51b7\u5374 MCP_BREAKER_COOLDOWN_SECONDS \u79d2，\u671f\u95f4\u6240\u6709\u8bf7\u6c42\u5feb\u901f\u5931\u8d25\u3002
      \n """<\/span><\/p>\n

      def<\/span> try_acquire<\/span>(<\/span>self)<\/span> –<\/span>><\/span> Tuple[<\/span>bool<\/span>,<\/span> str<\/span>]<\/span>:<\/span>
      \n now =<\/span> time.<\/span>monotonic(<\/span>)<\/span>
      \n if<\/span> now <<\/span> self.<\/span>_open_until:<\/span>
      \n return<\/span> False<\/span>,<\/span> f"\u670d\u52a1\u5df2\u7194\u65ad，\u8bf7 <\/span>{<\/span>int<\/span>(<\/span>self.<\/span>_open_until –<\/span> now)<\/span> +<\/span> 1<\/span>}<\/span><\/span> \u79d2\u540e\u91cd\u8bd5"<\/span><\/span><\/p>\n

      if<\/span> self.<\/span>inflight >=<\/span> self.<\/span>max_concurrency:<\/span>
      \n self.<\/span>_trips +=<\/span> 1<\/span>
      \n if<\/span> self.<\/span>cooldown_seconds ><\/span> 0<\/span> and<\/span> self.<\/span>_trips >=<\/span> self.<\/span>trip_threshold:<\/span>
      \n self.<\/span>_open_until =<\/span> now +<\/span> self.<\/span>cooldown_seconds
      \n self.<\/span>_trips =<\/span> 0<\/span>
      \n return<\/span> False<\/span>,<\/span> f"\u5e76\u53d1\u8d85\u8fc7\u4e0a\u9650（<\/span>{<\/span>self.<\/span>max_concurrency}<\/span><\/span>），\u670d\u52a1\u7194\u65ad <\/span>{<\/span>self.<\/span>cooldown_seconds}<\/span><\/span> \u79d2"<\/span><\/span>
      \n return<\/span> False<\/span>,<\/span> f"\u5f53\u524d\u8bf7\u6c42\u8fc7\u591a（\u5e76\u53d1\u4e0a\u9650 <\/span>{<\/span>self.<\/span>max_concurrency}<\/span><\/span>），\u8bf7\u7a0d\u540e\u91cd\u8bd5"<\/span><\/span><\/p>\n

      self.<\/span>inflight +=<\/span> 1<\/span>
      \n return<\/span> True<\/span>,<\/span> ""<\/span><\/p>\n

      def<\/span> release<\/span>(<\/span>self)<\/span> –<\/span>><\/span> None<\/span>:<\/span>
      \n if<\/span> self.<\/span>inflight ><\/span> 0<\/span>:<\/span>
      \n self.<\/span>inflight -=<\/span> 1<\/span>
      \n self.<\/span>_trips =<\/span> 0<\/span> # \u6709\u8bf7\u6c42\u6210\u529f\u5b8c\u6210\u5c31\u91cd\u7f6e\u8fde\u51fb\u8ba1\u6570<\/span><\/p>\n

      \u5de5\u5177\u91cc\u7684\u7528\u6cd5（finally \u5fc5\u987b\u91ca\u653e）：<\/p>\n

      ok,<\/span> reason =<\/span> _GUARD.<\/span>try_acquire(<\/span>)<\/span>
      \n if<\/span> not<\/span> ok:<\/span>
      \n logger.<\/span>warning(<\/span>f"[mcp-server] \u62d2\u7edd\u8c03\u7528 caller=<\/span>{<\/span>caller or<\/span> '-'<\/span>}<\/span><\/span> reason=<\/span>{<\/span>reason}<\/span><\/span>"<\/span><\/span>)<\/span>
      \n return<\/span> f"\u3010\u9650\u6d41\u3011<\/span>{<\/span>reason}<\/span><\/span>"<\/span><\/span>
      \n try<\/span>:<\/span>
      \n .<\/span>.<\/span>.<\/span>
      \n finally<\/span>:<\/span>
      \n _GUARD.<\/span>release(<\/span>)<\/span><\/p>\n

      \u8fd4\u56de\u7684\u662f\u4e00\u6bb5\u666e\u901a\u6587\u672c\u800c\u4e0d\u662f\u629b\u5f02\u5e38，\u8fd9\u6837\u5927\u6a21\u578b\u62ff\u5230\u540e\u80fd\u6b63\u5e38\u8f6c\u8ff0\u7ed9\u7528\u6237，WorkBuddy \u91cc\u770b\u5230\u7684\u662f"\u5f53\u524d\u8bf7\u6c42\u8fc7\u591a，\u8bf7\u7a0d\u540e\u91cd\u8bd5"，\u800c\u4e0d\u662f\u4e00\u4e2a\u7ea2\u8272\u62a5\u9519\u3002<\/p>\n

      7.3 \u5b9e\u6d4b<\/h4>\n

      \u76f4\u63a5\u628a\u5b88\u536b\u62ff\u51fa\u6765\u8dd1（max=1, \u9608\u503c=2, \u51b7\u5374=30）：<\/p>\n

      1 (True, '')
      \n2 (False, '\u5f53\u524d\u8bf7\u6c42\u8fc7\u591a（\u5e76\u53d1\u4e0a\u9650 1），\u8bf7\u7a0d\u540e\u91cd\u8bd5')
      \n3 (False, '\u5e76\u53d1\u8d85\u8fc7\u4e0a\u9650（1），\u670d\u52a1\u7194\u65ad 30 \u79d2')
      \nopen True
      \n4 (False, '\u670d\u52a1\u5df2\u7194\u65ad，\u8bf7 31 \u79d2\u540e\u91cd\u8bd5')<\/p>\n

      \u524d\u4e24\u4e2a\u8bf7\u6c42\u5360\u6ee1\u5e76\u53d1 \u2192 \u7b2c 2 \u6b21\u62d2\u7edd\u8bb0 1 \u6b21\u8fde\u51fb \u2192 \u7b2c 3 \u6b21\u62d2\u7edd\u8fbe\u5230\u9608\u503c \u2192 \u7194\u65ad\u6253\u5f00 \u2192 \u4e4b\u540e\u5168\u90e8\u5feb\u901f\u5931\u8d25\u3002<\/p>\n

      \n

      8. MCP \u4fa7\u2464：\u6bcf\u4e2a\u7528\u6237\u6bcf\u5929 token \u4e0a\u9650<\/h3>\n

      8.1 token \u4ece\u54ea\u6765<\/h4>\n

      \u539f\u6765\u7684 RAGTool._run \u53ea\u8fd4\u56de\u5b57\u7b26\u4e32，\u62ff\u4e0d\u5230 token\u3002\u7ed9\u5b83\u52a0\u4e00\u4e2a\u5e26\u7528\u91cf\u7684\u65b9\u6cd5，_run \u4fdd\u6301 LangChain \u7684\u5de5\u5177\u5951\u7ea6\u4e0d\u53d8：<\/p>\n

      def<\/span> _run<\/span>(<\/span>self,<\/span> question:<\/span> str<\/span>)<\/span> –<\/span>><\/span> str<\/span>:<\/span>
      \n """\u6267\u884c\u77e5\u8bc6\u5e93\u95ee\u7b54（LangChain \u5de5\u5177\u5951\u7ea6：\u53ea\u8fd4\u56de\u6587\u672c）"""<\/span>
      \n answer,<\/span> _ =<\/span> self.<\/span>run_with_usage(<\/span>question)<\/span>
      \n return<\/span> answer<\/p>\n

      def<\/span> run_with_usage<\/span>(<\/span>self,<\/span> question:<\/span> str<\/span>)<\/span> –<\/span>><\/span> Tuple[<\/span>str<\/span>,<\/span> int<\/span>]<\/span>:<\/span>
      \n .<\/span>.<\/span>.<\/span>
      \n resp =<\/span> deepseek_client.<\/span>chat.<\/span>completions.<\/span>create(<\/span>.<\/span>.<\/span>.<\/span>)<\/span>
      \n answer =<\/span> resp.<\/span>choices[<\/span>0<\/span>]<\/span>.<\/span>message.<\/span>content or<\/span> ""<\/span><\/p>\n

      # \u7edf\u8ba1 token：\u4f18\u5148\u53d6 usage，\u7f3a\u5931\u65f6\u6309\u5b57\u7b26\u4f30\u7b97（2 \u5b57\u7b26 \u2248 1 token）<\/span>
      \n usage =<\/span> getattr<\/span>(<\/span>resp,<\/span> "usage"<\/span>,<\/span> None<\/span>)<\/span>
      \n tokens =<\/span> 0<\/span>
      \n if<\/span> usage is<\/span> not<\/span> None<\/span>:<\/span>
      \n tokens =<\/span> int<\/span>(<\/span>getattr<\/span>(<\/span>usage,<\/span> "prompt_tokens"<\/span>,<\/span> 0<\/span>)<\/span> or<\/span> 0<\/span>)<\/span> +<\/span> int<\/span>(<\/span>
      \n getattr<\/span>(<\/span>usage,<\/span> "completion_tokens"<\/span>,<\/span> 0<\/span>)<\/span> or<\/span> 0<\/span>
      \n )<\/span>
      \n if<\/span> tokens <=<\/span> 0<\/span>:<\/span>
      \n tokens =<\/span> max<\/span>(<\/span>1<\/span>,<\/span> (<\/span>len<\/span>(<\/span>prompt)<\/span> +<\/span> len<\/span>(<\/span>answer)<\/span>)<\/span> \/\/<\/span> 2<\/span>)<\/span>
      \n return<\/span> answer,<\/span> tokens<\/p>\n

      8.2 \u843d\u65e5\u5fd7 + \u6263\u989d\u5ea6<\/h4>\n

      MCP \u8c03\u7528\u4e0d\u7ecf\u8fc7\u4e3b\u7ba1\u7f16\u6392，\u6240\u4ee5\u8981\u5355\u72ec\u843d\u4e00\u6761\u65e5\u5fd7\u3002SKILL_ID_ \u8bb0 mcp:knowledge-base，\u8fd9\u5c31\u662f\u548c\u5bf9\u8bdd\u989d\u5ea6\u533a\u5206\u7684\u6807\u8bb0：<\/p>\n

      def<\/span> log_external_invoke<\/span>(<\/span>user_id,<\/span> question,<\/span> answer,<\/span> tokens,<\/span>
      \n source=<\/span>"mcp:knowledge-base"<\/span>,<\/span> success=<\/span>True<\/span>,<\/span> fail_msg=<\/span>""<\/span>)<\/span>:<\/span>
      \n .<\/span>.<\/span>.<\/span>
      \n with<\/span> db_service.<\/span>get_engine(<\/span>)<\/span>.<\/span>begin(<\/span>)<\/span> as<\/span> conn:<\/span>
      \n conn.<\/span>execute(<\/span>text(<\/span>text_insert_invoke(<\/span>)<\/span>)<\/span>,<\/span> {<\/span>
      \n .<\/span>.<\/span>.<\/span>
      \n "cost_token"<\/span>:<\/span> int<\/span>(<\/span>tokens or<\/span> 0<\/span>)<\/span>,<\/span>
      \n "skill_id"<\/span>:<\/span> _safe_text(<\/span>source,<\/span> 64<\/span>)<\/span>,<\/span> # mcp:knowledge-base<\/span>
      \n "create_by"<\/span>:<\/span> _safe_text(<\/span>user_id,<\/span> 64<\/span>)<\/span> or<\/span> "mcp"<\/span>,<\/span>
      \n .<\/span>.<\/span>.<\/span>
      \n }<\/span>)<\/span>
      \n # \u53f0\u8d26\u5199\u6210\u529f\u540e\u518d\u7d2f\u52a0 MCP \u989d\u5ea6，\u907f\u514d\u65e5\u5fd7\u5931\u8d25\u65f6\u989d\u5ea6\u88ab\u591a\u6263<\/span>
      \n token_quota_service.<\/span>add_tokens(<\/span>user_id,<\/span> tokens,<\/span> "mcp"<\/span>)<\/span><\/p>\n

      8.3 \u5de5\u5177\u5185\u6821\u9a8c<\/h4>\n

      # 1. \u6bcf\u65e5\u989d\u5ea6\u6821\u9a8c（\u672a\u7ed1\u5b9a\u7528\u6237\u7684 key \u4e0d\u505a\u989d\u5ea6\u9650\u5236）<\/span>
      \n quota_limit =<\/span> int<\/span>(<\/span>setting.<\/span>mcp_daily_token_limit or<\/span> 0<\/span>)<\/span>
      \n if<\/span> caller and<\/span> quota_limit ><\/span> 0<\/span>:<\/span>
      \n allowed,<\/span> used,<\/span> quota =<\/span> await<\/span> asyncio.<\/span>to_thread(<\/span>
      \n token_quota_service.<\/span>check,<\/span> caller,<\/span> quota_limit,<\/span> "mcp"<\/span>
      \n )<\/span>
      \n if<\/span> not<\/span> allowed:<\/span>
      \n return<\/span> (<\/span>f"\u3010\u989d\u5ea6\u3011\u60a8\u4eca\u65e5\u901a\u8fc7 MCP \u8c03\u7528\u5df2\u6d88\u8017 <\/span>{<\/span>used}<\/span><\/span> \/ <\/span>{<\/span>quota}<\/span><\/span> token，"<\/span><\/span>
      \n f"\u6682\u4e0d\u53ef\u7528，\u8bf7\u660e\u5929\u518d\u8bd5"<\/span><\/span>)<\/span><\/p>\n

      8.4 \u5b9e\u6d4b<\/h4>\n

      \u5148\u7528\u9ed8\u8ba4\u989d\u5ea6\u8dd1\u4e00\u6b21\u6b63\u5e38\u8c03\u7528（MCP_DAILY_TOKEN_LIMIT=50000）：<\/p>\n

      [mcp-server] SSE \u8fde\u63a5\u5efa\u7acb caller=1001
      \n[invoke_log] \u5df2\u5199\u5165\u5916\u90e8\u8c03\u7528\u65e5\u5fd7 source=mcp:knowledge-base user=1001 tokens=1068
      \n[mcp-server] \u8c03\u7528\u5b8c\u6210 caller=1001 tokens=1068 cost=2.583s inflight=1<\/p>\n

      Redis \u91cc\u80fd\u770b\u5230\u5f53\u65e5\u7528\u91cf：<\/p>\n

      quota:tokens:mcp:1001:20261027 = 1068<\/p>\n

      \u628a\u989d\u5ea6\u8c03\u5230 1000 \u540e\u518d\u542f\u52a8\u4e00\u4e2a\u5b9e\u4f8b，\u540c\u6837\u7684\u8c03\u7528\u76f4\u63a5\u88ab\u62e6\u622a：<\/p>\n

      [tools] count=1
      \n[call] search_knowledge_base question=\u6280\u672f\u6808\u662f\u4ec0\u4e48
      \n[call] isError=False
      \n\u3010\u989d\u5ea6\u3011\u60a8\u4eca\u65e5\u901a\u8fc7 MCP \u8c03\u7528\u5df2\u6d88\u8017 1068 \/ 1000 token，\u6682\u4e0d\u53ef\u7528，\u8bf7\u660e\u5929\u518d\u8bd5<\/p>\n

      \u518d\u9a8c\u8bc1\u4e24\u5957\u989d\u5ea6\u786e\u5b9e\u9694\u79bb：\u7528\u6237 1001 \u5df2\u7ecf\u6709 1068 \u7684 MCP \u6d88\u8017，\u67e5\u5bf9\u8bdd\u989d\u5ea6\u4ecd\u7136\u662f 0：<\/p>\n

      chat_quota (True, 0, 200000)<\/p>\n

      \n

      9. \u8054\u8c03\u4e0e\u9a8c\u8bc1<\/h3>\n

      9.1 \u542f\u52a8<\/h4>\n

      cd e:\\\\myProject\\\\my-langchain\\\\agent\\\\chat_py_server
      \nD:\\\\anaconda3\\\\envs\\\\test01\\\\python.<\/span>exe –<\/span>m app.<\/span>mcp.<\/span>knowledge_server —<\/span>preload<\/p>\n

      [mcp-server] starting name=knowledge-base transport=sse host=127.0.0.1 port=18765
      \n[mcp-server] auth=True keys=1 max_concurrency=3 breaker=5\u6b21\/30s daily_token_limit=50000<\/p>\n

      9.2 \u4e09\u4e2a\u5fc5\u6d4b\u70b9<\/h4>\n\n\u573a\u666f\u547d\u4ee4\u9884\u671f<\/tr>\n\n\n\n\n
      \u65e0 key<\/td>\ncurl.exe -s -i –max-time 3 http:\/\/127.0.0.1:18765\/sse<\/td>\n401 + \u201c\u7f3a\u5c11 API Key，\u8bf7\u5148\u83b7\u53d6 key \u540e\u518d\u8bbf\u95ee\u201d<\/td>\n<\/tr>\n
      \u5e26 key<\/td>\ncurl.exe -s -i –max-time 3 "http:\/\/127.0.0.1:18765\/sse?key=sk-mcp-demo-key"<\/td>\n200 + event: endpoint<\/td>\n<\/tr>\n
      \u5de5\u5177\u8c03\u7528<\/td>\n\u811a\u672c\u52a0 –key<\/td>\nisError=False，\u8fd4\u56de\u77e5\u8bc6\u5e93\u7b54\u6848<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n

      1.mcp\u8fde\u63a5\u5668\u72b6\u6001\u53d8\u4e3a\u9700\u8981\u8ba4\u8bc1
      \n\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"
      \n2.\u540e\u7aef\u63d0\u793a
      \n\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"
      \n3.\u8fde\u63a5\u5668\u6dfb\u52a0key
      \n\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"
      \n4.\u8fde\u63a5\u6210\u529f
      \n\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"<\/p>\n

      9.3 \u4f1a\u8bdd\u5e76\u53d1\u5b9e\u6d4b<\/h4>\n

      [True, True, True, False] # \u7b2c 4 \u6b21\u7533\u8bf7\u88ab\u62d2
      \ncount 3
      \nafter_release 0<\/p>\n

      9.4 \u68c0\u67e5\u6e05\u5355<\/h4>\n
        \n
      • \u7b2c 4 \u4e2a\u5e76\u53d1\u4f1a\u8bdd\u6536\u5230 reject \u4e8b\u4ef6，\u63d0\u793a"\u5df2\u8fbe\u4e0a\u9650（3 \u4e2a）"<\/li>\n
      • \u5173\u95ed\u5176\u4e2d\u4e00\u4e2a\u4f1a\u8bdd\u540e，\u53ef\u4ee5\u91cd\u65b0\u53d1\u8d77<\/li>\n
      • \u989d\u5ea6\u7528\u5c3d\u65f6\u6536\u5230"token \u989d\u5ea6\u5df2\u7528\u5b8c（\u5df2\u7528 X \/ \u4e0a\u9650 Y）"<\/li>\n
      • MCP \u65e0 key \u8fd4\u56de 401，\u5e26 key \u6b63\u5e38<\/li>\n
      • ai_invoke_log \u91cc MCP \u8c03\u7528\u884c\u7684 SKILL_ID_ \u662f mcp:knowledge-base<\/li>\n
      • Redis \u91cc quota:tokens:mcp:{userId}:{\u65e5\u671f} \u968f\u8c03\u7528\u9012\u589e<\/li>\n<\/ul>\n
        \n

        10. \u5e38\u89c1\u95ee\u9898<\/h3>\n\n\u73b0\u8c61\u539f\u56e0\u5904\u7406<\/tr>\n\n\n\n\n\n\n\n\n
        \u6240\u6709 MCP \u8bf7\u6c42\u90fd 401<\/td>\nMCP_AUTH_ENABLED=true \u4f46 MCP_API_KEYS \u4e3a\u7a7a<\/td>\n\u914d\u7f6e key；\u542f\u52a8\u65e5\u5fd7\u4f1a\u6253\u5370 keys=0 \u7684\u544a\u8b66<\/td>\n<\/tr>\n
        \u6539\u4e86 key \u4e0d\u751f\u6548<\/td>\nkey \u5728\u8fdb\u7a0b\u542f\u52a8\u65f6\u89e3\u6790\u4e00\u6b21<\/td>\n\u91cd\u542f MCP Server<\/td>\n<\/tr>\n
        \u5e76\u53d1\u6ca1\u5230\u4e0a\u9650\u4e5f\u88ab\u62d2<\/td>\n\u7194\u65ad\u5df2\u6253\u5f00<\/td>\n\u7b49 MCP_BREAKER_COOLDOWN_SECONDS \u79d2<\/td>\n<\/tr>\n
        \u989d\u5ea6\u6c38\u8fdc\u662f 0<\/td>\nCREATE_BY_ \u4e3a\u7a7a（stdio \u6a21\u5f0f\u6ca1\u6709\u7528\u6237\u8eab\u4efd）<\/td>\nstdio \u4e0d\u6821\u9a8c\u989d\u5ea6，\u5c5e\u9884\u671f<\/td>\n<\/tr>\n
        \u989d\u5ea6\u7b97\u5c11\u4e86<\/td>\nRedis \u91cc key \u88ab\u624b\u5de5\u6539\u8fc7 \/ \u6570\u636e\u5e93\u5199\u5165\u5931\u8d25<\/td>\n\u5220\u6389 quota:tokens:* \u8ba9\u7cfb\u7edf\u56de\u6e90\u91cd\u7b97<\/td>\n<\/tr>\n
        \u4f1a\u8bdd\u540d\u989d\u4e00\u76f4\u4e0d\u91ca\u653e<\/td>\n\u8fdb\u7a0b\u88ab\u5f3a\u6740，finally \u6ca1\u6267\u884c<\/td>\n\u7b49 TTL（2 \u5c0f\u65f6）\u81ea\u52a8\u5f52\u96f6；\u5fc5\u8981\u65f6\u624b\u52a8\u5220 chat:running:*<\/td>\n<\/tr>\n
        \u7528\u6237\u88ab\u9650\u6d41\u540e\u4e00\u76f4\u8fdb\u4e0d\u53bb<\/td>\n\u524d\u7aef\u6ca1\u5904\u7406 reject<\/td>\n\u524d\u7aef\u5df2\u652f\u6301，\u82e5\u81ea\u5b9a\u4e49\u5ba2\u6237\u7aef\u9700\u5355\u72ec\u5904\u7406\u8be5\u4e8b\u4ef6<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n
        \n

        11. \u5c0f\u7ed3<\/h3>\n

        \u672c\u7bc7\u628a"\u80fd\u8dd1"\u53d8\u6210\u4e86"\u6562\u5f00\u51fa\u53bb"：<\/p>\n\n\u7ef4\u5ea6\u624b\u6bb5\u843d\u70b9<\/tr>\n\n\n\n\n\n\n
        \u5e76\u53d1\u8d44\u6e90<\/td>\nRedis \u539f\u5b50\u8ba1\u6570 + TTL \u515c\u5e95<\/td>\nsession_limit_service<\/td>\n<\/tr>\n
        \u5bf9\u8bdd\u6210\u672c<\/td>\nai_invoke_log \u6c47\u603b + Redis \u8ba1\u6570<\/td>\ntoken_quota_service（scope=chat）<\/td>\n<\/tr>\n
        \u63a5\u5165\u5b89\u5168<\/td>\nAPI Key（Bearer \/ query \/ header）<\/td>\nknowledge_server._authenticate<\/td>\n<\/tr>\n
        \u670d\u52a1\u7a33\u5b9a<\/td>\n\u5e76\u53d1\u95f8\u95e8 + \u7194\u65ad<\/td>\nConcurrencyGuard<\/td>\n<\/tr>\n
        \u5916\u90e8\u6210\u672c<\/td>\n\u5916\u90e8\u8c03\u7528\u65e5\u5fd7 + \u72ec\u7acb\u989d\u5ea6<\/td>\nlog_external_invoke + scope=mcp<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n

        \u4e09\u6761\u7ecf\u9a8c：<\/p>\n

      • \u9650\u6d41\u72b6\u6001\u653e Redis，\u8fdb\u7a0b\u5185\u8ba1\u6570\u5728\u591a worker \u4e0b\u4f1a\u5931\u771f；\u4f46\u5fc5\u987b\u6709\u8fdb\u7a0b\u5185\u964d\u7ea7，\u5426\u5219 Redis \u4e00\u6302\u5168\u7ad9\u4e0d\u53ef\u7528\u3002<\/li>\n
      • \u989d\u5ea6\u8981\u548c"\u53f0\u8d26"\u7ed1\u5b9a：\u5148\u5199\u65e5\u5fd7\u518d\u6263\u989d\u5ea6，\u51fa\u73b0\u4e89\u8bae\u65f6\u4ee5 ai_invoke_log \u4e3a\u51c6，Redis \u53ea\u662f\u52a0\u901f\u7f13\u5b58\u3002<\/li>\n
      • \u5931\u8d25\u8981\u53ef\u8bfb：MCP \u4fa7\u8fd4\u56de\u6587\u672c\u800c\u4e0d\u662f\u5f02\u5e38，\u5bf9\u8bdd\u4fa7\u8fd4\u56de reject \u4e8b\u4ef6，\u7528\u6237\u770b\u5230\u7684\u662f"\u8bf7\u7a0d\u540e\u91cd\u8bd5"，\u800c\u4e0d\u662f 500\u3002<\/li>\n

        \u540e\u7eed\u8fd8\u80fd\u7ee7\u7eed\u505a：\u7f51\u5173\u5c42\u6309 IP \u9650\u6d41\u3001\u6ed1\u52a8\u7a97\u53e3\u66ff\u4ee3\u56fa\u5b9a\u65e5\u989d\u5ea6\u3001\u628a inflight \/ \u7194\u65ad\u72b6\u6001\u66b4\u9732\u6210 Prometheus \u6307\u6807\u3001\u6309 key \u505a\u66f4\u7ec6\u7684 QPS \u9650\u5236\u3002<\/p>\n

        \n

        \u9644：\u672c\u6587\u914d\u7f6e\u6c47\u603b<\/h3>\n

        CHAT_MAX_CONCURRENT_SESSIONS=3
        \nCHAT_DAILY_TOKEN_LIMIT=200000
        \nMCP_AUTH_ENABLED=true
        \nMCP_API_KEYS="sk-mcp-demo-key:1001"
        \nMCP_MAX_CONCURRENCY=3
        \nMCP_BREAKER_TRIP_THRESHOLD=5
        \nMCP_BREAKER_COOLDOWN_SECONDS=30
        \nMCP_DAILY_TOKEN_LIMIT=50000<\/p>\n

        WorkBuddy mcp.json：<\/p>\n

        {<\/span>
        \n "mcpServers"<\/span>:<\/span> {<\/span>
        \n "\u6d4b\u8bd5\u77e5\u8bc6\u5e93"<\/span>:<\/span> {<\/span>
        \n "type"<\/span>:<\/span> "sse"<\/span>,<\/span>
        \n "url"<\/span>:<\/span> "http:\/\/127.0.0.1:18765\/sse?key=sk-mcp-demo-key"<\/span>
        \n }<\/span>
        \n }<\/span>
        \n}<\/span><\/p>\n","protected":false},"excerpt":{"rendered":"

        \/* MD \/ \u5bcc\u6587\u672c\u4e2d\u7684 .toc\uff08\u542b\u535a\u5ba2\u56ed\u642c\u5bb6\u7b49\u5d4c\u5957\u7ed3\u6784\uff09\uff1b.toc-box \u5728\u4fa7\u680f\uff0c\u4e0d\u53d7\u5f71\u54cd *\/#content_views .toc,\/* \u7f16\u8f91\u5668\u5e38\u5728\u76ee\u5f55\u524d\u540e\u63d2\u5165\u7a7a p\uff08:empty \u4ecd\u5360 20px\uff09\uff0c\u4e00\u5e76\u53bb\u6389\u907f\u514d\u9876\u7a7a\u9699 *\/#content_views.markdown_views > p:empty:has(+ .toc),#content_views.markdown_views > .toc + p:empty,\/* \u5bcc\u6587\u672c\u65e7\u7248\u76ee\u5f55\u6807\u8bb0 *\/#content<\/p>\n","protected":false},"author":2,"featured_media":118404,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[13442,12231,73,4119,50],"topic":[],"class_list":["post-118408","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-server","tag-13442","tag-12231","tag-mcp","tag-rag","tag-50"],"yoast_head":"\nAI\u667a\u80fd\u4f53\u9879\u76ee\u5b9e\u6218\u8bb0\u5f55\uff0825\uff09\uff1a\u667a\u80fd\u4f53\u6dfb\u52a0\u9650\u6d41\uff0cMCP Server \u6dfb\u52a0\u9650\u6d41\u4e0e\u9274\u6743 - \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\/118408.html\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"AI\u667a\u80fd\u4f53\u9879\u76ee\u5b9e\u6218\u8bb0\u5f55\uff0825\uff09\uff1a\u667a\u80fd\u4f53\u6dfb\u52a0\u9650\u6d41\uff0cMCP Server \u6dfb\u52a0\u9650\u6d41\u4e0e\u9274\u6743 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"og:description\" content=\"\/* MD \/ \u5bcc\u6587\u672c\u4e2d\u7684 .toc\uff08\u542b\u535a\u5ba2\u56ed\u642c\u5bb6\u7b49\u5d4c\u5957\u7ed3\u6784\uff09\uff1b.toc-box \u5728\u4fa7\u680f\uff0c\u4e0d\u53d7\u5f71\u54cd *\/#content_views .toc,\/* \u7f16\u8f91\u5668\u5e38\u5728\u76ee\u5f55\u524d\u540e\u63d2\u5165\u7a7a p\uff08:empty \u4ecd\u5360 20px\uff09\uff0c\u4e00\u5e76\u53bb\u6389\u907f\u514d\u9876\u7a7a\u9699 *\/#content_views.markdown_views > p:empty:has(+ .toc),#content_views.markdown_views > .toc + p:empty,\/* \u5bcc\u6587\u672c\u65e7\u7248\u76ee\u5f55\u6807\u8bb0 *\/#content\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.wsisp.com\/helps\/118408.html\" \/>\n<meta property=\"og:site_name\" content=\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"article:published_time\" content=\"2026-10-27T03:16:51+00:00\" \/>\n<meta property=\"og:image\" content=\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/10\/20261027031648-6ae017a0e67e2.png\" \/>\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=\"11 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/118408.html\",\"url\":\"https:\/\/www.wsisp.com\/helps\/118408.html\",\"name\":\"AI\u667a\u80fd\u4f53\u9879\u76ee\u5b9e\u6218\u8bb0\u5f55\uff0825\uff09\uff1a\u667a\u80fd\u4f53\u6dfb\u52a0\u9650\u6d41\uff0cMCP Server \u6dfb\u52a0\u9650\u6d41\u4e0e\u9274\u6743 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"isPartOf\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\"},\"datePublished\":\"2026-10-27T03:16:51+00:00\",\"dateModified\":\"2026-10-27T03:16:51+00:00\",\"author\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/118408.html#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.wsisp.com\/helps\/118408.html\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/118408.html#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.wsisp.com\/helps\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"AI\u667a\u80fd\u4f53\u9879\u76ee\u5b9e\u6218\u8bb0\u5f55\uff0825\uff09\uff1a\u667a\u80fd\u4f53\u6dfb\u52a0\u9650\u6d41\uff0cMCP Server \u6dfb\u52a0\u9650\u6d41\u4e0e\u9274\u6743\"}]},{\"@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":"AI\u667a\u80fd\u4f53\u9879\u76ee\u5b9e\u6218\u8bb0\u5f55\uff0825\uff09\uff1a\u667a\u80fd\u4f53\u6dfb\u52a0\u9650\u6d41\uff0cMCP Server \u6dfb\u52a0\u9650\u6d41\u4e0e\u9274\u6743 - \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\/118408.html","og_locale":"zh_CN","og_type":"article","og_title":"AI\u667a\u80fd\u4f53\u9879\u76ee\u5b9e\u6218\u8bb0\u5f55\uff0825\uff09\uff1a\u667a\u80fd\u4f53\u6dfb\u52a0\u9650\u6d41\uff0cMCP Server \u6dfb\u52a0\u9650\u6d41\u4e0e\u9274\u6743 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","og_description":"\/* MD \/ \u5bcc\u6587\u672c\u4e2d\u7684 .toc\uff08\u542b\u535a\u5ba2\u56ed\u642c\u5bb6\u7b49\u5d4c\u5957\u7ed3\u6784\uff09\uff1b.toc-box \u5728\u4fa7\u680f\uff0c\u4e0d\u53d7\u5f71\u54cd *\/#content_views .toc,\/* \u7f16\u8f91\u5668\u5e38\u5728\u76ee\u5f55\u524d\u540e\u63d2\u5165\u7a7a p\uff08:empty \u4ecd\u5360 20px\uff09\uff0c\u4e00\u5e76\u53bb\u6389\u907f\u514d\u9876\u7a7a\u9699 *\/#content_views.markdown_views > p:empty:has(+ .toc),#content_views.markdown_views > .toc + p:empty,\/* \u5bcc\u6587\u672c\u65e7\u7248\u76ee\u5f55\u6807\u8bb0 *\/#content","og_url":"https:\/\/www.wsisp.com\/helps\/118408.html","og_site_name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","article_published_time":"2026-10-27T03:16:51+00:00","og_image":[{"url":"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/10\/20261027031648-6ae017a0e67e2.png"}],"author":"admin","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"admin","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"11 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.wsisp.com\/helps\/118408.html","url":"https:\/\/www.wsisp.com\/helps\/118408.html","name":"AI\u667a\u80fd\u4f53\u9879\u76ee\u5b9e\u6218\u8bb0\u5f55\uff0825\uff09\uff1a\u667a\u80fd\u4f53\u6dfb\u52a0\u9650\u6d41\uff0cMCP Server \u6dfb\u52a0\u9650\u6d41\u4e0e\u9274\u6743 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","isPartOf":{"@id":"https:\/\/www.wsisp.com\/helps\/#website"},"datePublished":"2026-10-27T03:16:51+00:00","dateModified":"2026-10-27T03:16:51+00:00","author":{"@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41"},"breadcrumb":{"@id":"https:\/\/www.wsisp.com\/helps\/118408.html#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.wsisp.com\/helps\/118408.html"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.wsisp.com\/helps\/118408.html#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.wsisp.com\/helps"},{"@type":"ListItem","position":2,"name":"AI\u667a\u80fd\u4f53\u9879\u76ee\u5b9e\u6218\u8bb0\u5f55\uff0825\uff09\uff1a\u667a\u80fd\u4f53\u6dfb\u52a0\u9650\u6d41\uff0cMCP Server \u6dfb\u52a0\u9650\u6d41\u4e0e\u9274\u6743"}]},{"@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\/118408","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=118408"}],"version-history":[{"count":0,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/118408\/revisions"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media\/118404"}],"wp:attachment":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media?parent=118408"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/categories?post=118408"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/tags?post=118408"},{"taxonomy":"topic","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/topic?post=118408"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}