{"id":36141,"date":"2025-05-07T23:45:40","date_gmt":"2025-05-07T15:45:40","guid":{"rendered":"https:\/\/www.wsisp.com\/helps\/36141.html"},"modified":"2025-05-07T23:45:40","modified_gmt":"2025-05-07T15:45:40","slug":"%e5%a4%9a%e7%ba%bf%e7%a8%8b%e6%9c%8d%e5%8a%a1%e5%99%a8%e5%88%86%e6%9e%90-reactor%e7%ba%bf%e7%a8%8b%e6%a8%a1%e5%9e%8b%e5%92%8c%e6%80%a7%e8%83%bd%e5%88%86%e6%9e%90%e5%9b%9b","status":"publish","type":"post","link":"https:\/\/www.wsisp.com\/helps\/36141.html","title":{"rendered":"\u591a\u7ebf\u7a0b\u670d\u52a1\u5668\u5206\u6790\u2014\u2014Reactor\u7ebf\u7a0b\u6a21\u578b\u548c\u6027\u80fd\u5206\u6790(\u56db)"},"content":{"rendered":"

\u591a\u7ebf\u7a0b\u670d\u52a1\u5668\u5206\u6790\u2014\u2014Reactor\u7ebf\u7a0b\u6a21\u578b\u548c\u6027\u80fd\u5206\u6790(\u4e09)<\/p>\n

4 \u6848\u4f8b\u5b9e\u73b0<\/h2>\n

\u3010\u4ee3\u7801：reactor\/distribute_storage\u3011 \u5728\u8fd9\u91cc\u5148\u53e0\u4e2a\u7532：\u4ee5\u4e0b\u8bb2\u8ff0\u7684\u5206\u5e03\u5f0f\u5b58\u50a8\u5e76\u975e\u4e1a\u754c\u771f\u5b9e\u4f7f\u7528\u7684\u5206\u5e03\u5f0f\u7cfb\u7edf，\u53ea\u662f\u5728\u8bbe\u8ba1\u4e0a\u5177\u6709\u76f8\u4f3c\u4e4b\u5904，\u90fd\u6709\u7f51\u5173\u3001\u6570\u636e\u7ba1\u7406，\u5143\u6570\u636e\u7ba1\u7406\u7b49\u7b49，\u56e0\u6b64\u4ee3\u7801\u90e8\u5206\u4e3b\u8981\u7740\u773c\u4e8e\u8bb2\u8ff0\u7684\u7ebf\u7a0b\u6a21\u578b\u7684\u5b9e\u73b0，\u5f88\u591a\u5f02\u5e38\u60c5\u51b5\u662f\u6ca1\u6709\u8003\u8651\u5230\u7684，\u4ee5\u53ca\u9488\u5bf9\u5199\u5931\u8d25\u60c5\u51b5\u7684\u5783\u573e\u56de\u6536\u4e5f\u5e76\u6ca1\u6709\u5b9e\u73b0，\u5e76\u4e14\u53ef\u80fd\u5305\u542b\u4e00\u4e9b\u672a\u77e5\u7684bug，\u8bf7\u8bfb\u8005\u6d77\u6db5\u3002<\/p>\n

4.1 Gateway\u7f51\u5173\u8fdb\u7a0b\u7684\u542f\u52a8<\/h3>\n

\u4e0b\u9762\u5c06\u6839\u636e\u524d\u9762\u6240\u6709\u7684\u5185\u5bb9\u5b9e\u73b0\u4e00\u4e2a\u57fa\u4e8ereactor + \u7ebf\u7a0b\u6c60\u7684\u5206\u5e03\u5f0f\u5b58\u50a8\u4e2d\u7684\u5199\u8bf7\u6c42，\u4e5f\u5c31\u662f\u4e0a\u4f20\u6587\u4ef6\u3002\u8fd9\u4e2a\u5206\u5e03\u5f0f\u5b58\u50a8\u7cfb\u7edf\u5728\u7b2c\u4e8c\u7ae0\u591a\u7ebf\u7a0b\u670d\u52a1\u5668\u5206\u6790\u2014\u2014Reactor\u7ebf\u7a0b\u6a21\u578b\u548c\u6027\u80fd\u5206\u6790(\u4e8c)\u4e2d\u76843.4\u8282\u63cf\u8ff0\u4e86\u5176\u4e1a\u52a1\u903b\u8f91\u548c\u63a5\u53e3\u8bbe\u8ba1\u7b49\u7b49，\u5728\u8fd9\u91cc\u6211\u4eec\u7b80\u5355\u56de\u987e\u4e00\u4e0b\u4e0a\u4f20\u6587\u4ef6\u7684\u903b\u8f91\u8fc7\u7a0b： \"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\" \u7f51\u5173（Gateway）：\u8d1f\u8d23\u63a5\u6536\u6765\u81ea\u5ba2\u6237\u7aef\u7684\u8bf7\u6c42\u5e76\u5904\u7406\u3002 \u6570\u636e\u7ba1\u7406（DataManager）：\u8d1f\u8d23\u5b58\u50a8\u4e0a\u4f20\u7684\u6570\u636e\u3002 \u5143\u6570\u636e\u7ba1\u7406（MetaDataManager）：\u8d1f\u8d23\u5b58\u50a8\u4e0a\u4f20\u6570\u636e\u7684\u5143\u6570\u636e\u4fe1\u606f，\u5305\u62ec\u6587\u4ef6\u5927\u5c0f\u3001\u521b\u5efa\u65f6\u95f4\u7b49\u7b49\u3002 \u4ece\u5ba2\u6237\u7aef\u4e0a\u4f20\u6587\u4ef6，\u5fc5\u7136\u4e0d\u53ef\u80fd\u662f\u4e00\u6574\u4e2a\u6587\u4ef6\u4e00\u4e0b\u5b50\u5199\u5165\u5230socket\u4e2d，\u800c\u662f\u5206\u5757\u8bfb\u53d6，\u5206\u5757\u4e0a\u4f20\u3002\u5f53\u8bf7\u6c42\u5230\u8fbe\u7f51\u5173\u5c42\u65f6，\u53d1\u73b0\u5ba2\u6237\u7aef\u662f\u7684\u8bf7\u6c42\u662f\u4e0a\u4f20\u6587\u4ef6，\u90a3\u4e48\u5c31\u5f00\u59cb\u63a5\u6536，\u63a5\u6536\u4e00\u4e2a\u5206\u5757\u5c31\u4f20\u9012\u7ed9\u6570\u636e\u7ba1\u7406\u5c42，\u76f4\u5230\u6700\u540e\u4e00\u4e2a\u5206\u5757\u5728\u6570\u636e\u7ba1\u7406\u5c42\u5199\u5165\u6210\u529f\u6216\u8005\u4e2d\u9014\u67d0\u4e2a\u5206\u5757\u5904\u7406\u5931\u8d25，\u6570\u636e\u7ba1\u7406\u5c42\u5c06\u8be5\u4fe1\u606f\u8fd4\u56de\u7ed9\u7f51\u5173\u5c42，\u5982\u679c\u5931\u8d25\u7f51\u5173\u5c42\u76f4\u63a5\u8fd4\u56de\u7528\u6237\u5199\u5165\u5931\u8d25，\u5982\u679c\u6210\u529f\u5219\u5411\u5143\u6570\u636e\u7ba1\u7406\u5c42\u5199\u5165\u5143\u6570\u636e，\u5143\u6570\u636e\u7ba1\u7406\u5c42\u5199\u5165\u6210\u529f\u518d\u8fd4\u56de\u7ed9\u7f51\u5173，\u76f4\u5230\u8fd9\u65f6\u7f51\u5173\u5c42\u624d\u80fd\u8fd4\u56de\u7ed9\u7528\u6237\u8be5\u6587\u4ef6\u5199\u5165\u6210\u529f\u7684\u54cd\u5e94\u3002 \u6211\u4eec\u5c31\u4ece\u7f51\u5173\u5c42\u7684main\u51fd\u6570\u5f00\u59cb，\u8bb2\u8ff0\u7f51\u5173\u8fdb\u7a0b\u7684\u542f\u52a8\u548c\u8fd0\u884c\u673a\u5236：<\/p>\n

\u3010\u4ee3\u7801：reactor\/distribute_storage\/gateway\/gateway_main.cc\u3011<\/p>\n

int<\/span> main<\/span>(<\/span>)<\/span> {<\/span>
\n GWGlobalContext*<\/span> context =<\/span> new<\/span> GWGlobalContext<\/span>(<\/span>THREAD_NUM,<\/span> GATEWAY_REQUEST_HANDLER)<\/span>;<\/span>
\n Server<<\/span>GatewayRequestCB,<\/span> GWRequestDispatcher><\/span> server =<\/span>
\n Gateway<\/span><<\/span>GatewayRequestCB,<\/span> GWRequestDispatcher><\/span><\/span><\/span>(<\/span>8890<\/span>,<\/span> SUBLOOP_NUM,<\/span> context)<\/span>;<\/span>
\n server.<\/span>start<\/span>(<\/span>)<\/span>;<\/span>
\n return<\/span> 0<\/span>;<\/span>
\n}<\/span><\/p>\n

\u9996\u5148\u662f\u4e00\u4e2aGWGlobalContext\u7c7b，\u8fd9\u662f\u4e00\u4e2a\u57fa\u7840\u7c7b，\u5b58\u50a8\u6240\u6709\u7684\u7c7b\u53ef\u80fd\u90fd\u9700\u8981\u7684\u6570\u636e\u7ed3\u6784，\u4f8b\u5982\u5404\u4e2a\u8fdb\u7a0b\u7684ip\u548cport，\u7528\u4e8e\u5904\u7406\u5404\u79cd\u4efb\u52a1\u7684\u7ebf\u7a0b\u6c60，\u8fd9\u91cc\u7ebf\u7a0b\u6c60\u6709\u4e24\u4e2a，\u4e00\u4e2a\u662f\u63a5\u6536\u8bf7\u6c42\u7684request_handler，\u53e6\u4e00\u4e2a\u5219\u662f\u63a5\u6536\u5904\u7406\u8bf7\u6c42\u8fc7\u7a0b\u4e2d\u4ea7\u751f\u7684\u963b\u585e\u4efb\u52a1： \u3010\u4ee3\u7801：reactor\/distribute_storage\/common\/Context.h\u3011<\/p>\n

class<\/span> GlobalContext<\/span> {<\/span>
\npublic<\/span>:<\/span>
\n Address gateway_adr;<\/span>
\n Address data_mgr_adr;<\/span>
\n Address metadata_mgr_adr;<\/span>
\n int<\/span> data_shard_num;<\/span>
\n int<\/span> metadata_shard_num;<\/span>
\n ThreadPool*<\/span> thread_pool;<\/span>
\n ThreadPool*<\/span> request_handler;<\/span>
\n GlobalContext<\/span>(<\/span>)<\/span> {<\/span>}<\/span>
\n GlobalContext<\/span>(<\/span>int<\/span> thread_num,<\/span> int<\/span> handler_num)<\/span> :<\/span>
\n thread_pool<\/span>(<\/span>new<\/span> ThreadPool<\/span>(<\/span>thread_num)<\/span>)<\/span>,<\/span>
\n request_handler<\/span>(<\/span>new<\/span> ThreadPool<\/span>(<\/span>handler_num)<\/span>)<\/span>,<\/span>
\n data_shard_num<\/span>(<\/span>DATA_SHARDS)<\/span>,<\/span>
\n metadata_shard_num<\/span>(<\/span>META_DATA_SHARDS)<\/span>,<\/span>
\n gateway_adr<\/span>(<\/span>Address<\/span>(<\/span>std::<\/span>string<\/span>(<\/span>GATEWAY_IP)<\/span>,<\/span> GATEWAY_PORT)<\/span>)<\/span>,<\/span>
\n data_mgr_adr<\/span>(<\/span>Address<\/span>(<\/span>std::<\/span>string<\/span>(<\/span>DATA_MGR_IP)<\/span>,<\/span> DATA_MGR_PORT)<\/span>)<\/span>,<\/span>
\n metadata_mgr_adr<\/span>(<\/span>Address<\/span>(<\/span>std::<\/span>string<\/span>(<\/span>METADATA_MGR_IP)<\/span>,<\/span> METADATA_MGR_PORT)<\/span>)<\/span> {<\/span>}<\/span>
\n}<\/span>;<\/span><\/p>\n

\u63a5\u4e0b\u6765\u5c31\u8981\u542f\u52a8server\u4e86，Server\u662f\u4e00\u4e2a\u6a21\u677f\u7c7b，\u7528\u4e8e\u5b9e\u73b0\u4e0d\u540c\u7684RequestCB\u548cRequestDispatcher，\u8fd9\u4e24\u4e2a\u7c7b\u7684\u4f5c\u7528\u5206\u522b\u662f\u4ec0\u4e48\u5462？ RequestDispatcher\u6bd4\u8f83\u597d\u7406\u89e3，\u5b57\u9762\u610f\u601d\u7406\u89e3\u5c31\u662f\u5206\u53d1\u8bf7\u6c42，\u56e0\u4e3a\u6709\u4e0d\u540c\u7c7b\u578b\u7684\u8bf7\u6c42，PUT\u3001GET，POST\u7b49\u7b49，Dispatcher\u5c31\u662f\u4e3a\u4e86\u7ed9\u8fd9\u4e9b\u8bf7\u6c42\u914d\u4e00\u4e2a\u5bf9\u5e94\u7684handler，\u4ee5\u4e0b\u7684\u5185\u5bb9\u5728\u591a\u7ebf\u7a0b\u670d\u52a1\u5668\u5206\u6790\u2014\u2014Reactor\u7ebf\u7a0b\u6a21\u578b\u548c\u6027\u80fd\u5206\u6790(\u4e09)\u76843.7.1\u8282\u6709\u8be6\u7ec6\u7684\u8bb2\u8ff0，\u8fd9\u91cc\u4ece\u542f\u52a8server\u5f00\u59cb\u7b80\u5355\u7684\u8fc7\u4e00\u4e0b： \u3010\u4ee3\u7801：reactor\/distribute_storage\/gateway\/Gateway.h\u3011<\/p>\n

RequestHandler*<\/span> GWRequestDispatcher<\/span>::<\/span>get_handler<\/span>(<\/span>ReqMethod method,<\/span> std::<\/span>shared_ptr<<\/span>RawRequest><\/span> request)<\/span> {<\/span>
\n if<\/span> (<\/span>method ==<\/span> ReqMethod::<\/span>TEST)<\/span>
\n return<\/span> new<\/span> TestRequestHandler<\/span>(<\/span>this<\/span>,<\/span> request)<\/span>;<\/span>
\n if<\/span> (<\/span>method ==<\/span> ReqMethod::<\/span>PUT)<\/span>
\n return<\/span> new<\/span> PutRequestHandler<\/span>(<\/span>this<\/span>,<\/span> request)<\/span>;<\/span>
\n if<\/span> (<\/span>method ==<\/span> ReqMethod::<\/span>POST)<\/span>
\n return<\/span> new<\/span> PostRequestHandler<\/span>(<\/span>this<\/span>,<\/span> request)<\/span>;<\/span>
\n \/\/ TODO implement other request methods<\/span>
\n return<\/span> nullptr<\/span>;<\/span>
\n}<\/span><\/p>\n

\u800c\u9488\u5bf9\u4e0d\u540c\u7c7b\u578b\u7684\u8bf7\u6c42，\u7ec6\u5206\u4e00\u4e0b\u53ef\u80fd\u6709\u4e0d\u540c\u7684\u64cd\u4f5c，\u4f8b\u5982GET\u8bf7\u6c42\u4e0b\u53ef\u4ee5get_data\u6216\u8005get_metadata，\u5206\u522b\u662f\u83b7\u53d6\u6570\u636e\u548c\u5143\u6570\u636e，\u56e0\u6b64\u53c8\u9700\u8981handler\u533a\u5206\u4e00\u4e0b\u5177\u4f53\u7684Op： \u3010\u4ee3\u7801：reactor\/distribute_storage\/gateway\/Gateway.cc\u3011<\/p>\n

class<\/span> TestRequestHandler<\/span> :<\/span> public<\/span> GWRequestHandler<\/span><\/span> {<\/span>
\npublic<\/span>:<\/span>
\n TestRequestHandler<\/span>(<\/span>RequestDispatcher*<\/span> req_disp,<\/span> std::<\/span>shared_ptr<<\/span>RawRequest><\/span> req)<\/span> :<\/span> GWRequestHandler<\/span>(<\/span>req_disp,<\/span> req)<\/span> {<\/span>}<\/span>
\n GatewayOP*<\/span> get_op<\/span>(<\/span>std::<\/span>map<<\/span>std::<\/span>string,<\/span> std::<\/span>string><\/span>*<\/span> header_data)<\/span> override<\/span> {<\/span>
\n .<\/span>.<\/span>.<\/span><\/p>\n

if<\/span> (<\/span>op_type ==<\/span> "ping_gw"<\/span>)<\/span> {<\/span>
\n return<\/span> new<\/span> TestPingGatewayOp<\/span>(<\/span>dispatcher-><\/span>_ctx,<\/span> this<\/span>)<\/span>;<\/span>
\n }<\/span>
\n .<\/span>.<\/span>.<\/span>
\n }<\/span>
\n void<\/span> send_response<\/span>(<\/span>)<\/span> override<\/span>;<\/span>
\n}<\/span>;<\/span><\/p>\n

\u4f8b\u5982\u4e0a\u9762\u7684Op\u5c31\u662f\u7ea6\u5b9a\u5ba2\u6237\u7aef\u8bf7\u6c42\u4e2d\u5e26\u6709\u300eping_gw\u300f\u5c31\u8868\u793aTEST\u8bf7\u6c42\u7c7b\u578b\u4e0b\u7684\u68c0\u9a8c\u7f51\u5173\u53ef\u7528\u6027\u7684Op，\u4e0a\u9762\u8fd9\u4e9b\u90fd\u662f\u9488\u5bf9\u7f51\u5173\u7279\u6709\u7684\u6570\u636e\u7ed3\u6784，\u5176\u57fa\u7c7b\u90fd\u6765\u81ea\u4e8ereactor\/distribute_storage\/common\/server.h\u4e2d\u7684Op\u3001RequestHandler\u3001RequestDispatcher\u7c7b\u3002<\/p>\n

\u56de\u5230RequestCB，\u8fd9\u4e2a\u6570\u636e\u7ed3\u6784\u89e3\u91ca\u8d77\u6765\u6709\u70b9\u590d\u6742，\u4f46\u5176\u5b9e\u5c31\u662f\u4e4b\u524d\u63d0\u5230\u7684EventLoop\u4e2d\u7684EventCallback\u7c7b\u7684\u5b50\u7c7b，\u4e5f\u5c31\u662f\u5f53socket\u53d1\u751f\u53ef\u8bfb\u4e8b\u4ef6（\u5373\u63a5\u6536\u5230\u6765\u81ea\u5ba2\u6237\u7aef\u6570\u636e）\u65f6\u6267\u884c\u7684\u56de\u8c03\u51fd\u6570：<\/p>\n

class<\/span> RequestCB<\/span> :<\/span> public<\/span> EventCallback<\/span><\/span> {<\/span>
\nprotected<\/span>:<\/span>
\n int<\/span> socket_fd;<\/span>
\n RequestDispatcher*<\/span> _dispatcher;<\/span>
\npublic<\/span>:<\/span>
\n .<\/span>.<\/span>.<\/span>
\n virtual<\/span> void<\/span> handle_request<\/span>(<\/span>)<\/span> {<\/span>}<\/span>;<\/span><\/p>\n

void<\/span> do_callback<\/span>(<\/span>)<\/span> override<\/span> {<\/span>
\n _loop-><\/span>remove_poll<\/span>(<\/span>socket_fd)<\/span>;<\/span>
\n handle_request<\/span>(<\/span>)<\/span>;<\/span>
\n _loop-><\/span>remove_event_from_map<\/span>(<\/span>socket_fd)<\/span>;<\/span>
\n }<\/span>
\n}<\/span>;<\/span><\/p>\n

\u4e5f\u5c31\u662f\u8bf4\u5f53socket\u53d1\u751f\u53ef\u8bfb\u4e8b\u4ef6\u7684\u65f6\u5019，\u4f1a\u8c03\u7528do_callback()\u51fd\u6570，\u6700\u7ec8\u5b9e\u73b0\u8bf7\u6c42\u903b\u8f91\u7684\u5219\u662fhandle_request()\u51fd\u6570，\u4e5f\u5c31\u662f\u8bf4，\u4e0d\u540c\u7684server\u53ea\u9700\u8981\u91cd\u5199handle_request()\u51fd\u6570\u5373\u53ef，\u4e3a\u4ec0\u4e48\u5728\u6267\u884chandler_request()\u51fd\u6570\u4e4b\u524d\u8981\u6267\u884c_loop->remove_poll(socket_fd)\u5462？ \u90a3\u662f\u56e0\u4e3a\u6765\u81ea\u5ba2\u6237\u7aef\u7684\u6570\u636e\u53ef\u80fd\u662f\u6e90\u6e90\u4e0d\u65ad\u7684，\u90a3\u4e48epoll\u76d1\u542c\u7684\u65f6\u5019\u5c31\u4f1a\u4e00\u76f4\u6709\u53ef\u8bfb\u4e8b\u4ef6，\u5bfc\u81f4\u5176\u4ed6\u7684socket\u4e0a\u4f20\u6765\u7684\u6570\u636e\u5f97\u4e0d\u5230\u5904\u7406\u3002<\/p>\n

\u5728\u770b\u7f51\u5173\u5b9e\u73b0\u7684handler_request()\u51fd\u6570\u4e4b\u524d，\u6211\u4eec\u63a5\u7740\u6765Server\u662f\u5982\u4f55\u542f\u52a8\u7684：<\/p>\n

template<\/span><<\/span>typename<\/span> CB<\/span>,<\/span> typename<\/span> DISPATCH<\/span>><\/span>
\nclass<\/span> Server<\/span> {<\/span>
\n.<\/span>.<\/span>.<\/span><\/p>\n

void<\/span> start<\/span>(<\/span>)<\/span> {<\/span>
\n main_loop =<\/span> new<\/span> EventLoop<\/span>(<\/span>true<\/span>,<\/span> sub_loop_count)<\/span>;<\/span><\/p>\n

listen_sock =<\/span> socket<\/span>(<\/span>AF_INET,<\/span> SOCK_STREAM,<\/span> 0<\/span>)<\/span>;<\/span>
\n .<\/span>.<\/span>.<\/span><\/p>\n

_dispatcher =<\/span> new<\/span> DISPATCH<\/span>(<\/span>ctx)<\/span>;<\/span>
\n EventRef main_ev =<\/span> std::<\/span>make_shared<\/span><<\/span>Event><\/span><\/span><\/span>(<\/span>listen_sock,<\/span> new<\/span> SocketEventCB<\/span><<\/span>CB><\/span><\/span><\/span>(<\/span>listen_sock,<\/span> main_loop,<\/span> _dispatcher)<\/span>)<\/span>;<\/span>
\n main_loop-><\/span>add_event<\/span>(<\/span>listen_sock,<\/span> main_ev,<\/span> false<\/span>,<\/span> false<\/span>)<\/span>;<\/span><\/p>\n

std::<\/span>vector<<\/span>EventLoop*<\/span>><\/span>&<\/span> subloops =<\/span> main_loop-><\/span>get_subloop<\/span>(<\/span>)<\/span>;<\/span>
\n for<\/span>(<\/span>int<\/span> i =<\/span> 0<\/span>;<\/span> i <<\/span> sub_loop_count;<\/span> ++<\/span>i)<\/span> {<\/span>
\n subloops[<\/span>i]<\/span>-><\/span>start<\/span>(<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

main_loop-><\/span>start<\/span>(<\/span>)<\/span>;<\/span>
\n }<\/span>
\n}<\/span>;<\/span><\/p>\n

\u6211\u4eec\u5c06\u591a\u7ebf\u7a0b\u670d\u52a1\u5668\u5206\u6790\u2014\u2014Reactor\u7ebf\u7a0b\u6a21\u578b\u548c\u6027\u80fd\u5206\u6790(\u4e09)\u76843.7.1\u8282\u4e2d\u7684\u5185\u5bb9\u7528\u56fe\u6765\u8868\u793a，\u52a0\u6df1\u4e00\u4e0b\u7406\u89e3： \"\u8bf7\u6dfb\u52a0\u56fe\u7247\u63cf\u8ff0\" \u5728server\u542f\u52a8\u7684\u65f6\u5019，\u5148\u542f\u52a8\u4e00\u4e2amain loop\u548c\u591a\u4e2asub loop，main loop\u53ea\u76d1\u542c\u4e00\u4e2asocket，\u5c31\u662f\u8d1f\u8d23accept\u5ba2\u6237\u7aef\u8bf7\u6c42\u7684\u90a3\u4e2asocket，\u4e0e\u8fd9\u4e2asocket\u7ed1\u5b9a\u7684\u56de\u8c03\u7c7b\u5219\u662fSocketEventCB，\u5b83\u7684\u804c\u8d23\u662f\u5c06accept\u4ea7\u751f\u7684socket\u79fb\u4ea4\u7ed9sub loop，\u7531sub loop\u8d1f\u8d23\u76d1\u542c\u5ba2\u6237\u7aef\u6765\u81ea\u5ba2\u6237\u7aef\u8bf7\u6c42\u7684\u6570\u636e；\u800c\u8ddf\u8fd9\u4e2asocket\u7ed1\u5b9a\u7684\u56de\u8c03\u7c7b\u5c31\u662fRequestCB，\u5f53sub loop\u76d1\u542c\u5230\u53ef\u8bfb\u4e8b\u4ef6\u7684\u65f6\u5019，\u5c31\u5c06\u53ef\u8bfb\u7684socket\u62ff\u51fa\u6765\u6309\u987a\u5e8f\u6267\u884c\u5b83\u4eec\u7684\u56de\u8c03\u51fd\u6570，\u56de\u8c03\u51fd\u6570\u6700\u7ec8\u6267\u884c\u7684\u5c31\u662fhandle_request()，\u4e5f\u5c31\u662f\u8bf4，\u6240\u6709\u7684\u4e1a\u52a1\u903b\u8f91\u90fd\u5728handle_request()\u51fd\u6570\u4e2d\u5b9e\u73b0\u3002<\/p>\n

4.2 \u4e0a\u4f20\u6587\u4ef6\u903b\u8f91\u7684\u5b9e\u73b0<\/h3>\n

\u63a5\u4e0b\u6765\u5c31\u662f\u9488\u5bf9handle_request()\u51fd\u6570\u7684\u5b9e\u73b0：<\/p>\n

void<\/span> GatewayRequestCB<\/span>::<\/span>handle_request<\/span>(<\/span>)<\/span> {<\/span>
\n auto<\/span> request =<\/span> std::<\/span>make_shared<\/span><<\/span>RawRequest><\/span><\/span><\/span>(<\/span>socket_fd)<\/span>;<\/span>
\n int<\/span> res =<\/span> request-><\/span>get_header<\/span>(<\/span>)<\/span>;<\/span>
\n .<\/span>.<\/span>.<\/span><\/p>\n

RequestHandler*<\/span> handler =<\/span> _dispatcher-><\/span>get_handler<\/span>(<\/span>request-><\/span>header.<\/span>method,<\/span> request)<\/span>;<\/span>
\n .<\/span>.<\/span>.<\/span><\/p>\n

Op*<\/span> op =<\/span> handler-><\/span>get_op<\/span>(<\/span>&<\/span>(<\/span>request-><\/span>header.<\/span>self_define)<\/span>)<\/span>;<\/span>
\n .<\/span>.<\/span>.<\/span>
\n op-><\/span>req =<\/span> request;<\/span><\/p>\n

std::<\/span>shared_ptr<<\/span>Op><\/span> req_op<\/span>(<\/span>op)<\/span>;<\/span>
\n std::<\/span>shared_ptr<<\/span>RequestHandler><\/span> req_handler<\/span>(<\/span>handler)<\/span>;<\/span><\/p>\n

_dispatcher-><\/span>_ctx-><\/span>request_handler-><\/span>enqueue_task<\/span>(<\/span>new<\/span> RequestTask<\/span>(<\/span>req_op,<\/span> req_handler)<\/span>)<\/span>;<\/span>
\n}<\/span><\/p>\n

\u6574\u4e2a\u51fd\u6570\u5e76\u4e0d\u590d\u6742，\u5c31\u662f\u6309\u7167\u6839\u636e\u8bf7\u6c42\u83b7\u53d6RequestHandler\u548cOp\u7684\u8fc7\u7a0b，\u5e76\u4e14\u5728\u6700\u540e\u5c06\u4e8c\u8005\u5c01\u88c5\u5728\u7ebf\u7a0b\u6c60\u7684Task\u4e2d\u52a0\u5165\u7ebf\u7a0b\u6c60，\u7531Worker\u7ebf\u7a0b\u6267\u884c\u903b\u8f91\u548c\u54cd\u5e94：<\/p>\n

class<\/span> RequestTask<\/span> :<\/span> public<\/span> ThreadPool::<\/span>Task<\/span><\/span> {<\/span>
\nprivate<\/span>:<\/span>
\n std::<\/span>shared_ptr<<\/span>Op><\/span> req_op;<\/span>
\n std::<\/span>shared_ptr<<\/span>RequestHandler><\/span> req_handler;<\/span>
\npublic<\/span>:<\/span>
\n .<\/span>.<\/span>.<\/span><\/p>\n

void<\/span> do_task<\/span>(<\/span>)<\/span> override<\/span> {<\/span>
\n req_op-><\/span>execute<\/span>(<\/span>)<\/span>;<\/span>
\n req_handler-><\/span>send_response<\/span>(<\/span>)<\/span>;<\/span>
\n }<\/span>
\n}<\/span>;<\/span><\/p>\n

\u6709\u4e00\u70b9\u503c\u5f97\u6ce8\u610f，\u5728\u591a\u7ebf\u7a0b\u670d\u52a1\u5668\u5206\u6790\u2014\u2014Reactor\u7ebf\u7a0b\u6a21\u578b\u548c\u6027\u80fd\u5206\u6790(\u4e09)\u76843.7.1\u4e2dGatewayRequestCB::handle_request()\u51fd\u6570\u6700\u540e\u7684\u90e8\u5206\u662f\u8fd9\u6837\u7684：<\/p>\n

void<\/span> GatewayRequestCB<\/span>::<\/span>handle_request<\/span>(<\/span>)<\/span> {<\/span>
\n .<\/span>.<\/span>.<\/span>
\n op-><\/span>execute<\/span>(<\/span>)<\/span>;<\/span> \/\/ \u6267\u884c\u903b\u8f91<\/span><\/p>\n

handler-><\/span>send_response<\/span>(<\/span>)<\/span>;<\/span> \/\/ \u8fd4\u56de\u54cd\u5e94<\/span>
\n}<\/span><\/p>\n

\u4e3a\u4ec0\u4e48\u8981\u6539\u6210\u7ebf\u7a0b\u6c60\u6765\u6267\u884c\u5904\u7406\u8bf7\u6c42\u7684\u903b\u8f91\u548c\u54cd\u5e94？ \u9996\u5148，EventLoop\u9488\u5bf9EventCallBack\u7684\u6267\u884c\u4e00\u76f4\u662f\u5728\u4e00\u4e2a\u7ebf\u7a0b\u4e2d\u8fdb\u884c\u7684：<\/p>\n

void<\/span> EventLoop<\/span>::<\/span>handle_events<\/span>(<\/span>)<\/span> {<\/span>
\n while<\/span> (<\/span>running)<\/span> {<\/span>
\n \/* execute events with fd *\/<\/span>
\n int<\/span> nfds =<\/span> poller.<\/span>wait_event<\/span>(<\/span>)<\/span>;<\/span>
\n .<\/span>.<\/span>.<\/span><\/p>\n

for<\/span> (<\/span>int<\/span> i =<\/span> 0<\/span>;<\/span> i <<\/span> nfds;<\/span> ++<\/span>i)<\/span> {<\/span>
\n int<\/span> fd =<\/span> poller.<\/span>events[<\/span>i]<\/span>.<\/span>data.<\/span>fd;<\/span>
\n if<\/span> (<\/span>event_map.<\/span>find<\/span>(<\/span>fd)<\/span> !=<\/span> event_map.<\/span>end<\/span>(<\/span>)<\/span>)<\/span> {<\/span>
\n EventRef ev =<\/span> event_map[<\/span>fd]<\/span>;<\/span>
\n ev-><\/span>callback<\/span>(<\/span>)<\/span>;<\/span>
\n }<\/span>
\n }<\/span><\/p>\n

\/* execute none fd events *\/<\/span>
\n .<\/span>.<\/span>.<\/span>
\n }<\/span><\/p>\n

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

ev->callback()\u7684\u6267\u884c\u662f\u901a\u8fc7\u904d\u5386socket\u7ed1\u5b9a\u7684\u56de\u8c03\u51fd\u6570，\u56e0\u6b64\u6267\u884c\u56de\u8c03\u51fd\u6570\u7684\u8fc7\u7a0b\u4e2d\u4e0d\u80fd\u51fa\u73b0\u963b\u585e，\u5426\u5219\u4f1a\u5f71\u54cd\u540e\u9762\u56de\u8c03\u51fd\u6570\u7684\u6267\u884c\u3002 \u63a5\u4e0b\u6765\u770b\u6587\u4ef6\u4e0a\u4f20\u7684\u6267\u884c，\u9996\u5148\u5904\u7406PUT\u8bf7\u6c42\u7684\u662fPutRequestHandler，\u4e0a\u4f20\u6587\u4ef6\u7684Op\u5219\u662fPutFileOp，\u771f\u6b63\u7684\u5904\u7406\u903b\u8f91\u662fPutFileOp::execute()，\u9996\u5148\u68c0\u67e5\u4e00\u4e9b\u7528\u6237\u7684\u8f93\u5165，\u5305\u62ec\u6587\u4ef6\u540d\u3001\u6587\u4ef6\u5927\u5c0f\u7b49\u7b49：<\/p>\n

void<\/span> PutFileOp<\/span>::<\/span>execute<\/span>(<\/span>)<\/span> {<\/span>
\n \/\/ get file name and size from header<\/span>
\n int<\/span> ret;<\/span>
\n auto<\/span>&<\/span> header_data =<\/span> req-><\/span>header.<\/span>self_define;<\/span>
\n if<\/span> (<\/span>header_data.<\/span>find<\/span>(<\/span>"filename"<\/span>)<\/span> ==<\/span> header_data.<\/span>end<\/span>(<\/span>)<\/span> ||<\/span>
\n header_data.<\/span>find<\/span>(<\/span>"filesize"<\/span>)<\/span> ==<\/span> header_data.<\/span>end<\/span>(<\/span>)<\/span>)<\/span> {<\/span>
\n _handler-><\/span>set_response_code<\/span>(<\/span>BAD_REQUEST)<\/span>;<\/span>
\n _handler-><\/span>set_response_data<\/span>(<\/span>
\n std::<\/span>map<<\/span>std::<\/span>string,<\/span> std::<\/span>string><\/span>{<\/span>{<\/span>"result"<\/span>,<\/span>
\n "lack of file name or file size"<\/span>}<\/span>}<\/span>
\n )<\/span>;<\/span>
\n return<\/span>;<\/span>
\n }<\/span><\/p>\n

int<\/span> file_size;<\/span>
\n if<\/span> (<\/span>!<\/span>str_to_int<\/span>(<\/span>header_data[<\/span>"filesize"<\/span>]<\/span>,<\/span> file_size)<\/span>)<\/span> {<\/span>
\n _handler-><\/span>set_response_code<\/span>(<\/span>BAD_REQUEST)<\/span>;<\/span>
\n return<\/span>;<\/span>
\n }<\/span><\/p>\n

.<\/span>.<\/span>.<\/span>
\n}<\/span><\/p>\n

\u63a5\u4e0b\u6765\u5219\u662f\u901a\u8fc7socket\u8bfb\u53d6\u7528\u6237\u53d1\u6765\u7684\u6587\u4ef6\u7684\u6570\u636e\u90e8\u5206：<\/p>\n

while<\/span> (<\/span>total_read <<\/span> file_size)<\/span> {<\/span>
\n ret =<\/span> req-><\/span>get_raw_data<\/span>(<\/span>&<\/span>read_str,<\/span> timeout)<\/span>;<\/span>
\n .<\/span>.<\/span>.<\/span><\/p>\n

\/\/ send the chunk read from socket to data manager<\/span>
\n send_data.<\/span>append<\/span>(<\/span>read_str)<\/span>;<\/span>
\n if<\/span> (<\/span>send_data.<\/span>size<\/span>(<\/span>)<\/span> >=<\/span> DATA_FLUSH_SIZE ||<\/span> file_size –<\/span> offset <=<\/span> DATA_FLUSH_SIZE)<\/span> {<\/span>
\n if<\/span> (<\/span>offset ==<\/span> 0<\/span>)<\/span> {<\/span>
\n ret =<\/span> client-><\/span>flush_data_chunk<\/span>(<\/span>offset,<\/span> header_data[<\/span>"filename"<\/span>]<\/span>,<\/span> file_size,<\/span> send_data,<\/span> req_id,<\/span> false<\/span>)<\/span>;<\/span>
\n .<\/span>.<\/span>.<\/span>
\n }<\/span> else<\/span> {<\/span>
\n PutFileOp::<\/span>PutDataChunkTask*<\/span> task =<\/span> new<\/span> PutFileOp<\/span>::<\/span>PutDataChunkTask<\/span>(<\/span>
\n context,<\/span>
\n client,<\/span>
\n offset,<\/span>
\n send_data,<\/span>
\n header_data[<\/span>"filename"<\/span>]<\/span>,<\/span>
\n req_id,<\/span>
\n file_size
\n )<\/span>;<\/span>
\n context-><\/span>thread_pool-><\/span>enqueue_task<\/span>(<\/span>task)<\/span>;<\/span>
\n }<\/span><\/p>\n

.<\/span>.<\/span>.<\/span>
\n }<\/span><\/p>\n

\u5728\u5ba2\u6237\u7aef\u4e0a\u4f20\u6587\u4ef6\u7684\u65f6\u5019，\u662f\u5c06\u6587\u4ef6\u8bfb\u4e00\u6bb5，\u4e0a\u4f20\u4e00\u6bb5，\u6574\u4e2a\u6587\u4ef6\u7684\u5206\u6bb5\u662f\u6309\u7167\u987a\u5e8f\u4f20\u8fc7\u6765\u7684，tcp\u5c42\u4f1a\u4fdd\u8bc1\u4f20\u9012\u7684\u987a\u5e8f\u4e0d\u4f1a\u4e71\u6389： \u3010\u4ee3\u7801：reactor\/distribute_storage\/client\/client_interface.cc\u3011<\/p>\n

int<\/span> GatewayClient<\/span>::<\/span>upload_file<\/span>(<\/span>std::<\/span>string file_path,<\/span> std::<\/span>string file_name)<\/span> {<\/span>
\n .<\/span>.<\/span>.<\/span><\/p>\n

while<\/span> (<\/span>file)<\/span> {<\/span>
\n .<\/span>.<\/span>.<\/span>
\n buffer[<\/span>CHUNK_SIZE]<\/span> =<\/span> '\\\\0'<\/span>;<\/span>
\n std::<\/span>streamsize bytesRead =<\/span> file.<\/span>gcount<\/span>(<\/span>)<\/span>;<\/span>
\n if<\/span> (<\/span>bytesRead ><\/span> 0<\/span>)<\/span> {<\/span>
\n \/\/ send to gateway<\/span>
\n std::<\/span>string to_send =<\/span> std::<\/span>string<\/span>(<\/span>buffer)<\/span>;<\/span>
\n ret =<\/span> request.<\/span>send_raw_body<\/span>(<\/span>to_send)<\/span>;<\/span>
\n if<\/span> (<\/span>ret <<\/span> 0<\/span>)<\/span>
\n break<\/span>;<\/span>
\n }<\/span>
\n }<\/span>
\n .<\/span>.<\/span>.<\/span>
\n}<\/span><\/p>\n

\u800c\u7f51\u5173\u5c42\u4e0b\u53d1\u7ed9\u6570\u636e\u7ba1\u7406\u5c42\u7684\u4e4b\u540e，\u91c7\u7528\u591a\u7ebf\u7a0b\u7684\u6a21\u5f0f\u5199\u5165\u540c\u4e00\u4e2a\u6587\u4ef6，\u56e0\u6b64\u5fc5\u987b\u91c7\u7528offset + length\u7684\u5f62\u5f0f\u8bb0\u5f55\u6bcf\u4e00\u4e2a\u5206\u6bb5，\u56e0\u4e3a\u7f51\u5173\u5c42\u5e76\u4e0d\u662f\u9488\u5bf9\u540c\u4e00\u4e2asocket\u5199\u5165\u6240\u6709\u5206\u6bb5，\u4e5f\u5c31\u4e0d\u80fd\u4fdd\u8bc1\u5206\u6bb5\u6309\u7167\u987a\u5e8f\u62b5\u8fbe\u6570\u636e\u7ba1\u7406\u5c42\u3002\u800c\u5c06\u8bfb\u5230\u7684\u6570\u636e\u4e0b\u5237\u7684\u51fd\u6570\u5c31\u662fManagerClient::flush_data_chunk()：<\/p>\n

int<\/span> ManagerClient<\/span>::<\/span>flush_data_chunk<\/span>(<\/span>off_t offset,<\/span> std::<\/span>string filename,<\/span> int<\/span> filesize,<\/span>
\n std::<\/span>string&<\/span> data,<\/span> std::<\/span>string req_id,<\/span> bool<\/span> asio)<\/span> {<\/span>
\n .<\/span>.<\/span>.<\/span><\/p>\n

if<\/span> (<\/span>asio)<\/span>
\n header[<\/span>"io_type"<\/span>]<\/span> =<\/span> "aio"<\/span>;<\/span>
\n else<\/span>
\n header[<\/span>"io_type"<\/span>]<\/span> =<\/span> "bio"<\/span>;<\/span>
\n request.<\/span>set_request_header<\/span>(<\/span>header)<\/span>;<\/span>
\n int<\/span> ret =<\/span> request.<\/span>send_header<\/span>(<\/span>"PUT"<\/span>,<\/span> data.<\/span>size<\/span>(<\/span>)<\/span>)<\/span>;<\/span>
\n .<\/span>.<\/span>.<\/span>
\n}<\/span><\/p>\n

\u8fd9\u4e2a\u51fd\u6570\u672c\u8eab\u6ca1\u4ec0\u4e48\u597d\u8bf4\u7684，\u53ea\u6709\u4e00\u4e2aasio\u53c2\u6570\u503c\u5f97\u601d\u8003\u4e00\u4e0b，\u8fd9\u4e2a\u53c2\u6570\u7684\u4f5c\u7528\u662f\u51b3\u5b9a\u4e0b\u5237\u8fd9\u4e00\u6bb5\u6570\u636e\u662f\u540c\u6b65\u7684\u8fd8\u662f\u5f02\u6b65\u7684，\u4e3a\u4ec0\u4e48\u8981\u8bbe\u7f6e\u8fd9\u6837\u4e00\u4e2a\u53c2\u6570？ \u9996\u5148\u6765\u60f3，\u4ece\u7f51\u5173\u5c42\u4e0b\u5237\u7684\u6570\u636e\u5206\u6bb5，\u9700\u4e0d\u9700\u8981\u7b49\u5f85\u6570\u636e\u7ba1\u7406\u5c42\u5199\u5165\u5b8c\u6210\u518d\u5199\u4e0b\u4e00\u6bb5？\u663e\u7136\u662f\u4e0d\u9700\u8981\u7684，\u90a3\u8fd9\u6837\u591a\u7ebf\u7a0b\u7684\u5199\u5165\u5c31\u5931\u53bb\u4e86\u610f\u4e49，\u4e5f\u5c31\u662f\u8bf4\u6bcf\u4e00\u6bb5\u7684\u5199\u5165\u5bf9\u4e8e\u7f51\u5173\u5c42\u6765\u8bf4\u90fd\u662f\u540c\u6b65\u7684，\u5199\u5165\u7684\u603b\u65f6\u95f4\u4e3a： <\/p>\n

T <\/p>\n

i <\/p>\n

m <\/p>\n

e <\/p>\n

t <\/p>\n

o <\/p>\n

t <\/p>\n

a <\/p>\n

l <\/p>\n

= <\/p>\n

\u5206\u5757\u6570 <\/p>\n

\u00d7 <\/p>\n

( <\/p>\n

\u4e0b\u5237\u5230\u6570\u636e\u7ba1\u7406\u5c42 <\/p>\n

+ <\/p>\n

\u6570\u636e\u7ba1\u7406\u5c42\u5199\u5165 <\/p>\n

+ <\/p>\n

\u6570\u636e\u7ba1\u7406\u5c42\u8fd4\u56de\u54cd\u5e94 <\/p>\n

) <\/p>\n

Time_{total} = \u5206\u5757\u6570 \\\\times (\u4e0b\u5237\u5230\u6570\u636e\u7ba1\u7406\u5c42 + \u6570\u636e\u7ba1\u7406\u5c42\u5199\u5165 + \u6570\u636e\u7ba1\u7406\u5c42\u8fd4\u56de\u54cd\u5e94) <\/p>\n

<\/span><\/span>T<\/span>im<\/span>e<\/span><\/span>t<\/span>o<\/span>t<\/span>a<\/span>l<\/span><\/span><\/span><\/span><\/span>\u200b<\/span><\/span><\/span><\/span><\/span><\/span><\/span><\/span><\/span>=<\/span><\/span><\/span><\/span>\u5206\u5757\u6570<\/span><\/span>\u00d7<\/span><\/span><\/span><\/span>(<\/span>\u4e0b\u5237\u5230\u6570\u636e\u7ba1\u7406\u5c42<\/span><\/span>+<\/span><\/span><\/span><\/span>\u6570\u636e\u7ba1\u7406\u5c42\u5199\u5165<\/span><\/span>+<\/span><\/span><\/span><\/span>\u6570\u636e\u7ba1\u7406\u5c42\u8fd4\u56de\u54cd\u5e94<\/span>)<\/span><\/span><\/span><\/span><\/span><\/span> \u8fd9\u4e0e\u63a5\u6536\u5206\u5757\u4f9d\u6b21\u4e0b\u53d1\u6ca1\u6709\u4efb\u4f55\u533a\u522b，\u56e0\u6b64\u9700\u8981\u5c06\u4e0b\u5237\u7684\u8bf7\u6c42\u6539\u4e3a\u5f02\u6b65，\u5373\u6570\u636e\u7ba1\u7406\u5c42\u63a5\u6536\u5230\u4e0b\u5237\u6570\u636e\u7684\u65f6\u5019\u53ea\u662f\u8fd4\u56de\u7ed9\u7f51\u5173\u5c42：\u300e\u6211\u63a5\u6536\u5230\u4e86\u4f60\u4e0b\u53d1\u7684\u6570\u636e\u300f，\u800c\u4e0d\u662f\u8fd4\u56de\u5199\u5165\u6210\u529f\u6216\u8005\u5931\u8d25\u7684\u54cd\u5e94，\u800c\u5f53\u6700\u540e\u4e00\u4e2a\u5206\u5757\u5199\u5165\u6210\u529f\u7684\u65f6\u5019\u6216\u8005\u4e2d\u9014\u67d0\u4e2a\u5206\u5757\u5199\u5165\u5931\u8d25，\u518d\u7ed9\u7f51\u5173\u5c42\u53d1\u4e00\u4e2a\u8bf7\u6c42\u544a\u77e5\u8fd9\u4e2a\u6587\u4ef6\u7684\u5199\u5165\u7ed3\u679c： \u3010\u4ee3\u7801reactor\/data_manager\/Datamanager.cc\u3011<\/p>\n

void<\/span> PutDataChunkOP<\/span>::<\/span>execute<\/span>(<\/span>)<\/span> {<\/span>
\n if<\/span> (<\/span>header_data.<\/span>find<\/span>(<\/span>"io_type"<\/span>)<\/span> !=<\/span> header_data.<\/span>end<\/span>(<\/span>)<\/span> &&<\/span> header_data[<\/span>"io_type"<\/span>]<\/span> ==<\/span> "aio"<\/span>)<\/span> {<\/span>
\n \/\/ send the write_data_by_offset to threadpool<\/span>
\n DataMgrOP::<\/span>AsyncWriteChunk*<\/span> task =<\/span> new<\/span> DataMgrOP<\/span>::<\/span>AsyncWriteChunk<\/span>(<\/span>context,<\/span> header_data[<\/span>"req-id"<\/span>]<\/span>,<\/span> chunk)<\/span>;<\/span>
\n context-><\/span>thread_pool-><\/span>enqueue_task<\/span>(<\/span>task)<\/span>;<\/span>
\n _handler-><\/span>set_response_code<\/span>(<\/span>REQ_RECEIVED)<\/span>;<\/span>
\n }<\/span> else<\/span> if<\/span> (<\/span>header_data.<\/span>find<\/span>(<\/span>"io_type"<\/span>)<\/span> !=<\/span> header_data.<\/span>end<\/span>(<\/span>)<\/span> &&<\/span> header_data[<\/span>"io_type"<\/span>]<\/span> ==<\/span> "bio"<\/span>)<\/span> {<\/span>
\n context-><\/span>register_req<\/span>(<\/span>header_data[<\/span>"req-id"<\/span>]<\/span>,<\/span> header_data[<\/span>"target"<\/span>]<\/span> +<\/span> header_data[<\/span>"filename"<\/span>]<\/span>,<\/span> filesize)<\/span>;<\/span>
\n bool<\/span> last_chunk;<\/span>
\n ret =<\/span> write_data_by_offset<\/span>(<\/span>header_data[<\/span>"req-id"<\/span>]<\/span>,<\/span> chunk,<\/span> offset,<\/span> last_chunk)<\/span>;<\/span>
\n if<\/span> (<\/span>ret <<\/span> 0<\/span>)<\/span> {<\/span>
\n _handler-><\/span>set_response_code<\/span>(<\/span>–<\/span>ret)<\/span>;<\/span>
\n _handler-><\/span>set_response_data<\/span>(<\/span>std::<\/span>map<<\/span>std::<\/span>string,<\/span> std::<\/span>string><\/span>{<\/span>{<\/span>"result"<\/span>,<\/span> "write head data failed"<\/span>}<\/span>}<\/span>)<\/span>;<\/span>
\n return<\/span>;<\/span>
\n }<\/span><\/p>\n

if<\/span> (<\/span>last_chunk)<\/span>
\n _handler-><\/span>set_response_code<\/span>(<\/span>FULL_REQ_SUCCESS)<\/span>;<\/span>
\n else<\/span>
\n _handler-><\/span>set_response_code<\/span>(<\/span>GWOP_SUCCESS)<\/span>;<\/span>
\n }<\/span> else<\/span> {<\/span>
\n _handler-><\/span>set_response_code<\/span>(<\/span>EINVALIDDATA)<\/span>;<\/span>
\n _handler-><\/span>set_response_data<\/span>(<\/span>std::<\/span>map<<\/span>std::<\/span>string,<\/span> std::<\/span>string><\/span>{<\/span>{<\/span>"result"<\/span>,<\/span> "invalid io type"<\/span>}<\/span>}<\/span>)<\/span>;<\/span>
\n }<\/span>
\n}<\/span><\/p>\n

\u5176\u4e2dwrite_data_by_offset()\u51fd\u6570\u5c31\u662f\u5199\u5165\u4e00\u4e2a\u5206\u5757，\u5f53\u770b\u5230\u8bf7\u6c42\u662fbio，\u4e5f\u5c31\u662f\u540c\u6b65\u8bf7\u6c42\u65f6，\u76f4\u63a5\u8c03\u7528，\u5e76\u8fd4\u56de\u7ed9\u7f51\u5173\u5c42\u5199\u5165\u7684\u7ed3\u679c；\u5982\u679c\u662faio\u5219\u5c06\u5176\u653e\u5165\u7ebf\u7a0b\u6c60\u4e2d，\u8fd4\u56deREQ_RECEIVED\u8868\u793a\u6536\u5230\u4e86\u5206\u5757\u6570\u636e\u3002 \u56de\u5230\u7f51\u5173\u5c42\u4e0b\u53d1\u5206\u5757：<\/p>\n

if<\/span> (<\/span>offset ==<\/span> 0<\/span>)<\/span> {<\/span>
\n ret =<\/span> client-><\/span>flush_data_chunk<\/span>(<\/span>offset,<\/span> header_data[<\/span>"filename"<\/span>]<\/span>,<\/span> file_size,<\/span> send_data,<\/span> req_id,<\/span> false<\/span>)<\/span>;<\/span>
\n .<\/span>.<\/span>.<\/span>
\n}<\/span><\/p>\n

\u5f53\u7b2c\u4e00\u4e2a\u5206\u5757\u4e0b\u53d1\u7684\u65f6\u5019，\u91c7\u7528\u540c\u6b65\u8bf7\u6c42，\u5728\u6570\u636e\u7ba1\u7406\u5c42\u521b\u5efa\u597d\u6587\u4ef6\u518d\u7ee7\u7eed\u591a\u7ebf\u7a0b\u5199\u5165\u3002<\/p>\n

\u90a3\u4e48\u7f51\u5173\u5c42\u662f\u5982\u4f55\u5f97\u77e5\u6570\u636e\u7ba1\u7406\u5c42\u5199\u5165\u7684\u7ed3\u679c\u5462？<\/p>\n

\u8fd9\u5c31\u9700\u8981\u4f7f\u7528\u5f02\u6b65\u56de\u8c03\u7684\u6982\u5ff5\u4e86：<\/p>\n

void<\/span> PutFileOp<\/span>::<\/span>execute<\/span>(<\/span>)<\/span> {<\/span>
\n .<\/span>.<\/span>.<\/span>
\n while<\/span> (<\/span>total_read <<\/span> file_size)<\/span> {<\/span>
\n .<\/span>.<\/span>.<\/span>
\n if<\/span> (<\/span>send_data.<\/span>size<\/span>(<\/span>)<\/span> >=<\/span> DATA_FLUSH_SIZE ||<\/span> file_size –<\/span> offset <=<\/span> DATA_FLUSH_SIZE)<\/span> {<\/span>
\n if<\/span> (<\/span>offset ==<\/span> 0<\/span>)<\/span> {<\/span>
\n ret =<\/span> client-><\/span>flush_data_chunk<\/span>(<\/span>offset,<\/span> header_data[<\/span>"filename"<\/span>]<\/span>,<\/span> file_size,<\/span> send_data,<\/span> req_id,<\/span> false<\/span>)<\/span>;<\/span>
\n .<\/span>.<\/span>.<\/span>
\n }<\/span> else<\/span> {<\/span>
\n PutFileOp::<\/span>PutDataChunkTask*<\/span> task =<\/span> new<\/span> PutFileOp<\/span>::<\/span>PutDataChunkTask<\/span>(<\/span>
\n .<\/span>.<\/span>.<\/span>
\n }<\/span>
\n context-><\/span>thread_pool-><\/span>enqueue_task<\/span>(<\/span>task)<\/span>;<\/span>
\n }<\/span><\/p>\n

if<\/span> (<\/span>file_size –<\/span> offset <=<\/span> DATA_FLUSH_SIZE &&<\/span> offset !=<\/span> 0<\/span>)<\/span> {<\/span>
\n waiter =<\/span> std::<\/span>make_shared<\/span><<\/span>AioCompleteWaiter><\/span><\/span><\/span>(<\/span>)<\/span>;<\/span>
\n std::<\/span>shared_ptr<<\/span>PutChunkcompletion><\/span> completion =<\/span> std::<\/span>make_shared<\/span><<\/span>PutChunkcompletion><\/span><\/span><\/span>(<\/span>waiter)<\/span>;<\/span>
\n GWGlobalContext*<\/span> context =<\/span> dynamic_cast<\/span><<\/span>GWGlobalContext*<\/span>><\/span><\/span><\/span>(<\/span>ctx)<\/span>;<\/span>
\n context-><\/span>complete_mgr-><\/span>register_completion<\/span>(<\/span>req_id,<\/span> completion)<\/span>;<\/span>
\n }<\/span>
\n .<\/span>.<\/span>.<\/span>
\n }<\/span><\/p>\n

\/\/ wait for finish or fail<\/span>
\n if<\/span> (<\/span>waiter.<\/span>use_count<\/span>(<\/span>)<\/span>)<\/span> {<\/span>
\n waiter-><\/span>wait_for_notify<\/span>(<\/span>)<\/span>;<\/span>
\n }<\/span>
\n}<\/span><\/p>\n

\u5f53\u7f51\u5173\u5c42\u4e0b\u5237\u6700\u540e\u4e00\u4e2a\u5206\u5757\u7684\u65f6\u5019（file_size – offset <= DATA_FLUSH_SIZE），\u4f1a\u8bbe\u7f6e\u4e00\u4e2aAioCompleteWaiter\u548cAioCompletion： \u3010\u4ee3\u7801：reactor\/distribute_storage\/gateway\/manager_client\/mgr_client_interface.h\u3011<\/p>\n

class<\/span> AioCompleteWaiter<\/span> {<\/span>
\npublic<\/span>:<\/span>
\n std::<\/span>mutex mtx;<\/span>
\n std::<\/span>condition_variable cv;<\/span>
\n bool<\/span> finish{<\/span>false<\/span>}<\/span>;<\/span>
\n int<\/span> ret;<\/span>
\n std::<\/span>map<<\/span>std::<\/span>string,<\/span> std::<\/span>string><\/span> results;<\/span><\/p>\n

void<\/span> wait_for_notify<\/span>(<\/span>)<\/span> {<\/span>
\n std::<\/span>unique_lock<<\/span>std::<\/span>mutex><\/span> lock<\/span>(<\/span>mtx)<\/span>;<\/span>
\n while<\/span> (<\/span>!<\/span>finish)<\/span> {<\/span>
\n \/\/tm<\/span>
\n std::<\/span>cout <<<\/span> "finish: "<\/span> <<<\/span> finish <<<\/span> std::<\/span>endl;<\/span>
\n cv.<\/span>wait<\/span>(<\/span>lock)<\/span>;<\/span>
\n }<\/span><\/p>\n

}<\/span><\/p>\n

void<\/span> notify<\/span>(<\/span>)<\/span> {<\/span>
\n std::<\/span>unique_lock<<\/span>std::<\/span>mutex><\/span> lock<\/span>(<\/span>mtx)<\/span>;<\/span>
\n finish =<\/span> true<\/span>;<\/span>
\n cv.<\/span>notify_one<\/span>(<\/span>)<\/span>;<\/span>
\n }<\/span>
\n}<\/span>;<\/span><\/p>\n

class<\/span> AioCompletion<\/span> {<\/span>
\nprotected<\/span>:<\/span>
\n int<\/span> retcode;<\/span>
\n std::<\/span>map<<\/span>std::<\/span>string,<\/span> std::<\/span>string><\/span> result_data;<\/span>
\npublic<\/span>:<\/span>
\n virtual<\/span> void<\/span> do_completion<\/span>(<\/span>)<\/span> {<\/span>}<\/span>
\n AioCompletion<\/span>(<\/span>)<\/span> {<\/span>}<\/span>
\n void<\/span> set_retcode<\/span>(<\/span>int<\/span> ret)<\/span> {<\/span> retcode =<\/span> ret;<\/span> }<\/span>
\n void<\/span> set_results<\/span>(<\/span>std::<\/span>map<<\/span>std::<\/span>string,<\/span> std::<\/span>string><\/span> res)<\/span> {<\/span> result_data =<\/span> res;<\/span> }<\/span>
\n}<\/span>;<\/span><\/p>\n

AioCompletion\u7684\u4f5c\u7528\u662f\u5f53\u8bf7\u6c42\u8fd4\u56de\u65f6，\u6267\u884c\u5bf9\u5e94\u7684\u56de\u8c03\u51fd\u6570，\u56de\u8c03\u51fd\u6570\u5219\u662f\u901a\u8fc7\u4e00\u4e2a\u968f\u673a\u51fa\u6765\u768416\u4f4d\u5b57\u7b26\u4e32\u4f5c\u4e3arequest id\u8bb0\u5f55\u5728CompletionManager\u4e2d：<\/p>\n

class<\/span> CompletionManager<\/span> {<\/span>
\nprivate<\/span>:<\/span>
\n std::<\/span>mutex mtx;<\/span>
\n std::<\/span>map<<\/span>std::<\/span>string,<\/span> std::<\/span>shared_ptr<<\/span>AioCompletion>><\/span> completions;<\/span>
\npublic<\/span>:<\/span>
\n bool<\/span> register_completion<\/span>(<\/span>std::<\/span>string req_id,<\/span> std::<\/span>shared_ptr<<\/span>AioCompletion><\/span> completion)<\/span> {<\/span>
\n std::<\/span>lock_guard<<\/span>std::<\/span>mutex><\/span> lock<\/span>(<\/span>mtx)<\/span>;<\/span>
\n if<\/span> (<\/span>completions.<\/span>find<\/span>(<\/span>req_id)<\/span> !=<\/span> completions.<\/span>end<\/span>(<\/span>)<\/span>)<\/span>
\n return<\/span> false<\/span>;<\/span>
\n completions[<\/span>req_id]<\/span> =<\/span> completion;<\/span>
\n return<\/span> true<\/span>;<\/span>
\n }<\/span>
\n .<\/span>.<\/span>.<\/span>
\n}<\/span>;<\/span><\/p>\n

\u5f53\u7f51\u5173\u5c42\u4e0b\u53d1\u5206\u5757\u6570\u636e\u65f6，\u8bf7\u6c42\u4e2d\u4f1a\u5e26\u6709\u8fd9\u4e2a16\u4f4d\u7684request id，\u540c\u65f6\u6570\u636e\u7ba1\u7406\u5c42\u6267\u884c\u5b8c\u6bd5\u4e5f\u4f1a\u643a\u5e26\u8fd9\u4e2arequest id\u8bf7\u6c42\u5411\u7f51\u5173\u5c42\u53d1\u9001\u8bf7\u6c42，\u7f51\u5173\u5c42\u5224\u65ad\u5230\u6765\u81ea\u6570\u636e\u7ba1\u7406\u5c42\u7684\u8bf7\u6c42\u65f6\u4f1a\u6839\u636erequest id\u627e\u5230\u5bf9\u5e94\u7684AioCompletion\u5e76\u6267\u884c\u56de\u8c03\u51fd\u6570：<\/p>\n

void<\/span> ChunkOp<\/span>::<\/span>execute<\/span>(<\/span>)<\/span> {<\/span>
\n .<\/span>.<\/span>.<\/span>
\n req_id =<\/span> body_data[<\/span>"req-id"<\/span>]<\/span>;<\/span>
\n if<\/span> (<\/span>body_data.<\/span>find<\/span>(<\/span>"status_code"<\/span>)<\/span> ==<\/span> body_data.<\/span>end<\/span>(<\/span>)<\/span>)<\/span> {<\/span>
\n .<\/span>.<\/span>.<\/span><\/p>\n

completion-><\/span>set_retcode<\/span>(<\/span>retcode)<\/span>;<\/span>
\n completion-><\/span>do_completion<\/span>(<\/span>)<\/span>;<\/span>
\n context-><\/span>complete_mgr-><\/span>unregister_completion<\/span>(<\/span>req_id)<\/span>;<\/span>
\n}<\/span><\/p>\n

\u7531\u4e8e\u5168\u90e8\u5199\u5165\u5206\u5757\u6570\u636e\u6210\u529f\u4e4b\u540e\u624d\u80fd\u5199\u5165\u5143\u6570\u636e，\u56e0\u6b64\u7f51\u5173\u5c42\u5fc5\u987b\u7b49\u5f85\u5199\u5165\u7684\u7ed3\u679c：<\/p>\n

void<\/span> PutFileOP<\/span>::<\/span>execute<\/span>(<\/span>)<\/span> {<\/span>
\n .<\/span>.<\/span>.<\/span>
\n if<\/span> (<\/span>file_size –<\/span> offset <=<\/span> DATA_FLUSH_SIZE &&<\/span> offset !=<\/span> 0<\/span>)<\/span> {<\/span>
\n waiter =<\/span> std::<\/span>make_shared<\/span><<\/span>AioCompleteWaiter><\/span><\/span><\/span>(<\/span>)<\/span>;<\/span>
\n std::<\/span>shared_ptr<<\/span>PutChunkcompletion><\/span> completion =<\/span> std::<\/span>make_shared<\/span><<\/span>PutChunkcompletion><\/span><\/span><\/span>(<\/span>waiter)<\/span>;<\/span>
\n GWGlobalContext*<\/span> context =<\/span> dynamic_cast<\/span><<\/span>GWGlobalContext*<\/span>><\/span><\/span><\/span>(<\/span>ctx)<\/span>;<\/span>
\n context-><\/span>complete_mgr-><\/span>register_completion<\/span>(<\/span>req_id,<\/span> completion)<\/span>;<\/span>
\n }<\/span>
\n .<\/span>.<\/span>.<\/span>
\n }<\/span><\/p>\n

\/\/ wait for finish or fail<\/span>
\n if<\/span> (<\/span>waiter.<\/span>use_count<\/span>(<\/span>)<\/span>)<\/span> {<\/span>
\n waiter-><\/span>wait_for_notify<\/span>(<\/span>)<\/span>;<\/span>
\n }<\/span>
\n .<\/span>.<\/span>.<\/span>
\n}<\/span><\/p>\n

\u5728AioCompletion\u7684\u56de\u8c03\u51fd\u6570\u4e2dnotify：<\/p>\n

void<\/span> PutChunkcompletion<\/span>::<\/span>do_completion<\/span>(<\/span>)<\/span> {<\/span>
\n set_waiter_retcode<\/span>(<\/span>retcode)<\/span>;<\/span>
\n set_waiter_results<\/span>(<\/span>result_data)<\/span>;<\/span>
\n waiter-><\/span>notify<\/span>(<\/span>)<\/span>;<\/span>
\n}<\/span><\/p>\n

PutFileOP::execute()\u5c31\u53ef\u4ee5\u7ee7\u7eed\u6267\u884c\u5143\u6570\u636e\u7684\u5199\u5165\u4e86，\u6700\u7ec8\u518d\u901a\u8fc7_handler->set_response_code()\u8bbe\u7f6e\u8fd4\u56de\u7684\u54cd\u5e94\u7801，\u6700\u7ec8\u8fd4\u56de\u7ed9\u7528\u6237\u6574\u4e2a\u6587\u4ef6\u4e0a\u4f20\u7684\u7ed3\u679c：<\/p>\n

void<\/span> PutFileOP<\/span>::<\/span>execute<\/span>(<\/span>)<\/span> {<\/span>
\n .<\/span>.<\/span>.<\/span>
\n if<\/span> (<\/span>waiter.<\/span>use_count<\/span>(<\/span>)<\/span>)<\/span> {<\/span>
\n waiter-><\/span>wait_for_notify<\/span>(<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/\/ write metadata for file<\/span>
\n ret =<\/span> client-><\/span>write_meta_data<\/span>(<\/span>header_data[<\/span>"filename"<\/span>]<\/span>,<\/span> file_size,<\/span> crc32)<\/span>;<\/span>
\n if<\/span> (<\/span>ret <<\/span> 0<\/span>)<\/span> {<\/span>
\n .<\/span>.<\/span>.<\/span>
\n }<\/span> <\/p>\n

_handler-><\/span>set_response_code<\/span>(<\/span>STATUS_OK)<\/span>;<\/span>
\n}<\/span><\/p>\n

\u4ee5\u4e0a\u5c31\u662f\u5199\u5165\u4e00\u4e2a\u6587\u4ef6\u7684\u5168\u90e8\u8fc7\u7a0b，\u7531\u4e8e\u6570\u636e\u7ba1\u7406\u5c42\u548c\u5143\u6570\u636e\u7ba1\u7406\u5c42\u90fd\u662f\u590d\u7528\u7684\u540c\u4e00\u5957Server\u4ee3\u7801，\u56e0\u6b64\u5728\u8fd9\u91cc\u4e0d\u5728\u8d58\u8ff0，\u8bfb\u8005\u53ef\u4ee5\u901a\u8fc7\u9605\u8bfb\u4ee3\u7801\u67e5\u770b\u8be6\u7ec6\u7684\u5199\u5165\u6570\u636e\u548c\u5143\u6570\u636e\u7684\u8fc7\u7a0b\u3002\u53e6\u5916\u5143\u6570\u636e\u548c\u6570\u636e\u7684\u5199\u5165\u4f4d\u7f6e\u90fd\u5728\/home\/storage\/metadata\u548c\/home\/storage\/data\u4e2d，\u901a\u8fc7\u6587\u4ef6\u540d\u54c8\u5e0c\u5e76\u53d6\u5199\u5230\u8fd9\u4e24\u4e2a\u6587\u4ef6\u5939\u4e0b\u7684\u67d0\u4e2a\u6570\u5b57\u8868\u793a\u7684\u6587\u4ef6\u5939\u4e0b\u9762，\u5b9e\u9645\u7684\u5206\u5e03\u5f0f\u5b58\u50a8\u7cfb\u7edf\u4e2d\u8fd9\u4e9b\u6570\u5b57\u6587\u4ef6\u5939\u53ef\u80fd\u4ee3\u8868\u7740\u4e00\u5757\u78c1\u76d8\u3002<\/p>\n

4.3 \u5c0f\u7ed3<\/h2>\n

\u672c\u7ae0\u6839\u636e\u4e00\u4e2a\u5b9e\u9645\u7684\u5206\u5e03\u5f0f\u5b58\u50a8\u7cfb\u7edf\u7684\u5199\u5165\u6587\u4ef6\u7684\u6848\u4f8b，\u7ed3\u5408\u4e4b\u524d\u8bb2\u8ff0\u7684\u7ebf\u7a0b\u6a21\u578b，\u5b9e\u73b0\u4e86\u4e00\u4e2a\u5b8c\u6574\u7684\u591a\u7ebf\u7a0b\u4efb\u52a1\u7684\u6267\u884c\u903b\u8f91\u3002\u5728PutFileOP::execute()\u4e2d，\u5176\u5b9e\u6709\u66f4\u9ad8\u6548\u7684\u6267\u884c\u65b9\u6cd5，\u90a3\u5c31\u662f\u5728AioCompletion\u7684\u5f02\u6b65\u56de\u8c03\u51fd\u6570\u4e2d\u52a0\u4e0a\u5199\u5165\u5143\u6570\u636e\u7684\u903b\u8f91，\u8fd9\u6837\u5c31\u4e0d\u5fc5\u5728\u5f53\u524d\u7ebf\u7a0b\u4e2d\u7b49\u5f85\u6570\u636e\u7ba1\u7406\u5c42\u5199\u5165\u7684\u7ed3\u679c，\u63d0\u9ad8\u4e86\u7ebf\u7a0b\u7684\u5229\u7528\u7387，\u8fd9\u4e5f\u662fProactor\u7ebf\u7a0b\u6a21\u578b\u7684\u601d\u60f3\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"

\u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb1.1k\u6b21\uff0c\u70b9\u8d5e34\u6b21\uff0c\u6536\u85cf29\u6b21\u3002\u5f53\u8bf7\u6c42\u5230\u8fbe\u7f51\u5173\u5c42\u65f6\uff0c\u53d1\u73b0\u5ba2\u6237\u7aef\u662f\u7684\u8bf7\u6c42\u662f\u4e0a\u4f20\u6587\u4ef6\uff0c\u90a3\u4e48\u5c31\u5f00\u59cb\u63a5\u6536\uff0c\u63a5\u6536\u4e00\u4e2a\u5206\u5757\u5c31\u4f20\u9012\u7ed9\u6570\u636e\u7ba1\u7406\u5c42\uff0c\u76f4\u5230\u6700\u540e\u4e00\u4e2a\u5206\u5757\u5728\u6570\u636e\u7ba1\u7406\u5c42\u5199\u5165\u6210\u529f\u6216\u8005\u4e2d\u9014\u67d0\u4e2a\u5206\u5757\u5904\u7406\u5931\u8d25\uff0c\u6570\u636e\u7ba1\u7406\u5c42\u5c06\u8be5\u4fe1\u606f\u8fd4\u56de\u7ed9\u7f51\u5173\u5c42\uff0c\u5982\u679c\u5931\u8d25\u7f51\u5173\u5c42\u76f4\u63a5\u8fd4\u56de\u7528\u6237\u5199\u5165\u5931\u8d25\uff0c\u5982\u679c\u6210\u529f\u5219\u5411\u5143\u6570\u636e\u7ba1\u7406\u5c42\u5199\u5165\u5143\u6570\u636e\uff0c\u5143\u6570\u636e\u7ba1\u7406\u5c42\u5199\u5165\u6210\u529f\u518d\u8fd4\u56de\u7ed9\u7f51\u5173\uff0c\u76f4\u5230\u8fd9\u65f6\u7f51\u5173\u5c42\u624d\u80fd\u8fd4\u56de\u7ed9\u7528\u6237\u8be5\u6587\u4ef6\u5199\u5165\u6210\u529f\u7684\u54cd\u5e94\u3002\u672c\u7ae0\u6839\u636e\u4e00\u4e2a\u5b9e\u9645\u7684\u5206\u5e03\u5f0f\u5b58\u50a8\u7cfb\u7edf\u7684\u5199\u5165\u6587\u4ef6\u7684\u6848\u4f8b\uff0c\u7ed3\u5408\u4e4b\u524d\u8bb2\u8ff0\u7684\u7ebf\u7a0b\u6a21\u578b\uff0c\u5b9e\u73b0\u4e86\u4e00\u4e2a\u5b8c\u6574\u7684\u591a\u7ebf\u7a0b\u4efb\u52a1\u7684\u6267\u884c\u903b\u8f91\u3002_gateway\u5982\u4f55\u914d\u7f6ereactor\u7ebf\u7a0b<\/p>\n","protected":false},"author":2,"featured_media":36139,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[55,252,43],"topic":[],"class_list":["post-36141","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-server","tag-c","tag-252","tag-43"],"yoast_head":"\n\u591a\u7ebf\u7a0b\u670d\u52a1\u5668\u5206\u6790\u2014\u2014Reactor\u7ebf\u7a0b\u6a21\u578b\u548c\u6027\u80fd\u5206\u6790(\u56db) - \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\/36141.html\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"\u591a\u7ebf\u7a0b\u670d\u52a1\u5668\u5206\u6790\u2014\u2014Reactor\u7ebf\u7a0b\u6a21\u578b\u548c\u6027\u80fd\u5206\u6790(\u56db) - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"og:description\" content=\"\u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb1.1k\u6b21\uff0c\u70b9\u8d5e34\u6b21\uff0c\u6536\u85cf29\u6b21\u3002\u5f53\u8bf7\u6c42\u5230\u8fbe\u7f51\u5173\u5c42\u65f6\uff0c\u53d1\u73b0\u5ba2\u6237\u7aef\u662f\u7684\u8bf7\u6c42\u662f\u4e0a\u4f20\u6587\u4ef6\uff0c\u90a3\u4e48\u5c31\u5f00\u59cb\u63a5\u6536\uff0c\u63a5\u6536\u4e00\u4e2a\u5206\u5757\u5c31\u4f20\u9012\u7ed9\u6570\u636e\u7ba1\u7406\u5c42\uff0c\u76f4\u5230\u6700\u540e\u4e00\u4e2a\u5206\u5757\u5728\u6570\u636e\u7ba1\u7406\u5c42\u5199\u5165\u6210\u529f\u6216\u8005\u4e2d\u9014\u67d0\u4e2a\u5206\u5757\u5904\u7406\u5931\u8d25\uff0c\u6570\u636e\u7ba1\u7406\u5c42\u5c06\u8be5\u4fe1\u606f\u8fd4\u56de\u7ed9\u7f51\u5173\u5c42\uff0c\u5982\u679c\u5931\u8d25\u7f51\u5173\u5c42\u76f4\u63a5\u8fd4\u56de\u7528\u6237\u5199\u5165\u5931\u8d25\uff0c\u5982\u679c\u6210\u529f\u5219\u5411\u5143\u6570\u636e\u7ba1\u7406\u5c42\u5199\u5165\u5143\u6570\u636e\uff0c\u5143\u6570\u636e\u7ba1\u7406\u5c42\u5199\u5165\u6210\u529f\u518d\u8fd4\u56de\u7ed9\u7f51\u5173\uff0c\u76f4\u5230\u8fd9\u65f6\u7f51\u5173\u5c42\u624d\u80fd\u8fd4\u56de\u7ed9\u7528\u6237\u8be5\u6587\u4ef6\u5199\u5165\u6210\u529f\u7684\u54cd\u5e94\u3002\u672c\u7ae0\u6839\u636e\u4e00\u4e2a\u5b9e\u9645\u7684\u5206\u5e03\u5f0f\u5b58\u50a8\u7cfb\u7edf\u7684\u5199\u5165\u6587\u4ef6\u7684\u6848\u4f8b\uff0c\u7ed3\u5408\u4e4b\u524d\u8bb2\u8ff0\u7684\u7ebf\u7a0b\u6a21\u578b\uff0c\u5b9e\u73b0\u4e86\u4e00\u4e2a\u5b8c\u6574\u7684\u591a\u7ebf\u7a0b\u4efb\u52a1\u7684\u6267\u884c\u903b\u8f91\u3002_gateway\u5982\u4f55\u914d\u7f6ereactor\u7ebf\u7a0b\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.wsisp.com\/helps\/36141.html\" \/>\n<meta property=\"og:site_name\" content=\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"article:published_time\" content=\"2025-05-07T15:45:40+00:00\" \/>\n<meta property=\"og:image\" content=\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/05\/20250507154539-681b80233894c.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=\"10 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/36141.html\",\"url\":\"https:\/\/www.wsisp.com\/helps\/36141.html\",\"name\":\"\u591a\u7ebf\u7a0b\u670d\u52a1\u5668\u5206\u6790\u2014\u2014Reactor\u7ebf\u7a0b\u6a21\u578b\u548c\u6027\u80fd\u5206\u6790(\u56db) - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"isPartOf\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\"},\"datePublished\":\"2025-05-07T15:45:40+00:00\",\"dateModified\":\"2025-05-07T15:45:40+00:00\",\"author\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/36141.html#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.wsisp.com\/helps\/36141.html\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/36141.html#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.wsisp.com\/helps\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"\u591a\u7ebf\u7a0b\u670d\u52a1\u5668\u5206\u6790\u2014\u2014Reactor\u7ebf\u7a0b\u6a21\u578b\u548c\u6027\u80fd\u5206\u6790(\u56db)\"}]},{\"@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":"\u591a\u7ebf\u7a0b\u670d\u52a1\u5668\u5206\u6790\u2014\u2014Reactor\u7ebf\u7a0b\u6a21\u578b\u548c\u6027\u80fd\u5206\u6790(\u56db) - \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\/36141.html","og_locale":"zh_CN","og_type":"article","og_title":"\u591a\u7ebf\u7a0b\u670d\u52a1\u5668\u5206\u6790\u2014\u2014Reactor\u7ebf\u7a0b\u6a21\u578b\u548c\u6027\u80fd\u5206\u6790(\u56db) - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","og_description":"\u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb1.1k\u6b21\uff0c\u70b9\u8d5e34\u6b21\uff0c\u6536\u85cf29\u6b21\u3002\u5f53\u8bf7\u6c42\u5230\u8fbe\u7f51\u5173\u5c42\u65f6\uff0c\u53d1\u73b0\u5ba2\u6237\u7aef\u662f\u7684\u8bf7\u6c42\u662f\u4e0a\u4f20\u6587\u4ef6\uff0c\u90a3\u4e48\u5c31\u5f00\u59cb\u63a5\u6536\uff0c\u63a5\u6536\u4e00\u4e2a\u5206\u5757\u5c31\u4f20\u9012\u7ed9\u6570\u636e\u7ba1\u7406\u5c42\uff0c\u76f4\u5230\u6700\u540e\u4e00\u4e2a\u5206\u5757\u5728\u6570\u636e\u7ba1\u7406\u5c42\u5199\u5165\u6210\u529f\u6216\u8005\u4e2d\u9014\u67d0\u4e2a\u5206\u5757\u5904\u7406\u5931\u8d25\uff0c\u6570\u636e\u7ba1\u7406\u5c42\u5c06\u8be5\u4fe1\u606f\u8fd4\u56de\u7ed9\u7f51\u5173\u5c42\uff0c\u5982\u679c\u5931\u8d25\u7f51\u5173\u5c42\u76f4\u63a5\u8fd4\u56de\u7528\u6237\u5199\u5165\u5931\u8d25\uff0c\u5982\u679c\u6210\u529f\u5219\u5411\u5143\u6570\u636e\u7ba1\u7406\u5c42\u5199\u5165\u5143\u6570\u636e\uff0c\u5143\u6570\u636e\u7ba1\u7406\u5c42\u5199\u5165\u6210\u529f\u518d\u8fd4\u56de\u7ed9\u7f51\u5173\uff0c\u76f4\u5230\u8fd9\u65f6\u7f51\u5173\u5c42\u624d\u80fd\u8fd4\u56de\u7ed9\u7528\u6237\u8be5\u6587\u4ef6\u5199\u5165\u6210\u529f\u7684\u54cd\u5e94\u3002\u672c\u7ae0\u6839\u636e\u4e00\u4e2a\u5b9e\u9645\u7684\u5206\u5e03\u5f0f\u5b58\u50a8\u7cfb\u7edf\u7684\u5199\u5165\u6587\u4ef6\u7684\u6848\u4f8b\uff0c\u7ed3\u5408\u4e4b\u524d\u8bb2\u8ff0\u7684\u7ebf\u7a0b\u6a21\u578b\uff0c\u5b9e\u73b0\u4e86\u4e00\u4e2a\u5b8c\u6574\u7684\u591a\u7ebf\u7a0b\u4efb\u52a1\u7684\u6267\u884c\u903b\u8f91\u3002_gateway\u5982\u4f55\u914d\u7f6ereactor\u7ebf\u7a0b","og_url":"https:\/\/www.wsisp.com\/helps\/36141.html","og_site_name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","article_published_time":"2025-05-07T15:45:40+00:00","og_image":[{"url":"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/05\/20250507154539-681b80233894c.png"}],"author":"admin","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"admin","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"10 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.wsisp.com\/helps\/36141.html","url":"https:\/\/www.wsisp.com\/helps\/36141.html","name":"\u591a\u7ebf\u7a0b\u670d\u52a1\u5668\u5206\u6790\u2014\u2014Reactor\u7ebf\u7a0b\u6a21\u578b\u548c\u6027\u80fd\u5206\u6790(\u56db) - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","isPartOf":{"@id":"https:\/\/www.wsisp.com\/helps\/#website"},"datePublished":"2025-05-07T15:45:40+00:00","dateModified":"2025-05-07T15:45:40+00:00","author":{"@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41"},"breadcrumb":{"@id":"https:\/\/www.wsisp.com\/helps\/36141.html#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.wsisp.com\/helps\/36141.html"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.wsisp.com\/helps\/36141.html#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.wsisp.com\/helps"},{"@type":"ListItem","position":2,"name":"\u591a\u7ebf\u7a0b\u670d\u52a1\u5668\u5206\u6790\u2014\u2014Reactor\u7ebf\u7a0b\u6a21\u578b\u548c\u6027\u80fd\u5206\u6790(\u56db)"}]},{"@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\/36141","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=36141"}],"version-history":[{"count":0,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/36141\/revisions"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media\/36139"}],"wp:attachment":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media?parent=36141"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/categories?post=36141"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/tags?post=36141"},{"taxonomy":"topic","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/topic?post=36141"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}