\u89c6\u9891\u8d44\u6599\u53c2\u8003up\u604b\u604b\u98ce\u8fb0：<\/p>\n
\u3010C++ \u7f51\u7edc\u7f16\u7a0b(19) \u5229\u7528\u534f\u7a0b\u5b9e\u73b0\u5e76\u53d1\u670d\u52a1\u5668(\u4e0a)\u3011<\/p>\n
https:\/\/www.bilibili.com\/video\/BV18k4y1M7Nx?vd_source=cb95e3058c2624d2641da6f4eeb7e3a1\u200bwww.bilibili.com\/video\/BV18k4y1M7Nx?vd_source=cb95e3058c2624d2641da6f4eeb7e3a1<\/p>\n
\u3010C++ \u7f51\u7edc\u7f16\u7a0b(20) \u5229\u7528\u534f\u7a0b\u5b9e\u73b0\u5e76\u53d1\u670d\u52a1\u5668(\u4e0b)\u3011<\/p>\n
https:\/\/www.bilibili.com\/video\/BV1ch4y1G7Dc?vd_source=cb95e3058c2624d2641da6f4eeb7e3a1\u200bwww.bilibili.com\/video\/BV1ch4y1G7Dc?vd_source=cb95e3058c2624d2641da6f4eeb7e3a1<\/p>\n
1. Const.h<\/h3>\n1. Const.h<\/h3>\n
#pragma once
\n#define MAX_LENGTH 1024*2
\n#define HEAD_TOTAL_LEN 4
\n#define HEAD_ID_LEN 2
\n#define HEAD_DATA_LEN 2
\n#define MAX_RECVQUE 1000
\n#define MAX_SENDQUE 1000<\/p>\n
enum MSG_ID {
\nMSG_HELLO_WORD = 1001
\n};<\/p>\n
\u8be5\u5934\u6587\u4ef6\u7528\u4e8e\u5b9a\u4e49\u6d88\u606f\u6536\u53d1\u4e2d\u9700\u8981\u7528\u5230\u7684\u5b8f<\/p>\n
- \n
- MAX_LENGTH：\u4e00\u6b21\u6700\u591a\u63a5\u65362048\u5b57\u8282\u7684\u5185\u5bb9<\/li>\n
- HEAD_TOTAL_LEN：\u6d88\u606f\u5934\u7ed3\u70b9\u603b\u957f\u5ea6\u4e3a4\u5b57\u8282，\u5305\u62ec\u6d88\u606fid\u548c\u6d88\u606f\u4f53\u957f\u5ea6<\/li>\n
- HEAD_ID_LEN：\u6d88\u606fid，2\u5b57\u8282<\/li>\n
- HEAD_DATA_LEN：\u6d88\u606f\u957f\u5ea6，2\u5b57\u8282<\/li>\n
- MAX_RECVQUE：\u63a5\u6536\u961f\u5217\u6700\u591a\u5bb9\u7eb31000\u4e2a\u5904\u7406\u8bf7\u6c42<\/li>\n
- MAX_SENDQUE：\u53d1\u9001\u961f\u5217\u6700\u591a\u5bb9\u7eb31000\u4e2a\u5904\u7406\u8bf7\u6c42<\/li>\n
- MSG_ID：\u7528\u4e8e\u5b58\u50a8\u6d88\u606fid，\u901a\u8fc7id\u5728\u903b\u8f91\u961f\u5217\u4e2d\u67e5\u627e\u5bf9\u5e94\u7684\u56de\u8c03\u51fd\u6570<\/li>\n<\/ul>\n
2. \u6d88\u606f\u5b58\u50a8\u8282\u70b9MsgNode<\/h3>\n
a. MsgNode.h<\/h4>\n
#pragma once
\n#include <string>
\n#include "Const.h"
\n#include <iostream>
\n#include <boost\/asio.hpp><\/p>\nclass MsgNode
\n{
\npublic:
\nshort _cur_len;
\nshort _total_len;
\nchar* _data;<\/p>\nMsgNode(short max_len) : _total_len(max_len), _cur_len(0) {
\n_data = new char[_total_len + 1]();
\n_data[_total_len] = '\\\\0';
\n}
\n~MsgNode() {
\nstd::cout << "destruct MsgNode" << std::endl;
\ndelete[] _data;
\n}
\nvoid Clear() {
\n::memset(_data, 0, _total_len);
\n_cur_len = 0;
\n}
\n};<\/p>\nclass RecvNode : public MsgNode {
\nprivate:
\nshort _msg_id;
\npublic:
\nRecvNode(short max_len, short msg_id);
\nconst short& GetMsgID() { return _msg_id; }
\n};<\/p>\nclass SendNode : public MsgNode {
\nprivate:
\nshort _msg_id;
\npublic:
\nSendNode(const char* msg, short max_len, short msg_id);
\n};<\/p>\nMsgNode\u7c7b\u4e3b\u8981\u7528\u4e8e\u6784\u5efa\u6d88\u606f\u63a5\u6536\u8282\u70b9\u548c\u6d88\u606f\u53d1\u9001\u8282\u70b9<\/p>\n
- \n
- RecvNode\u8282\u70b9\u4f5c\u4e3a\u63a5\u6536\u8282\u70b9，\u6784\u9020\u51fd\u6570\u4ec5\u9700\u6700\u5927\u957f\u5ea6\u548c\u6d88\u606fid，\u540c\u65f6\u5b9a\u4e49\u4e00\u4e2aGetMsgID()\u51fd\u6570\u7528\u4e8e\u8fd4\u56de\u6d88\u606fid（\u5728\u903b\u8f91\u5c42\u6839\u636e\u6d88\u606fid\u5bfb\u627e\u5bf9\u5e94\u5df2\u6ce8\u518c\u56de\u8c03\u51fd\u6570\u65f6\u9700\u8981\u7528\u5230）<\/li>\n
- SendNode\u8282\u70b9\u4f5c\u4e3a\u53d1\u9001\u8282\u70b9，\u4e0d\u4ec5\u9700\u8981\u77e5\u9053\u6700\u5927\u957f\u5ea6\u548c\u6d88\u606fid，\u8fd8\u9700\u4f20\u5165\u6d88\u606f\u9996\u5730\u5740msg<\/li>\n<\/ul>\n
b. \u6210\u5458\u51fd\u6570\u5b9e\u73b0<\/h4>\n
#include "MsgNode.h"<\/p>\n
RecvNode::RecvNode(short max_len, short msg_id) : MsgNode(max_len), _msg_id(msg_id){
\n}<\/p>\nSendNode::SendNode(const char* msg, short max_len, short msg_id) :
\nMsgNode(max_len + HEAD_TOTAL_LEN), _msg_id(msg_id) {
\n\/\/ \u5148\u53d1\u9001id，\u5e76\u8f6c\u6362\u4e3a\u7f51\u7edc\u5b57\u8282\u5e8f
\nshort msg_id_net = boost::asio::detail::socket_ops::host_to_network_short(msg_id);
\nmemcpy(_data, &msg_id_net, HEAD_ID_LEN);
\n\/\/ \u53d1\u9001\u6d88\u606f\u957f\u5ea6，\u8f6c\u6362\u4e3a\u7f51\u7edc\u5b57\u8282\u5e8f
\nshort max_len_net = boost::asio::detail::socket_ops::host_to_network_short(max_len);
\nmemcpy(_data + HEAD_ID_LEN, &max_len_net, HEAD_DATA_LEN);
\nmemcpy(_data + HEAD_TOTAL_LEN, msg, max_len);
\n}<\/p>\n- \n
- RecvNode\u8282\u70b9\u7684\u6784\u9020\u51fd\u6570\u6bd4\u8f83\u7b80\u5355，\u53ea\u9700\u8981\u8c03\u7528\u57fa\u7c7bMsgNode\u7684\u6784\u9020\u51fd\u6570\u5e76\u5c06\u6d88\u606fid\u4f20\u5165_msg_id<\/li>\n
- SendNode\u4e0d\u4ec5\u9700\u8981\u4e0a\u8ff0\u4e24\u6b65（\u57fa\u7c7bMsgNode\u6784\u9020\u51fd\u6570\u4f20\u5165\u7684\u6700\u5927\u957f\u5ea6\u4e0d\u662f\u4f20\u5165\u7684\u503c，\u8fd8\u9700\u8981\u518d\u4f20\u5165\u503c\u57fa\u7840\u4e0a\u52a04\u5b57\u8282，4\u5b57\u8282\u7528\u4e8e\u5b58\u50a8\u6d88\u606fid\u548c\u6d88\u606f\u4f53\u957f\u5ea6），\u8fd8\u9700\u8fdb\u884c\u4ee5\u4e0b\u64cd\u4f5c：\n
- \n
- \u5c06\u4f20\u5165\u7684\u6d88\u606fid\u8f6c\u6362\u4e3a\u7f51\u7edc\u5b57\u8282\u5e8f\u5e76\u5b58\u50a8\u81f3_data（MsgNode\u7c7b\u6210\u5458\u53d8\u91cf），\u957f\u5ea62\u5b57\u8282<\/li>\n
- \u5c06\u4f20\u5165\u7684\u6d88\u606f\u957f\u5ea6\u8f6c\u6362\u4e3a\u7f51\u7edc\u5b57\u8282\u5e8f\u5e76\u5b58\u50a8\u81f3_data（MsgNode\u7c7b\u6210\u5458\u53d8\u91cf），\u957f\u5ea62\u5b57\u8282<\/li>\n
- _data\u504f\u79fb4\u5b57\u8282\u540e\u5b58\u50a8\u6d88\u606f\u4f53\u5185\u5bb9，\u957f\u5ea6\u4e3a\u4f20\u5165\u503cmax_len<\/li>\n<\/ul>\n<\/li>\n<\/ul>\n
\u56e0\u4e3a\u4e0d\u540c\u8bbe\u5907\u7684\u5b57\u8282\u5e8f\u5b58\u5728\u5927\u7aef\u5e8f\u548c\u5c0f\u7aef\u5e8f\u7684\u95ee\u9898，\u5fc5\u987b\u5c06\u6d88\u606fid\u548c\u6d88\u606f\u957f\u5ea6\u8f6c\u6362\u4e3a\u7f51\u7edc\u5e8f，\u5426\u5219\u6d88\u606f\u5185\u5bb9\u53ef\u80fd\u4f1a\u7d0a\u4e71，\u7f51\u7edc\u5b57\u8282\u5e8f\u7684\u5185\u5bb9\u53ef\u53c2\u8003<\/p>\n
\u7231\u5403\u571f\u8c46：\u7f51\u7edc\u7f16\u7a0b（8）+\u5b57\u8282\u5e8f\u5904\u74060 \u8d5e\u540c \u00b7 0 \u8bc4\u8bba\u6587\u7ae0<\/p>\n
3. CServer<\/h3>\n
a. CServer.h<\/h4>\n
#pragma once
\n#include <memory>
\n#include <map>
\n#include <mutex>
\n#include "boost\/asio.hpp"
\n#include "CSession.h"
\n#include "AsioIOServicePool.h"
\n#include <boost\/uuid\/uuid_generators.hpp>
\n#include <boost\/uuid\/uuid_io.hpp>
\n#include <boost\/asio\/co_composed.hpp>
\n#include <boost\/asio\/detached.hpp>
\n#include "Const.h"
\n#include <queue>
\n#include <mutex>
\n#include <memory>
\n#include "MsgNode.h"<\/p>\nusing boost::asio::ip::tcp;
\nusing boost::asio::awaitable;
\nusing boost::asio::co_spawn;
\nusing boost::asio::detached;
\nusing boost::asio::use_awaitable;
\nnamespace this_coro = boost::asio::this_coro;<\/p>\nclass CServer
\n{
\nprivate:
\nvoid HandleAccept(std::shared_ptr<CSession>, const boost::system::error_code& error);
\nvoid StartAccept();
\nboost::asio::io_context& _io_context;
\nshort _port;
\nboost::asio::ip::tcp::acceptor _acceptor;
\nstd::map<std::string, std::shared_ptr<CSession>> _sessions;
\nstd::mutex _mutex;
\npublic:
\nCServer(boost::asio::io_context& io_context, short port);
\n~CServer();
\nvoid ClearSession(std::string);
\n};<\/p>\n\u5305\u542b\u8981\u6c42\u7684\u5934\u6587\u4ef6\u5e76using\u9700\u8981\u4f7f\u7528\u7684\u547d\u540d\u7a7a\u95f4\u548c\u51fd\u6570（\u534f\u7a0b）<\/p>\n
\u6210\u5458\u51fd\u6570\u5728\u5b9a\u4e49\u7684\u65f6\u5019\u8be6\u7ec6\u89e3\u91ca，\u8fd9\u91cc\u4ecb\u7ecd\u4ee5\u4e0b\u6210\u5458\u53d8\u91cf：<\/p>\n
- \n
- io_context& _io_context：\u58f0\u660e\u4e00\u4e2a_io_context\u7684\u5f15\u7528，\u6ce8\u610f，\u548c\u00a0boost::asio::io_context _io_context\u4e0d\u540c，io_context&\u00a0_io_context\u8868\u793a\u5bf9\u73b0\u6709io_context\u5bf9\u8c61（\u5176\u4ed6\u5730\u65b9\u521b\u5efa\u7684ioc\u5bf9\u8c61）\u7684\u5f15\u7528，\u8fd9\u91cc\u5e76\u4e0d\u662f\u58f0\u660e\u4e00\u4e2aioc\u5b9e\u4f8b，\u800c\u662f\u8868\u793a\u5bf9\u5916\u754c\u4f20\u5165ioc\u7684\u5f15\u7528（\u4e3b\u51fd\u6570\u9700\u8981\u5c06\u76d1\u542c\u9519\u8bef\u4fe1\u53f7signal\u7684ioc\u4f20\u5165server\u7528\u4e8e\u76d1\u542c\u5ba2\u6237\u7aef\u7684\u8fde\u63a5\u8bf7\u6c42accept）<\/li>\n
- _port：\u670d\u52a1\u5668\u7aef\u53e3，\u5ba2\u6237\u7aef\u4e0e\u670d\u52a1\u5668\u7684\u6307\u5b9a\u7aef\u53e3\u8fdb\u884c\u8fde\u63a5<\/li>\n
- _acceptor：\u7528\u4e8e\u7ed1\u5b9a\u670d\u52a1\u5668\u6307\u5b9aip\u548c\u7aef\u53e3\u53f7，\u5e76\u8fdb\u884c\u76d1\u542c\u5ba2\u6237\u7aef\u8fde\u63a5\u4fe1\u53f7<\/li>\n
- _sessions：\u5b58\u50a8\u4f1a\u8bdd\u4efb\u52a1\u7684\u5bb9\u5668，\u7c7b\u4f3cpython\u7684\u5b57\u5178，\u952e\u662f\u4e00\u4e2a\u5b57\u7b26\u4e32（\u4e0d\u540c\u4f1a\u8bdd\u6709\u4e0d\u540c\u7684uuid），\u503c\u662fsession，\u4e3a\u6bcf\u4e2asession\u4f1a\u8bdd\u6620\u5c04\u5bf9\u5e94\u7684uuid，\u901a\u8fc7uuid\u53ef\u5b9e\u73b0\u4f1a\u8bdd\u7684\u64e6\u9664\u3001\u63d2\u5165\u548c\u5bfb\u627e<\/li>\n
- _mutex：\u9501，\u4fdd\u8bc1\u7ebf\u7a0b\u5b89\u5168<\/li>\n<\/ul>\n
b. \u6210\u5458\u51fd\u6570\u5b9e\u73b0<\/h4>\n
CServer::CServer(boost::asio::io_context& io_context, short port) :
\n_io_context(io_context), _port(port), _acceptor(io_context, boost::asio::ip::tcp::endpoint(boost::asio::ip::tcp::v4(), port)) {
\nstd::cout << "Server start success, on port: " << port << std::endl;
\nStartAccept();
\n}<\/p>\nCServer\u7684\u6784\u9020\u51fd\u6570\u63a5\u6536\u6307\u5b9a\u7684\u4e0a\u4e0b\u6587\u670d\u52a1io_context\u548c\u7aef\u53e3\u53f7，\u5e76\u5c06acceptor\u7ed1\u5b9a\u670d\u52a1\u5668\u6307\u5b9a\u7684ip\u548c\u7aef\u53e3\u53f7，\u6700\u540e\u8c03\u7528StartAccept()\u542f\u52a8\u76d1\u542c\u670d\u52a1<\/p>\n
void CServer::StartAccept() {
\nauto& io_context = AsioIOServicePool::GetInstance()->GetIOService();
\nstd::shared_ptr<CSession> new_session = std::make_shared<CSession>(io_context, this);
\n_acceptor.async_accept(new_session->GetSocket(),
\nstd::bind(&CServer::HandleAccept, this, new_session, std::placeholders::_1));
\n}<\/p>\n\u4e3b\u51fd\u6570（\u4e3b\u7ebf\u7a0b）\u7684io_context\u4e3b\u8981\u7528\u4e8e\u76d1\u542c\u9519\u8bef\u4fe1\u53f7\u548c\u76d1\u542c\u5ba2\u6237\u7aef\u8fde\u63a5\u8bf7\u6c42，\u4f46\u5728\u6bcf\u4e2a\u7ebf\u7a0b\u4e2d\u7684io_context\u90fd\u662f\u4ece\u7ebf\u7a0b\u6c60AsioIOServicePool\u4e2d\u53d6\u51fa\u72ec\u7acb\u8fd0\u884c\u7684\u3002\u603b\u5171\u542f\u52a8n+1\u4e2aio_context，n\u662f\u7ebf\u7a0b\u6c60\u4e2d\u5b58\u50a8\u7684ioc，1\u662f\u4e3b\u51fd\u6570\u4e2d\u7684ioc\u3002\u51fd\u6570\u6d41\u7a0b\u5982\u4e0b：<\/p>\n
- \n
- \u9996\u5148，\u4ece\u7ebf\u7a0b\u6c60\u4e2d\u53d6\u51fa\u4e00\u4e2aioc，\u5e76\u5c06\u7ebf\u7a0b\u6c60\u4e2dioc\u7684\u7d22\u5f15+1，\u4ee5\u4fbf\u8f6e\u8be2\u53d6\u51fa\u4e0b\u4e00\u4e2aioc；<\/li>\n
- \u7136\u540e，\u5b9a\u4e49\u4e00\u4e2a\u65b0\u7684session\u4f1a\u8bdd，\u4f20\u5165\u4ece\u7ebf\u7a0b\u6c60\u4e2d\u53d6\u51fa\u7684ioc，\u5e76\u5c06server\u6307\u9488\u4f20\u5165（\u5982\u679c\u8be5session\u4f1a\u8bdd\u9519\u8bef，\u901a\u8fc7server\u7684Clear\u51fd\u6570\u64e6\u9664\u8be5session\u4f1a\u8bdd）\u3002\u901a\u8fc7\u667a\u80fd\u6307\u9488shared_ptr\u7ba1\u7406session\u58f0\u660e\u5468\u671f，\u901a\u8fc7\u667a\u80fd\u6307\u9488\u5728C++\u4e2d\u5b9e\u73b0\u4f2a\u95ed\u5305，\u4ee5\u9632session\u5728\u7ebf\u7a0b\u7ed3\u675f\u524d\u88ab\u63d0\u524d\u91ca\u653e\u5bfc\u81f4\u7ebf\u7a0b\u5b89\u5168；<\/li>\n
- \u6700\u540e，\u4f7f\u7528\u7ed1\u5b9a\u4e3b\u51fd\u6570\u4f20\u5165ioc\u548c\u6307\u5b9a\u7aef\u70b9\u7684acceptor\u76d1\u542c\u5ba2\u6237\u7aef（\u5df2\u7ecf\u4e3a\u8be5\u5ba2\u6237\u7aef\u5efa\u7acb\u4e86\u4f1a\u8bddsession，\u53ea\u9700\u5ba2\u6237\u7aef\u8fdb\u884c\u8fde\u63a5\u5373\u53ef\u8fdb\u884c\u6536\u53d1\u64cd\u4f5c）\u8fde\u63a5\u3002\u5982\u679c\u76d1\u542c\u6210\u529f，\u8c03\u7528\u56de\u8c03\u51fd\u6570HandleAccept\u3002<\/li>\n<\/ul>\n
void CServer::HandleAccept(std::shared_ptr<CSession> new_session, const boost::system::error_code& error) {
\nif (!error) {
\nnew_session->Start();
\nstd::lock_guard<std::mutex> lock(_mutex);
\n_sessions.insert(make_pair(new_session->GetUuid(), new_session));
\n}
\nelse {
\nstd::cerr << "session accept failed, error is " << error.what() << std::endl;
\n}<\/p>\nStartAccept();
\n}<\/p>\n\u8be5\u56de\u8c03\u51fd\u6570\u4e3b\u8981\u5904\u7406\u5ba2\u6237\u7aef\u7684\u8fde\u63a5\u8bf7\u6c42，\u5982\u679c\u5ba2\u6237\u7aef\u8fde\u63a5\u6210\u529f（\u6ca1\u6709\u9519\u8bef），\u90a3\u4e48\u542f\u52a8\u4f1a\u8bdd（new_session->Start()），\u5e76\u52a0\u9501\u5c06\u8be5\u4f1a\u8bdd\u4ee5\u53ca\u5bf9\u5e94\u7684uuid\u63d2\u5165\u81f3_sessions，\u4ee5\u4fbf\u540e\u7eed\u7ba1\u7406\u6b64session，\u2018}\u2019\u7ed3\u675f\u540e\u81ea\u52a8\u91ca\u653e\u9501，\u65e0\u9700\u624b\u52a8\u91ca\u653e\u3002<\/p>\n
\u6700\u540e\u8c03\u7528StartAccept()，\u91cd\u65b0\u4ece\u7ebf\u7a0b\u6c60\u4e2d\u53d6\u51faioc\u5e76\u521b\u5efa\u4e00\u4e2a\u65b0\u7684\u4f1a\u8bddsession，\u53ea\u5f85\u4e3b\u7ebf\u7a0b\u7684ioc\u76d1\u542c\u5230\u5ba2\u6237\u7aef\u8fde\u63a5\u7533\u8bf7\u4e4b\u540e，\u4fbf\u5c06\u65b0\u4f1a\u8bdd\u4ea4\u7ed9\u65b0\u8fde\u63a5\u8bf7\u6c42\u8fdb\u884c\u6536\u53d1\u3002<\/p>\n
void CServer::ClearSession(std::string uuid) {
\nstd::lock_guard<std::mutex> lock(_mutex);
\n_sessions.erase(uuid);
\n}<\/p>\n\u8be5\u51fd\u6570\u7528\u4e8e\u5c06\u6307\u5b9auuid\u7684\u4f1a\u8bdd\u4ece\u4f1a\u8bdd\u5b58\u50a8\u5bb9\u5668_sessions\u4e2d\u64e6\u9664，\u6bcf\u4e2auuid\u5bf9\u5e94\u4e00\u4e2asession，uuid\u901a\u8fc7\u96ea\u82b1\u7b97\u6cd5\u5b9e\u73b0\u3002<\/p>\n
4. \u7ebf\u7a0b\u6c60AsioIOServicePool<\/h3>\n
a. AsioIOServicePool.h<\/h4>\n
#pragma once
\n#include "boost\/asio.hpp"
\n#include <iostream>
\n#include <vector>
\n#include <memory><\/p>\nclass AsioIOServicePool;<\/p>\n
class SafeDeletor{
\npublic:
\nvoid operator()(AsioIOServicePool* st);
\n};<\/p>\nclass AsioIOServicePool
\n{
\npublic:
\nfriend class SafeDeletor;
\nusing IOService = boost::asio::io_context;
\nusing Work = boost::asio::io_context::work;
\nusing WorkPtr = std::unique_ptr<Work>;<\/p>\nstatic std::shared_ptr<AsioIOServicePool> GetInstance() {
\nstatic std::once_flag s_flag;
\nstd::call_once(s_flag, [&]() { \/\/ call_once\u5185\u90e8\u6709\u9501
\n_instance = std::shared_ptr<AsioIOServicePool>(new AsioIOServicePool, SafeDeletor());
\n});
\nreturn _instance;
\n}
\nboost::asio::io_context& GetIOService();
\nvoid Stop();
\nprivate:
\nAsioIOServicePool(std::size_t size = std::thread::hardware_concurrency());
\n~AsioIOServicePool();
\nAsioIOServicePool(const AsioIOServicePool&) = delete;
\nAsioIOServicePool& operator = (const AsioIOServicePool&) = delete;<\/p>\nstd::vector<IOService> _ioServices;
\nstd::vector<WorkPtr> _works;
\nstd::vector<std::thread> _threads;
\nstd::size_t _nextIOService;
\nstatic std::shared_ptr<AsioIOServicePool> _instance;
\n};<\/p>\n\u5efa\u7acb\u7ebf\u7a0b\u6c60AsioIOServicePool，\u7528\u4e8e\u591a\u7ebf\u7a0b\u6536\u53d1\u3002\u8be5\u670d\u52a1\u5668\u6709\u4e24\u4e2a\u5355\u4f8b\u7c7b，\u5206\u522b\u662fAsioIOServicePool（\u7ebf\u7a0b\u6c60）\u548cLogicSystem（\u903b\u8f91\u5c42），\u6211\u4f7f\u7528\u4e86\u4e24\u79cd\u65b9\u5f0f\u5b9e\u73b0\u5355\u4f8b\u6a21\u5f0f，AsioIOServicePool\u7684\u5355\u4f8b\u5b9e\u73b0\u6bd4\u8f83\u8be6\u7ec6，LogicSystem\u7684\u5b9e\u73b0\u6bd4\u8f83\u7b80\u5355，\u4f46\u4ee3\u7801\u66f4\u5c11\u66f4\u6e05\u6670\u3002<\/p>\n
class SafeDeletor{
\npublic:
\nvoid operator()(AsioIOServicePool* st);
\n};<\/p>\nSafeDeletor\u662f\u6307\u5b9a\u7684\u5220\u9664\u5668，\u6211\u4eec\u5c06\u6790\u6784\u51fd\u6570\u8bbe\u7f6e\u4e3a\u79c1\u6709，\u9632\u6b62\u6790\u6784\u51fd\u6570\u88ab\u4e3b\u52a8\u8c03\u7528，\u6790\u6784\u51fd\u6570\u53ea\u80fd\u901a\u8fc7\u5220\u9664\u5668SafeDeletor\u88ab\u8c03\u7528，\u8fd9\u91cc\u91cd\u8f7d\u4e86()，\u5c06SafeDeletor\u7c7b\u4f5c\u4e3a\u4eff\u51fd\u6570\u4f7f\u7528\u3002<\/p>\n
AsioIOServicePool\u7684\u6210\u5458\u51fd\u6570\u5728\u540e\u9762\u5b9a\u4e49\u7684\u65f6\u5019\u8be6\u7ec6\u89e3\u91ca，\u8fd9\u91cc\u4ecb\u7ecdAsioIOServicePool\u4ee5\u4e0b\u6210\u5458\u53d8\u91cf：<\/p>\n
- \n
- IOService：\u5c06boost::asio::io_context\u91cd\u547d\u540d\u4e3aIOService，\u4ee5\u4fbf\u4f7f\u7528<\/li>\n
- Work：\u5c06boost::asio::io_context::work\u91cd\u547d\u540d\u4e3aWork，Work\u7528\u6765\u7ed1\u5b9aioc，\u4ee5\u9632ioc.run()\u63d0\u524d\u8fd4\u56de，\u8be6\u7ec6\u89e3\u91ca\u53ef\u53c2\u8003<\/li>\n<\/ul>\n
\u7231\u5403\u571f\u8c46：\u7f51\u7edc\u7f16\u7a0b（16）\u2014\u2014asio\u591a\u7ebf\u7a0b\u6a21\u578bIOServicePool5 \u8d5e\u540c \u00b7 0 \u8bc4\u8bba\u6587\u7ae0<\/p>\n
- \n
- WorkPtr：\u4f7f\u7528unique_ptr\u7ba1\u7406work，\u5e0c\u671b\u8be5work\u4e0d\u4f1a\u88ab\u62f7\u8d1d，\u53ea\u80fd\u79fb\u52a8\u6216\u8005\u4ece\u5934\u7528\u5230\u5c3e\u4e0d\u88ab\u6539\u53d8<\/li>\n
- _ioServices：io_context\u5b58\u50a8\u5bb9\u5668，\u7528\u4e8e\u5b58\u50a8\u6307\u5b9a\u6570\u91cf\u7684io_context<\/li>\n
- _works：\u5b58\u50a8\u4e0eioc\u6570\u91cf\u5bf9\u5e94\u7684work<\/li>\n
- _threads：\u5b58\u50a8\u6307\u5b9a\u6570\u91cf\u7684\u7ebf\u7a0b<\/li>\n
- _nextIOService：\u8bb0\u5f55ioc\u5728vector\u7684\u4e0b\u6807，\u901a\u8fc7\u8f6e\u8be2\u8fd4\u56deioc\u65f6，\u9700\u8981\u8bb0\u5f55\u5f53\u524dioc\u7684\u4e0b\u6807，\u7d2f\u52a0，\u5f53\u8d85\u8fc7vector\u7684size\u65f6\u5c31\u5f52\u96f6，\u7136\u540e\u7ee7\u7eed\u6309\u8f6e\u8be2\u7684\u65b9\u5f0f\u8fd4\u56de<\/li>\n
- _instance：\u58f0\u660e\u4e00\u4e2a\u9759\u6001\u6210\u5458\u53d8\u91cf，\u7528\u4e8e\u5b58\u50a8\u5355\u4f8b\u7c7bAsioIOServicePool\u552f\u4e00\u5b9e\u4f8b，\u901a\u8fc7\u61d2\u6c49\u65b9\u5f0f\u5b9e\u73b0，\u5355\u4f8b\u6a21\u5f0f\u7684\u8be6\u7ec6\u4ecb\u7ecd\u53ef\u53c2\u8003：<\/li>\n<\/ul>\n
\u7231\u5403\u571f\u8c46：\u7f51\u7edc\u7f16\u7a0b（13）\u2014\u2014\u5355\u4f8b\u6a21\u5f0f0 \u8d5e\u540c \u00b7 0 \u8bc4\u8bba\u6587\u7ae0<\/p>\n
b. \u6210\u5458\u51fd\u6570\u5b9e\u73b0<\/h4>\n
void SafeDeletor::operator()(AsioIOServicePool* st) {
\nstd::cout << "this is safe deleter operator() of AsioIOServicePool" << std::endl;
\ndelete st;
\n}<\/p>\n\u4e0d\u80fd\u76f4\u63a5\u8c03\u7528\u5355\u4f8b\u7c7b\u7684\u6790\u6784\u51fd\u6570，\u53ea\u80fd\u901a\u8fc7\u5220\u9664\u5668\u95f4\u63a5\u8c03\u7528，\u5355\u4f8b\u7c7b\u7684\u6784\u9020\u51fd\u6570\u548c\u6790\u6784\u51fd\u6570\u90fd\u79c1\u6709\u5316，\u5e76\u5c06\u590d\u5236\u6784\u9020\u51fd\u6570\u548c\u8d4b\u503c\u8fd0\u7b97\u7b26delete，\u9632\u6b62\u5355\u4f8b\u7c7b\u88ab\u62f7\u8d1d\u548c\u8d4b\u503c\u3002<\/p>\n
AsioIOServicePool::AsioIOServicePool(std::size_t size) :
\n_ioServices(size), _works(size), _nextIOService(0) {
\nfor (std::size_t i = 0; i < size; i++) {
\n_works[i] = std::unique_ptr<Work>(new Work(_ioServices[i]));
\n}<\/p>\n\/\/ \u904d\u5386\u591a\u4e2aioservice,\u521b\u5efa\u591a\u4e2a\u7ebf\u7a0b，\u6bcf\u4e2a\u7ebf\u7a0b\u5185\u90e8\u542f\u52a8ioservice
\nfor (std::size_t i = 0; i < _ioServices.size(); i++) {
\n_threads.emplace_back([this, i]() {
\n_ioServices[i].run();
\n});
\n}
\n}<\/p>\n\u7ebf\u7a0b\u6c60AsioIOServicePool\u7684\u6784\u9020\u51fd\u6570\u9700\u63a5\u6536ioc\u7684\u6307\u5b9a\u6570\u91cfsize，\u5982\u679c\u4e0d\u663e\u5f0f\u6307\u5b9a，\u90a3\u4e48size\u4f1a\u4f7f\u7528\u9ed8\u8ba4\u503c\u00a0std::thread::hardware_concurrency()，\u8be5\u51fd\u6570\u7528\u4e8e\u83b7\u53d6CPU\u6838\u6570\u3002<\/p>\n
work\u7684\u6570\u91cf\u548cioc\u7684\u6570\u91cf\u76f8\u540c，\u7d22\u5f15_nextIOService\u9ed8\u8ba4\u503c\u4e3a0，\u4e0a\u9650\u4e3aioc\u7684\u6570\u91cfsize<\/p>\n
\u8fd8\u6709\u4e24\u4e2afor\u5faa\u73af，\u7b2c\u4e00\u4e2afor\u5faa\u73af\u4f7f\u7528Work()\u51fd\u6570\u5c06\u6307\u5b9aioc\u4e0ework\u7ed1\u5b9a\u5e76\u901a\u8fc7\u53f3\u503c\u79fb\u52a8\u7ed9\u5bf9\u5e94\u4f4d\u7f6e\u7684_works\u5bb9\u5668，\u6b64\u65f6_works\u5bb9\u5668\u4e2d\u5bf9\u5e94\u7d22\u5f15\u4fbf\u5b58\u50a8\u4e86\u4e0e\u5bf9\u5e94ioc\u7ed1\u5b9a\u7684work，\u53ea\u6709\u5c06work\u7ed9reset\u4e4b\u540e，ioc.run()\u624d\u4f1a\u8fd4\u56de\u3002\u7b2c\u4e8c\u4e2afor\u5faa\u73af\u542f\u52a8\u6307\u5b9aioc\u6570\u91cf_size\u7684\u7ebf\u7a0b，\u6bcf\u4e2a\u7ebf\u7a0b\u4e2d\u6709\u72ec\u7acb\u7684ioc，\u5e76\u542f\u52a8ioc.run()<\/p>\n
boost::asio::io_context& AsioIOServicePool::GetIOService() {
\nauto& service = _ioServices[_nextIOService++];
\nif (_nextIOService == _ioServices.size())
\n_nextIOService = 0;<\/p>\nreturn service;
\n}<\/p>\n\u4ee5_nextIOService\u4e3a\u7d22\u5f15\u8f6e\u8be2\u53d6\u51fa\u7ebf\u7a0b\u6c60\u4e2d\u7684io_context<\/p>\n
void AsioIOServicePool::Stop() {
\nfor (auto& work : _works) {
\nwork.reset();
\n}<\/p>\nfor (auto& t : _threads) {
\nt.join();
\n}
\n}<\/p>\n\u4e0d\u540c\u7ebf\u7a0b\u7684io_context\u5982\u679c\u60f3\u8981\u505c\u6b62\u8fd4\u56de，\u90a3\u4e48\u5fc5\u987b\u5c06\u5df2\u7ed1\u5b9a\u7684work\u91ca\u653e，\u8be5\u51fd\u6570\u7528\u4e8e\u91ca\u653e\u6240\u6709ioc\u7684work，\u56e0\u4e3a\u4e0d\u540c\u7ebf\u7a0b\u72ec\u7acb\u8fd0\u884c，\u6240\u4ee5\u5fc5\u987b\u8981\u7b49\u5f85\u6bcf\u4e2a\u7ebf\u7a0b\u7ed3\u675f\u540e\u624d\u7ed3\u675f\u7a0b\u5e8f\u3002<\/p>\n
static std::shared_ptr<AsioIOServicePool> GetInstance() {
\nstatic std::once_flag s_flag;
\nstd::call_once(s_flag, [&]() { \/\/ call_once\u5185\u90e8\u6709\u9501
\n_instance = std::shared_ptr<AsioIOServicePool>(new AsioIOServicePool, SafeDeletor());
\n});
\nreturn _instance;
\n}<\/p>\n\u5b9a\u4e49\u9759\u6001\u6210\u5458\u51fd\u6570GetInstance()，\u901a\u8fc7C++11\u65b0\u7279\u6027once_flag \u548ccall_once\u5b9e\u73b0\u7ebf\u7a0b\u5b89\u5168，\u4fdd\u8bc1\u591a\u7ebf\u7a0b\u4e2dAsioIOServicePool\u53ea\u4f1a\u88ab\u521b\u5efa\u4e00\u6b21，\u6709\u4e14\u4ec5\u6709\u552f\u4e00\u5b9e\u4f8b\u3002<\/p>\n
once_flag \u548ccall_once\u7684\u8be6\u7ec6\u4ecb\u7ecd\u53ef\u53c2\u8003：<\/p>\n
\u7231\u5403\u571f\u8c46：C++11\u65b0\u7279\u60270 \u8d5e\u540c \u00b7 0 \u8bc4\u8bba\u6587\u7ae0<\/p>\n
\u6700\u540e\u6ce8\u610f，\u975e\u6a21\u677f\u7c7b\u7684\u9759\u6001\u6210\u5458\u53d8\u91cf\u548c\u51fd\u6570\u9700\u8981\u5728\u5b9e\u73b0\u6587\u4ef6cpp\u4e2d\u521d\u59cb\u5316，\u4e0d\u80fd\u5728\u5934\u6587\u4ef6\u4e2d\u521d\u59cb\u5316\u3002\u6a21\u677f\u7c7b\u7684\u9759\u6001\u6210\u5458\u53d8\u91cf\u5fc5\u987b\u5728\u5934\u6587\u4ef6\u4e2d\u5b9a\u4e49，\u6a21\u677f\u7c7b\u4e2d\u7684\u9759\u6001\u53d8\u91cf\u53ef\u4ee5\u5728\u5934\u6587\u4ef6\u4e2d\u5b9a\u4e49，\u662f\u56e0\u4e3a\u6a21\u677f\u7c7b\u5728\u7f16\u8bd1\u65f6\u4e0d\u4f1a\u50cf\u666e\u901a\u7c7b\u90a3\u6837\u751f\u6210\u5177\u4f53\u7684\u7c7b\u578b\u548c\u7b26\u53f7\u3002\u76f8\u53cd，\u6a21\u677f\u7c7b\u7684\u4ee3\u7801\u53ea\u4f1a\u5728\u6a21\u677f\u88ab\u5b9e\u4f8b\u5316\u65f6\u624d\u751f\u6210\u5177\u4f53\u7684\u7c7b\u578b\u3002\u56e0\u6b64，\u6a21\u677f\u7c7b\u7684\u9759\u6001\u6210\u5458\u53d8\u91cf\u4e0d\u4f1a\u50cf\u666e\u901a\u7c7b\u7684\u9759\u6001\u6210\u5458\u90a3\u6837\u5728\u591a\u4e2a\u7f16\u8bd1\u5355\u5143\u4e2d\u91cd\u590d\u5b9a\u4e49\u3002<\/p>\n
AsioIOServicePool.cpp
\n\/\/ \u521d\u59cb\u5316
\nstd::shared_ptr<AsioIOServicePool> AsioIOServicePool::_instance = nullptr;<\/p>\n5. \u903b\u8f91\u5c42LogicSystem<\/h3>\n
\u4e00\u822c\u5728\u89e3\u6790\u5b8c\u5bf9\u7aef\u53d1\u9001\u7684\u6570\u636e\u4e4b\u540e，\u8fd8\u8981\u5bf9\u8be5\u8bf7\u6c42\u505a\u66f4\u8fdb\u4e00\u6b65\u5730\u5904\u7406，\u6bd4\u5982\u6839\u636e\u4e0d\u540c\u7684\u6d88\u606fid\u6267\u884c\u4e0d\u540c\u7684\u903b\u8f91\u5c42\u51fd\u6570\u6216\u4e0d\u540c\u7684\u64cd\u4f5c，\u6bd4\u5982\u8bfb\u6570\u636e\u5e93\u3001\u5199\u6570\u636e\u5e93，\u8fd8\u6bd4\u5982\u6e38\u620f\u4e2d\u53ef\u80fd\u9700\u8981\u7ed9\u73a9\u5bb6\u53e0\u52a0\u4e0d\u540c\u7684buff\u3001\u589e\u52a0\u79ef\u5206\u7b49\u7b49，\u8fd9\u4e9b\u90fd\u9700\u8981\u4ea4\u7ed9\u903b\u8f91\u5c42\u5904\u7406，\u800c\u4e0d\u4ec5\u4ec5\u662f\u628a\u6d88\u606f\u53d1\u7ed9\u5bf9\u7aef\u3002<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250419143636-6803b4f42ea25.png\")
<\/p>\n\u670d\u52a1\u5668\u67b6\u6784<\/p>\n
\u4e0a\u56fe\u6240\u793a\u7684\u662f\u4e00\u4e2a\u5b8c\u6210\u7684\u670d\u52a1\u5668\u67b6\u6784，\u4e00\u822c\u9700\u8981\u5c06\u903b\u8f91\u5c42\u72ec\u7acb\u51fa\u6765，\u56e0\u4e3a\u5982\u679c\u5728\u89e3\u6790\u5b8c\u5bf9\u7aef\u6570\u636e\u540e\u9700\u8981\u6267\u884c\u4e00\u4e9b\u590d\u6742\u7684\u64cd\u4f5c，\u6bd4\u5982\u73a9\u5bb6\u9700\u8981\u53e0\u52a0\u5404\u81eabuff\u6216\u8005\u6280\u80fd，\u6b64\u65f6\u53ef\u80fd\u4f1a\u8017\u65f61s\u751a\u81f3\u66f4\u591a，\u5982\u679c\u6ca1\u6709\u72ec\u7acb\u7684\u903b\u8f91\u5c42\u8fdb\u884c\u64cd\u4f5c，\u90a3\u4e48\u7cfb\u7edf\u4f1a\u4e00\u76f4\u505c\u7559\u5728\u6267\u884c\u56de\u8c03\u51fd\u6570\u90a3\u4e00\u6b65，\u9020\u6210\u963b\u585e，\u76f4\u81f3\u64cd\u4f5c\u7ed3\u675f\u3002<\/p>\n
\u800c\u903b\u8f91\u5c42\u662f\u72ec\u7acb\u7684，\u56de\u8c03\u51fd\u6570\u53ea\u9700\u5c06\u6570\u636e\u6295\u9012\u7ed9\u903b\u8f91\u961f\u5217（\u56de\u8c03\u51fd\u6570\u5c06\u6570\u636e\u653e\u5165\u961f\u5217\u4e2d\u4e4b\u540e\u7cfb\u7edf\u4f1a\u8fd0\u884c\u4e0b\u4e00\u6b65，\u4fbf\u4e0d\u4f1a\u88ab\u963b\u585e），\u903b\u8f91\u7cfb\u7edf\u4f1a\u81ea\u52a8\u4ece\u961f\u5217\u4e2d\u53d6\u6570\u636e\u5e76\u505a\u76f8\u5e94\u64cd\u4f5c，\u5982\u679c\u9700\u8981\u5728\u6267\u884c\u5b8c\u64cd\u4f5c\u4e4b\u540e\u505a\u76f8\u5e94\u56de\u590d，\u90a3\u4e48\u903b\u8f91\u7cfb\u7edf\u4f1a\u8c03\u7528\u5199\u4e8b\u4ef6\u5e76\u6ce8\u518c\u5199\u56de\u8c03\u7ed9asio\u7f51\u7edc\u5c42，\u7f51\u7edc\u5c42\u5c31\u662fasio\u5e95\u5c42\u901a\u4fe1\u7684\u7f51\u7edc\u5c42\u6b65\u9aa4\u3002<\/p>\n
a. LogicSystem.h<\/h4>\n
#pragma once
\n#include <queue>
\n#include <thread>
\n#include "CSession.h"
\n#include <map>
\n#include <functional>
\n#include "Const.h"
\n#include <json\/json.h>
\n#include <json\/value.h>
\n#include <json\/reader.h><\/p>\nclass LogicNode;
\nclass CSession;<\/p>\ntypedef std::function<void(std::shared_ptr<CSession>, const short& msg_id, const std::string& msg_data)> FunCallBack;<\/p>\n
class LogicSystem
\n{
\nprivate:
\nLogicSystem();
\n~LogicSystem();
\nLogicSystem(const LogicSystem&) = delete;
\nLogicSystem& operator=(const LogicSystem&) = delete;<\/p>\nvoid RegisterCallBacks();
\nvoid HelloWordCallBack(std::shared_ptr<CSession>, const short& msg_id, const std::string& msg_data);
\nvoid DealMsg();<\/p>\nstd::queue<std::shared_ptr<LogicNode>> _msg_que;
\nstd::mutex _mutex;
\nstd::condition_variable _consume;
\nstd::thread _worker_thread;
\nbool _b_stop;
\nstd::map<short, FunCallBack> _fun_callback;
\npublic:
\nvoid PostMsgToQue(std::shared_ptr<LogicNode> msg);
\nstatic LogicSystem& GetInstance();
\n};<\/p>\n\u5b9a\u4e49\u903b\u8f91\u7c7b\u7684\u5934\u6587\u4ef6，\u6210\u5458\u51fd\u6570\u5728\u540e\u9762\u5b9a\u4e49\u65f6\u8be6\u7ec6\u4ecb\u7ecd，\u8fd9\u91cc\u4ecb\u7ecd\u4e00\u4e0b\u903b\u8f91\u7c7b\u7684\u6210\u5458\u53d8\u91cf：<\/p>\n
- \n
- FunCallBack\u4e3a\u8981\u6ce8\u518c\u7684\u56de\u8c03\u51fd\u6570\u7c7b\u578b，\u5176\u53c2\u6570\u4e3a\u4f1a\u8bddSession\u7c7b\u667a\u80fd\u6307\u9488，\u6d88\u606fid，\u4ee5\u53ca\u6d88\u606f\u5185\u5bb9\u3002<\/li>\n
- _msg_que\u4e3a\u903b\u8f91\u961f\u5217，\u5176\u4e2d\u7684\u5143\u7d20\u76f8\u5f53\u4e8eRecvNode，\u53ea\u4e0d\u8fc7\u4e3a\u4e86\u5b9e\u73b0\u4f2a\u95ed\u5305，\u6240\u4ee5\u521b\u5efa\u4e00\u4e2aLogicNode\u7c7b，\u5305\u542bSession\u7684\u667a\u80fd\u6307\u9488\u9632\u6b62\u88ab\u63d0\u524d\u91ca\u653e<\/li>\n
- _mutex\u00a0\u4e3a\u4fdd\u8bc1\u903b\u8f91\u961f\u5217\u5b89\u5168\u7684\u4e92\u65a5\u91cf<\/li>\n
- _consume\u8868\u793a\u6d88\u8d39\u8005\u6761\u4ef6\u53d8\u91cf，\u7528\u6765\u63a7\u5236\u5f53\u903b\u8f91\u961f\u5217\u4e3a\u7a7a\u65f6\u4fdd\u8bc1\u7ebf\u7a0b\u6682\u65f6\u6302\u8d77\u7b49\u5f85，\u4e0d\u8981\u5e72\u6270\u5176\u4ed6\u7ebf\u7a0b\u3002<\/li>\n
- _fun_callbacks\u7528\u4e8e\u5b58\u50a8\u6d88\u606fid\u548c\u5bf9\u5e94\u6d88\u606fid\u7684\u56de\u8c03\u51fd\u6570，\u6839\u636eid\u67e5\u627e\u5bf9\u5e94\u7684\u903b\u8f91\u5904\u7406\u51fd\u6570\u3002<\/li>\n
- _worker_thread\u8868\u793a\u5de5\u4f5c\u7ebf\u7a0b，\u7528\u6765\u4ece\u903b\u8f91\u961f\u5217\u4e2d\u53d6\u6570\u636e\u5e76\u6267\u884c\u56de\u8c03\u51fd\u6570\u3002<\/li>\n
- _b_stop\u8868\u793a\u6536\u5230\u5916\u90e8\u7684\u505c\u6b62\u4fe1\u53f7，\u903b\u8f91\u7c7b\u8981\u4e2d\u6b62\u5de5\u4f5c\u7ebf\u7a0b\u5e76\u4f18\u96c5\u9000\u51fa\u3002<\/li>\n<\/ul>\n
_fun_callback\u7684\u5b9a\u4e49\u5982\u4e0b：<\/p>\n
typedef std::function<void(std::shared_ptr<CSession>, const short& msg_id, const std::string& msg_data)> FunCallBack;<\/p>\n
std::map<short, FunCallBack> _fun_callback;<\/p>\n
_fun_callback\u662f\u4e00\u4e2amap，\u503c\u548c\u952e\u7684\u7c7b\u578b\u5206\u522b\u4e3ashort\u548cFunCallBack，\u524d\u8005\u662f\u6d88\u606fid\u7684\u7c7b\u578b，\u540e\u8005\u662f\u56de\u8c03\u51fd\u6570\u3002<\/p>\n
FunCallBack\u4f7f\u7528\u4e86C++11\u65b0\u7279\u6027std::function\u6765\u58f0\u660e\u4e86\u4e00\u4e2a\u51fd\u6570\u7b7e\u540d，\u8868\u793a\u63a5\u53d7\u4e00\u4e2a\u00a0shared_ptr\u00a0\u6307\u5411\u00a0CSession\u3001\u4e00\u4e2a\u00a0short\u00a0\u7c7b\u578b\u7684\u6d88\u606f ID \u548c\u4e00\u4e2a\u00a0std::string\u00a0\u7c7b\u578b\u7684\u6d88\u606f\u6570\u636e\u7684\u53ef\u8c03\u7528\u5bf9\u8c61<\/p>\n
std::function\u7684\u8be6\u7ec6\u4ecb\u7ecd\u53ef\u53c2\u8003<\/p>\n
\u7231\u5403\u571f\u8c46：C++11\u65b0\u7279\u60270 \u8d5e\u540c \u00b7 0 \u8bc4\u8bba\u6587\u7ae0<\/p>\n
\u56e0\u4e3a\u903b\u8f91\u961f\u5217\u5b58\u50a8\u7684\u6210\u5458\u9700\u8981\u5305\u542b\u5bf9\u5e94session\u548c\u6d88\u606f\u5185\u5bb9，\u6240\u4ee5\u9700\u8981\u91cd\u65b0\u5b9a\u4e49\u4e00\u4e2a\u903b\u8f91\u8282\u70b9，\u7528\u4e8e\u5b58\u50a8\u4f1a\u8bddsession\u4e2d\u5c06\u5bf9\u5e94\u6d88\u606f\u6295\u9012\u81f3\u903b\u8f91\u961f\u5217\u7684\u5185\u5bb9，\u5305\u62ec\u8be5session\u548c\u6d88\u606f\u5185\u5bb9\u3002<\/p>\n
b. LogicNode<\/h4>\n
class LogicNode {
\nfriend class LogicSystem;
\npublic:
\nLogicNode(std::shared_ptr<CSession>, std::shared_ptr<RecvNode>);
\nprivate:
\nstd::shared_ptr<CSession> _session;
\nstd::shared_ptr<RecvNode> _recvnode;
\n};<\/p>\nLogicNode\u7c7b\u5b9a\u4e49\u5728CSession.h\u4e2d，CSession.h\u5728\u6587\u7ae0\u540e\u9762\u4ecb\u7ecd<\/p>\n
- \n
- _session：\u58f0\u660eSession\u7684\u667a\u80fd\u6307\u9488，\u5b9e\u73b0\u4f2a\u95ed\u5305，\u9632\u6b62Session\u88ab\u63d0\u524d\u91ca\u653e<\/li>\n
- _recvnode：\u63a5\u6536\u6d88\u606f\u8282\u70b9\u7684\u667a\u80fd\u6307\u9488<\/li>\n<\/ul>\n
\u6784\u9020\u51fd\u6570\u5982\u4e0b：<\/p>\n
LogicNode::LogicNode(std::shared_ptr<CSession> session, std::shared_ptr<RecvNode> recvnode) :
\n_session(session), _recvnode(recvnode){}<\/p>\n\u7528\u4e8e\u63a5\u6536\u4e00\u4e2asession\u4f1a\u8bdd\u548c\u8be5\u4f1a\u8bdd\u6295\u9012\u7684\u6d88\u606f\u5185\u5bb9<\/p>\n
c. \u6210\u5458\u51fd\u6570\u5b9e\u73b0<\/h4>\n
LogicSystem::LogicSystem() :_b_stop(false) {
\nRegisterCallBacks();
\n_worker_thread = std::thread(&LogicSystem::DealMsg, this);
\n}<\/p>\n- \n
- _b_stop\u521d\u59cb\u5316\u4e3afalse，\u5f53\u524d\u5de5\u4f5c\u7ebf\u7a0b\u4e0d\u4f1a\u505c\u6b62<\/li>\n
- RegisterCallBacks()：\u8c03\u7528\u56de\u8c03\u6ce8\u518c\u51fd\u6570：\u8fd9\u4e2a\u51fd\u6570\u7528\u4e8e\u6ce8\u518c\u6d88\u606f\u5904\u7406\u7684\u56de\u8c03\u51fd\u6570\u3002\u5c06\u4e0d\u540c\u7684\u6d88\u606f ID \u548c\u5bf9\u5e94\u7684\u5904\u7406\u51fd\u6570\u5173\u8054\u8d77\u6765，\u4ee5\u4fbf\u5728\u5904\u7406\u6d88\u606f\u65f6\u80fd\u591f\u627e\u5230\u6b63\u786e\u7684\u51fd\u6570\u3002<\/li>\n
- _worker_thread = std::thread(&LogicSystem::DealMsg, this);\n
- \n
- \u521b\u5efa\u5de5\u4f5c\u7ebf\u7a0b：\u4f7f\u7528 std::thread \u521b\u5efa\u4e00\u4e2a\u65b0\u7684\u7ebf\u7a0b\u3002<\/li>\n
- &LogicSystem::DealMsg：\u6307\u5b9a\u8981\u5728\u65b0\u7ebf\u7a0b\u4e2d\u6267\u884c\u7684\u6210\u5458\u51fd\u6570，\u5373 DealMsg，\u8be5\u51fd\u6570\u5c06\u8d1f\u8d23\u4ece\u6d88\u606f\u961f\u5217\u4e2d\u63d0\u53d6\u6d88\u606f\u5e76\u5904\u7406\u5b83\u3002<\/li>\n
- this：\u4f20\u9012\u5f53\u524d\u5bf9\u8c61\u7684\u6307\u9488，\u4ee5\u4fbf DealMsg \u53ef\u4ee5\u8bbf\u95ee LogicSystem \u7684\u6210\u5458\u53d8\u91cf\u548c\u51fd\u6570\u3002<\/li>\n<\/ul>\n<\/li>\n<\/ul>\n
void LogicSystem::RegisterCallBacks() {
\n_fun_callback[MSG_HELLO_WORD] = std::bind(&LogicSystem::HelloWordCallBack,
\nthis, std::placeholders::_1, std::placeholders::_2, std::placeholders::_3);
\n}<\/p>\n\u5c06\u6d88\u606fID：MSG_HELLO_WORD\u6620\u5c04\u81f3\u56de\u8c03\u51fd\u6570HelloWordCallBack，\u5e76\u5b58\u50a8\u81f3_fun_callback\u3002\u5f53\u63a5\u6536\u5230\u6d88\u606fMSG_HELLO_WORD\u65f6，\u7cfb\u7edf\u4f1a\u8c03\u7528 HelloWordCallBack \u65b9\u6cd5\u6765\u5904\u7406\u6d88\u606f\u3002<\/p>\n
void LogicSystem::HelloWordCallBack(std::shared_ptr<CSession> session, const short& msg_id, const std::string& msg_data) {
\nJson::Reader reader;
\nJson::Value root;
\nreader.parse(msg_data, root);
\nstd::cout << "receive msg id is " << root["id"].asInt() << " msg data is "
\n<< root["data"].asString() << std::endl;
\nroot["data"] = "server has receive msg, msg data is " + root["data"].asString();<\/p>\nstd::string return_str = root.toStyledString();
\nsession->Send(return_str, root["id"].asInt());
\n}<\/p>\n- \n
- HelloWordCallBack\u662f\u5bf9\u5e94\u6d88\u606fid：MSG_HELLO_WORD\u7684\u56de\u8c03\u51fd\u6570\n
- \n
- \u4f7f\u7528jsoncpp\u5e93\u5305\u88c5\u6216\u8005\u89e3\u6790\u6570\u636e<\/li>\n
- \u8c03\u7528 parse \u65b9\u6cd5\u5c06\u00a0msg_data\u00a0\u5b57\u7b26\u4e32\u89e3\u6790\u4e3a JSON \u683c\u5f0f，\u7ed3\u679c\u5b58\u50a8\u5728 root \u4e2d<\/li>\n
- \u901a\u8fc7session\u7c7b\u7684send\u56de\u4f20\u6d88\u606f<\/li>\n<\/ul>\n<\/li>\n<\/ul>\n
void LogicSystem::DealMsg() {
\nfor (;;) {
\nstd::unique_lock<std::mutex> unique_lk(_mutex);
\n\/\/ \u5faa\u73af\u4f1a\u8017\u8d39\u8d44\u6e90，\u8fd9\u91cc\u4f7f\u7528\u6761\u4ef6\u53d8\u91cf\u6302\u8d77\u7ebf\u7a0b，\u5e76\u91ca\u653e\u9501，\u76f4\u81f3\u88ab\u5524\u9192
\nwhile (_msg_que.empty() and !_b_stop) {
\n_consume.wait(unique_lk);
\n}<\/p>\n\/\/ \u5224\u65ad\u5982\u679c\u4e3a\u5173\u95ed\u72b6\u6001，\u53d6\u51fa\u903b\u8f91\u961f\u5217\u6240\u6709\u6570\u636e\u5904\u7406\u5e76\u9000\u51fa\u5faa\u73af
\nif (_b_stop) {
\nwhile (!_msg_que.empty()) {
\nauto msg_node = _msg_que.front();
\nstd::cout << "recv msg id is " << msg_node->_recvnode->GetMsgID() << std::endl;
\nauto call_back_iter = _fun_callback.find(msg_node->_recvnode->GetMsgID());
\nif (call_back_iter == _fun_callback.end()) { \/\/ \u5982\u679c\u672a\u6ce8\u518c\u5bf9\u5e94\u6d88\u606fid\u7684\u56de\u8c03\u51fd\u6570
\n_msg_que.pop(); \/\/ \u91ca\u653e\u8be5\u6d88\u606f
\ncontinue; \/\/ \u5904\u7406\u4e0b\u4e00\u6761\u6d88\u606f
\n}
\n\/\/ \u53d6\u51fa\u5bf9\u5e94\u6d88\u606fid\u7684\u56de\u8c03\u51fd\u6570
\ncall_back_iter->second(msg_node->_session, msg_node->_recvnode->GetMsgID(),
\nstd::string(msg_node->_recvnode->_data, msg_node->_recvnode->_total_len));
\n_msg_que.pop();
\n}
\nbreak;
\n}<\/p>\n\/\/ \u5982\u679c\u6ca1\u6709\u505c\u670d，\u4e14\u961f\u5217\u4e0d\u4e3a\u7a7a
\nauto msg_node = _msg_que.front();
\nstd::cout << "recv msg id is " << msg_node->_recvnode->GetMsgID() << std::endl;<\/p>\nauto call_back_iter = _fun_callback.find(msg_node->_recvnode->GetMsgID());
\n\/\/ \u82e5\u961f\u5217\u4e2d\u6ca1\u6709\u8be5\u6d88\u606f\u5bf9\u5e94\u7684\u56de\u8c03\u51fd\u6570，\u5219\u91ca\u653e\u8be5\u6d88\u606f\u5e76\u5904\u7406\u4e0b\u4e00\u6761
\n\/\/ \u6ce8\u518c_fun_callback\u65f6，\u5c06\u6d88\u606fid\u4ee5\u53ca\u5339\u914d\u7684\u56de\u8c03\u51fd\u6570\u7ed1\u5b9a\u5728\u4e00\u8d77
\nif (call_back_iter == _fun_callback.end()) {
\n_msg_que.pop();
\ncontinue;
\n}
\n\/\/ \u6267\u884c\u6d88\u606f\u7c7b\u578b\u5bf9\u5e94\u7684\u56de\u8c03\u51fd\u6570
\ncall_back_iter->second(msg_node->_session, msg_node->_recvnode->GetMsgID(),
\nstd::string(msg_node->_recvnode->_data, msg_node->_recvnode->_total_len));
\n_msg_que.pop();
\n}
\n}<\/p>\n\u5f53\u903b\u8f91\u7c7b\u5b9e\u4f8b\u5316\u540e，\u5f00\u59cb\u5faa\u73af\u8fd0\u884c\u6d88\u606f\u5904\u7406\u51fd\u6570DealMsg()<\/p>\n
\u4e3a\u4e86\u5b9e\u73b0\u81ea\u7531\u52a0\u89e3\u9501，\u5b9a\u4e49\u4e00\u4e2aunique_lock\u7c7b\u7684\u9501unique_lk<\/p>\n
\u5f53\u903b\u8f91\u961f\u5217\u4e3a\u7a7a\u5e76\u4e14\u670d\u52a1\u5668\u672a\u505c\u6b62\u65f6，\u8fdb\u884c\u7b49\u5f85while\u5faa\u73af\u4e2d，\u56e0\u4e3awhile\u5faa\u73af\u4e5f\u4f1a\u5360\u7528\u8d44\u6e90，\u6240\u4ee5\u4f7f\u7528C++11\u7279\u6027\u6761\u4ef6\u53d8\u91cf\u00a0std::condition_variable\u5c06\u7ebf\u7a0b\u6302\u8d77，\u8be5\u7ebf\u7a0b\u4e0d\u4f1a\u5360\u7528cpu\u8d44\u6e90，\u5e76\u91ca\u653e\u9501\u4f7f\u5f97\u5176\u4ed6\u7ebf\u7a0b\u53ef\u4ee5\u83b7\u53d6\u5171\u4eab\u8d44\u6e90，\u7ebf\u7a0b\u6302\u8d77\u6301\u7eed\u81f3\u88ab\u5524\u9192（notify_one()\u6216\u8005notify_all()）\u3002\u6761\u4ef6\u53d8\u91cf\u7684\u8be6\u7ec6\u4ecb\u7ecd\u53ef\u53c2\u8003<\/p>\n
\u7231\u5403\u571f\u8c46：C++11\u65b0\u7279\u60270 \u8d5e\u540c \u00b7 0 \u8bc4\u8bba\u6587\u7ae0<\/p>\n
\u5f53\u7ebf\u7a0b\u88ab\u5524\u9192\u540e，\u5982\u679c\u670d\u52a1\u5668\u5173\u95ed，\u5219\u53d6\u51fa\u903b\u8f91\u961f\u5217\u6240\u6709\u6570\u636e\u5904\u7406\u5e76\u9000\u51fa\u5faa\u73af<\/p>\n
\u5f53\u7ebf\u7a0b\u88ab\u5524\u9192\u540e，\u5982\u679c\u961f\u5217\u4e0d\u4e3a\u7a7a\u4e14\u670d\u52a1\u5668\u672a\u5173\u95ed，\u90a3\u4e48\u53d6\u51fa\u961f\u5217\u7b2c\u4e00\u4e2a\u6570\u636e，\u5e76\u5728\u6ce8\u518cmap\u4e2d\u67e5\u627e\u5bf9\u5e94\u6570\u636eid\u7684\u56de\u8c03\u51fd\u6570，\u5982\u679c\u6ca1\u6709\u627e\u5230，\u90a3\u4e48\u91ca\u653e\u8be5\u6570\u636e\u5e76\u5904\u7406\u4e0b\u4e00\u6761\u6d88\u606f；\u53cd\u4e4b，\u8c03\u7528\u8be5\u56de\u8c03\u51fd\u6570\u3002\u8fd9\u91cc\u6211\u4eec\u53ea\u4f1a\u4f20\u5165\u6d88\u606fid：MSG_HELLO_WORD，\u56de\u8c03\u51fd\u6570HelloWordCallBack\u4f1a\u88ab\u8c03\u7528<\/p>\n
LogicSystem::~LogicSystem() {
\nstd::cout << "\u903b\u8f91\u5c42\u6210\u529f\u6790\u6784" << std::endl;
\n_b_stop = true;
\n_consume.notify_one();
\n_worker_thread.join();
\n}<\/p>\n\u903b\u8f91\u7c7b\u7684\u6790\u6784\u51fd\u6570\u5728\u6240\u6709\u5de5\u4f5c\u7ebf\u7a0b\u8fd0\u884c\u7ed3\u675f\u540e\u88ab\u6267\u884c，\u4f46\u5de5\u4f5c\u7ebf\u7a0b\u53ef\u80fd\u4f1a\u5904\u4e8e\u6302\u8d77\u72b6\u6001，\u6b64\u65f6\u9700\u8981\u4e00\u4e2a\u6fc0\u6d3b\u4fe1\u53f7\u6253\u65ad_consume\u7684wait\u72b6\u6001（\u5728\u8be5\u547d\u4ee4\u524d\u4e00\u6b65\u5c06_b_stop\u7f6e\u4e3atrue）<\/p>\n
void LogicSystem::PostMsgToQue(std::shared_ptr<LogicNode> msg) {
\nstd::unique_lock<std::mutex> unique_lk(_mutex); \/\/ \u9501\u5b9a\u4e92\u65a5\u91cf\u4ee5\u4fdd\u62a4\u5171\u4eab\u6570\u636e
\n_msg_que.push(msg); \/\/ \u5c06\u6d88\u606f\u63a8\u5165\u961f\u5217<\/p>\nif (_msg_que.size() == 1) { \/\/ \u5982\u679c\u8fd9\u662f\u961f\u5217\u4e2d\u7684\u7b2c\u4e00\u4e2a\u6d88\u606f
\n_consume.notify_one(); \/\/ \u901a\u77e5\u6d88\u8d39\u8005\u7ebf\u7a0b，\u7ed3\u675fwait\u72b6\u6001
\n}
\n}<\/p>\n\u8be5\u51fd\u6570\u5728Session\u4f1a\u8bdd\u4e2d\u5c06\u5bf9\u5e94session\u6307\u9488\u548c\u6d88\u606f\u5185\u5bb9\u6295\u9012\u81f3\u903b\u8f91\u961f\u5217\u5904\u7406\u3002<\/p>\n
LogicSystem& LogicSystem::GetInstance() {
\n\/\/ \u8fd4\u56de\u5c40\u90e8\u9759\u6001\u53d8\u91cf\u5728C++11\u53ca\u4ee5\u4e0a\u662f\u7ebf\u7a0b\u5b89\u5168\u7684
\nstatic LogicSystem instance;
\nreturn instance;
\n}<\/p>\nLogicSystem\u7c7b\u4e5f\u662f\u4e00\u4e2a\u5355\u4f8b\u6a21\u5f0f，\u6211\u8fd9\u91cc\u4f7f\u7528\u4e86\u7b2c\u4e8c\u79cd\u65b9\u5f0f\u6765\u5b9a\u4e49\u5355\u4f8b\u6a21\u5f0f\u3002\u6211\u4eec\u53ea\u9700\u8981\u5b9a\u4e49\u4e00\u4e2a\u9759\u6001\u6210\u5458\u51fd\u6570GetInstance()，\u5728\u8be5\u51fd\u6570\u4e2d\u8fd4\u56de\u5c40\u90e8\u9759\u6001\u53d8\u91cfinstance，instance\u662fLogicSystem \u7684\u5b9e\u4f8b\u3002\u8be5\u65b9\u6cd5\u53ea\u80fd\u5728C++11\u53ca\u4ee5\u540e\u7684\u5e73\u53f0\u624d\u53ef\u4ee5\u4f7f\u7528，\u56e0\u4e3a\u8fd4\u56de\u5c40\u90e8\u9759\u6001\u53d8\u91cf\u53ea\u6709\u5728C++11\u53ca\u4ee5\u4e0a\u662f\u7ebf\u7a0b\u5b89\u5168\u7684\u3002<\/p>\n
\u903b\u8f91\u7c7b\u7684\u8be6\u7ec6\u4ecb\u7ecd\u53ef\u53c2\u8003：<\/p>\n
\u7231\u5403\u571f\u8c46：\u7f51\u7edc\u7f16\u7a0b（12）\u2014\u2014\u5b8c\u5584\u7c98\u5305\u5904\u7406\u64cd\u4f5c+asio\u5e95\u5c42\u901a\u4fe1\u8fc7\u7a0b2 \u8d5e\u540c \u00b7 0 \u8bc4\u8bba\u6587\u7ae0<\/p>\n
\u7231\u5403\u571f\u8c46：\u7f51\u7edc\u7f16\u7a0b（14）\u2014\u2014\u57fa\u4e8e\u5355\u4f8b\u6a21\u677f\u5b9e\u73b0\u7684\u903b\u8f91\u5c421 \u8d5e\u540c \u00b7 0 \u8bc4\u8bba\u6587\u7ae0<\/p>\n
6. CSession<\/h3>\n
CSession\u7528\u4e8e\u63a5\u6536\u5ba2\u6237\u7aef\u7684\u8fde\u63a5，\u5e76\u5904\u7406\u5f02\u6b65\u6536\u53d1，\u5728\u8be5\u7c7b\u4e2d，\u6784\u9020\u4e00\u4e2a\u6536\u534f\u7a0b\u7528\u4e8e\u63a5\u6536\u6570\u636e，\u4f46\u53d1\u4ecd\u7136\u901a\u8fc7Send\u51fd\u6570\u8fdb\u884c\u961f\u5217\u53d1\u9001，\u4e0d\u5728\u6784\u9020\u4e00\u4e2a\u53d1\u534f\u7a0b\u3002\u7406\u7531\u5982\u4e0b：<\/p>\n
- \n
- \u53ef\u4ee5\u6784\u5efa\u53d1\u9001\u534f\u7a0b\u7528\u4e8e\u53d1\u9001\u6570\u636e，\u4f46\u8003\u8651\u5230\u534f\u7a0b\u5f88\u5927\u7a0b\u5ea6\u4e0a\u5728\u4f7f\u7528\u5c42\u9762\u7b80\u5316\u4e86\u4ee3\u7801，\u4f46\u5b9e\u9645\u4e0a\u4e5f\u8017\u8d39\u8d44\u6e90，\u5982\u679c\u670d\u52a1\u5668\u8fdb\u884c\u9891\u7e41\u53d1\u9001\u64cd\u4f5c，\u4e14\u5904\u4e8e\u4efb\u4f55\u65f6\u523b\u90fd\u53ef\u80fd\u8c03\u7528\u7684\u60c5\u51b5\u4e0b，\u4f7f\u7528\u534f\u7a0b\u53ef\u80fd\u5e76\u4e0d\u65b9\u4fbf ，\u56e0\u4e3a\u53ef\u80fd\u5728\u4e00\u4e2a\u7ebf\u7a0b\u4e2d，\u968f\u7740\u53d1\u9001\u6b21\u6570\u7684\u4e0a\u5347，\u542f\u52a8\u5f88\u591a\u534f\u7a0b<\/li>\n
- \u8fd8\u6709\u4e00\u4e2a\u539f\u56e0\u662f：\u5982\u679c\u53d1\u9001\u7684\u65f6\u5019\u5904\u4e8e\u53e6\u4e00\u4e2a\u7ebf\u7a0b，\u5982\u679c\u7528\u53d1\u9001\u534f\u7a0b\u7684\u8bdd，\u53ef\u80fd\u4f1a\u5bfc\u81f4\u5176\u4ed6\u7ebf\u7a0b\u58f0\u660e\u5468\u671f\u7684\u6539\u53d8<\/li>\n<\/ul>\n
\u6240\u4ee5\u6211\u4eec\u8fd9\u91cc\u4ecd\u7136\u4f7f\u7528\u4e4b\u524d\u4ee3\u7801\u4e2d\u7528\u5230\u7684\u53d1\u9001\u961f\u5217\u7684\u65b9\u5f0f\u3002<\/p>\n
a. CSession.h<\/h4>\n
#pragma once
\n#include <iostream>
\n#include <boost\/asio.hpp>
\n#include <queue>
\n#include "MsgNode.h"
\n#include "LogicSystem.h"<\/p>\nclass CServer;<\/p>\n
class CSession :public std::enable_shared_from_this<CSession>
\n{
\nprivate:
\nvoid HandleWrite(const boost::system::error_code& error, std::shared_ptr<CSession> shared_self);
\nboost::asio::io_context& _io_context;
\nCServer* _server;
\nboost::asio::ip::tcp::socket _socket;
\nstd::string _uuid;
\nbool _b_close;
\nstd::mutex _send_lock;
\nstd::queue<std::shared_ptr<SendNode>> _send_que;
\nstd::shared_ptr<RecvNode> _recv_msg_node;
\nstd::shared_ptr<MsgNode> _recv_head_node;
\npublic:
\nCSession(boost::asio::io_context& io_context, CServer* server);
\n~CSession();
\nboost::asio::ip::tcp::socket& GetSocket();
\nvoid Start();
\nstd::string& GetUuid();
\nvoid Close();
\nvoid Send(const char* msg, short max_length, short msg_id);
\nvoid Send(std::string msg, short msg_id);
\n};<\/p>\nclass LogicNode {
\nfriend class LogicSystem;
\npublic:
\nLogicNode(std::shared_ptr<CSession>, std::shared_ptr<RecvNode>);
\nprivate:
\nstd::shared_ptr<CSession> _session;
\nstd::shared_ptr<RecvNode> _recvnode;
\n};<\/p>\n\u540c\u6837，CSession\u7c7b\u7684\u6210\u5458\u51fd\u6570\u5728\u540e\u9762\u5b9a\u4e49\u65f6\u8be6\u7ec6\u4ecb\u7ecd，\u8fd9\u91cc\u4ec5\u4ecb\u7ecd\u6210\u5458\u53d8\u91cf：<\/p>\n
- \n
- boost::asio::io_context&\u00a0_io_context：\u7528\u4e8e\u63a5\u6536\u4ece\u7ebf\u7a0b\u6c60AsioIOServicePool\u4e2d\u63d0\u53d6\u7684ioc，\u6ce8\u610f，\u8fd9\u91cc\u662f\u5f15\u7528\u800c\u4e0d\u662f\u91cd\u65b0\u58f0\u660e\u4e00\u4e2aio_context\u65b0\u5b9e\u4f8b<\/li>\n
- CServer* _server：\u63a5\u6536CServer\u6307\u9488，\u5f53Session\u6536\u53d1\u64cd\u4f5c\u51fa\u9519\u65f6，\u65b9\u4fbf\u8c03\u7528Server\u7684Clear\u51fd\u6570\u64e6\u9664\u8be5session\u4f1a\u8bdd\u4efb\u52a1<\/li>\n
- _socket：\u6bcf\u4e2asession\u90fd\u6709\u4e00\u4e2a\u72ec\u7acb\u7684\u5957\u63a5\u5b57，\u8d1f\u8d23\u5f02\u6b65\u6536\u53d1<\/li>\n
- _b_close：session\u4f1a\u8bdd\u4efb\u52a1\u662f\u5426\u7ed3\u675f\u7684\u6807\u5fd7\u4f4d<\/li>\n
- _send_que：\u53d1\u9001\u961f\u5217，\u903b\u8f91\u5c42\u4f1a\u8c03\u7528session\u7684Send\u53d1\u9001\u51fd\u6570，Send\u51fd\u6570\u4f1a\u5c06\u9700\u8981\u53d1\u9001\u7684\u6d88\u606f\u6dfb\u52a0\u5230\u53d1\u9001\u961f\u5217，\u4fdd\u8bc1\u53d1\u9001\u7684\u987a\u5e8f\u6027<\/li>\n
- _recv_msg_node：\u63a5\u6536\u8282\u70b9，\u5c06\u63a5\u6536\u7684\u6d88\u606f\u5b58\u50a8\u81f3\u8be5\u8282\u70b9，\u5305\u62ec\u6d88\u606fid\u548c\u6d88\u606f\u5185\u5bb9<\/li>\n
- _recv_head_node：\u6d88\u606f\u5934\u8282\u70b9，\u5c06\u6536\u5230\u6d88\u606f\u7684id\u548c\u957f\u5ea6\u5b58\u50a8\u81f3\u8be5\u8282\u70b9<\/li>\n
- LogicNode：\u903b\u8f91\u8282\u70b9，\u8d1f\u8d23\u5c06session\u548c\u6d88\u606f\u5185\u5bb9\u6295\u9012\u81f3\u903b\u8f91\u961f\u5217，\u903b\u8f91\u961f\u5217\u5143\u7d20\u7684\u683c\u5f0f\u4e3aLogicNode<\/li>\n<\/ul>\n
b. \u6210\u5458\u51fd\u6570\u5b9e\u73b0<\/h4>\n
CSession::CSession(boost::asio::io_context& io_context, CServer* server) :
\n_io_context(io_context), _server(server), _socket(io_context), _b_close(false) {
\n\/\/ random_generator\u662f\u51fd\u6570\u5bf9\u8c61，\u52a0()\u5c31\u662f\u51fd\u6570，\u518d\u52a0\u4e00\u4e2a()\u5c31\u662f\u8c03\u7528\u8be5\u51fd\u6570
\nboost::uuids::uuid a_uuid = boost::uuids::random_generator()();
\n_uuid = boost::uuids::to_string(a_uuid);
\n_recv_head_node = std::make_shared<MsgNode>(HEAD_TOTAL_LEN);
\n}<\/p>\n- \n
- CSession\u7684\u6784\u9020\u51fd\u6570\u9700\u8981\u63a5\u6536\u7ebf\u7a0b\u6c60\u4e2d\u7684ioc\u3001server\u6307\u9488，\u5e76\u5c06_b_close\u7f6e\u4e3afalse，\u8868\u793a\u8be5\u4f1a\u8bdd\u672a\u5173\u95ed<\/li>\n
- \u901a\u8fc7boost\u7684random_generator()()\u51fd\u6570\u83b7\u53d6\u4e00\u4e2auuid，\u6bcf\u4e2asession\u90fd\u6709\u81ea\u5df1\u7684uuid，\u76f8\u5f53\u4e8e\u4e00\u4e2a\u540d\u79f0，\u901a\u8fc7\u8be5\u540d\u79f0\u53ef\u627e\u51fa\u5bf9\u5e94\u7684session\u4f1a\u8bdd，\u8be5\u51fd\u6570\u901a\u8fc7\u96ea\u82b1\u7b97\u6cd5\u5b9e\u73b0\u3002<\/li>\n
- \u5b9a\u4e49\u6d88\u606f\u63a5\u6536\u8282\u70b9_recv_head_node，\u603b\u957f\u5ea64\u5b57\u8282，\u5305\u62ec\u6d88\u606fid\u548c\u6d88\u606f\u957f\u5ea6<\/li>\n<\/ul>\n
void CSession::Start() {
\n\/\/ \u9632\u6b62\u534f\u7a0b\u5904\u7406\u8fc7\u7a0b\u4e2d，\u667a\u80fd\u6307\u9488\u88ab\u610f\u5916\u91ca\u653e，\u901a\u8fc7\u667a\u80fd\u6307\u9488\u5b9e\u73b0\u4f2a\u95ed\u5305
\nauto shared_this = shared_from_this();
\n\/\/ \u5f00\u542f\u534f\u7a0b\u63a5\u6536
\nboost::asio::co_spawn(_io_context, [self = shared_from_this(), this]()->boost::asio::awaitable<void> {
\ntry {
\nfor (; !_b_close;) {
\n_recv_head_node->Clear();
\n\/\/ \u4ee5\u540c\u6b65\u7684\u65b9\u5f0f\u8c03\u7528\u5f02\u6b65\u8bfb，\u5e76\u5c06\u8bfb\u5230\u7684\u5b57\u8282\u6570（4\u5b57\u8282）\u8fd4\u56de（\u4f7f\u7528\u7b80\u6613\u7c98\u5305\u5904\u7406\u65b9\u5f0f）
\nstd::size_t n = co_await boost::asio::async_read(_socket, boost::asio::buffer(
\n_recv_head_node->_data, HEAD_TOTAL_LEN), use_awaitable);<\/p>\nif (n == 0) { \/\/ \u5982\u679c\u6ca1\u8bfb\u5230\u6570\u636e
\nstd::cout << "receive peer closed" << std::endl;
\nClose();
\n_server->ClearSession(_uuid);
\nco_return; \/\/ \u7c7b\u4f3creturn，\u4f46co_return\u662f\u975e\u963b\u585e\u7684
\n}<\/p>\n\/\/ \u83b7\u53d6\u5934\u90e8\u6d88\u606fid
\nshort msg_id = 0;
\nmemcpy(&msg_id, _recv_head_node->_data, HEAD_ID_LEN);
\n\/\/ \u8f6c\u6362\u7f51\u7edc\u5b57\u8282\u5e8f\u4e3a\u672c\u5730\u5b57\u8282\u5e8f
\nmsg_id = boost::asio::detail::socket_ops::network_to_host_short(msg_id);
\nstd::cout << "msg id is " << msg_id << std::endl;
\nif (msg_id > MAX_LENGTH) {
\nstd::cout << "invalid msg id is " << msg_id << std::endl;
\nClose();
\n_server->ClearSession(_uuid);
\nco_return;
\n}<\/p>\n\/\/ \u83b7\u53d6\u6d88\u606f\u957f\u5ea6
\nshort msg_len = 0;
\nmemcpy(&msg_len, _recv_head_node->_data + HEAD_ID_LEN, HEAD_DATA_LEN);
\nmsg_len = boost::asio::detail::socket_ops::network_to_host_short(msg_len);
\nstd::cout << "msg len is " << msg_len << std::endl;
\nif (msg_len > MAX_LENGTH) {
\nstd::cout << "invalid msg len is " << msg_len << std::endl;
\nClose();
\n_server->ClearSession(_uuid);
\nco_return;
\n}<\/p>\n\/\/ \u83b7\u53d6\u6d88\u606f\u5185\u5bb9
\n_recv_msg_node = std::make_shared<RecvNode>(msg_len, msg_id); \/\/ \u6784\u9020\u6d88\u606f\u8282\u70b9
\n\/\/ \u5c06\u5f02\u6b65\u8bfb\u4ee5\u540c\u6b65\u65b9\u5f0f\u8c03\u7528，\u6307\u5b9a\u8bfb\u53d6\u5b57\u8282\u6570
\nn = co_await boost::asio::async_read(_socket, boost::asio::buffer(_recv_msg_node->_data,
\n_recv_msg_node->_total_len),use_awaitable);
\nif (n == 0) {
\nstd::cout << "receive peer closed " << std::endl;
\nClose();
\n_server->ClearSession(_uuid);
\nco_return;
\n}<\/p>\n_recv_msg_node->_data[_recv_msg_node->_total_len] = '\\\\0';
\nstd::cout << "receive data is " << _recv_msg_node->_data << std::endl;
\n\/\/ \u6295\u9012\u81f3\u903b\u8f91\u7ebf\u7a0b
\nLogicSystem::GetInstance().PostMsgToQue(std::make_shared<LogicNode>(shared_from_this(), _recv_msg_node));
\n}
\n}
\ncatch (std::exception& e) {
\nstd::cerr << "exception is " << e.what() << std::endl;
\nClose();
\n_server->ClearSession(_uuid);
\n}
\n}, detached);
\n}<\/p>\nStart()\u51fd\u6570\u7528\u4e8e\u63a5\u6536\u6d88\u606f\u5185\u5bb9，\u5e76\u901a\u8fc7\u53e6\u4e00\u79cd\u7b80\u4fbf\u7684\u7c98\u5305\u5904\u7406\u65b9\u5f0f\u83b7\u5f97\u6d88\u606fid\u3001\u6d88\u606f\u957f\u5ea6，\u53ef\u53c2\u8003：<\/p>\n
\u7231\u5403\u571f\u8c46：\u7f51\u7edc\u7f16\u7a0b（11）\u2014\u2014\u53e6\u4e00\u79cd\u7b80\u4fbf\u7684\u7c98\u5305\u5904\u7406\u65b9\u5f0f1 \u8d5e\u540c \u00b7 0 \u8bc4\u8bba\u6587\u7ae0<\/p>\n
\u8be5\u51fd\u6570\u5728Server\u4e2d\u6536\u5230\u5ba2\u6237\u7aef\u8fde\u63a5\u8bf7\u6c42\u540e，Server\u5c06\u4e00\u4e2a\u65b0\u7684session\u5206\u914d\u7ed9\u8be5\u5ba2\u6237\u7aef，\u5e76\u8c03\u7528Start()\u51fd\u6570\u3002<\/p>\n
\u9996\u5148，\u6784\u9020\u4e00\u4e2a\u6536\u534f\u7a0b：<\/p>\n
- \n
- \u8fd9\u91cc\u901a\u8fc7boost::asio::co_spawn\u6784\u9020\u4e00\u4e2a\u6536\u534f\u7a0b，\u4f20\u5165ioc\u548clambda\u51fd\u6570，\u4ee5\u53cadetached\u3002\u6ce8\u610f，\u5982\u679c\u7528=\u6355\u83b7\u6240\u6709\u53d8\u91cf，\u4f46\u662flambda\u8868\u8fbe\u5f0f\u5e76\u672a\u4f7f\u7528\u667a\u80fd\u6307\u9488\u5219\u4e0d\u4f1a\u589e\u52a0\u5f15\u7528\u8ba1\u6570，\u9664\u975e\u5728lambda\u5185\u90e8\u4f7f\u7528\u8fd9\u4e2a\u6307\u9488\u6216\u8005\u5728\u3010\u3011\u4e2d\u663e\u5f0f\u6355\u83b7\u8be5\u6307\u9488，\u6211\u4eec\u8fd9\u91cc\u901a\u8fc7\u3010self = shared_from_this(), this\u3011\u663e\u5f0f\u589e\u52a0session\u7684\u5f15\u7528\u8ba1\u6570，\u9632\u6b62\u534f\u7a0b\u5904\u7406\u8fc7\u7a0b\u4e2d，\u667a\u80fd\u6307\u9488\u88ab\u610f\u5916\u91ca\u653e，\u901a\u8fc7\u667a\u80fd\u6307\u9488\u5b9e\u73b0\u4f2a\u95ed\u5305\u3002<\/li>\n
- \u663e\u5f0f\u6307\u5b9a\u8fd4\u56de\u7c7b\u578b\u4e3aboost::asio::awaitable<void>，awaitable<void>\u7c7b\u578b\u5141\u8bb8\u51fd\u6570\u5728\u6267\u884c\u65f6\u53ef\u4ee5\u88ab\u6682\u505c\u548c\u6062\u590d，\u8fd9\u4f7f\u5f97\u5b83\u80fd\u591f\u4e0e\u00a0co_await\u00a0\u4e00\u8d77\u4f7f\u7528，\u6240\u4ee5\u51fd\u6570\u8fd4\u56de\u7c7b\u578b\u5fc5\u987b\u662fawaitable<void>\u3002<\/li>\n
- session\u4f1a\u5728Start()\u51fd\u6570\u4e2d\u5faa\u73af\u6267\u884c\u6536\u534f\u7a0b，\u76f4\u81f3\u8be5\u4f1a\u8bdd\u88ab\u5173\u95ed，\u6bcf\u4e00\u6b21\u6267\u884c\u90fd\u9700\u8981\u5c06\u6d88\u606f\u5934\u7ed3\u70b9\u6e05\u7a7a，\u63a5\u6536\u4e0b\u4e00\u4e2a\u6d88\u606f\u3002\u901a\u8fc7co_await\u00a0\u5173\u952e\u5b57\u548cuse_awaitable\u00a0\u4ee5\u540c\u6b65\u7684\u65b9\u5f0f\u8c03\u7528\u5f02\u6b65\u8bfb\u64cd\u4f5casync_read，\u5e76\u5c06\u8bfb\u5230\u7684\u5b57\u8282\u6570（4\u5b57\u8282）\u8fd4\u56de，\u53ea\u6709\u8bfb\u52304\u5b57\u8282\u624d\u4f1a\u8fd4\u56de，\u5426\u5219\u5df2\u77e5\u6302\u8d77\u3002\u8fd9\u91cc\u548casynv_read_some\u6709\u4e00\u4e9b\u533a\u522b\u7136\u540e\u5206\u522b\u8bfb\u53d6\u6d88\u606fid\u3001\u6d88\u606f\u957f\u5ea6\u548c\u6d88\u606f\u5185\u5bb9，\u4e14\u9700\u8981\u5c06\u6d88\u606fid\u548c\u6d88\u606f\u957f\u5ea6\u4ece\u7f51\u7edc\u5e8f\u5217\u8f6c\u6362\u4e3a\u672c\u5730\u5e8f\u5217\u3002\u8fd9\u91cc\u4f7f\u7528async_read\u6307\u5b9a\u8bfb\u53d6\u5b57\u8282\u6570，\u800c\u4e0d\u662f\u50cf\u4e4b\u524d\u7c98\u5305\u5904\u7406\u4f7f\u7528async_read_some\u51fd\u6570，\u901a\u8fc7\u8c03\u7528\u56de\u8c03\u51fd\u6570\u5904\u7406\u7c98\u5305\u95ee\u9898\u3002<\/li>\n
- \u6700\u540e，\u5728\u63a5\u6536\u5b8c\u6240\u6709\u6d88\u606f\u540e，\u5c06\u6d88\u606f\u6295\u9012\u81f3\u903b\u8f91\u961f\u5217\u8fdb\u884c\u76f8\u5e94\u7684\u5904\u7406\u3002<\/li>\n<\/ul>\n
\u5728\u534f\u7a0b\u4e2d，co_return\u7528\u6765\u8fd4\u56de\u4e00\u4e2a\u503c\u6216\u8868\u793a\u534f\u7a0b\u7ed3\u675f，\u5b83\u5c06\u628a\u503c\u4f20\u9012\u7ed9\u534f\u7a0b\u7684\u8fd4\u56de\u5bf9\u8c61（\u5982\u679c\u8fd4\u56de\u7c7b\u578b\u4e0d\u4e3aboost::asio::awaitable<void>，\u5bf9\u8c61\u662fboost::asio::awaitable）\u3002<\/p>\n
- \n
- co_return \u53ea\u80fd\u5728\u534f\u7a0b\u4e2d\u4f7f\u7528，\u800c\u666e\u901a\u51fd\u6570\u4e2d\u4f7f\u7528\u7684\u662f return\u3002<\/li>\n
- co_return \u5c06\u7ed3\u679c\u4f20\u9012\u7ed9\u534f\u7a0b\u7684\u627f\u8bfa（promise）\u5bf9\u8c61，\u8fd9\u4e2a\u5bf9\u8c61\u4f1a\u5c06\u503c\u4ea4\u7ed9\u534f\u7a0b\u7684\u8fd4\u56de\u7c7b\u578b<\/li>\n<\/ul>\n
\u534f\u7a0b\u5173\u952e\u5b57\u548c\u51fd\u6570use_awaitable\u3001co_spawn\u3001detached\u5982\u4f55\u4f7f\u7528\u8bf7\u53c2\u8003\u6587\u7ae0：<\/p>\n
\u7231\u5403\u571f\u8c46：\u7f51\u7edc\u7f16\u7a0b（18）\u2014\u2014\u4f7f\u7528asio\u534f\u7a0b\u5b9e\u73b0\u5e76\u53d1\u670d\u52a1\u5668demo（\u5b98\u65b9\u6848\u4f8b）4 \u8d5e\u540c \u00b7 0 \u8bc4\u8bba\u6587\u7ae0<\/p>\n
\u6211\u4eec\u5df2\u7ecf\u6784\u5efa\u4e86\u4e00\u4e2a\u63a5\u6536\u534f\u7a0b\u7528\u4e8e\u63a5\u6536\u6570\u636e，\u90a3\u4e48\u6211\u4eec\u9700\u8981\u6784\u5efa\u53d1\u9001\u534f\u7a0b\u5417？<\/p>\n
- \n
- \u53ef\u4ee5\u6784\u5efa\u53d1\u9001\u534f\u7a0b\u7528\u4e8e\u53d1\u9001\u6570\u636e，\u4f46\u8003\u8651\u5230\u534f\u7a0b\u5f88\u5927\u7a0b\u5ea6\u4e0a\u5728\u4f7f\u7528\u5c42\u9762\u7b80\u5316\u4e86\u4ee3\u7801，\u4f46\u5b9e\u9645\u4e0a\u4e5f\u8017\u8d39\u8d44\u6e90，\u5982\u679c\u670d\u52a1\u5668\u8fdb\u884c\u9891\u7e41\u53d1\u9001\u64cd\u4f5c，\u4e14\u5904\u4e8e\u4efb\u4f55\u65f6\u523b\u90fd\u53ef\u80fd\u8c03\u7528\u7684\u60c5\u51b5\u4e0b，\u4f7f\u7528\u534f\u7a0b\u53ef\u80fd\u5e76\u4e0d\u65b9\u4fbf ，\u56e0\u4e3a\u53ef\u80fd\u5728\u4e00\u4e2a\u7ebf\u7a0b\u4e2d，\u968f\u7740\u53d1\u9001\u6b21\u6570\u7684\u4e0a\u5347，\u542f\u52a8\u5f88\u591a\u534f\u7a0b<\/li>\n
- \u8fd8\u6709\u4e00\u4e2a\u539f\u56e0\u662f：\u5982\u679c\u53d1\u9001\u7684\u65f6\u5019\u5904\u4e8e\u53e6\u4e00\u4e2a\u7ebf\u7a0b，\u5982\u679c\u7528\u53d1\u9001\u534f\u7a0b\u7684\u8bdd，\u53ef\u80fd\u4f1a\u5bfc\u81f4\u5176\u4ed6\u7ebf\u7a0b\u58f0\u660e\u5468\u671f\u7684\u6539\u53d8<\/li>\n<\/ul>\n
\u6240\u4ee5\u6211\u4eec\u8fd9\u91cc\u4ecd\u7136\u4f7f\u7528\u4e4b\u524d\u4ee3\u7801\u4e2d\u7528\u5230\u7684\u53d1\u9001\u961f\u5217\u7684\u65b9\u5f0f，Send\u51fd\u6570\u4e24\u79cd\u91cd\u8f7d\u5b9a\u4e49\u5982\u4e0b：<\/p>\n
void CSession::Send(const char* msg, short max_length, short msg_id) {
\nbool pending = false; \/\/ \u53d1\u9001\u6807\u5fd7，true\u65f6\u6709\u672a\u5b8c\u6210\u7684\u53d1\u9001\u64cd\u4f5c，false\u4e3a\u7a7a
\nstd::unique_lock<std::mutex> lock(_send_lock);
\nint send_que_size = _send_que.size();
\nif (send_que_size > MAX_SENDQUE) {
\nstd::cout << "session: " << _uuid << " send que fulled, size is " << MAX_SENDQUE << std::endl;
\nreturn;
\n}<\/p>\n\/\/ \u5224\u65ad\u961f\u5217\u662f\u5426\u6709\u672a\u5b8c\u6210\u7684\u53d1\u9001\u64cd\u4f5c
\nif (_send_que.size() > 0) {
\npending = true;
\n}
\n_send_que.push(std::make_shared<SendNode>(msg, max_length, msg_id));
\nif (pending) { \/\/ \u5982\u679c\u6709\u672a\u5b8c\u6210\u7684\u53d1\u9001，\u76f4\u63a5\u8fd4\u56de
\nreturn;
\n}<\/p>\nauto msgnode = _send_que.front();
\n\/\/ \u6570\u636e\u53d6\u51fa\u6765\u4e4b\u540e\u5c31\u89e3\u9501，\u4ec5\u5728\u4f7f\u7528\u961f\u5217\u65f6\u52a0\u9501，\u907f\u514d\u4e0d\u76f8\u5e72\u7684\u903b\u8f91\u5360\u7528\u9501
\nlock.unlock();
\nboost::asio::async_write(_socket, boost::asio::buffer(msgnode->_data, msgnode->_total_len),
\nstd::bind(&CSession::HandleWrite, this, std::placeholders::_1, shared_from_this()));
\n}<\/p>\nvoid CSession::Send(std::string msg, short msg_id) {
\nbool pending = false; \/\/ \u53d1\u9001\u6807\u5fd7，true\u65f6\u6709\u672a\u5b8c\u6210\u7684\u53d1\u9001\u64cd\u4f5c，false\u4e3a\u7a7a
\nstd::unique_lock<std::mutex> lock(_send_lock);
\nint send_que_size = _send_que.size();
\nif (send_que_size > MAX_SENDQUE) {
\nstd::cout << "session: " << _uuid << " send que fulled, size is " << MAX_SENDQUE << std::endl;
\nreturn;
\n}<\/p>\n\/\/ \u5224\u65ad\u961f\u5217\u662f\u5426\u6709\u672a\u5b8c\u6210\u7684\u53d1\u9001\u64cd\u4f5c
\nif (_send_que.size() > 0) {
\npending = true;
\n}
\n_send_que.push(std::make_shared<SendNode>(msg.c_str(), msg.length(), msg_id));
\nif (pending) { \/\/ \u5982\u679c\u6709\u672a\u5b8c\u6210\u7684\u53d1\u9001，\u76f4\u63a5\u8fd4\u56de
\nreturn;
\n}<\/p>\nauto msgnode = _send_que.front();
\n\/\/ \u6570\u636e\u53d6\u51fa\u6765\u4e4b\u540e\u5c31\u89e3\u9501，\u4ec5\u5728\u4f7f\u7528\u961f\u5217\u65f6\u52a0\u9501，\u907f\u514d\u4e0d\u76f8\u5e72\u7684\u903b\u8f91\u5360\u7528\u9501
\nlock.unlock();
\nboost::asio::async_write(_socket, boost::asio::buffer(msgnode->_data, msgnode->_total_len),
\nstd::bind(&CSession::HandleWrite, this, std::placeholders::_1, shared_from_this()));
\n}<\/p>\nSend()\u7684\u4e24\u79cd\u91cd\u8f7d，\u9488\u5bf9\u6570\u636e\u5185\u5bb9\u662fstring\u7c7b\u578b\u548cchar*\u7c7b\u578b\u3002<\/p>\n
\u9996\u5148\u8bbe\u7f6eunique_lock，\u65b9\u4fbf\u81ea\u7531\u52a0\u89e3\u9501；<\/p>\n
\u83b7\u53d6\u53d1\u9001\u961f\u5217\u5143\u7d20\u4e2a\u6570，\u5e76\u5224\u65ad\u5143\u7d20\u6570\u91cf\u662f\u5426\u5408\u6cd5，\u5982\u679c\u961f\u5217\u4e2d\u5df2\u5b58\u5728\u5143\u7d20，\u90a3\u4e48\u5c06\u672c\u6761\u6d88\u606f\u4f20\u5165\u961f\u5217\u7136\u540e\u8fd4\u56de，\u7b49\u5f85\u4e0a\u4e00\u6761\u6d88\u606f\u53d1\u9001\u6210\u529f；\u5982\u679c\u961f\u5217\u4e3a\u7a7a，\u90a3\u4e48\u53d6\u51fa\u961f\u5217\u7684\u7b2c\u4e00\u4e2a\u5143\u7d20\u5e76\u89e3\u9501（\u6211\u4eec\u53ea\u9700\u8981\u5728\u4f7f\u7528\u961f\u5217\u65f6\u52a0\u9501，\u4e0d\u4f7f\u7528\u961f\u5217\u662f\u89e3\u9501，\u907f\u514d\u4e0d\u76f8\u5e72\u7684\u903b\u8f91\u5360\u7528\u9501），\u7136\u540e\u540c\u6b65\u5f02\u6b65\u5199async_write\u53d1\u9001\u6570\u636e（\u6307\u5b9a\u5b57\u8282\u6570\u91cf），\u8fd9\u91cc\u4e0d\u9700\u8981\u6784\u9020\u5199\u534f\u7a0b，\u800c\u662f\u76f4\u63a5\u901a\u8fc7send\u51fd\u6570\u8c03\u7528\u5f02\u6b65\u5199\u8fdb\u884c\u53d1\u9001，\u53d1\u9001\u6210\u529f\u540e\u8c03\u7528\u56de\u8c03\u51fd\u6570HandleWrite\u3002<\/p>\n
void CSession::HandleWrite(const boost::system::error_code& error, std::shared_ptr<CSession> shared_self) {
\ntry {
\nif (!error) {
\nstd::unique_lock<std::mutex> lock(_send_lock); \/\/ \u52a0\u9501\u4fdd\u62a4\u53d1\u9001\u961f\u5217
\n_send_que.pop(); \/\/ \u79fb\u9664\u4e0a\u4e00\u4e2a\u5df2\u53d1\u9001\u7684\u6d88\u606f（send\u51fd\u6570\u4e2d\u7684\u5f02\u6b65\u53d1）
\nif (!_send_que.empty()) { \/\/ \u82e5\u961f\u5217\u4e0d\u4e3a\u7a7a，\u5904\u7406\u4e0b\u4e00\u4e2a\u6d88\u606f
\nauto& msgnode = _send_que.front();
\nlock.unlock(); \/\/ \u89e3\u9501，\u907f\u514d\u4e0d\u76f8\u5e72\u903b\u8f91\u5360\u7528\u9501
\nboost::asio::async_write(_socket, boost::asio::buffer(msgnode->_data, msgnode->_total_len),
\nstd::bind(&CSession::HandleWrite, this, std::placeholders::_1, shared_self));
\n}
\n}
\nelse {
\nstd::cerr << "handle write failed, error is " << error.what() << std::endl;
\nClose();
\n_server->ClearSession(_uuid);
\n}
\n}
\ncatch (std::exception& e) {
\nstd::cout << "exception is " << e.what() << std::endl;
\nClose();
\n_server->ClearSession(_uuid);
\n}
\n}<\/p>\n\u5982\u679c\u53d1\u9001\u6210\u529f，\u90a3\u4e48\u5148\u52a0\u9501\u4fdd\u62a4\u53d1\u9001\u961f\u5217，\u7136\u540e\u79fb\u9664\u4e0a\u4e00\u4e2a\u5df2\u53d1\u9001\u7684\u6d88\u606f，\u5e76\u5224\u65ad\u961f\u5217\u662f\u5426\u4e3a\u7a7a，\u5982\u679c\u4e0d\u4e3a\u7a7a，\u53d6\u51fa\u7b2c\u4e00\u4e2a\u6570\u636e\u5e76\u89e3\u9501，\u5e76\u8c03\u7528\u5f02\u6b65\u53d1\u51fd\u6570\u53d1\u9001\u8be5\u6570\u636e；\u5982\u679c\u53d1\u9001\u5931\u8d25，\u90a3\u4e48\u5173\u95edsession，\u5e76\u8c03\u7528Server\u7684ClearSession\u51fd\u6570\u64e6\u9664\u5bf9\u5e94uuid\u7684session\u3002<\/p>\n
boost::asio::ip::tcp::socket& CSession::GetSocket() {
\nreturn _socket;
\n}<\/p>\n\u8fd4\u56desession\u7684\u72ec\u7acb\u5957\u63a5\u5b57<\/p>\n
std::string& CSession::GetUuid() {
\nreturn _uuid;
\n}<\/p>\n\u8fd4\u56desession\u7684uuid<\/p>\n
void CSession::Close() {
\n_b_close = true;
\n_socket.close();
\n}<\/p>\n\u663e\u5f0f\u5173\u95edSession\u4f1a\u8bdd，\u9996\u5148\u5c06\u6807\u5fd7\u4f4d_b_close \u7f6e1，\u5e76\u5173\u95ed\u5957\u63a5\u5b57<\/p>\n
CSession::~CSession() {
\ntry {
\nstd::cout << "~CSession destruct" << std::endl;
\n}
\ncatch (std::exception& e) {
\nstd::cerr << "exception is " << e.what() << std::endl;
\n}
\n}<\/p>\n7. \u4e3b\u51fd\u6570<\/h3>\n
#include <iostream>
\n#include "CServer.h"
\n#include <csignal>
\n#include <thread>
\n#include <mutex>
\n#include "AsioIOServicePool.h"<\/p>\nint main()
\n{
\ntry {
\nauto pool = AsioIOServicePool::GetInstance();
\nboost::asio::io_context io_context;
\nboost::asio::signal_set signals(io_context, SIGINT, SIGTERM);
\nsignals.async_wait([&io_context, &pool](auto,auto) {
\nio_context.stop();
\npool->Stop();
\n});<\/p>\nCServer s(io_context, 10086);
\nio_context.run();
\n}
\ncatch (std::exception& e) {
\nstd::cerr << "Exception: " << e.what() << std::endl;
\n }
\n}<\/p>\n8. \u5ba2\u6237\u7aef<\/h3>\n
#include <boost\/asio.hpp>
\n#include <iostream>
\n#include <json\/json.h>
\n#include <json\/value.h>
\n#include <json\/reader.h><\/p>\nusing namespace boost::asio::ip;
\nusing std::cout;
\nusing std::endl;
\nconst int MAX_LENGTH = 1024 * 2; \/\/ \u53d1\u9001\u548c\u63a5\u6536\u7684\u957f\u5ea6\u4e3a1024 * 2\u5b57\u8282
\nconst int HEAD_LENGTH = 2;
\nconst int HEAD_TOTAL = 4;<\/p>\nint main()
\n{
\n try {
\n boost::asio::io_context ioc; \/\/ \u521b\u5efa\u4e0a\u4e0b\u6587\u670d\u52a1
\n \/\/ 127.0.0.1\u662f\u672c\u673a\u7684\u56de\u8def\u5730\u5740，\u4e5f\u5c31\u662f\u670d\u52a1\u5668\u548c\u5ba2\u6237\u7aef\u5728\u4e00\u4e2a\u673a\u5668\u4e0a
\n tcp::endpoint remote_ep(address::from_string("127.0.0.1"), 10086); \/\/ \u6784\u9020endpoint
\n tcp::socket sock(ioc);
\n boost::system::error_code error = boost::asio::error::host_not_found; \/\/ \u9519\u8bef：\u4e3b\u673a\u672a\u627e\u5230
\n sock.connect(remote_ep, error);
\n if (error) {
\n cout << "connect failed, code is " << error.value() << " error msg is " << error.message();
\n return 0;
\n }<\/p>\nJson::Value root;
\n root["id"] = 1001;
\n root["data"] = "hello world";
\n std::string request = root.toStyledString();
\n size_t request_length = request.length();
\n char send_data[MAX_LENGTH] = { 0 };
\n int msgid = 1001;
\n int msgid_host = boost::asio::detail::socket_ops::host_to_network_short(msgid);
\n memcpy(send_data, &msgid_host, 2);<\/p>\n\/\/\u8f6c\u4e3a\u7f51\u7edc\u5b57\u8282\u5e8f
\n int request_host_length = boost::asio::detail::socket_ops::host_to_network_short(request_length);
\n memcpy(send_data + 2, &request_host_length, 2);
\n memcpy(send_data + 4, request.c_str(), request_length);
\n boost::asio::write(sock, boost::asio::buffer(send_data, request_length + 4));<\/p>\nchar reply_head[HEAD_TOTAL]; \/\/ \u9996\u5148\u8bfb\u53d6\u5bf9\u7aef\u53d1\u9001\u6d88\u606f\u7684\u603b\u957f\u5ea6
\n size_t reply_length = boost::asio::read(sock, boost::asio::buffer(reply_head, HEAD_TOTAL));
\n msgid = 0;
\n memcpy(&msgid, reply_head, HEAD_LENGTH);
\n short msglen = 0; \/\/ \u6d88\u606f\u603b\u957f\u5ea6
\n memcpy(&msglen, reply_head + 2, HEAD_LENGTH); \/\/ \u5c06\u6d88\u606f\u603b\u957f\u5ea6\u8d4b\u503c\u7ed9msglen
\n \/\/\u8f6c\u4e3a\u672c\u5730\u5b57\u8282\u5e8f
\n msglen = boost::asio::detail::socket_ops::network_to_host_short(msglen);
\n char msg[MAX_LENGTH] = { 0 }; \/\/ \u6784\u5efa\u6d88\u606f\u4f53（\u4e0d\u542b\u6d88\u606f\u603b\u957f\u5ea6）
\n size_t msg_length = boost::asio::read(sock, boost::asio::buffer(msg, msglen));<\/p>\nJson::Reader reader;
\n reader.parse(std::string(msg, msg_length), root);
\n std::cout << "msg id is " << root["id"] << " msg is " << root["data"] << endl;
\n getchar();
\n }
\n catch (std::exception& e) {
\n std::cerr << "Exception: " << e.what() << endl;
\n }
\n return 0;
\n}<\/p>\n9. \u6d4b\u8bd5<\/h3>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250419143636-6803b4f456377.png\")
<\/p>\n<\/p>\n\u4ee3\u7801：<\/p>\n
https:\/\/github.com\/qiaobeibei\/CoroutineServer\u200bgithub.com\/qiaobeibei\/CoroutineServer<\/p>\n","protected":false},"excerpt":{"rendered":"
\u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb1.2k\u6b21\uff0c\u70b9\u8d5e11\u6b21\uff0c\u6536\u85cf32\u6b21\u3002\u53cd\u4e4b\uff0c\u8c03\u7528\u8be5\u56de\u8c03\u51fd\u6570\u3002\u4e0a\u56fe\u6240\u793a\u7684\u662f\u4e00\u4e2a\u5b8c\u6210\u7684\u670d\u52a1\u5668\u67b6\u6784\uff0c\u4e00\u822c\u9700\u8981\u5c06\u903b\u8f91\u5c42\u72ec\u7acb\u51fa\u6765\uff0c\u56e0\u4e3a\u5982\u679c\u5728\u89e3\u6790\u5b8c\u5bf9\u7aef\u6570\u636e\u540e\u9700\u8981\u6267\u884c\u4e00\u4e9b\u590d\u6742\u7684\u64cd\u4f5c\uff0c\u6bd4\u5982\u73a9\u5bb6\u9700\u8981\u53e0\u52a0\u5404\u81eabuff\u6216\u8005\u6280\u80fd\uff0c\u6b64\u65f6\u53ef\u80fd\u4f1a\u8017\u65f61s\u751a\u81f3\u66f4\u591a\uff0c\u5982\u679c\u6ca1\u6709\u72ec\u7acb\u7684\u903b\u8f91\u5c42\u8fdb\u884c\u64cd\u4f5c\uff0c\u90a3\u4e48\u7cfb\u7edf\u4f1a\u4e00\u76f4\u505c\u7559\u5728\u6267\u884c\u56de\u8c03\u51fd\u6570\u90a3\u4e00\u6b65\uff0c\u9020\u6210\u3002\u4e00\u822c\u5728\u89e3\u6790\u5b8c\u5bf9\u7aef\u53d1\u9001\u7684\u6570\u636e\u4e4b\u540e\uff0c\u8fd8\u8981\u5bf9\u8be5\u8bf7\u6c42\u505a\u66f4\u8fdb\u4e00\u6b65\u5730\u5904\u7406\uff0c\u6bd4\u5982\u6839\u636e\u4e0d\u540c\u7684\u6d88\u606fid\u6267\u884c\u4e0d\u540c\u7684\u903b\u8f91\u5c42\u51fd\u6570\u6216\u4e0d\u540c\u7684\u64cd\u4f5c\uff0c\u6bd4\u5982\u8bfb\u6570\u636e\u5e93\u3001\u5199\u6570\u636e\u5e93\uff0c\u8fd8\u6bd4\u5982\u6e38\u620f\u4e2d\u53ef\u80fd\u9700\u8981\u7ed9\u73a9\u5bb6\u53e0\u52a0\u4e0d\u540c\u7684buff\u3001\u589e\u52a0\u79ef\u5206\u7b49\u7b49\uff0c\u8fd9\u4e9b\u90fd\u9700\u8981\u4ea4\u7ed9\u3002_c++ asio<\/p>\n","protected":false},"author":2,"featured_media":28046,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[2245,55,2246,43,396],"topic":[],"class_list":["post-28048","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-server","tag-asio","tag-c","tag-2246","tag-43","tag-396"],"yoast_head":"\n
\u7f51\u7edc\u7f16\u7a0b\uff0819\uff09\u2014\u2014C++\u4f7f\u7528asio\u534f\u7a0b\u5b9e\u73b0\u5e76\u53d1\u670d\u52a1\u5668 - \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\/28048.html\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"\u7f51\u7edc\u7f16\u7a0b\uff0819\uff09\u2014\u2014C++\u4f7f\u7528asio\u534f\u7a0b\u5b9e\u73b0\u5e76\u53d1\u670d\u52a1\u5668 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"og:description\" content=\"\u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb1.2k\u6b21\uff0c\u70b9\u8d5e11\u6b21\uff0c\u6536\u85cf32\u6b21\u3002\u53cd\u4e4b\uff0c\u8c03\u7528\u8be5\u56de\u8c03\u51fd\u6570\u3002\u4e0a\u56fe\u6240\u793a\u7684\u662f\u4e00\u4e2a\u5b8c\u6210\u7684\u670d\u52a1\u5668\u67b6\u6784\uff0c\u4e00\u822c\u9700\u8981\u5c06\u903b\u8f91\u5c42\u72ec\u7acb\u51fa\u6765\uff0c\u56e0\u4e3a\u5982\u679c\u5728\u89e3\u6790\u5b8c\u5bf9\u7aef\u6570\u636e\u540e\u9700\u8981\u6267\u884c\u4e00\u4e9b\u590d\u6742\u7684\u64cd\u4f5c\uff0c\u6bd4\u5982\u73a9\u5bb6\u9700\u8981\u53e0\u52a0\u5404\u81eabuff\u6216\u8005\u6280\u80fd\uff0c\u6b64\u65f6\u53ef\u80fd\u4f1a\u8017\u65f61s\u751a\u81f3\u66f4\u591a\uff0c\u5982\u679c\u6ca1\u6709\u72ec\u7acb\u7684\u903b\u8f91\u5c42\u8fdb\u884c\u64cd\u4f5c\uff0c\u90a3\u4e48\u7cfb\u7edf\u4f1a\u4e00\u76f4\u505c\u7559\u5728\u6267\u884c\u56de\u8c03\u51fd\u6570\u90a3\u4e00\u6b65\uff0c\u9020\u6210\u3002\u4e00\u822c\u5728\u89e3\u6790\u5b8c\u5bf9\u7aef\u53d1\u9001\u7684\u6570\u636e\u4e4b\u540e\uff0c\u8fd8\u8981\u5bf9\u8be5\u8bf7\u6c42\u505a\u66f4\u8fdb\u4e00\u6b65\u5730\u5904\u7406\uff0c\u6bd4\u5982\u6839\u636e\u4e0d\u540c\u7684\u6d88\u606fid\u6267\u884c\u4e0d\u540c\u7684\u903b\u8f91\u5c42\u51fd\u6570\u6216\u4e0d\u540c\u7684\u64cd\u4f5c\uff0c\u6bd4\u5982\u8bfb\u6570\u636e\u5e93\u3001\u5199\u6570\u636e\u5e93\uff0c\u8fd8\u6bd4\u5982\u6e38\u620f\u4e2d\u53ef\u80fd\u9700\u8981\u7ed9\u73a9\u5bb6\u53e0\u52a0\u4e0d\u540c\u7684buff\u3001\u589e\u52a0\u79ef\u5206\u7b49\u7b49\uff0c\u8fd9\u4e9b\u90fd\u9700\u8981\u4ea4\u7ed9\u3002_c++ asio\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.wsisp.com\/helps\/28048.html\" \/>\n<meta property=\"og:site_name\" content=\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"article:published_time\" content=\"2025-04-19T14:36:37+00:00\" \/>\n<meta property=\"og:image\" content=\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250419143636-6803b4f42ea25.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=\"23 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/28048.html\",\"url\":\"https:\/\/www.wsisp.com\/helps\/28048.html\",\"name\":\"\u7f51\u7edc\u7f16\u7a0b\uff0819\uff09\u2014\u2014C++\u4f7f\u7528asio\u534f\u7a0b\u5b9e\u73b0\u5e76\u53d1\u670d\u52a1\u5668 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"isPartOf\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\"},\"datePublished\":\"2025-04-19T14:36:37+00:00\",\"dateModified\":\"2025-04-19T14:36:37+00:00\",\"author\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/28048.html#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.wsisp.com\/helps\/28048.html\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/28048.html#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.wsisp.com\/helps\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"\u7f51\u7edc\u7f16\u7a0b\uff0819\uff09\u2014\u2014C++\u4f7f\u7528asio\u534f\u7a0b\u5b9e\u73b0\u5e76\u53d1\u670d\u52a1\u5668\"}]},{\"@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":"\u7f51\u7edc\u7f16\u7a0b\uff0819\uff09\u2014\u2014C++\u4f7f\u7528asio\u534f\u7a0b\u5b9e\u73b0\u5e76\u53d1\u670d\u52a1\u5668 - \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\/28048.html","og_locale":"zh_CN","og_type":"article","og_title":"\u7f51\u7edc\u7f16\u7a0b\uff0819\uff09\u2014\u2014C++\u4f7f\u7528asio\u534f\u7a0b\u5b9e\u73b0\u5e76\u53d1\u670d\u52a1\u5668 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","og_description":"\u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb1.2k\u6b21\uff0c\u70b9\u8d5e11\u6b21\uff0c\u6536\u85cf32\u6b21\u3002\u53cd\u4e4b\uff0c\u8c03\u7528\u8be5\u56de\u8c03\u51fd\u6570\u3002\u4e0a\u56fe\u6240\u793a\u7684\u662f\u4e00\u4e2a\u5b8c\u6210\u7684\u670d\u52a1\u5668\u67b6\u6784\uff0c\u4e00\u822c\u9700\u8981\u5c06\u903b\u8f91\u5c42\u72ec\u7acb\u51fa\u6765\uff0c\u56e0\u4e3a\u5982\u679c\u5728\u89e3\u6790\u5b8c\u5bf9\u7aef\u6570\u636e\u540e\u9700\u8981\u6267\u884c\u4e00\u4e9b\u590d\u6742\u7684\u64cd\u4f5c\uff0c\u6bd4\u5982\u73a9\u5bb6\u9700\u8981\u53e0\u52a0\u5404\u81eabuff\u6216\u8005\u6280\u80fd\uff0c\u6b64\u65f6\u53ef\u80fd\u4f1a\u8017\u65f61s\u751a\u81f3\u66f4\u591a\uff0c\u5982\u679c\u6ca1\u6709\u72ec\u7acb\u7684\u903b\u8f91\u5c42\u8fdb\u884c\u64cd\u4f5c\uff0c\u90a3\u4e48\u7cfb\u7edf\u4f1a\u4e00\u76f4\u505c\u7559\u5728\u6267\u884c\u56de\u8c03\u51fd\u6570\u90a3\u4e00\u6b65\uff0c\u9020\u6210\u3002\u4e00\u822c\u5728\u89e3\u6790\u5b8c\u5bf9\u7aef\u53d1\u9001\u7684\u6570\u636e\u4e4b\u540e\uff0c\u8fd8\u8981\u5bf9\u8be5\u8bf7\u6c42\u505a\u66f4\u8fdb\u4e00\u6b65\u5730\u5904\u7406\uff0c\u6bd4\u5982\u6839\u636e\u4e0d\u540c\u7684\u6d88\u606fid\u6267\u884c\u4e0d\u540c\u7684\u903b\u8f91\u5c42\u51fd\u6570\u6216\u4e0d\u540c\u7684\u64cd\u4f5c\uff0c\u6bd4\u5982\u8bfb\u6570\u636e\u5e93\u3001\u5199\u6570\u636e\u5e93\uff0c\u8fd8\u6bd4\u5982\u6e38\u620f\u4e2d\u53ef\u80fd\u9700\u8981\u7ed9\u73a9\u5bb6\u53e0\u52a0\u4e0d\u540c\u7684buff\u3001\u589e\u52a0\u79ef\u5206\u7b49\u7b49\uff0c\u8fd9\u4e9b\u90fd\u9700\u8981\u4ea4\u7ed9\u3002_c++ asio","og_url":"https:\/\/www.wsisp.com\/helps\/28048.html","og_site_name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","article_published_time":"2025-04-19T14:36:37+00:00","og_image":[{"url":"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/04\/20250419143636-6803b4f42ea25.png"}],"author":"admin","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"admin","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"23 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.wsisp.com\/helps\/28048.html","url":"https:\/\/www.wsisp.com\/helps\/28048.html","name":"\u7f51\u7edc\u7f16\u7a0b\uff0819\uff09\u2014\u2014C++\u4f7f\u7528asio\u534f\u7a0b\u5b9e\u73b0\u5e76\u53d1\u670d\u52a1\u5668 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","isPartOf":{"@id":"https:\/\/www.wsisp.com\/helps\/#website"},"datePublished":"2025-04-19T14:36:37+00:00","dateModified":"2025-04-19T14:36:37+00:00","author":{"@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41"},"breadcrumb":{"@id":"https:\/\/www.wsisp.com\/helps\/28048.html#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.wsisp.com\/helps\/28048.html"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.wsisp.com\/helps\/28048.html#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.wsisp.com\/helps"},{"@type":"ListItem","position":2,"name":"\u7f51\u7edc\u7f16\u7a0b\uff0819\uff09\u2014\u2014C++\u4f7f\u7528asio\u534f\u7a0b\u5b9e\u73b0\u5e76\u53d1\u670d\u52a1\u5668"}]},{"@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\/28048","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=28048"}],"version-history":[{"count":0,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/28048\/revisions"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media\/28046"}],"wp:attachment":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media?parent=28048"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/categories?post=28048"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/tags?post=28048"},{"taxonomy":"topic","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/topic?post=28048"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}
- HelloWordCallBack\u662f\u5bf9\u5e94\u6d88\u606fid：MSG_HELLO_WORD\u7684\u56de\u8c03\u51fd\u6570\n