![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/11\/20261104220101-6aebab1d8cfd7.png\")
<\/p>\n\u00a0<\/p>\n
🔥\u5c0f\u53f6-duck<\/span>：\u4e2a\u4eba\u4e3b\u9875<\/p>\n \u00a0\u2744\ufe0f\u4e2a\u4eba\u4e13\u680f<\/span>：\u300aData-Structure-Learning\u300b\u300aC++\u5165\u95e8\u5230\u8fdb\u9636&\u81ea\u6211\u5b66\u4e60\u8fc7\u7a0b\u8bb0\u5f55\u300b \u300aLinux\u7cfb\u7edf\u4ece\u5165\u95e8\u5230\u5b9e\u8df5\u300b\u300aLinux\u7f51\u7edc\u4ece\u5165\u95e8\u5230\u5b9e\u8df5\u300b \u300aQt \u65b9\u5bf8\u6781\u5883\u300b\u00a0\u300aMySQL\u300b<\/p>\n \u2728\u672a\u62e9\u4e4b\u8def，\u4e0d\u987b\u56de\u5934 \u5df2\u62e9\u4e4b\u8def，\u7eb5\u662f\u8346\u68d8\u904d\u91ce，\u4ea6\u4f5c\u82b1\u6d77\u9068\u6e38<\/span><\/p>\n \u76ee\u5f55<\/p>\n \u524d\u8a00<\/p>\n \u4e00\u3001DeepSeek \u6d41\u5f0f\u54cd\u5e94\u63a5\u53e3\u5b9e\u73b0<\/p>\n \u00a0 1.1\u00a0\u63a5\u53e3\u5b9a\u4e49\u4e0e\u804c\u8d23\u8fb9\u754c<\/p>\n \u00a0 \u00a0 1.1.1\u00a0\u65b9\u6cd5\u7b7e\u540d<\/p>\n \u00a0 \u00a0 1.1.2\u00a0\u56de\u8c03\u5951\u7ea6<\/p>\n \u00a0 1.2\u00a0\u5b8c\u6574\u5b9e\u73b0\u6d41\u7a0b\u4e0e\u4ee3\u7801\u9010\u6b65\u89e3\u6790<\/p>\n \u00a0 \u00a0 1.2.1\u00a0\u6a21\u578b\u53ef\u7528\u6027\u6821\u9a8c<\/p>\n \u00a0 \u00a0 1.2.2\u00a0\u6784\u9020\u5e76\u83b7\u53d6\u8bf7\u6c42\u53c2\u6570<\/p>\n \u00a0 \u00a0 1.2.3\u00a0\u7ec4\u88c5 messages \u5bf9\u8bdd\u6570\u7ec4<\/p>\n \u00a0 \u00a0 1.2.4\u00a0\u6784\u9020\u8bf7\u6c42\u4f53，\u5f00\u542f\u6d41\u5f0f\u5f00\u5173<\/p>\n \u00a0 \u00a0 1.2.5\u00a0JSON \u5e8f\u5217\u5316 + \u6784\u9020 httplib \u5ba2\u6237\u7aef\u4e0e\u8bf7\u6c42\u5934<\/p>\n \u00a0 \u00a0 1.2.6\u00a0\u5b9a\u4e49\u5168\u5c40\u7f13\u5b58\u4e0e\u72b6\u6001\u6807\u8bb0<\/p>\n \u00a0 \u00a0 1.2.7\u00a0\u6784\u5efa httplib::Request \u8bf7\u6c42\u5bf9\u8c61<\/p>\n \u00a0 \u00a0 1.2.8\u00a0response_handler：\u54cd\u5e94\u5934\u6821\u9a8c\u56de\u8c03<\/p>\n \u00a0 \u00a0 1.2.9\u00a0content_receiver：SSE \u5206\u7247\u89e3\u6790\u6838\u5fc3\u56de\u8c03<\/p>\n \u00a0 \u00a0 1.2.10\u00a0client.send \u53d1\u8d77\u8bf7\u6c42 + \u7ed3\u679c\u5224\u65ad<\/p>\n \u00a0 \u00a0 \u8865\u5145 client.send \u539f\u7406\u5206\u6790<\/p>\n \u00a0 \u00a0 1.2.11\u00a0\u6d41\u5f0f\u54cd\u5e94\u63a5\u53e3\u5b8c\u6574\u4ee3\u7801（\u9644\u6ce8\u91ca\u5206\u6790）<\/p>\n \u00a0 1.3 \u8865\u5145：\u7f16\u8bd1\u95ee\u9898\u5b9a\u4f4d\u4e0e\u4fee\u590d<\/p>\n \u00a0 \u00a0 1.3.1\u00a0\u9519\u8bef\u73b0\u8c61<\/p>\n \u00a0 \u00a0 1.3.2\u00a0\u6839\u56e0\u5206\u6790<\/p>\n \u00a0 \u00a0 1.3.3\u00a0\u4fee\u590d\u65b9\u6848<\/p>\n \u00a0 \u00a0 1.3.4\u00a0\u5c0f\u7ed3<\/p>\n \u4e8c\u3001\u6d41\u5f0f\u54cd\u5e94\u5355\u5143\u6d4b\u8bd5<\/p>\n \u00a0 2.1\u00a0\u521d\u59cb\u5316\u4e0e\u914d\u7f6e<\/p>\n \u00a0 2.2\u00a0\u5165\u53e3\u51fd\u6570<\/p>\n \u00a0 2.3 \u8fd0\u884c\u7ed3\u679c\u5c55\u793a<\/p>\n \u00a0 2.4\u00a0\u5f15\u51fa\u7591\u95ee<\/p>\n \u00a0 \u00a0 2.4.1\u00a0\u5148\u89e3\u91ca：\u670d\u52a1\u5668\u7684\u201c\u8d34\u5fc3\u201d，\u5927\u6982\u7387\u53d1\u9001\u5b8c\u6574\u7684 SSE<\/p>\n \u00a0 \u00a0 2.4.2\u00a0\u73b0\u5b9e\u7684\u201c\u6b8b\u9177\u201d：\u9632\u4eba\u4e4b\u5fc3\u4e0d\u53ef\u65e0<\/p>\n \u00a0 \u00a0 2.4.3\u00a0\u7ed3\u8bba：\u65e5\u5fd7\u91cc\u770b\u4e0d\u5230\u534a\u5305 \u2260 \u4e0d\u9700\u8981 buffer + while \u515c\u5e95<\/p>\n \u603b\u7ed3：<\/p>\n \u7ed3\u675f\u8bed<\/p>\n \u00a0 \u00a0 \u00a0 \u524d\u9762\u7ae0\u8282\u6211\u4eec\u5df2\u7ecf\u5b8c\u6210\u4e86 DeepSeek \u975e\u6d41\u5f0f\u63a5\u53e3\u7684\u5c01\u88c5\u3001\u8c03\u8bd5\u4e0e\u5355\u5143\u6d4b\u8bd5，\u7406\u89e3\u4e86\u5982\u4f55\u901a\u8fc7 httplib \u53d1\u8d77 HTTP \u8bf7\u6c42\u3001\u89e3\u6790 JSON \u8fd4\u56de\u7ed3\u679c\u3002\u4f46\u5927\u6a21\u578b\u5bf9\u8bdd\u4ea7\u54c1\u6700\u5e38\u7528\u3001\u4f53\u9a8c\u66f4\u597d\u7684\u6d41\u5f0f\u8f93\u51fa\u80fd\u529b，\u4f9d\u8d56 SSE \u534f\u8bae\u5b9e\u73b0，\u8fd9\u4e5f\u662f\u6211\u4eec\u672c\u7ae0\u8981\u653b\u514b\u7684\u6838\u5fc3\u5185\u5bb9\u3002<\/p>\n \u00a0 \u00a0 \u00a0 \u6d41\u5f0f\u63a5\u53e3\u7684\u5b9e\u73b0\u8fdc\u6bd4\u4e00\u6b21\u6027\u8fd4\u56de\u7684\u5168\u91cf\u54cd\u5e94\u590d\u6742，\u5b83\u4e0d\u518d\u662f\u4e00\u6b21\u8bf7\u6c42\u3001\u4e00\u6b21\u5e94\u7b54\u7684\u7b80\u5355\u6a21\u5f0f，\u800c\u662f\u4f9d\u9760\u5206\u6bb5\u56de\u8c03\u6301\u7eed\u63a5\u6536\u670d\u52a1\u7aef\u63a8\u9001\u7684\u6570\u636e\u3002\u8fd9\u91cc\u5b58\u5728\u4e24\u5c42\u5bb9\u6613\u6df7\u6dc6\u7684\u6570\u636e\u8fb9\u754c：HTTP Chunk \u5206\u7247\u8fb9\u754c\u548c SSE \u4e8b\u4ef6\u8fb9\u754c，\u534a\u5305\u89e3\u6790\u3001\u6570\u636e\u7f13\u5b58\u3001\u4e8b\u4ef6\u8fc7\u6ee4\u90fd\u662f\u5f00\u53d1\u4e2d\u6781\u6613\u8e29\u5751\u7684\u5730\u65b9\u3002<\/p>\n \u00a0 \u00a0 \u00a0 \u672c\u7ae0\u5c06\u4ece\u63a5\u53e3\u804c\u8d23\u5b9a\u4e49\u5165\u624b，\u4e00\u6b65\u6b65\u62c6\u89e3 DeepSeek \u6d41\u5f0f\u63a5\u53e3\u7684\u5b8c\u6574\u5b9e\u73b0\u6d41\u7a0b：\u4ece\u53c2\u6570\u7ec4\u88c5\u3001\u8bf7\u6c42\u6784\u5efa，\u5230\u54cd\u5e94\u5934\u6821\u9a8c\u3001content_receiver\u5206\u7247\u89e3\u6790\u56de\u8c03\u7684\u6838\u5fc3\u7f16\u7801；\u540c\u65f6\u7ed3\u5408\u6211\u4eec\u5b9e\u9645\u8dd1\u901a\u7684\u6d4b\u8bd5\u65e5\u5fd7，\u89e3\u7b54\u4e00\u4e2a\u5f88\u5173\u952e\u7684\u7591\u95ee：\u6d4b\u8bd5\u65f6\u6bcf\u6b21\u6536\u5230\u7684 Chunk \u91cc SSE \u4e8b\u4ef6\u90fd\u662f\u5b8c\u6574\u7684，\u4e3a\u4ec0\u4e48\u4ee3\u7801\u4ecd\u7136\u5fc5\u987b\u505a Buffer \u7f13\u5b58\u4e0e\u5faa\u73af\u5207\u5206\u7684\u9632\u5fa1\u6027\u89e3\u6790\u3002<\/p>\n \u00a0 \u00a0 \u00a0 \u9664\u6b64\u4e4b\u5916，\u6211\u4eec\u4e5f\u4f1a\u8bb0\u5f55\u5f00\u53d1\u9014\u4e2d\u9047\u5230\u7684\u7f16\u8bd1\u62a5\u9519\u95ee\u9898，\u68b3\u7406\u5bf9\u5e94\u7684\u5b9a\u4f4d\u601d\u8def\u4e0e\u4fee\u590d\u65b9\u6848，\u6700\u540e\u501f\u52a9 GTest \u5b8c\u6210\u6d41\u5f0f\u63a5\u53e3\u7684\u5355\u5143\u6d4b\u8bd5，\u9a8c\u8bc1\u6574\u5957\u6d41\u5f0f SDK \u94fe\u8def\u7684\u53ef\u7528\u6027\u3002\u8bfb\u5b8c\u672c\u7ae0，\u4f60\u5c06\u638c\u63e1\u5728 C++ \u4e2d\u57fa\u4e8e httplib \u5b9e\u73b0 SSE \u6d41\u5f0f\u5927\u6a21\u578b\u8c03\u7528\u7684\u5b8c\u6574\u5de5\u7a0b\u5199\u6cd5，\u7406\u89e3\u6d41\u5f0f\u89e3\u6790\u80cc\u540e\u7684\u534f\u8bae\u7ec6\u8282\u4e0e\u9632\u5fa1\u6027\u7f16\u7801\u601d\u60f3\u3002<\/p>\n \u00a0 \u00a0 \u00a0 \u5728\u524d\u4e00\u7ae0\u6211\u4eec\u5403\u900f\u4e86 HTTP Chunk\u3001SSE \u4e8b\u4ef6\u5757\u3001httplib \u6d41\u5f0f\u56de\u8c03\u7684\u5e95\u5c42\u89c4\u5219\u4e0e\u5404\u7c7b\u8fb9\u754c\u5f02\u5e38\u573a\u666f，\u672c\u7ae0\u5c31\u843d\u5730\u7f16\u7801，\u5b9e\u73b0sendMessageStream\u6d41\u5f0f\u589e\u91cf\u63a5\u53e3，\u5b8c\u6210\u5927\u6a21\u578b\u6253\u5b57\u673a\u9010\u5b57\u8f93\u51fa\u6548\u679c\u3002<\/p>\n namespace ai_chat_sdk { \u00a0 \u00a0 \u00a0 \u8fd9\u4e2a\u63a5\u53e3\u4f5c\u4e3a\u4e0a\u5c42\u5bf9\u5916\u8c03\u7528\u5165\u53e3，\u8fd4\u56de\u503c\u662f\u62fc\u63a5\u5b8c\u6210\u540e\u7684\u5b8c\u6574\u56de\u7b54\u5185\u5bb9；\u6838\u5fc3\u4ea4\u4e92\u4f9d\u9760\u4f20\u5165\u7684\u56de\u8c03\u51fd\u6570\u5411\u5916\u63a8\u9001\u5206\u7247\u6570\u636e\u3002<\/p>\n \u00a0 \u00a0 \u00a0\u56de\u8c03\u51fd\u6570 std::function<void(const std::string &response, bool isEnd)> \u662f\u6d41\u5f0f SDK \u89e3\u8026\u7684\u5173\u952e，\u7ea6\u5b9a\u5982\u4e0b：<\/p>\n if (!IsAvailable()) \u00a0 \u00a0 \u00a0 \u7b2c\u4e00\u6b65\u505a\u57fa\u7840\u72b6\u6001\u68c0\u67e5，\u5224\u65ad\u5f53\u524d Provider \u662f\u5426\u5df2\u7ecf\u5b8c\u6210\u521d\u59cb\u5316\u3001\u914d\u7f6e\u597dapi-key\u4e0ebaseUrl，\u672a\u5c31\u7eea\u76f4\u63a5\u8fd4\u56de，\u63d0\u524d\u62e6\u622a\u975e\u6cd5\u8c03\u7528\u3002<\/p>\n \u00a0 \u00a0 \u00a0 \u6211\u4eec\u628a\u53c2\u6570\u5206\u4e3a\u4e24\u7c7b：\u4e00\u7c7b\u662f\u56fa\u5b9a\u5728\u57fa\u7c7b\u7684\u8fde\u63a5\u914d\u7f6e，\u53e6\u4e00\u7c7b\u662f\u6bcf\u6b21\u8bf7\u6c42\u53ef\u53d8\u7684\u8bf7\u6c42\u53c2\u6570，\u653e\u5728requestParam\u4e2d\u4f20\u5165\u3002<\/p>\n \/\/ 2.1 \u8bbe\u7f6e\u53c2\u6570\u9ed8\u8ba4\u503c \/\/ 2.2 \u4ece\u5165\u53c2map\u8986\u76d6\u9ed8\u8ba4\u914d\u7f6e \/\/ model \u6a21\u578b\u540d\u79f0\u4e3a\u5fc5\u586b\u9879，\u8c03\u7528\u65b9\u5fc5\u987b\u4f20\u5165 \u00a0 \u00a0 \u00a0 \u53c2\u6570\u8bbe\u8ba1\u903b\u8f91：temperature\u3001max_tokens\u7b49\u63d0\u4f9b\u9ed8\u8ba4\u503c，\u8c03\u7528\u65b9\u6309\u9700\u8986\u76d6；\u800cmodel\u662f\u6bcf\u6b21\u5bf9\u8bdd\u8bf7\u6c42\u5fc5\u987b\u6307\u5b9a，\u4e0d\u63d0\u4f9b\u9ed8\u8ba4\u503c，\u7f3a\u5931\u76f4\u63a5\u62a5\u9519\u8fd4\u56de\u3002<\/p>\n \u00a0 \u00a0 \u00a0 \u5faa\u73af\u904d\u5386\u4f20\u5165\u7684\u5386\u53f2\u6d88\u606f\u5217\u8868，\u6309\u7167 DeepSeek \u63a5\u53e3\u6587\u6863\u8981\u6c42，\u7ec4\u88c5role\u548ccontent\u5b57\u6bb5，\u6784\u9020 JSON \u6570\u7ec4，\u643a\u5e26\u4e0a\u4e0b\u6587\u5b9e\u73b0\u591a\u8f6e\u5bf9\u8bdd\u3002<\/p>\n Json::Value messageArray = Json::arrayValue; \u00a0 \u00a0 \u00a0 \u91cd\u70b9：stream:true\u662f\u5f00\u542f\u589e\u91cf\u6d41\u5f0f\u8fd4\u56de\u7684\u6838\u5fc3\u6807\u8bc6，\u4e0d\u914d\u7f6e\u8fd9\u4e2a\u5b57\u6bb5，\u63a5\u53e3\u4f1a\u76f4\u63a5\u8fd4\u56de\u4e00\u6b21\u6027\u5168\u91cf\u5e94\u7b54，\u4e0d\u4f1a\u8d70 SSE \u6d41\u5f0f\u63a8\u9001\u3002<\/p>\n Json::Value requestBody; \u00a0 \u00a0 \u00a0 \u5e8f\u5217\u5316 JSON \u7ed3\u6784\u4f53\u5f97\u5230\u5b57\u7b26\u4e32，\u540c\u65f6\u914d\u7f6e\u6d41\u5f0f\u8bf7\u6c42\u5fc5\u987b\u7684 HTTP \u8bf7\u6c42\u5934：Accept: text\/event-stream\u544a\u8bc9\u670d\u52a1\u7aef\u5ba2\u6237\u7aef\u53ef\u4ee5\u63a5\u6536 SSE \u4e8b\u4ef6\u6d41\u3002<\/p>\n Json::StreamWriterBuilder writerbuilder; httplib::Client client(_baseUrl); httplib::Headers headers = { \u00a0 \u00a0 \u00a0 \u8fd9\u4e00\u7ec4\u53d8\u91cf\u7528\u6765\u89e3\u51b3\u4e0a\u7bc7\u6587\u7ae0\u91cd\u70b9\u8bb2\u89e3\u7684\u534a\u5305\u3001\u7c98\u5305\u95ee\u9898，\u662f SSE \u89e3\u6790\u7684\u72b6\u6001\u5bb9\u5668：<\/p>\n std::string buffer; \/\/ \u7f13\u5b58\u672a\u5904\u7406\u5b8c\u7684\u5206\u7247\u6570\u636e，\u62fc\u63a5\u534a\u5305 httplib::Request request; \u00a0 \u00a0 \u00a0 \u8fd9\u4e00\u6b65\u53ea\u662f\u628a\u9759\u6001\u7684\u8bf7\u6c42\u4fe1\u606f\u586b\u5145\u5b8c\u6bd5，\u8fd8\u6ca1\u6709\u53d1\u8d77\u7f51\u7edc\u8bf7\u6c42\u3002\u586b\u5145\u5b8c\u57fa\u7840\u6210\u5458\u4e4b\u540e，\u6211\u4eec\u7d27\u63a5\u7740\u7ed9\u8fd9\u4e2a request \u5bf9\u8c61\u6302\u8f7dresponse_handler\u548ccontent_receiver\u4e24\u4e2a\u6d41\u5f0f\u56de\u8c03，\u8fd9\u4e5f\u662f\u6d41\u5f0f\u8bf7\u6c42\u548c\u666e\u901a\u5168\u91cf\u8bf7\u6c42\u6700\u5927\u7684\u533a\u522b\u3002<\/p>\n \u00a0 \u00a0 \u00a0 \u8fd9\u4e2a\u56de\u8c03\u53ea\u4f1a\u5728\u6536\u5230 HTTP \u54cd\u5e94\u5934\u90e8\u65f6\u6267\u884c\u4e00\u6b21，\u7528\u6765\u6821\u9a8c\u72b6\u6001\u7801，\u6355\u83b7\u8fde\u63a5\u5efa\u7acb\u4e4b\u540e\u7684 HTTP \u5c42\u9762\u9519\u8bef\u3002<\/p>\n request.response_handler = [&](const httplib::Response &res) -> bool \u00a0 \u00a0 \u00a0 \u8fd4\u56defalse\u4ee3\u8868\u7ec8\u6b62\u672c\u6b21\u8bf7\u6c42，\u4e0d\u518d\u63a5\u6536\u540e\u7eed chunk \u6570\u636e；\u8fd4\u56detrue\u4ee3\u8868\u6b63\u5e38\u63a5\u6536\u6d41\u5f0f body \u5206\u7247，\u8fdb\u5165content_receiver\u3002<\/p>\n \u00a0 \u00a0 \u00a0 \u8be5\u56de\u8c03\u4f1a\u5728\u6bcf\u6536\u5230\u4e00\u4e2a\u5b8c\u6574\u00a0HTTP Chunk \u65f6\u8fdb\u884c\u89e6\u53d1，\u6211\u4eec\u5728\u8fd9\u91cc\u5b8c\u6210 SSE \u4e8b\u4ef6\u7684\u7f13\u5b58\u3001\u5207\u5206\u3001\u89e3\u6790，\u4e5f\u662f\u5904\u7406\u534a\u5305\u7c98\u5305\u7684\u6838\u5fc3\u4f4d\u7f6e\u3002<\/p>\n request.content_receiver = [&](const char *data, size_t data_length, \/\/ 2. \u5faa\u73af\u5207\u5272\u5b8c\u6574SSE\u4e8b\u4ef6\u5757，\u5206\u9694\u7b26\u662f \\\\n\\\\n \/\/ 3. \u9010\u884c\u89e3\u6790\u5355\u6761SSE\u4e8b\u4ef6，\u8fc7\u6ee4\u6ce8\u91ca\u884c\u3001\u7a7a\u884c \/\/ 4. \u5224\u65ad\u6d41\u7ed3\u675f\u6807\u8bb0 [DONE] \/\/ 5. \u53cd\u5e8f\u5217\u5316data\u540e\u7684json，\u63d0\u53d6delta\u589e\u91cf\u5185\u5bb9 \/\/ 6. \u53d6\u51fachoices[0].delta.content\u589e\u91cf\u6587\u672c \u6838\u5fc3\u8bbe\u8ba1\u8981\u70b9：<\/p>\n auto result = client.send(request); \/\/ \u515c\u5e95：\u670d\u52a1\u7aef\u5f02\u5e38\u65ad\u5f00，\u6ca1\u6709\u8fd4\u56de[DONE]\u7ed3\u675f\u6807\u8bb0 \u00a0 \u00a0 \u00a0 cpp-httplib \u7684 send \u5b58\u5728\u4e24\u79cd\u5de5\u4f5c\u6a21\u5f0f，\u533a\u5206\u7684\u6838\u5fc3\u6761\u4ef6\u5c31\u662f\u662f\u5426\u6302\u8f7d\u4e86 content_receiver \u6d41\u5f0f\u63a5\u6536\u56de\u8c03：<\/p>\n \u00a0 \u00a0 \u00a0 \u6ce8\u610f：\u8fd9\u91cc\u8bf4\u7684\u975e\u963b\u585e\u4e0d\u662f\u6307\u5957\u63a5\u5b57\u975e\u963b\u585e IO，\u662f\u6307send\u51fd\u6570\u4e0d\u4f1a\u7b49\u5f85\u5168\u90e8\u6570\u636e\u8fd4\u56de\u624d\u8fd4\u56de\u3002<\/p>\n \u4e24\u5c42\u9519\u8bef\u8fb9\u754c\u5c0f\u7ed3：<\/p>\n \/\/ \u53d1\u9001\u6d88\u606f：\u589e\u91cf\u8c03\u7528，\u5b9e\u65f6\u8fd4\u56de\u54cd\u5e94 \/\/ 2\u3001\u6784\u9020\u5e76\u83b7\u53d6\u8bf7\u6c42\u53c2\u6570 \/\/ 2.3 \u6784\u9020\u5e76\u83b7\u53d6\u5386\u53f2\u6d88\u606f：\u83b7\u53d6\u8bf7\u6c42\u4f53\u4e2d\u7684 messages \u8fd9\u4e2aJson\u6570\u7ec4 \/\/ 3\u3001\u6784\u9020\u8bf7\u6c42\u4f53 \/\/ 4\u3001\u5bf9requestBody\u8fdb\u884c\u5e8f\u5217\u5316 \/\/ 5\u3001\u4f7f\u7528cpp-httplib\u6784\u5efaHTTP\u5ba2\u6237\u7aef \/\/ \u5230\u8fd9\u91cc\u6211\u4eec\u80fd\u50cf\u5168\u91cf\u54cd\u5e94\u90a3\u6837，\u76f4\u63a5\u5c06\u5e8f\u5217\u5316\u540e\u7684\u8bf7\u6c42POST\u5230\u6a21\u578b\u7684\u63a5\u53e3\u5417？\u4e0d\u80fd std::string buffer; \/\/ \u7528\u4e8e\u5b58\u50a8\u6bcf\u6b21\u8bfb\u53d6\u5230\u7684Chunk\u6570\u636e\u5757\u4e2d\u7684\u5185\u5bb9 \/\/ 6\u3001\u6784\u5efa\u8bf7\u6c42\u5bf9\u8c61 \/\/ 6.1 \u6784\u5efa\u54cd\u5e94\u5904\u7406\u5668\u56de\u8c03\u51fd\u6570：response_handler \/\/ 6.2 \u6784\u5efa\u6570\u636e\u63a5\u6536\u5904\u7406\u5668\u56de\u8c03\u51fd\u6570：content_receiver \/\/ 2\u3001\u8ffd\u52a0\u5f53\u524d\u6240\u6709\u7684\u4e8b\u4ef6\u5757\u5230\u7f13\u51b2\u533a，\u4fdd\u8bc1\u6bcf\u6b21\u5904\u7406\u7684\u4e8b\u4ef6\u5757\u90fd\u662f\u5b8c\u6574\u7684 \/\/ 3\u3001\u89e3\u6790\u7f13\u51b2\u533a\u4e2d\u7684\u4e8b\u4ef6\u5757，\u5224\u65ad\u662f\u5426\u4e3a\u5b8c\u6574\u7684 SSE \u4e8b\u4ef6\u5757 \/\/ 3.2 \u5173\u952e\u5904\u7406：\u89e3\u6790\u5f53\u524d\u4e8b\u4ef6\u5757\u4e2d\u7684\u6bcf\u4e00\u884c \/\/ \u68c0\u6d4b\u662f\u5426\u4e3a\u7ed3\u675f\u6807\u8bb0 \/\/ \u4ecemodeldataJson\u4e2d\u63d0\u53d6\u54cd\u5e94\u5185\u5bb9\u4e2dcontent\u5b57\u6bb5 \/\/ \u6700\u540e\u5c06\u672c\u6b21\u5f53\u524d\u89e3\u6790\u5f97\u5230\u7684\u4e8b\u4ef6\u5757\u4e2d\u7684content\u5185\u5bb9\u4f20\u7ed9\u8c03\u7528sendMessageStream\u7684\u7528\u6237\u67e5\u770b — \u56de\u8c03\u5904\u7406 \/\/ 7\u3001\u53d1\u9001\u8bf7\u6c42，\u83b7\u53d6\u670d\u52a1\u5668\u54cd\u5e94 \/\/ \u6240\u4ee5，\u6211\u4eec\u5e76\u4e0d\u662f\u62ff\u7740send\u7684\u8fd4\u56de\u503c\u83b7\u53d6\u670d\u52a1\u5668\u54cd\u5e94，\u6211\u4eec\u4e5f\u4e0d\u9700\u8981\u5728\u8fd9\u91cc\u83b7\u53d6，\u4e3a\u4ec0\u4e48？ \/\/ 7.1 \u5224\u65ad\u8bf7\u6c42\u53d1\u9001\u662f\u5426\u6210\u529f \/\/ \u7279\u6b8a\u60c5\u51b5：streamEnd\u4e3afalse，\u4e5f\u5c31\u662f\u8bf4\u6211\u4eec\u83b7\u53d6\u5b8c\u54cd\u5e94\u5185\u5bb9，\u4f46\u662f\u6ca1\u6709\u6536\u5230[DONE]\u7ed3\u675f\u6807\u8bb0 return fullResponce; \u00a0 \u00a0 \u00a0 \u7f16\u8bd1\u62a5\u9519：spdlog \u65e5\u5fd7\u683c\u5f0f\u5316\u5b8f\u65e0\u6cd5\u76f4\u63a5\u683c\u5f0f\u5316 httplib::Error \u7c7b\u578b\u53c2\u6570，\u63d0\u793a\u7c7b\u578b\u4e0d\u5339\u914d\u3001\u683c\u5f0f\u5316\u5931\u8d25\u3002 \u00a0 \u00a0 \u00a0 \u89e6\u53d1\u4ee3\u7801（\u539f\u59cb\u62a5\u9519\u5199\u6cd5）：<\/p>\n ERR("DeepSeekProvider sendMessageStream send request ERROR: {}", result.error());<\/p>\n \u00a0 \u00a0 \u00a0 result.error() \u8fd4\u56de\u7684 httplib::Error \u662f C++11 \u5f3a\u7c7b\u578b\u679a\u4e3e enum class，\u8fd9\u662f\u62a5\u9519\u7684\u6838\u5fc3\u6839\u6e90：<\/p>\n \u00a0 \u00a0 \u00a0 \u62d3\u5c55\u7406\u89e3：static_cast<int>(err) \u4e5f\u53ef\u4ee5\u663e\u5f0f\u628a enum class\u00a0\u7c7b\u578b\u8f6c\u4e3a\u5e95\u5c42\u6574\u6570\u3002 \u00a0 \u00a0 \u00a0 static_cast \u7684\u542b\u4e49\u4e0d\u662f \u201c\u4fdd\u8bc1\u8f6c\u6362\u4e00\u5b9a\u6b63\u786e\u201d，\u800c\u662f\u6807\u8bb0\u8fd9\u91cc\u662f\u7a0b\u5e8f\u5458\u4e3b\u52a8\u627f\u62c5\u7c7b\u578b\u8f6c\u6362\u98ce\u9669\u3002<\/p>\n \u00a0 \u00a0 \u00a0 \u7f16\u8bd1\u5668\u653e\u5f00\u8f6c\u6362\u6743\u9650\u7684\u5e95\u5c42\u903b\u8f91：enum class \u5728\u5185\u5b58\u5e95\u5c42\u672c\u8d28\u5c31\u662f\u6574\u578b\u5b58\u50a8；\u6807\u51c6\u53ea\u662f\u7981\u6b62\u9690\u5f0f\u8f6c\u6362，\u5e76\u6ca1\u6709\u7981\u6b62\u6211\u4eec\u4e3b\u52a8\u663e\u5f0f\u8f6c\u6362\u3002 \u00a0 \u00a0 \u00a0 \u4e24\u79cd\u4fee\u590d\u65b9\u6848\u5bf9\u6bd4：<\/p>\n \/\/ \u4fee\u590d\u524d：\u7f16\u8bd1\u5931\u8d25 \/\/ \u65b9\u68481\u3010\u63a8\u8350\u3011：\u8c03\u7528httplib\u81ea\u5e26to_string，\u8f6c\u4e3a\u53ef\u8bfb\u5b57\u7b26\u4e32 \/\/ \u65b9\u68482：static_cast\u663e\u5f0f\u8f6c\u4e3aint（\u4ec5\u8f93\u51fa\u9519\u8bef\u7801） #include "..\/SDK\/include\/DeepSeekProvider.h" using namespace ai_chat_sdk;<\/p>\n TEST(DeepSeekProviderTest, sendMessage) \/\/ 2\u3001\u6784\u5efa\u6a21\u578b\u914d\u7f6e \/\/ 3\u3001\u521d\u59cb\u5316DeepSeekProvider \/\/ 4\u3001\u6784\u5efa\u8bf7\u6c42\u53c2\u6570\u914d\u7f6e(\u4e0d\u5199\u5219\u4f7f\u7528\u9ed8\u8ba4\u503c) \/\/ 5\u3001\u6784\u5efa\u6d88\u606f\u5217\u8868 \/\/ \/\/ \u5e26\u4e0a\u89d2\u8272\u8bbe\u5b9a \/\/ \u5e26\u4e0a\u5386\u53f2\u4fe1\u606f \/\/ 6\u3001\u8c03\u7528ssendMessageStreame\u53d1\u9001\u6d88\u606f int main(int argc, char **argv) \/\/ \u521d\u59cb\u5316\u65e5\u5fd7\u7cfb\u7edf \/\/ \u8fd0\u884c\u6240\u6709\u6d4b\u8bd5\u7528\u4f8b # \u8fdb\u5165\u6784\u5efa\u76ee\u5f55 # \u751f\u6210\u6784\u5efa\u6587\u4ef6 # \u6e05\u7406\u5e76\u7f16\u8bd1 # \u8fd0\u884c\u6d4b\u8bd5\u7a0b\u5e8f \u00a0 \u00a0 \u00a0 \u8fd9\u662f\u5185\u5bb9\u62fc\u63a5\u5b8c\u7684\u6700\u7ec8\u5b8c\u6574\u6837\u5b50，\u90a3\u6d41\u5f0f\u7684\u6548\u679c\u662f\u4ec0\u4e48\u6837\u7684\u5462？\u5982\u4e0b\u9762\u6240\u793a：<\/p>\n \u00a0 \u00a0 \u00a0 \u770b\u5230\u4e0a\u9762\u7684\u65e5\u5fd7\u6253\u5370\u7ed3\u679c\u60f3\u5fc5\u5927\u5bb6\u5fc3\u91cc\u4e00\u5b9a\u4f1a\u5b58\u5728\u4e00\u4e2a\u95ee\u9898：<\/p>\n DeepSeek \u8fd4\u56de\u7684\u6bcf\u4e00\u6b21 content_receiver \u56de\u8c03\u62ff\u5230\u7684 HTTP Chunk \u91cc\u9762，\u5305\u88f9\u7684\u5168\u90e8\u662f\u5b8c\u6574\u3001\u53ef\u76f4\u63a5\u5206\u5272\u7684 SSE \u4e8b\u4ef6，\u6ca1\u6709\u51fa\u73b0\u534a\u622a\u3001\u622a\u65ad\u7684 SSE \u62a5\u6587，\u8fd9\u662f\u4e3a\u4ec0\u4e48？ \u4e0d\u7ba1\u662f\u524d\u9762\u6211\u4eec\u5b66\u4e60SSE\u534f\u8bae\u8fd8\u662f\u4e0a\u7bc7\u6587\u7ae0\u6211\u4eec\u5bf9 httplib Request \u53c2\u6570\u8fdb\u884c\u8bb2\u89e3，\u90fd\u63d0\u5230\u4e86\u670d\u52a1\u5668\u53d1\u9001\u8fc7\u6765\u7684\u62a5\u6587\u6240\u643a\u5e26\u7684HTTP chunk\u6570\u636e\u5757\u5185\u7684SSE\u4e8b\u4ef6\u5757\u53ef\u80fd\u5b58\u5728\u6b8b\u7f3a\u7684\u60c5\u51b5，\u4f46\u662f\u65e5\u5fd7\u6253\u5370\u7684\u7ed3\u679c\u5b8c\u5168\u6ca1\u6709\u51fa\u73b0\u8fd9\u79cd\u60c5\u51b5，\u96be\u9053\u662f\u6211\u4eec\u524d\u9762\u8bb2\u9519\u4e86\u5417？<\/p>\n \u00a0 \u00a0 \u00a0 DeepSeek \u8fd9\u79cd\u5927\u6a21\u578b\u670d\u52a1\u7aef，\u5728\u5e95\u5c42\u53d1\u9001\u6d41\u5f0f\u6570\u636e\u65f6，\u901a\u5e38\u662f\u7531\u5176 Web \u6846\u67b6（\u6bd4\u5982 Python \u7684 FastAPI\u3001Go \u7684 Gin \u7b49）\u63a7\u5236\u7684\u3002 \u00a0 \u00a0 \u00a0 \u670d\u52a1\u7aef\u5728 yield \u6570\u636e\u65f6，\u901a\u5e38\u662f\u6309\u903b\u8f91\u5757\u5410\u51fa\u7684\u3002\u7f51\u7edc\u534f\u8bae\u6808\u5728\u6253\u5305\u6210 HTTP Chunk \u65f6，\u5f80\u5f80（\u5728\u7edd\u5927\u591a\u6570\u7f51\u7edc\u72b6\u51b5\u826f\u597d\u7684\u60c5\u51b5\u4e0b）\u4f1a\u628a\u4e00\u4e2a\u5b8c\u6574\u7684 data: {…}\\\\n\\\\n \u4f5c\u4e3a\u4e00\u4e2a\u6574\u4f53\u585e\u8fdb Chunk \u91cc\u3002\u8fd9\u5927\u5927\u51cf\u8f7b\u4e86\u5ba2\u6237\u7aef\u7684\u89e3\u6790\u538b\u529b\u3002\u00a0<\/p>\n \u00a0 \u00a0 \u00a0 \u5c3d\u7ba1\u670d\u52a1\u7aef\u4f1a\u5c3d\u91cf\u53d1\u5b8c\u6574\u7684，\u4f46\u7f51\u7edc\u4f20\u8f93\u662f\u7269\u7406\u884c\u4e3a，\u4e0d\u53ef\u63a7\u56e0\u7d20\u592a\u591a\u4e86：<\/p>\n \u7f51\u7edc\u4e2d\u95f4\u8bbe\u5907（\u4ee3\u7406\u3001\u7f51\u5173）：\u6709\u65f6\u5019 Nginx \u7b49\u4e2d\u95f4\u4ef6\u4f1a\u5bf9\u6d41\u8fdb\u884c\u91cd\u65b0\u5207\u5206\u3002<\/p>\n<\/li>\n TCP \u7684 Nagle \u7b97\u6cd5：\u53ef\u80fd\u628a\u5305\u5408\u5e76\u6216\u8005\u62c6\u5206\u3002<\/p>\n<\/li>\n \u6781\u7aef\u7684\u957f\u6587\u672c：\u5982\u679c\u67d0\u6b21\u6a21\u578b\u5410\u51fa\u7684\u5355\u5b57\u7279\u522b\u957f（\u6216\u8005\u5305\u542b\u6781\u5927\u7684 Base64 \u56fe\u7247\u6570\u636e），\u5bfc\u81f4\u4e00\u4e2a SSE Event \u7684\u957f\u5ea6\u8d85\u8fc7\u4e86\u4e00\u4e2a HTTP Chunk \u7684\u6700\u5927\u9650\u5236，\u670d\u52a1\u7aef\u5c31\u4e0d\u5f97\u4e0d\u628a\u5b83\u5207\u5f00\u53d1\u9001\u3002<\/p>\n<\/li>\n<\/ul>\n \u00a0 \u00a0 \u00a0 \u4e5f\u5c31\u662f\u8bf4：\u670d\u52a1\u7aef\u53ea\u662f \u201c\u5c3d\u91cf\u6309\u5b8c\u6574 SSE \u6253\u5305\u201d，\u534f\u8bae\u5c42\u9762\u6ca1\u6709\u4efb\u4f55\u627f\u8bfa\u4fdd\u8bc1 SSE \u4e0d\u4f1a\u8de8 chunk\u3002<\/p>\n \u00a0 \u00a0 \u00a0 \u6b63\u56e0\u4e3a\u4e0a\u8ff0\u7684\u201c\u4e0d\u786e\u5b9a\u6027\u201d，\u6211\u4eec\u6240\u8bbe\u8ba1\u7684\u4ee3\u7801\u5c31\u7edd\u4e0d\u80fd\u8d4c\u201c\u670d\u52a1\u7aef\u6bcf\u6b21\u53d1\u7684\u90fd\u662f\u5b8c\u6574\u7684\u201d\u3002\u670d\u52a1\u7aef\u53ef\u4ee5\u5e2e\u6211\u4eec\u51cf\u5c11\u534a\u5305\u6982\u7387，\u4f46\u662f\u5ba2\u6237\u7aef\u4e0d\u80fd\u628a\u4e1a\u52a1\u6b63\u786e\u6027\u5bc4\u6258\u5728\u670d\u52a1\u7aef\u548c\u7f51\u7edc \u201c\u597d\u5fc3\u4e0d\u62c6\u5305\u201d \u4e0a\u3002 \u00a0 \u00a0 \u00a0\u00a0\u6240\u4ee5，\u6700\u6807\u51c6\u3001\u6700\u65e0\u61c8\u53ef\u51fb\u7684\u5904\u7406\u65b9\u6848：<\/p>\n \u201c\u5c06\u6b8b\u7559\u7684SSE\u4fdd\u5b58\u5230buffer\u7b49\u5f85\u4e0b\u6b21\u6570\u636e\u5230\u6765\u8fdb\u884c\u8ffd\u52a0\u201d<\/p>\n \u00a0 \u00a0 \u00a0 \u8fd9\u4e2a\u8fc7\u7a0b\u5c31\u8868\u73b0\u4e3a：<\/p>\n \u6570\u636e\u6765\u4e86，\u65e0\u8111\u585e\u8fdb buffer\u3002<\/p>\n<\/li>\n while \u627e \\\\n\\\\n\u3002\u627e\u5230\u4e86\u5207\u51fa\u6765，\u5904\u7406\u5b8c\u5e76\u5220\u9664；\u627e\u4e0d\u5230\u5c31\u4e0d\u7ba1\u3002<\/p>\n<\/li>\n \u5982\u679c\u8fd9\u6b21\u662f\u4e2a\u201c\u534a\u5305\u201d，buffer \u91cc\u5c31\u4f1a\u7559\u4e0b\u7c7b\u4f3c data: {"content": "\u95ee\u6211 \u8fd9\u6837\u7684\u6b8b\u7559\u3002<\/p>\n<\/li>\n \u4e0b\u6b21 content_receiver \u88ab\u89e6\u53d1，\u65b0\u7684\u6570\u636e "}}\\\\n\\\\n \u8ffd\u52a0\u8fdb buffer\u3002<\/p>\n<\/li>\n \u77ac\u95f4\u51d1\u9f50，while \u6210\u529f\u5207\u51fa\u5b8c\u6574\u7684 data: {"content": "\u95ee\u6211"}\\\\n\\\\n，\u6e05\u7406 buffer\u3002<\/p>\n<\/li>\n \u00a0 \u00a0 \u00a0 \u670d\u52a1\u7aef\u8d1f\u8d23\u201c\u5c3d\u91cf\u53d1\u5f97\u5b8c\u6574\u201d，\u5ba2\u6237\u7aef\u8d1f\u8d23\u201c\u4e0d\u7ba1\u4f60\u600e\u4e48\u53d1，\u6211\u90fd\u80fd\u62fc\u5b8c\u6574\u201d\u3002 \u00a0 \u00a0 \u00a0\u00a0\u6211\u4eec\u672c\u6b21\u6d4b\u8bd5\u89c2\u6d4b\u5230\u6240\u6709 HTTP chunk \u5185 SSE \u90fd\u662f\u5b8c\u6574\u7684，\u662f DeepSeek \u670d\u52a1\u6846\u67b6\u5728\u826f\u597d\u7f51\u7edc\u4e0b\u7684\u4f18\u5316\u6253\u5305\u884c\u4e3a；HTTP \u534f\u8bae\u672c\u8eab\u4e0d\u7ea6\u675f SSE \u4e8b\u4ef6\u4e0d\u80fd\u8de8 HTTP chunk，\u5f31\u7f51\u3001\u957f\u5185\u5bb9\u3001\u53cd\u5411\u4ee3\u7406\u573a\u666f\u4e0b\u4e00\u5b9a\u4f1a\u4ea7\u751f SSE \u534a\u5305，\u56e0\u6b64 buffer \u7f13\u5b58\u3001\u5faa\u73af\u5207\u5206\u7684\u89e3\u6790\u903b\u8f91\u662f\u5fc5\u987b\u4fdd\u7559\u7684\u3002<\/p>\n \u00a0 \u00a0 \u00a0 \u5230\u8fd9\u91cc，DeepSeek \u6d41\u5f0f\u54cd\u5e94\u63a5\u53e3\u7684\u4ee3\u7801\u5b9e\u73b0\u3001\u95ee\u9898\u6392\u9519\u3001\u5355\u5143\u6d4b\u8bd5\u4e0e\u534f\u8bae\u5c42\u9762\u7684\u601d\u8003\u5c31\u5168\u90e8\u5b8c\u6210\u4e86\u3002<\/p>\n \u00a0 \u00a0 \u00a0 \u6211\u4eec\u987a\u7740\u76ee\u5f55\u4e00\u6b65\u6b65\u843d\u5730\u4e86 SSE \u6d41\u5f0f\u8c03\u7528\u94fe\u8def，\u4e0d\u4ec5\u5199\u51fa\u4e86\u53ef\u8fd0\u884c\u7684 C++ \u4ee3\u7801，\u66f4\u5398\u6e05\u4e86 HTTP Chunk \u548c SSE \u4e8b\u4ef6\u4e24\u5957\u72ec\u7acb\u7684\u5206\u7247\u8fb9\u754c\u3002\u4ece\u5b9e\u9645\u6d4b\u8bd5\u65e5\u5fd7\u4e2d\u6211\u4eec\u770b\u5230\u7406\u60f3\u73af\u5883\u4e0b\u670d\u52a1\u7aef\u5e38\u5e38\u8fd4\u56de\u5b8c\u6574 SSE \u4e8b\u4ef6，\u4f46\u4e5f\u660e\u767d\u4e86\u8fd9\u53ea\u662f\u670d\u52a1\u6846\u67b6\u5e26\u6765\u7684\u4fbf\u5229，\u4e0d\u80fd\u4f5c\u4e3a\u7f16\u7801\u7684\u524d\u63d0，buffer + while\u7684\u534a\u5305\u5904\u7406\u662f\u9762\u5411\u516c\u7f51\u3001\u5f31\u7f51\u3001\u53cd\u5411\u4ee3\u7406\u573a\u666f\u5fc5\u4e0d\u53ef\u5c11\u7684\u9632\u5fa1\u903b\u8f91\u3002\u540c\u65f6\u6211\u4eec\u4e5f\u8bb0\u5f55\u4e86\u5f00\u53d1\u8fc7\u7a0b\u91cc\u9047\u5230\u7684\u7f16\u8bd1\u95ee\u9898，\u628a\u8e29\u5751\u7ecf\u9a8c\u6c89\u6dc0\u4e0b\u6765\u3002<\/p>\n \u00a0 \u00a0 \u00a0 \u6d41\u5f0f\u63a5\u53e3\u662f\u5927\u6a21\u578b SDK \u91cc\u590d\u6742\u5ea6\u5f88\u9ad8\u7684\u4e00\u73af，\u4e5f\u662f\u804a\u5929\u7c7b\u4e1a\u52a1\u7684\u6838\u5fc3\u80fd\u529b\u3002\u638c\u63e1\u8fd9\u90e8\u5206\u4e4b\u540e，\u6211\u4eec\u7684 SDK \u5df2\u7ecf\u540c\u65f6\u652f\u6301\u975e\u6d41\u5f0f\u3001\u6d41\u5f0f\u4e24\u79cd\u8c03\u7528\u6a21\u5f0f\u3002\u540e\u7eed\u6211\u4eec\u53ef\u4ee5\u57fa\u4e8e\u5f53\u524d\u8fd9\u5957 Provider \u62bd\u8c61，\u7ee7\u7eed\u63a5\u5165\u5176\u4ed6\u5382\u5546\u7684\u5927\u6a21\u578b\u670d\u52a1，\u8fdb\u4e00\u6b65\u5b8c\u5584\u6574\u4e2a SDK \u7684\u6269\u5c55\u6027\u3002<\/p>\n","protected":false},"excerpt":{"rendered":" 🔥\u5c0f\u53f6-duck：\u4e2a\u4eba\u4e3b\u9875 \u2744\ufe0f\u4e2a\u4eba\u4e13\u680f：\u300aData-Structure-Learning\u300b\u300aC\u5165\u95e8\u5230\u8fdb\u9636&\u81ea\u6211\u5b66\u4e60\u8fc7\u7a0b\u8bb0\u5f55\u300b \u300aLinux\u7cfb\u7edf\u4ece\u5165\u95e8\u5230\u5b9e\u8df5\u300b\u300aLinux\u7f51\u7edc\u4ece\u5165\u95e8\u5230\u5b9e\u8df5\u300b \u300aQt \u65b9\u5bf8\u6781\u5883\u300b\u00a0\u300aMySQL\u300b
\n
\n\u524d\u8a00<\/h2>\n
\u4e00\u3001DeepSeek \u6d41\u5f0f\u54cd\u5e94\u63a5\u53e3\u5b9e\u73b0<\/h2>\n
\u00a0 1.1\u00a0\u63a5\u53e3\u5b9a\u4e49\u4e0e\u804c\u8d23\u8fb9\u754c<\/h3>\n
\u00a0 \u00a0 1.1.1\u00a0\u65b9\u6cd5\u7b7e\u540d<\/h4>\n
\nclass DeepSeekProvider {
\npublic:
\n \/**
\n * @brief \u53d1\u9001\u6d88\u606f\u5e76\u63a5\u6536\u6d41\u5f0f\u589e\u91cf\u54cd\u5e94
\n * @param messages \u5386\u53f2\u5bf9\u8bdd\u6d88\u606f\u5217\u8868
\n * @param requestParam \u8bf7\u6c42\u53c2\u6570\u6620\u5c04（temperature\u3001max_tokens\u7b49）
\n * @param callback \u589e\u91cf\u6570\u636e\u56de\u8c03\u51fd\u6570，\u7531\u8c03\u7528\u65b9\u5b9e\u73b0\u4e1a\u52a1\u903b\u8f91
\n * @return std::optional<std::string> \u5b8c\u6574\u7684\u54cd\u5e94\u6587\u672c（\u6240\u6709\u589e\u91cf\u62fc\u63a5\u7ed3\u679c）
\n *\/
\n std::optional<std::string> sendMessageStream(
\n const std::vector<Message>& messages,
\n const std::map<std::string, std::string>& requestParam,
\n std::function<void(const std::string &response, bool isEnd)> callback
\n );
\n};
\n}<\/p>\n\u00a0 \u00a0 1.1.2\u00a0\u56de\u8c03\u5951\u7ea6<\/h4>\n
\n
\u00a0 1.2\u00a0\u5b8c\u6574\u5b9e\u73b0\u6d41\u7a0b\u4e0e\u4ee3\u7801\u9010\u6b65\u89e3\u6790<\/h3>\n
\u00a0 \u00a0 1.2.1\u00a0\u6a21\u578b\u53ef\u7528\u6027\u6821\u9a8c<\/h4>\n
\n{
\n ERR("DeepSeekProvider sendMessageStream model not available");
\n return std::nullopt;
\n}<\/p>\n\u00a0 \u00a0 1.2.2\u00a0\u6784\u9020\u5e76\u83b7\u53d6\u8bf7\u6c42\u53c2\u6570<\/h4>\n
\ndouble temperature = 0.7;
\nint max_tokens = 2048;
\nstd::string thinking_type = "disabled";
\nstd::string reasoning_effort = "high";
\nstd::string model;<\/p>\n
\nauto it = requestParam.find("temperature");
\nif (it != requestParam.end())
\n{
\n temperature = std::stod(it->second);
\n}
\nit = requestParam.find("max_tokens");
\nif (it != requestParam.end())
\n{
\n max_tokens = std::stoi(it->second);
\n}
\nit = requestParam.find("thinking_type");
\nif (it != requestParam.end())
\n{
\n thinking_type = it->second;
\n}
\nit = requestParam.find("reasoning_effort");
\nif (it != requestParam.end())
\n{
\n reasoning_effort = it->second;
\n}<\/p>\n
\nit = requestParam.find("model");
\nif (it != requestParam.end())
\n{
\n model = it->second;
\n}
\nelse
\n{
\n ERR("model name not found in requestParams, must config it");
\n return std::nullopt;
\n}
\nJson::Value Type;
\nType["type"] = thinking_type; <\/p>\n\u00a0 \u00a0 1.2.3\u00a0\u7ec4\u88c5 messages \u5bf9\u8bdd\u6570\u7ec4<\/h4>\n
\nfor (auto& message : messages)
\n{
\n Json::Value messageObject;
\n messageObject["role"] = message._role;
\n messageObject["content"] = message._content;
\n messageArray.append(messageObject);
\n}<\/p>\n\u00a0 \u00a0 1.2.4\u00a0\u6784\u9020\u8bf7\u6c42\u4f53，\u5f00\u542f\u6d41\u5f0f\u5f00\u5173<\/h4>\n
\nrequestBody["model"] = model;
\nrequestBody["messages"] = messageArray;
\nrequestBody["temperature"] = temperature;
\nrequestBody["max_tokens"] = max_tokens;
\nrequestBody["thinking"] = thinking_type;
\nrequestBody["reasoning_effort"] = reasoning_effort;
\nrequestBody["stream"] = true;<\/p>\n\u00a0 \u00a0 1.2.5\u00a0JSON \u5e8f\u5217\u5316 + \u6784\u9020 httplib \u5ba2\u6237\u7aef\u4e0e\u8bf7\u6c42\u5934<\/h4>\n
\nstd::string requestBodyStr = Json::writeString(factory(writerbuilder), requestBody);<\/p>\n
\nclient.set_connection_timeout(20, 0); \/\/ \u8fde\u63a5\u8d85\u65f6\u65f6\u95f420\u79d2
\nclient.set_read_timeout(300, 0); \/\/ \u4f5c\u4e3a\u6d41\u5f0f\u54cd\u5e94，\u8bfb\u53d6\u65f6\u95f4\u76f8\u5bf9\u8f83\u957f，\u8bbe\u7f6e\u8d85\u65f6\u65f6\u95f4\u4e3a300\u79d2<\/p>\n
\n {"Accept", "text\/event-stream"},
\n {"Content-Type", "application\/json"},
\n {"Authorization", "Bearer " + _apikey}
\n};<\/p>\n\u00a0 \u00a0 1.2.6\u00a0\u5b9a\u4e49\u5168\u5c40\u7f13\u5b58\u4e0e\u72b6\u6001\u6807\u8bb0<\/h4>\n
\nstd::string fullResponse; \/\/ \u7d2f\u52a0\u6240\u6709\u589e\u91cf，\u6700\u7ec8\u4f5c\u4e3a\u51fd\u6570\u8fd4\u56de\u503c
\nbool streamEnd = false; \/\/ \u6d41\u7ed3\u675f\u6807\u8bb0
\nbool isError = false; \/\/ \u5168\u5c40\u9519\u8bef\u6807\u8bb0
\nstd::string errorMsg; \/\/ \u7528\u4e8e\u5b58\u50a8\u9519\u8bef\u63cf\u8ff0\u4fe1\u606f<\/p>\n\u00a0 \u00a0 1.2.7\u00a0\u6784\u5efa httplib::Request \u8bf7\u6c42\u5bf9\u8c61<\/h4>\n
\nrequest.method = "POST";
\nrequest.path = "\/v1\/chat\/completions";
\nrequest.headers = headers;
\nrequest.body = requestBodyStr;<\/p>\n\u00a0 \u00a0 1.2.8\u00a0response_handler：\u54cd\u5e94\u5934\u6821\u9a8c\u56de\u8c03<\/h4>\n
\n{
\n if (res.status != 200)
\n {
\n isError = true;
\n ERR("DeepSeekProvider sendMessageStream status not 200, status: {}, body: {}", res.status, res.body);
\n return false;
\n }
\n return true;
\n};<\/p>\n\u00a0 \u00a0 1.2.9\u00a0content_receiver：SSE \u5206\u7247\u89e3\u6790\u6838\u5fc3\u56de\u8c03<\/h4>\n
\n uint64_t offset, uint64_t total_length) -> bool
\n{
\n if (isError)
\n {
\n return false;
\n }
\n \/\/ 1. \u5148\u628a\u65b0\u6536\u5230\u7684\u6570\u636e\u8ffd\u52a0\u5230\u7f13\u51b2\u533a，\u89e3\u51b3\u534a\u5305\u95ee\u9898
\n buffer.append(data, data_length);<\/p>\n
\n size_t pos;
\n while ((pos = buffer.find("\\\\n\\\\n")) != std::string::npos)
\n {
\n std::string event = buffer.substr(0, pos);
\n buffer.erase(0, pos + 2);<\/p>\n
\n std::istringstream eventStream(event);
\n std::string line;
\n std::string modeldata;
\n while (std::getline(eventStream, line))
\n {
\n \/\/ \u8df3\u8fc7\u7a7a\u884c\u3001SSE\u6ce8\u91ca\u5fc3\u8df3\u884c（\u4ee5:\u5f00\u5934）
\n if (line.empty() || line[0] == ':')
\n {
\n continue;
\n }
\n \/\/ \u63d0\u53d6data: \u540e\u9762\u7684JSON\u5b57\u7b26\u4e32
\n if (line.compare(0, 6, "data: ") == 0)
\n {
\n modeldata = line.substr(6);
\n }
\n }<\/p>\n
\n if (modeldata == "[DONE]")
\n {
\n streamEnd = true;
\n callback("", true);
\n return true;
\n }<\/p>\n
\n Json::Value modeldataJson;
\n Json::CharReaderBuilder readerbuilder;
\n std::istringstream modeldataStream(modeldata);
\n bool ret = Json::parseFromStream(readerbuilder, modeldataStream, &modeldataJson, &errorMsg);
\n if (!ret)
\n {
\n WARN("DeepSeekProvider sendMessageStream parseFromStream error, errorMsg: {}", errorMsg);
\n \/\/ \u5355\u6761\u4e8b\u4ef6\u89e3\u6790\u5931\u8d25\u4e0d\u963b\u65ad\u6574\u4e2a\u6d41，\u7ee7\u7eed\u5904\u7406\u4e0b\u4e00\u4e2a\u4e8b\u4ef6
\n continue;
\n }<\/p>\n
\n if (modeldataJson.isMember("choices") && modeldataJson["choices"].isArray() && !modeldataJson["choices"].empty())
\n {
\n auto& firstChoice = modeldataJson["choices"][0];
\n if (firstChoice.isMember("delta") && firstChoice["delta"].isMember("content"))
\n {
\n std::string datacontent = firstChoice["delta"]["content"].asString();
\n fullResponse += datacontent;
\n \/\/ \u5411\u5916\u63a8\u9001\u589e\u91cf\u5206\u7247，\u7ed3\u675f\u6807\u8bb0false
\n callback(datacontent, false);
\n }
\n }
\n }
\n return true;
\n};<\/p>\n![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/11\/20261104220101-6aebab1da2709.png\")
<\/p>\n\u00a0 \u00a0 1.2.10\u00a0client.send \u53d1\u8d77\u8bf7\u6c42 + \u7ed3\u679c\u5224\u65ad<\/h4>\n
\n\/\/ send\u8fd4\u56de\u503c\u53ea\u4ee3\u8868\u8bf7\u6c42\u662f\u5426\u6210\u529f\u53d1\u51fa\u53bb，\u53ea\u68c0\u67e5\u8fde\u63a5\u9636\u6bb5\u9519\u8bef
\nif (!result)
\n{
\n ERR("DeepSeekProvider sendMessageStream send request ERROR: {}", httplib::to_string(result.error()));
\n return "";
\n}<\/p>\n
\nif (!streamEnd)
\n{
\n WARN("DeepSeekProvider stream end used without [DONE] marker");
\n callback("\\\\n\\\\n[\u7cfb\u7edf\u63d0\u793a: \u8fde\u63a5\u610f\u5916\u4e2d\u65ad，\u8bf7\u91cd\u8bd5]", true);
\n}
\nreturn fullResponse;<\/p>\n\u00a0 \u00a0 \u8865\u5145 client.send \u539f\u7406\u5206\u6790<\/h5>\n
\n
\n
\u00a0 \u00a0 1.2.11\u00a0\u6d41\u5f0f\u54cd\u5e94\u63a5\u53e3\u5b8c\u6574\u4ee3\u7801（\u9644\u6ce8\u91ca\u5206\u6790）<\/h4>\n
\nstd::optional<std::string> DeepSeekProvider::sendMessageStream(const std::vector<Message> &messages,
\n const std::unordered_map<std::string, std::string> &requestParams,
\n std::function<void(const std::string &response, bool isEnd)> callback)
\n{
\n \/\/ 1\u3001\u68c0\u67e5\u6a21\u578b\u662f\u5426\u6709\u6548
\n if (!IsAvailable())
\n {
\n ERR("DeepSeekProvider sendMessageStream model not available");
\n return std::nullopt;
\n }<\/p>\n
\n \/\/ 2.1 \u6784\u9020\u9ed8\u8ba4\u8bf7\u6c42\u53c2\u6570：\u5982\u679crequestParams\u4e2d\u6ca1\u6709\u6307\u5b9atemperature\u3001maxTokens\u3001thinking_type\u3001reasoning_effort，\u5219\u4f7f\u7528\u9ed8\u8ba4\u503c
\n double temperature = 0.7;
\n int max_tokens = 2048;
\n std::string thinking_type = "disabled";
\n std::string reasoning_effort = "high";
\n std::string model; \/\/ \u8bf7\u6c42\u53c2\u6570model\u65e0\u6cd5\u9ed8\u8ba4\u503c，\u5fc5\u987b\u7528\u6237\u624b\u52a8\u914d\u7f6e
\n \/\/ 2.2 \u4ecerequestParams\u4e2d\u83b7\u53d6temperature\u3001maxTokens\u3001thinking_type\u3001reasoning_effort\u53c2\u6570：\u5982\u679crequestParams\u4e2d\u6307\u5b9a\u4e86，\u5219\u4f7f\u7528\u6307\u5b9a\u503c
\n \/\/ \u6ce8\u610f：\u8bf7\u6c42\u53c2\u6570model\u5728\u4e0d\u540c\u7684\u6a21\u578b\u4e2d\u662f\u5fc5\u586b\u9879，\u4f46\u662f\u8fd9\u4e2a\u53c2\u6570\u7531\u4e8e\u6a21\u578b\u7248\u672c\u7684\u66f4\u65b0，\u53ef\u80fd\u4f1a\u6709\u4e0d\u540c\u7684\u5b57\u6bb5\u540d\u79f0，\u6240\u4ee5\u5c31\u4e0d\u80fd\u4f7f\u7528\u9ed8\u8ba4\u503c\u4e86，\u9700\u8981\u7528\u6237\u81ea\u884c\u6307\u5b9a\u6b63\u786e\u7684model
\n auto it = requestParams.find("temperature");
\n if (it != requestParams.end())
\n {
\n temperature = std::stod(it->second);
\n }
\n it = requestParams.find("max_tokens");
\n if (it != requestParams.end())
\n {
\n max_tokens = std::stoi(it->second);
\n }
\n it = requestParams.find("thinking_type");
\n if (it != requestParams.end())
\n {
\n thinking_type = it->second;
\n }
\n it = requestParams.find("reasoning_effort");
\n if (it != requestParams.end())
\n {
\n reasoning_effort = it->second;
\n }
\n \/\/ \u8bf7\u6c42\u53c2\u6570model\u5fc5\u987b\u7528\u6237\u624b\u52a8\u914d\u7f6e，\u5982\u679c\u6ca1\u6709\u914d\u7f6e\u5219\u76f4\u63a5\u8fd4\u56de\u7a7a\u503cnullopt\u62a5\u9519\u544a\u8bc9\u7528\u6237
\n it = requestParams.find("model");
\n if (it != requestParams.end())
\n {
\n model = it->second;
\n }
\n else
\n {
\n ERR("model name not found in requestParams, must config it");
\n return std::nullopt;
\n }
\n Json::Value Type;
\n Type["type"] = thinking_type;<\/p>\n
\n Json::Value messageArray(Json::arrayValue);
\n for (auto &message : messages)
\n {
\n Json::Value messageObject;
\n \/\/ \u8fd9\u91cc\u7684\u5b57\u6bb5\u540d\u79f0\u5fc5\u987b\u4e0edeepseek-flash\u6a21\u578b\u7684\u63a5\u53e3\u6587\u6863\u4e2d\u8981\u6c42\u7684\u4e00\u81f4
\n messageObject["role"] = message._role;
\n messageObject["content"] = message._content;
\n messageArray.append(messageObject);
\n }<\/p>\n
\n \/\/ \u548c\u5386\u53f2\u6d88\u606f\u6784\u9020\u4e00\u6837，\u8bf7\u6c42\u4f53\u7684\u5b57\u6bb5\u540d\u79f0\u5fc5\u987b\u4e0edeepseek-flash\u6a21\u578b\u7684\u63a5\u53e3\u6587\u6863\u4e2d\u8981\u6c42\u7684\u4e00\u81f4
\n Json::Value requestBody;
\n requestBody["model"] = model;
\n requestBody["messages"] = messageArray;
\n requestBody["temperature"] = temperature;
\n requestBody["max_tokens"] = max_tokens;
\n requestBody["thinking"] = Type;
\n requestBody["reasoning_effort"] = reasoning_effort;
\n \/\/ \u5173\u952e：\u6d41\u5f0f\u54cd\u5e94\u9700\u8981\u8bbe\u7f6estream\u4e3atrue（\u5426\u5219\u662f\u5168\u91cf\u54cd\u5e94\u4f1a\u8fd4\u56de\u5b8c\u6574\u7684\u54cd\u5e94\u4f53，\u800c\u4e0d\u662f\u589e\u91cf\u54cd\u5e94）
\n requestBody["stream"] = true;<\/p>\n
\n Json::StreamWriterBuilder writerbuilder;
\n std::string requestBodyStr = Json::writeString(writerbuilder, requestBody);
\n INFO("DeepSeekProvider sendMessage requestBody: {}", requestBodyStr);<\/p>\n
\n \/\/ 5.1\u8bbe\u7f6e\u8d85\u65f6\u65f6\u95f4
\n httplib::Client client(_baseUrl);
\n client.set_connection_timeout(20, 0); \/\/ \u8fde\u63a5\u8d85\u65f6\u65f6\u95f420\u79d2
\n client.set_read_timeout(300, 0); \/\/ \u4f5c\u4e3a\u6d41\u5f0f\u54cd\u5e94，\u8bfb\u53d6\u65f6\u95f4\u76f8\u5bf9\u8f83\u957f，\u8bbe\u7f6e\u8d85\u65f6\u65f6\u95f4\u4e3a300\u79d2
\n \/\/ 5.2 \u6784\u5efa\u8bf7\u6c42\u5934（\u5173\u952e：\u76f8\u8f83\u4e8e\u975e\u6d41\u5f0f\u54cd\u5e94，\u6d41\u5f0f\u54cd\u5e94\u9700\u8981\u8bbe\u7f6eAccept\u4e3atext\/event-stream）
\n httplib::Headers headers = {
\n {"Accept", "text\/event-stream"},
\n {"Content-Type", "application\/json"},
\n {"Authorization", "Bearer " + _apikey}};<\/p>\n
\n \/\/ \u56e0\u4e3a\u6d41\u5f0f\u54cd\u5e94\u662f\u589e\u91cf\u8fd4\u56de，\u6211\u4eec\u4f5c\u4e3a\u7528\u6237\u9700\u8981\u81ea\u5df1\u53bb\u9010\u884c\u89e3\u6790\u6bcf\u4e00\u4e2a\u54cd\u5e94\u4f53，\u90a3\u6211\u4eec\u5982\u4f55\u89e3\u6790？\u5728\u54ea\u89e3\u6790？
\n \/\/ \u7b54\u6848：\u6211\u4eec\u9700\u8981\u5148\u521b\u5efa\u4e00\u4e2aRequest\u5bf9\u8c61，\u5e76\u4e14\u8bbe\u7f6e\u4e00\u4e0b\u76f8\u5173\u53c2\u6570，
\n \/\/ \u800c\u5176\u4e2d response_handler \u4ee5\u53ca content_receiver \u8fd9\u4e24\u4e2a\u53c2\u6570\u5c31\u662f\u7528\u6765\u5904\u7406\u54cd\u5e94\u7684\u56de\u8c03\u51fd\u6570，\u6211\u4eec\u9700\u8981\u81ea\u5df1\u624b\u52a8\u5b9e\u73b0\u8fd9\u4e24\u4e2a\u51fd\u6570，\u5728\u5176\u4e2d\u89e3\u6790\u54cd\u5e94\u4f53\u3002
\n \/\/ \u5728\u6784\u5efa\u8bf7\u6c42\u5bf9\u8c61\u4e4b\u524d，\u6211\u4eec\u53ef\u4ee5\u5148\u8bbe\u7f6e\u4e00\u4e9b\u6d41\u5f0f\u5904\u7406\u53d8\u91cf，\u7528\u4e8e\u5904\u7406\u56de\u8c03\u8fc7\u7a0b\u4e2d\u7684\u76f8\u5173\u903b\u8f91\u3002<\/p>\n
\n std::string fullResponce; \/\/ \u7528\u4e8e\u7d2f\u79ef\u5b58\u50a8\u83b7\u53d6\u5230\u7684\u5b8c\u6574\u7684\u54cd\u5e94\u4f53
\n bool streamEnd = false; \/\/ \u7528\u4e8e\u6807\u8bb0\u6d41\u5f0f\u54cd\u5e94\u662f\u5426\u7ed3\u675f
\n bool isError = false; \/\/ \u7528\u4e8e\u6807\u8bb0\u662f\u5426\u53d1\u751f\u9519\u8bef
\n std::string errorMsg; \/\/ \u7528\u4e8e\u5b58\u50a8\u9519\u8bef\u63cf\u8ff0\u4fe1\u606f<\/p>\n
\n httplib::Request request;
\n request.method = "POST";
\n request.path = "\/v1\/chat\/completions";
\n request.headers = headers;
\n request.body = requestBodyStr;<\/p>\n
\n \/\/ \u5173\u952e：response_handler \u51fd\u6570\u4f1a\u5728\u6536\u5230\u54cd\u5e94\u5934\u65f6\u88ab\u8c03\u7528，\u6211\u4eec\u53ef\u4ee5\u5728\u5176\u4e2d\u5224\u65ad\u54cd\u5e94\u662f\u5426\u6b63\u5e38（\u8be5\u56de\u8c03\u51fd\u6570\u53ea\u8c03\u7528\u4e00\u6b21），
\n \/\/ \u5982\u679c\u54cd\u5e94\u5f02\u5e38，\u6211\u4eec\u53ef\u4ee5\u76f4\u63a5\u8fd4\u56defalse，\u7ed3\u675f\u8bf7\u6c42\u3002
\n \/\/ \u5982\u679c\u54cd\u5e94\u6b63\u5e38，\u6211\u4eec\u53ef\u4ee5\u8fd4\u56detrue，\u7ee7\u7eed\u5904\u7406\u54cd\u5e94\u4f53\u3002
\n request.response_handler = [&](const httplib::Response &res) -> bool
\n {
\n \/\/ \u5982\u679c\u54cd\u5e94\u72b6\u6001\u7801\u4e0d\u662f200，\u8bf4\u660e\u54cd\u5e94\u5f02\u5e38，\u6211\u4eec\u53ef\u4ee5\u76f4\u63a5\u8fd4\u56defalse，\u7ed3\u675f\u8bf7\u6c42\u3002
\n if (res.status != 200)
\n {
\n isError = true;
\n ERR("DeepSeekProvider sendMessageStream status not 200, status: {}, body: {}", res.status, res.body);
\n return false;
\n }
\n return true; \/\/ \u5982\u679c\u54cd\u5e94\u72b6\u6001\u7801\u662f200，\u8bf4\u660e\u54cd\u5e94\u6b63\u5e38，\u6211\u4eec\u53ef\u4ee5\u8fd4\u56detrue，\u7ee7\u7eed\u5904\u7406\u54cd\u5e94\u4f53\u3002
\n };<\/p>\n
\n \/\/ \u5173\u952e：content_receiver \u51fd\u6570\u4f1a\u5728\u6536\u5230\u5b8c\u6574Chunk\u6570\u636e\u5757\u65f6\u88ab\u8c03\u7528，\u6211\u4eec\u53ef\u4ee5\u5728\u5176\u4e2d\u89e3\u6790\u54cd\u5e94\u4f53（\u8be5\u56de\u8c03\u51fd\u6570\u4f1a\u88ab\u591a\u6b21\u8c03\u7528），
\n \/\/ \u5982\u679c\u89e3\u6790\u8fc7\u7a0b\u4e2d\u53d1\u751f\u4e25\u91cd\u9519\u8bef，\u6211\u4eec\u53ef\u4ee5\u76f4\u63a5\u8fd4\u56defalse，\u7ed3\u675f\u8bf7\u6c42\u3002
\n \/\/ \u5982\u679c\u89e3\u6790\u8fc7\u7a0b\u6b63\u5e38，\u6211\u4eec\u53ef\u4ee5\u8fd4\u56detrue，\u7ee7\u7eed\u5904\u7406\u4e0b\u4e00\u4e2a\u6570\u636e\u5757\u3002
\n request.content_receiver = [&](const char *data, size_t data_length,
\n uint64_t offset, uint64_t total_length) -> bool
\n {
\n \/\/ 1\u3001\u9a8c\u8bc1\u524d\u9762\u7684\u54cd\u5e94\u5934\u662f\u5426\u51fa\u9519，\u51fa\u9519\u4e86，\u76f4\u63a5\u8fd4\u56defalse\u7ed3\u675f\u8bf7\u6c42，\u4e0d\u9700\u8981\u518d\u63a5\u6536\u6570\u636e
\n if (isError)
\n {
\n return false;
\n }<\/p>\n
\n buffer.append(data, data_length);
\n INFO("DeepSeekProvider sendMessageStream data: {}", buffer);<\/p>\n
\n size_t pos;
\n while ((pos = buffer.find("\\\\n\\\\n")) != std::string::npos)
\n {
\n \/\/ 3.1 \u622a\u53d6\u5f53\u524d\u627e\u5230\u7684\u4e8b\u4ef6\u5757
\n std::string event = buffer.substr(0, pos);
\n buffer.erase(0, pos + 2); \/\/ \u79fb\u9664\u5df2\u5904\u7406\u7684\u4e8b\u4ef6\u5757，\u907f\u514d\u540e\u7eed\u89e3\u6790\u65f6\u91cd\u590d\u5904\u7406<\/p>\n
\n \/\/ \u6ce8\u610f：\u4e0d\u80fd\u76f4\u63a5\u5bf9event\u8fdb\u884c\u89e3\u6790，\u5e76\u4e14\u5229\u7528event\u5224\u65ad\u662f\u5426\u4e3a\u7a7a\u884c\u6216\u8005\u4ee5":"\u5f00\u5934\u7684\u6ce8\u91ca\u884c，
\n \/\/ \u56e0\u4e3a\u5f53\u524d\u7684\u4e8b\u4ef6\u5757\u4e2d\u53ef\u80fd\u4e0d\u4ec5\u4ec5\u53ea\u6709\u7a7a\u884c\u6216\u8005\u4ee5":"\u5f00\u5934\u7684\u6ce8\u91ca\u884c，\u53ef\u80fd\u8fde\u5e26\u7740\u540e\u7eed\u90e8\u5206\u7684"data: "\u884c\u4e00\u8d77\u53d1\u9001\u8fc7\u6765\u4e86
\n \/\/ \u5982\u679c\u76f4\u63a5\u5bf9event\u8fdb\u884c\u89e3\u6790，\u5e76\u4e14\u5224\u65ad\u7b2c\u4e00\u4e2a\u5b57\u7b26':'，\u5c31\u4f1a\u8bef\u5224\u4e3a\u53ea\u6709\u6ce8\u91ca\u884c\u800c\u8fdb\u884ccontinue，
\n \/\/ \u5c31\u4f1a\u5bfc\u81f4\u540e\u7eed\u7684"data: "\u884c\u8fde\u540c\u6ce8\u91ca\u884c\u4e00\u8d77\u88ab\u5220\u9664\u4e86，\u4ece\u800c\u5bfc\u81f4data\u6570\u636e\u90e8\u5206\u4e22\u5931
\n \/\/ \u6240\u4ee5\u6211\u4eec\u9700\u8981\u501f\u52a9\u8f93\u5165\u6d41\u901a\u8fc7std::getline()\u51fd\u6570\u9010\u884c\u89e3\u6790\u5f53\u524d\u4e8b\u4ef6\u5757，\u8fd9\u6837\u5c31\u80fd\u786e\u4fdd\u6bcf\u4e2a\u4e8b\u4ef6\u884c\u90fd\u662f\u72ec\u7acb\u7684，\u4e0d\u4f1a\u88ab\u9519\u8bef\u89e3\u6790
\n std::istringstream eventStream(event);
\n std::string line;
\n std::string modeldata;
\n while (std::getline(eventStream, line))
\n {
\n \/\/ \u8fc7\u6ee4\u7a7a\u884c\u548c\u6ce8\u91ca\u884c
\n if (line.empty() || line[0] == ':')
\n {
\n continue;
\n }
\n \/\/ \u5224\u65ad\u662f\u5426\u4e3adata\u884c，\u63d0\u53d6data\u6570\u636e\u90e8\u5206
\n if (line.compare(0, 6, "data: ") == 0)
\n {
\n \/\/ \u76f4\u63a5\u4ece\u7b2c6\u4e2a\u5b57\u7b26\u622a\u53d6\u5230\u6700\u540e\u5373\u53ef，line\u4e3a\u4e00\u884c\u7684\u6570\u636e，\u4e0d\u4f1a\u5c06data\u6362\u884c\u7b26\u4e4b\u540e\u7684\u65e0\u6548\u6570\u636e\u5305\u542b\u8fdb\u6765
\n modeldata = line.substr(6);
\n BUG("DeepSeekProvider sendMessageStream eventType: {}", modeldata);
\n }
\n }<\/p>\n
\n if (modeldata == "[DONE]")
\n {
\n streamEnd = true;
\n callback("", true);
\n return true;
\n }
\n \/\/ 3.3 \u89e3\u6790\u5f53\u524d\u4e8b\u4ef6\u5757\u4e2d\u7684Json\u5b57\u7b26\u4e32 — \u53cd\u5e8f\u5217\u5316
\n Json::Value modeldataJson;
\n Json::CharReaderBuilder readerbuilder;
\n std::istringstream modeldataStream(modeldata);
\n bool ret = Json::parseFromStream(readerbuilder, modeldataStream, &modeldataJson, &errorMsg);
\n if (!ret)
\n {
\n WARN("DeepSeekProvider sendMessageStream parseFromStream error, errorMsg: {}", errorMsg);
\n \/\/ \u89e3\u6790\u5931\u8d25，\u53ea\u80fd\u8bf4\u5f53\u524d\u4e8b\u4ef6\u5757\u4e2d\u5305\u542b\u4e86\u65e0\u6548\u7684Json\u6570\u636e，\u76f4\u63a5\u8df3\u51fa\u5f53\u524d\u4e8b\u4ef6\u5757\u7684\u6570\u636e\u89e3\u6790，\u7ee7\u7eed\u5904\u7406\u4e0b\u4e00\u4e2a\u4e8b\u4ef6\u5757
\n \/\/ \u4e0d\u80fd\u76f4\u63a5\u8fd4\u56defalse，\u5426\u5219\u5c31\u4f1a\u5bfc\u81f4\u540e\u7eed\u7684\u4e8b\u4ef6\u5757\u90fd\u65e0\u6cd5\u89e3\u6790，\u4ece\u800c\u5bfc\u81f4\u8bf7\u6c42\u5931\u8d25
\n continue;
\n }<\/p>\n
\n \/\/ \u6a21\u578b\u8fd4\u56de\u7684\u54cd\u5e94\u4e2d\u7684choices\u5b57\u6bb5\u662f\u4e00\u4e2aJson\u6570\u7ec4，\u6570\u7ec4\u4e2d\u6bcf\u4e00\u4e2a\u5143\u7d20\u5305\u542bdelta\u5b57\u6bb5，delta\u5b57\u6bb5\u4e2d\u5305\u542bcontent\u5b57\u6bb5，content\u5b57\u6bb5\u5c31\u662f\u6a21\u578b\u751f\u6210\u7684\u56de\u590d
\n \/\/ \u5148\u68c0\u67e5 choices \u662f\u5426\u5b58\u5728\u4e14\u662f\u6570\u7ec4\u4e14\u4e0d\u4e3a\u7a7a — \u4fdd\u8bc1\u6211\u4eec\u80fd\u83b7\u53d6\u5230\u6709\u6570\u636e\u7684choices\u5b57\u6bb5
\n if (modeldataJson.isMember("choices") && modeldataJson["choices"].isArray() && !modeldataJson["choices"].empty())
\n {
\n Json::Value firstChoice = modeldataJson["choices"][0];
\n \/\/ \u518d\u68c0\u67e5choices\u6570\u7ec4\u4e2d\u662f\u5426\u5b58\u5728delta\u5b57\u6bb5\u4e14delta\u5b57\u6bb5\u4e2d\u662f\u5426\u5b58\u5728content
\n if (firstChoice.isMember("delta") && firstChoice["delta"].isMember("content"))
\n {
\n std::string datacontent = firstChoice["delta"]["content"].asString();
\n \/\/ \u5c06\u83b7\u53d6\u5230\u7684\u6a21\u578b\u56de\u590d\u7684datacontent\u8ffd\u52a0\u5230fullResponce
\n fullResponce += datacontent;<\/p>\n
\n callback(datacontent, streamEnd);
\n }
\n }
\n }
\n \/\/ \u5230\u8fd9，\u8bf4\u660e\u5f53\u524d\u6570\u636e\u5757chunk\u4e2d\u7684\u6240\u6709\u4e8b\u4ef6\u5757\u5df2\u7ecf\u5904\u7406\u5b8c，\u7ee7\u7eed\u7b49\u5f85\u540e\u7eed\u6570\u636e\u5757\u7684\u5230\u6765
\n return true;
\n };
\n \/\/ \u5199\u5230\u8fd9\u4e00\u5b9a\u8981\u6ce8\u610f：\u4e0a\u9762\u6211\u4eec\u6240\u5199\u7684\u5904\u7406\u8fc7\u7a0b\u53ea\u662f\u9488\u5bf9Resquest\u5bf9\u8c61\u8bbe\u7f6e\u53c2\u6570，\u6211\u4eec\u8fd8\u6ca1\u6709\u53d1\u9001\u8bf7\u6c42，
\n \/\/ \u4ee5\u6211\u4eec\u9700\u8981\u8c03\u7528client.send(request)\u53d1\u9001\u8bf7\u6c42，\u624d\u80fd\u83b7\u53d6\u5230\u670d\u52a1\u5668\u7684\u54cd\u5e94<\/p>\n
\n auto result = client.send(request);
\n \/\/ \u5173\u952e\u70b9：Post\u7684\u8fd4\u56de\u503c\u548csend\u7684\u8fd4\u56de\u503c\u867d\u7136\u90fd\u662fhttplib::Result\u7c7b\u578b，\u4f46\u662f\u542b\u4e49\u5b8c\u5168\u4e0d\u4e00\u6837
\n \/\/ send\u7684\u8fd4\u56de\u503c\u9488\u5bf9\u7684\u662f\u8bf7\u6c42\u53d1\u9001\u9636\u6bb5，\u800cPost\u7684\u8fd4\u56de\u503c\u9488\u5bf9\u7684\u662f\u54cd\u5e94\u63a5\u6536\u9636\u6bb5<\/p>\n
\n \/\/ \u56e0\u4e3a\u670d\u52a1\u5668\u5728\u4e00\u6b21\u6b21\u53d1\u9001\u6570\u636e\u5757\u7684\u65f6\u5019，\u4f1a\u8c03\u7528\u4e0a\u9762\u6211\u4eec\u6240\u5199\u7684content_receiver\u56de\u8c03\u51fd\u6570，
\n \/\/ \u800c\u5728\u56de\u8c03\u51fd\u6570\u4e2d，\u6211\u4eec\u5df2\u7ecf\u5c06\u6bcf\u6b21\u63a5\u6536\u5230\u7684\u6570\u636e\u5757\u4e2d\u7684content\u5185\u5bb9\u62fc\u63a5\u8d77\u6765，\u5b8c\u6210\u4e86\u54cd\u5e94\u5185\u5bb9\u7684\u83b7\u53d6
\n \/\/ \u6240\u4ee5，send\u7684\u8fd4\u56de\u503c\u53ea\u662f\u7528\u6765\u5224\u65ad\u6211\u4eec\u7684\u8bf7\u6c42\u53d1\u9001\u662f\u5426\u662f\u6210\u529f\u7684，\u4e5f\u5c31\u662f\u8bf4\u5982\u679c\u662f\u6210\u529f，\u6211\u4eec\u81ea\u7136\u4e5f\u5c31\u83b7\u53d6\u5230\u4e86\u54cd\u5e94\u5185\u5bb9<\/p>\n
\n if (!result)
\n {
\n \/\/ \u53d1\u9001\u8bf7\u6c42\u5931\u8d25，\u53ef\u80fd\u51fa\u73b0\u7f51\u7edc\u95ee\u9898，\u6bd4\u5982DNS\u89e3\u6790\u5931\u8d25，\u8fde\u63a5\u8d85\u65f6\u7b49\u7b49
\n ERR("DeepSeekProvider sendMessageStream send request error: {}", httplib::to_string(result.error()));
\n \/\/ ERR("DeepSeekProvider sendMessageStream send request error: {}", static_cast<int>(result.error()));
\n \/\/ \u8fd9\u4e2a\u5199\u6cd5\u4e5f\u53ef\u4ee5，\u4e0a\u9762\u662f\u76f4\u63a5\u4f7f\u7528httplib\u4e2d\u5b9e\u73b0\u7684to_string\u51fd\u6570\u76f4\u63a5\u5c06Error\u679a\u4e3e\u503c\u8f6c\u6362\u4e3a\u5b57\u7b26\u4e32
\n \/\/ \u8fd9\u4e2a\u5199\u6cd5\u662f\u901a\u8fc7\u663e\u5f0f\u8f6c\u6362\u6210int\u7c7b\u578b
\n \/\/ ERR("DeepSeekProvider sendMessageStream send request error: {}", result.error()); \/\/error
\n \/\/ error()\u8fd4\u56de\u7c7b\u578b\u662fError，\u662f\u4e00\u4e2aenum class，enum class \u4e0d\u540c\u4e8e\u666e\u901a\u7684enum，enum\u53ef\u4ee5\u9690\u5f0f\u7c7b\u578b\u8f6c\u6362，\u800cenum class\u4e0d\u80fd
\n return std::nullopt;
\n }<\/p>\n
\n \/\/ \u8fd9\u79cd\u60c5\u51b5\u53ef\u80fd\u662f\u8fc7\u7a0b\u4e2d\u51fa\u73b0\u4e86\u4e00\u4e9b\u95ee\u9898，\u4f46\u662f\u6211\u4eec\u5df2\u7ecf\u83b7\u53d6\u5230\u4e86\u54cd\u5e94\u5185\u5bb9，\u6240\u4ee5\u6211\u4eec\u53ea\u80fd\u8b66\u544a\u4e00\u4e0b\u7528\u6237，\u544a\u8bc9\u7528\u6237\u53ef\u80fd\u4f1a\u5b58\u5728\u4e00\u4e9b\u95ee\u9898
\n \/\/ \u6ce8\u610f：\u5f53\u6211\u4eec\u7ed9\u7528\u6237\u4e00\u4e2a\u8b66\u544a\u540e，\u5fc5\u987b\u518d\u6b21\u8fdb\u884c\u56de\u8c03\u5904\u7406，\u624b\u52a8\u5c06\u7b2c\u4e8c\u4e2a\u53c2\u6570\u8bbe\u7f6e\u6210true，\u5426\u5219\u4e0a\u9762\u7528\u6237\u5c42\u7684\u5faa\u73af\u4f1a\u7ee7\u7eed\u8fd0\u884c，\u5bfc\u81f4\u65e0\u9650\u7b49\u5f85
\n if (!streamEnd)
\n {
\n WARN("DeepSeekProvider stream ended without [DONE] marker");
\n \/\/ \u624b\u52a8\u5c06\u7b2c\u4e8c\u4e2a\u53c2\u6570\u8bbe\u7f6e\u6210true，\u544a\u8bc9\u7528\u6237\u6211\u4eec\u5df2\u7ecf\u83b7\u53d6\u5230\u4e86\u54cd\u5e94\u5185\u5bb9，\u4f46\u662f\u6ca1\u6709\u6536\u5230[DONE]\u7ed3\u675f\u6807\u8bb0
\n callback("\\\\n\\\\n[\u7cfb\u7edf\u63d0\u793a: \u8fde\u63a5\u610f\u5916\u4e2d\u65ad，\u8bf7\u91cd\u8bd5]", true);
\n }<\/p>\n
\n} <\/p>\n\u00a0 1.3 \u8865\u5145：\u7f16\u8bd1\u95ee\u9898\u5b9a\u4f4d\u4e0e\u4fee\u590d<\/h3>\n
\u00a0 \u00a0 1.3.1\u00a0\u9519\u8bef\u73b0\u8c61<\/h4>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/11\/20261104220103-6aebab1f1ceba.png\")
<\/p>\n\u00a0 \u00a0 1.3.2\u00a0\u6839\u56e0\u5206\u6790<\/h4>\n
\n
\u00a0 \u00a0 1.3.3\u00a0\u4fee\u590d\u65b9\u6848<\/h4>\n
\nERR("DeepSeekProvider sendMessageStream send request ERROR: {}", result.error());<\/p>\n
\nERR("DeepSeekProvider sendMessageStream send request ERROR: {}", httplib::to_string(result.error()));<\/p>\n
\n\/\/ ERR("DeepSeekProvider sendMessageStream send request ERROR: {}", static_cast<int>(result.error()));<\/p>\n\u00a0 \u00a0 1.3.4\u00a0\u5c0f\u7ed3<\/h4>\n
\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/11\/20261104220103-6aebab1fbd9fa.png\")
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/11\/20261104220106-6aebab2216459.png\")
<\/p>\n\u4e8c\u3001\u6d41\u5f0f\u54cd\u5e94\u5355\u5143\u6d4b\u8bd5<\/h2>\n
\u00a0 2.1\u00a0\u521d\u59cb\u5316\u4e0e\u914d\u7f6e<\/h3>\n
\n#include <gtest\/gtest.h>
\n#include <spdlog\/common.h><\/p>\n
\n{
\n \/\/ 1\u3001\u521b\u5efaDeepSeekProvider\u5bf9\u8c61
\n std::shared_ptr<LLMProvider> deepseekProvider = std::make_shared<DeepSeekProvider>();
\n \/\/ 1.1 \u68c0\u67e5DeepSeekProvider\u662f\u5426\u521d\u59cb\u5316\u6210\u529f
\n ASSERT_TRUE(deepseekProvider != nullptr);<\/p>\n
\n std::unordered_map<std::string, std::string> modelConfig;
\n modelConfig["api_key"] = getenv("deepseek_apikey") ? getenv("deepseek_apikey") : "";
\n modelConfig["base_url"] = "https:\/\/api.deepseek.com";<\/p>\n
\n deepseekProvider->initModel(modelConfig);
\n \/\/ 3.1 \u68c0\u67e5\u6a21\u578b\u662f\u5426\u6709\u6548
\n ASSERT_TRUE(deepseekProvider->IsAvailable());<\/p>\n
\n std::unordered_map<std::string, std::string> requestConfig;
\n requestConfig["model"] = "deepseek-flash";
\n requestConfig["temperature"] = "0.7";
\n requestConfig["max_tokens"] = "2048";
\n requestConfig["thinking_type"] = "disabled";
\n requestConfig["reasoning_effort"] = "high";<\/p>\n
\n \/\/ \u9ed8\u8ba4\u5f62\u5f0f
\n std::vector<Message> messages;
\n \/\/ \/\/ messages.push_back({"user", "\u4f60\u597d, \u8bf7\u7b80\u5355\u4ecb\u7ecd\u4e00\u4e0b\u4f60\u81ea\u5df1"});<\/p>\n
\n \/\/ messages.push_back({"system", "\u4f60\u662f\u4e00\u4e2a\u6709\u7740\u5341\u5e74\u7ecf\u9a8c\u7684C++\u5f00\u53d1\u5de5\u7a0b\u5e08\u4ee5\u53caAI\u5f00\u53d1\u5de5\u7a0b\u5e08"});
\n \/\/ messages.push_back({"user", "\u57fa\u4e8e\u5927\u6a21\u578bapi\u7684\u6d41\u5f0f\u54cd\u5e94, \u7b80\u5355\u8bb2\u89e3\u4e00\u4e0bSSE\u4e8b\u4ef6\u662f\u4ec0\u4e48?"});<\/p>\n
\n \/\/ \u7b2c\u4e00\u8f6e\u7528\u6237\u63d0\u95ee
\n messages.push_back({"user", "\u6211\u53eb\u5f20\u4e09，\u4f60\u662f\u8c01？"});
\n \/\/ \u586b\u5165\u4e0a\u4e00\u8f6e\u5927\u6a21\u578b\u8fd4\u56de\u7684assistant\u56de\u7b54，\u5f62\u6210\u5386\u53f2\u4e0a\u4e0b\u6587
\n messages.push_back({"assistant", "\u4f60\u597d\u5f20\u4e09！\u6211\u662f\u4e00\u4e2a\u4eba\u5de5\u667a\u80fd\u52a9\u624b，\u5f88\u9ad8\u5174\u4e3a\u4f60\u670d\u52a1\u3002"});
\n \/\/ \u65b0\u4e00\u8f6e\u7528\u6237\u63d0\u95ee：\u6a21\u578b\u9700\u8981\u7ed3\u5408\u4e0a\u9762\u4e24\u6761\u5386\u53f2\u4e00\u8d77\u7406\u89e3\u4e0a\u4e0b\u6587，\u77e5\u9053\u201c\u6211\u53eb\u4ec0\u4e48\u201d
\n messages.push_back({"user", "\u6211\u53eb\u4ec0\u4e48？"});<\/p>\n
\n auto response = deepseekProvider->sendMessageStream(
\n messages, requestConfig,
\n [&](const std::string &chunk, bool isEnd)
\n {
\n INFO("chunk: {}", chunk);
\n if (isEnd)
\n {
\n INFO("[DONE]");
\n }
\n });
\n \/\/ 6.1 \u68c0\u67e5\u54cd\u5e94\u662f\u5426\u4e3a\u7a7a
\n ASSERT_TRUE(response.has_value());
\n INFO("response: {}", response.value());
\n} <\/p>\n\u00a0 2.2\u00a0\u5165\u53e3\u51fd\u6570<\/h3>\n
\n{
\n \/\/ \u521d\u59cb\u5316Google Test\u6846\u67b6
\n testing::InitGoogleTest(&argc, argv);<\/p>\n
\n Logger::logger_init("testLLM", "stdout", spdlog::level::debug);<\/p>\n
\n return RUN_ALL_TESTS();
\n} <\/p>\n\u00a0 2.3 \u8fd0\u884c\u7ed3\u679c\u5c55\u793a<\/h3>\n
\ncd test\/build<\/p>\n
\ncmake ..<\/p>\n
\nmake clean
\nmake<\/p>\n
\n.\/testLLM<\/p>\n![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/11\/20261104220107-6aebab2365be3.png\")
<\/p>\n![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/11\/20261104220107-6aebab23ceeab.png\")
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/11\/20261104220108-6aebab244e8eb.png\")
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/11\/20261104220108-6aebab24bf8fd.png\")
<\/p>\n\u00a0 2.4\u00a0\u5f15\u51fa\u7591\u95ee<\/h3>\n
\u00a0 \u00a0 2.4.1\u00a0\u5148\u89e3\u91ca：\u670d\u52a1\u5668\u7684\u201c\u8d34\u5fc3\u201d，\u5927\u6982\u7387\u53d1\u9001\u5b8c\u6574\u7684 SSE<\/h4>\n
\u00a0 \u00a0 2.4.2\u00a0\u73b0\u5b9e\u7684\u201c\u6b8b\u9177\u201d：\u9632\u4eba\u4e4b\u5fc3\u4e0d\u53ef\u65e0<\/h4>\n
\n
\u00a0 \u00a0 2.4.3\u00a0\u7ed3\u8bba：\u65e5\u5fd7\u91cc\u770b\u4e0d\u5230\u534a\u5305 \u2260 \u4e0d\u9700\u8981 buffer + while \u515c\u5e95<\/h4>\n
\u603b\u7ed3：<\/h4>\n
\u7ed3\u675f\u8bed<\/h2>\n
\n\u2728\u672a\u62e9\u4e4b\u8def，\u4e0d\u987b\u56de\u5934 \u5df2\u62e9\u4e4b\u8def，\u7eb5\u662f\u8346\u68d8\u904d\u91ce，\u4ea6\u4f5c\u82b1\u6d77\u9068\u6e38 \u76ee\u5f55
\n\u524d\u8a00
\n\u4e00\u3001DeepSeek \u6d41\u5f0f\u54cd\u5e94\u63a5\u53e3\u5b9e\u73b0 1.1\u00a0\u63a5\u53e3\u5b9a\u4e49\u4e0e\u804c\u8d23\u8fb9\u754c 1.1.1\u00a0\u65b9\u6cd5\u7b7e\u540d <\/p>\n","protected":false},"author":2,"featured_media":122562,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[11820,55,190,78,51],"topic":[],"class_list":["post-122571","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-server","tag-atomgit","tag-c","tag-190","tag-78","tag-51"],"yoast_head":"\n