{"id":116038,"date":"2026-10-20T17:17:10","date_gmt":"2026-10-20T09:17:10","guid":{"rendered":"https:\/\/www.wsisp.com\/helps\/116038.html"},"modified":"2026-10-20T17:17:10","modified_gmt":"2026-10-20T09:17:10","slug":"%e3%80%90%e5%9c%a8%e7%ba%bf%e4%ba%94%e5%ad%90%e6%a3%8b%e5%af%b9%e6%88%98%e3%80%91%e6%9c%8d%e5%8a%a1%e5%99%a8%e4%b8%9a%e5%8a%a1%e5%88%86%e7%b1%bb%e8%af%b7%e6%b1%82%e5%a4%84%e7%90%86","status":"publish","type":"post","link":"https:\/\/www.wsisp.com\/helps\/116038.html","title":{"rendered":"\u3010\u5728\u7ebf\u4e94\u5b50\u68cb\u5bf9\u6218\u3011\u670d\u52a1\u5668\u4e1a\u52a1\u5206\u7c7b\u8bf7\u6c42\u5904\u7406"},"content":{"rendered":"

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

\u76ee\u5f55<\/p>\n

Http\u8bf7\u6c42\u5904\u7406<\/p>\n

\u9759\u6001\u8d44\u6e90\u8bf7\u6c42<\/p>\n

\u6ce8\u518c\u8bf7\u6c42<\/p>\n

\u767b\u5f55\u8bf7\u6c42<\/p>\n

\u4fe1\u606f\u83b7\u53d6\u8bf7\u6c42<\/p>\n

Websocket\u8bf7\u6c42\u5904\u7406<\/p>\n

\u6253\u5f00\u5927\u5385\u8bf7\u6c42<\/p>\n

\u5173\u95ed\u5927\u5385\u8bf7\u6c42<\/p>\n

\u5927\u5385\u6d88\u606f\u8bf7\u6c42<\/p>\n

\u6253\u5f00\u623f\u95f4\u8bf7\u6c42<\/p>\n

\u5173\u95ed\u623f\u95f4\u8bf7\u6c42<\/p>\n

\u623f\u95f4\u6d88\u606f\u8bf7\u6c42<\/p>\n

\u9879\u76ee\u603b\u7ed3<\/p>\n

\n

\u901a\u8fc7\u5b9a\u4e49\u4e00\u4e2a\u670d\u52a1\u5668\u7c7b\u5bf9\u8c61，\u7ba1\u7406\u4e4b\u524d\u6240\u6709\u7684\u6a21\u5757\u7c7b，\u5e76\u5b9e\u73b0\u5bf9http\u3001open\u3001close\u3001message\u7684\u8bf7\u6c42\u5904\u7406\u65b9\u6cd5<\/p>\n

class Gomoku_Server
\n{
\n using websocket_server = websocketpp::server<websocketpp::config::asio>;<\/p>\n

public:
\n Gomoku_Server(const std::string &host,
\n const std::string &user,
\n const std::string &passwd,
\n const std::string &db,
\n uint16_t port = 3306,
\n const std::string &wwwroot = WWWROOT)
\n : _webroot(wwwroot), _user(host, user, passwd, db, port), _room(&_user, &_online), _session(&_server), _matcher(&_room, &_online, &_user)
\n {
\n websocket_server &server = _server; \/\/ \u4e3a\u4e86\u65b9\u4fbf\u4e0b\u9762\u7684lambda\u65b9\u6cd5\u5f15\u7528
\n _server.set_access_channels(websocketpp::log::alevel::none); \/\/ \u8bbe\u7f6e\u65e5\u5fd7\u7ea7\u522b
\n _server.init_asio(); \/\/ \u521d\u59cb\u5316asio\u8c03\u5ea6\u5668
\n _server.set_reuse_addr(true); \/\/ \u5f00\u542f\u5730\u5740\u91cd\u7528<\/p>\n

\/\/ \u8bbe\u7f6ehttp\u56de\u8c03\u65b9\u6cd5
\n _server.set_http_handler([&server, this](websocketpp::connection_hdl hdl) {<\/p>\n

});
\n _server.set_open_handler([&server](websocketpp::connection_hdl) {<\/p>\n

});
\n _server.set_close_handler([&server](websocketpp::connection_hdl) {<\/p>\n

});
\n _server.set_message_handler([&server](websocketpp::connection_hdl, websocket_server::message_ptr msg_ptr) {<\/p>\n

});
\n }<\/p>\n

void Start(uint16_t port)
\n {
\n _server.listen(port); \/\/ \u8bbe\u7f6e\u7aef\u53e3\u53f7
\n _server.start_accept(); \/\/ \u542f\u52a8\u76d1\u542c
\n _server.run(); \/\/ \u542f\u52a8\u670d\u52a1\u7aef
\n }<\/p>\n

private:
\n void File_Handler(websocket_server::connection_ptr &conn)
\n \/\/ \u9759\u6001\u8d44\u6e90\u8bf7\u6c42\u7684\u5904\u7406
\n {
\n }<\/p>\n

void Register(websocket_server::connection_ptr &conn)
\n \/\/ \u7528\u6237\u6ce8\u518c\u529f\u80fd\u8bf7\u6c42\u7684\u5904\u7406
\n {
\n }<\/p>\n

void Login(websocket_server::connection_ptr &conn)
\n \/\/ \u7528\u6237\u767b\u5f55\u529f\u80fd\u8bf7\u6c42\u7684\u5904\u7406
\n {
\n }<\/p>\n

void Info(websocket_server::connection_ptr &conn)
\n \/\/ \u7528\u6237\u4fe1\u606f\u83b7\u53d6\u529f\u80fd\u8bf7\u6c42\u7684\u5904\u7406
\n {
\n }<\/p>\n

private:
\n std::string _webroot; \/\/ \u670d\u52a1\u5668\u6839\u76ee\u5f55 \u4f8b\u5982 \/register.html -> .\/wwwroot\/register.html<\/p>\n

User_Table _user; \/\/ \u7528\u6237\u7ba1\u7406
\n Online_Manager _online; \/\/ \u5728\u7ebf\u7528\u6237\u7ba1\u7406
\n Room_Manager _room; \/\/ \u623f\u95f4\u7ba1\u7406
\n Matcher _matcher; \/\/ \u5339\u914d\u7ba1\u7406<\/p>\n

Session_Manager _session; \/\/ session\u7ba1\u7406<\/p>\n

websocket_server _server; \/\/ websocket\u670d\u52a1\u7aef
\n}; <\/p>\n

\u5f53\u8c03\u7528\u8be5\u7c7b\u65f6，\u76f4\u63a5.Start()，\u670d\u52a1\u5668\u5c31\u8dd1\u8d77\u6765\u4e86<\/p>\n

Http\u8bf7\u6c42\u5904\u7406<\/h2>\n

\u5bf9\u4e8eHttp\u8bf7\u6c42，\u5206\u4e3a\u9759\u6001\u8d44\u6e90\u8bf7\u6c42（html\u8d44\u6e90）\u3001\u548c\u52a8\u6001\u8d44\u6e90\u8bf7\u6c42（\u6ce8\u518c\u3001\u767b\u5f55\u3001\u4fe1\u606f\u83b7\u53d6…），\u56e0\u6b64\u5728 _server.set_http_handler() <\/span>\u4e2d\u5148\u5b9e\u73b0\u5bf9\u8bf7\u6c42\u7684\u5206\u7c7b<\/p>\n

_server.set_http_handler([&server, this](websocketpp::connection_hdl hdl)
\n {
\n \/\/ \u83b7\u53d6\u8fde\u63a5
\n websocket_server::connection_ptr conn = server.get_con_from_hdl(hdl);
\n \/\/ \u83b7\u53d6\u8bf7\u6c42\u4e2d\u7684\u65b9\u6cd5\u548curi
\n websocketpp::http::parser::request request = conn->get_request();
\n std::string method = request.get_method();
\n std::string uri = request.get_uri();
\n \/\/ \u5224\u65ad\u662f\u4ec0\u4e48\u7c7b\u578b\u7684\u8bf7\u6c42
\n if(method == "POST" && uri == "\/register") \/\/ \u6ce8\u518c\u8bf7\u6c42
\n return Register(conn);
\n else if(method == "POST" && uri == "\/login") \/\/ \u767b\u5f55\u8bf7\u6c42
\n return Login(conn);
\n else if(method == "GET" && uri == "\/info") \/\/ \u6d88\u606f\u8bf7\u6c42
\n return Info(conn); \/\/ \u9759\u6001\u8d44\u6e90\u8bf7\u6c42
\n else
\n return File_Handler(conn); }); <\/p>\n

\u9759\u6001\u8d44\u6e90\u8bf7\u6c42<\/h3>\n

\u5f53\u5ba2\u6237\u7aef\u8bf7\u6c42\u9759\u6001\u8d44\u6e90\u65f6，File_Handler\u7684\u4efb\u52a1\u662f\u8bfb\u53d6\u8be5\u6587\u4ef6\u5e76\u8fd4\u56de\u7ed9\u5ba2\u6237\u7aef \u82e5\u8d44\u6e90\u4e0d\u5b58\u5728\u5219\u8fd4\u56de404<\/p>\n

void File_Handler(websocket_server::connection_ptr &conn)
\n\/\/ \u9759\u6001\u8d44\u6e90\u8bf7\u6c42\u7684\u5904\u7406
\n{
\n \/\/ \u83b7\u53d6\u8bf7\u6c42\u7684uri\u8d44\u6e90\u8def\u5f84
\n websocketpp::http::parser::request request = conn->get_request();
\n std::string uri = request.get_uri();
\n \/\/ \u7ec4\u5408\u6210\u771f\u5b9e\u8def\u5f84
\n std::string filepath = _webroot + uri;
\n \/\/ \u82e5\u8def\u5f84\u662f\u76ee\u5f55，\u589e\u52a0\u4e00\u4e2a\u540e\u7f00，\u4f8b\u5982login.html
\n if (filepath.back() == '\/')
\n filepath += "login.html";<\/p>\n

\/\/ \u8bfb\u53d6\u6587\u4ef6\u5185\u5bb9
\n Json::Value response;
\n std::string body;
\n if (File_Util::Read(filepath, body) == false) \/\/ \u82e5\u6587\u4ef6\u4e0d\u5b58\u5728，\u8fd4\u56de404
\n {
\n body += "<html><head><meta charset=\\\\"UTF-8\\\\"\/><\/head><body><h1> Not Found <\/h1><\/body><\/html>";
\n conn->set_status(websocketpp::http::status_code::not_found); \/\/ \u8bbe\u7f6e404\u72b6\u6001\u7801
\n conn->set_body(body);
\n return;
\n }<\/p>\n

\/\/ \u8bbe\u7f6e\u54cd\u5e94\u6b63\u6587
\n conn->set_body(body);
\n conn->set_status(websocketpp::http::status_code::ok);
\n} <\/p>\n

\u6ce8\u518c\u8bf7\u6c42<\/h3>\n

Register\u7684\u4efb\u52a1\u662f\u5c06\u5ba2\u6237\u7aef\u53d1\u6765\u7684 \u7528\u6237\u540d&\u5bc6\u7801 \u5b58\u5230\u6570\u636e\u5e93<\/p>\n

void Register(websocket_server::connection_ptr &conn)
\n\/\/ \u7528\u6237\u6ce8\u518c\u529f\u80fd\u8bf7\u6c42\u7684\u5904\u7406
\n{
\n \/\/ \u83b7\u53d6\u8bf7\u6c42\u6b63\u6587
\n \/\/ \u5bf9\u6b63\u6587JSON\u53cd\u5e8f\u5217\u5316，\u5f97\u5230\u7528\u6237\u540d&\u5bc6\u7801
\n std::string req_body = conn->get_request_body();
\n Json::Value user_info;
\n if (Json_Util::Deserialization(req_body, user_info) == false)
\n \/\/ \u53cd\u5e8f\u5217\u5316\u5931\u8d25
\n {
\n LOG(LogLv::ERROR, "\u53cd\u5e8f\u5217\u5316\u6ce8\u518c\u4fe1\u606f\u5931\u8d25");
\n Set_Json_Response(conn, Protocol::MakeHttpError("\u8bf7\u6c42\u7684\u6b63\u6587\u683c\u5f0f\u9519\u8bef"),
\n websocketpp::http::status_code::bad_request);
\n return;
\n }
\n \/\/ \u63d2\u5165\u6570\u636e\u5e93
\n auto is_blank = [](const Json::Value &value)
\n {
\n \/* \u5224\u65ad\u5b57\u7b26\u4e32\u662f\u5426\u4e3a\u7a7a *\/
\n if (!value.isString())
\n return true;
\n const std::string text = value.asString();
\n return std::all_of(text.begin(), text.end(), [](unsigned char ch)
\n { return std::isspace(ch) != 0; });
\n };
\n if (is_blank(user_info["username"]) || is_blank(user_info["password"]))
\n \/\/ \u7528\u6237\u540d|\u5bc6\u7801 \u6709\u7a7a
\n {
\n LOG(LogLv::ERROR, "\u7528\u6237\u540d\u6216\u5bc6\u7801\u4e3a\u7a7a");
\n Set_Json_Response(conn, Protocol::MakeHttpError("\u8bf7\u8f93\u5165\u7528\u6237\u540d\/\u5bc6\u7801"),
\n websocketpp::http::status_code::bad_request);
\n return;
\n }
\n if (_user.Register(user_info) == false)
\n \/\/ \u7528\u6237\u540d\u88ab\u5360\u7528
\n {
\n Set_Json_Response(conn, Protocol::MakeHttpError("\u7528\u6237\u540d\u88ab\u5360\u7528"),
\n websocketpp::http::status_code::bad_request);
\n return;
\n }
\n \/\/ \u6210\u529f\u8fd4\u56de200
\n LOG(LogLv::DEBUG, "\u6ce8\u518c\u6210\u529f");
\n Set_Json_Response(conn, Protocol::MakeHttpSuccess("\u6ce8\u518c\u6210\u529f"),
\n websocketpp::http::status_code::ok);
\n return;
\n} <\/p>\n

\u767b\u5f55\u8bf7\u6c42<\/h3>\n

\u5c06\u524d\u7aef\u53d1\u6765\u7684\u7528\u6237\u540d&\u5bc6\u7801\u4e0e\u6570\u636e\u5e93\u4f5c\u6bd4\u5bf9，\u82e5\u6210\u529f，\u5219\u8ba9\u7528\u6237\u8df3\u8f6c\u5230\u5927\u5385\u754c\u9762<\/p>\n

void Login(websocket_server::connection_ptr &conn)
\n\/\/ \u7528\u6237\u767b\u5f55\u529f\u80fd\u8bf7\u6c42\u7684\u5904\u7406
\n{
\n \/\/ \u83b7\u53d6\u8bf7\u6c42\u6b63\u6587
\n std::string req_body = conn->get_request_body();
\n \/\/ \u5bf9\u6b63\u6587\u53cd\u5e8f\u5217\u5316\u5f97\u5230\u7528\u6237\u540d&\u5bc6\u7801
\n Json::Value user_info;
\n if (Json_Util::Deserialization(req_body, user_info) == false)
\n \/\/ \u53cd\u5e8f\u5217\u5316\u5931\u8d25
\n {
\n LOG(LogLv::ERROR, "\u53cd\u5e8f\u5217\u5316\u6ce8\u518c\u767b\u5f55\u5931\u8d25");
\n Set_Json_Response(conn, Protocol::MakeHttpError("\u8bf7\u6c42\u7684\u6b63\u6587\u683c\u5f0f\u9519\u8bef"),
\n websocketpp::http::status_code::bad_request);
\n return;
\n }
\n \/\/ \u6821\u9a8c\u6b63\u6587\u5b8c\u6574\u6027
\n auto is_blank = [](const Json::Value &value)
\n {
\n \/* \u5224\u65ad\u5b57\u7b26\u4e32\u662f\u5426\u4e3a\u7a7a *\/
\n if (!value.isString())
\n return true;
\n const std::string text = value.asString();
\n return std::all_of(text.begin(), text.end(), [](unsigned char ch)
\n { return std::isspace(ch) != 0; });
\n };
\n if (is_blank(user_info["username"]) || is_blank(user_info["password"]))
\n \/\/ \u7528\u6237\u540d|\u5bc6\u7801 \u6709\u7a7a
\n {
\n LOG(LogLv::ERROR, "\u7528\u6237\u540d\u6216\u5bc6\u7801\u4e3a\u7a7a");
\n Set_Json_Response(conn, Protocol::MakeHttpError("\u8bf7\u8f93\u5165\u7528\u6237\u540d\/\u5bc6\u7801"),
\n websocketpp::http::status_code::bad_request);
\n return;
\n }
\n \/\/ \u7528\u6237\u4fe1\u606f\u9a8c\u8bc1
\n if (_user.Login(user_info) == false)
\n \/\/ \u6821\u9a8c\u5931\u8d25
\n {
\n LOG(LogLv::ERROR, "\u7528\u6237\u540d&\u5bc6\u7801\u9519\u8bef");
\n Set_Json_Response(conn, Protocol::MakeHttpError("\u5bc6\u7801\u9519\u8bef，\u8bf7\u91cd\u8bd5"),
\n websocketpp::http::status_code::bad_request);
\n return;
\n }<\/p>\n

\/\/ \u9a8c\u8bc1\u6210\u529f，\u521b\u5efaSession
\n int uid = user_info["id"].asInt();
\n session_ptr ssp = _session.Create_Session(uid, Session_Status::LOGIN);
\n if (ssp.get() == nullptr)
\n \/\/ \u521b\u5efasession\u5931\u8d25
\n {
\n LOG(LogLv::ERROR, "\u521b\u5efaSession\u5931\u8d25");
\n Set_Json_Response(conn, Protocol::MakeHttpError("\u521b\u5efaSession\u5931\u8d25"),
\n websocketpp::http::status_code::internal_server_error);
\n return;
\n }
\n \/\/ \u521b\u5efaSession\u6210\u529f，\u8bbe\u7f6e\u8fc7\u671f\u65f6\u95f4
\n _session.Set_Session_ExpireTime(ssp->Get_Ssid(), SESSION_TIMEOUT);
\n \/\/ \u521b\u5efaSession\u6210\u529f，\u8bbe\u7f6e\u4e3aCookie
\n std::string ssid = "SSID=" + std::to_string(ssp->Get_Ssid());
\n conn->append_header("Set-Cookie", ssid);
\n \/\/ \u8bbe\u7f6e\u6210\u529f\u54cd\u5e94
\n LOG(LogLv::DEBUG, "\u767b\u5f55\u6210\u529f");
\n Set_Json_Response(conn, Protocol::MakeHttpSuccess("\u767b\u5f55\u6210\u529f"),
\n websocketpp::http::status_code::ok);
\n} <\/p>\n

\u5728\u767b\u5f55\u6210\u529f\u540e，\u4e5f\u4f1a\u7ed9\u8be5\u7528\u6237\u521b\u5efa\u4e00\u4e2aSession，\u548c\u54cd\u5e94\u4e00\u5e76\u8fd4\u56de\u7ed9\u524d\u7aef<\/p>\n

\u4fe1\u606f\u83b7\u53d6\u8bf7\u6c42<\/h3>\n

\u5728\u7528\u6237\u767b\u5f55\u8fdb\u5165\u5927\u5385\u540e，\u9700\u8981\u7528\u8fc7GET\u8bf7\u6c42\u83b7\u53d6\u8be5\u7528\u6237\u7684\u5bf9\u6218\u573a\u6b21\u3001\u79ef\u5206\u7b49\u7b49\u4fe1\u606f<\/p>\n

void Info(websocket_server::connection_ptr &conn)
\n \/\/ \u7528\u6237\u4fe1\u606f\u83b7\u53d6\u529f\u80fd\u8bf7\u6c42\u7684\u5904\u7406
\n {
\n \/\/ \u901a\u8fc7SSID\u627e\u5230Session
\n session_ptr ssp = Get_Session_From_Cookie(conn);
\n if (ssp.get() == nullptr) \/\/ Session\u8fc7\u671f
\n {
\n LOG(LogLv::ERROR, "ssid\u5bf9\u5e94Session\u5931\u6548");
\n Set_Json_Response(conn, Protocol::MakeHttpError("\u767b\u5f55\u8fc7\u671f，\u8bf7\u91cd\u65b0\u767b\u5f55"),
\n websocketpp::http::status_code::bad_request);
\n return;
\n }
\n \/\/ \u901a\u8fc7Session\u627e\u5230\u7528\u6237
\n int uid = ssp->Get_User();
\n \/\/ \u53d6\u51fa\u7528\u6237\u4fe1\u606f\u5e76\u8fd4\u56de
\n Json::Value user_info;
\n if (_user.SelectById(uid, user_info) == false) \/\/ \u83b7\u53d6\u7528\u6237\u4fe1\u606f\u5931\u8d25
\n {
\n LOG(LogLv::ERROR, "\u83b7\u53d6\u7528\u6237\u4fe1\u606f\u5931\u8d25");
\n Set_Json_Response(conn, Protocol::MakeHttpError("\u627e\u4e0d\u5230\u7528\u6237\u4fe1\u606f，\u8bf7\u91cd\u65b0\u767b\u5f55"),
\n websocketpp::http::status_code::bad_request);
\n return;
\n }
\n Set_Json_Response(conn, user_info, websocketpp::http::status_code::ok);
\n \/\/ \u5237\u65b0Session\u8fc7\u671f\u65f6\u95f4
\n _session.Set_Session_ExpireTime(ssp->Get_Ssid(), SESSION_TIMEOUT);
\n } <\/p>\n

Websocket\u8bf7\u6c42\u5904\u7406<\/h2>\n

\u5728\u521d\u59cb\u5316server\u7c7b\u65f6，\u4f1a\u8bbe\u7f6e\u8be5\u670d\u52a1\u7aef\u5bf9\u4e8ewebsocoket\u6253\u5f00\/\u5173\u95ed\/\u6d88\u606f\/http\u7684\u56de\u8c03\u51fd\u6570，\u5bf9\u4e8e\u4e0a\u9762\u7684http\u8bf7\u6c42，\u90fd\u5728_server.set_http_handler\u4e2d\u8bbe\u7f6e\u597d\u4e86<\/p>\n

\u4e0b\u9762\u4e00\u4e00\u5bf9\u8bbe\u7f6e\u7684\u6253\u5f00\/\u5173\u95ed\/\u6d88\u606f\u56de\u8c03\u51fd\u6570\u5185\u7684\u63a5\u53e3\u8fdb\u884c\u5b9e\u73b0<\/p>\n

Gomoku_Server(const std::string &host,
\n const std::string &user,
\n const std::string &passwd,
\n const std::string &db,
\n uint16_t port = 3306,
\n const std::string &wwwroot = WWWROOT)
\n : _webroot(wwwroot), _user(host, user, passwd, db, port), _room(&_user, &_online), _session(&_server), _matcher(&_room, &_online, &_user)
\n {
\n websocket_server &server = _server; \/\/ \u4e3a\u4e86\u65b9\u4fbf\u4e0b\u9762\u7684lambda\u65b9\u6cd5\u5f15\u7528
\n _server.set_access_channels(websocketpp::log::alevel::none); \/\/ \u8bbe\u7f6e\u65e5\u5fd7\u7ea7\u522b
\n _server.init_asio(); \/\/ \u521d\u59cb\u5316asio\u8c03\u5ea6\u5668
\n _server.set_reuse_addr(true); \/\/ \u5f00\u542f\u5730\u5740\u91cd\u7528<\/p>\n

\/\/ \u8bbe\u7f6ehttp\u56de\u8c03\u65b9\u6cd5
\n _server.set_http_handler([&server, this](websocketpp::connection_hdl hdl)
\n {
\n \/\/ \u83b7\u53d6\u8fde\u63a5
\n websocket_server::connection_ptr conn = server.get_con_from_hdl(hdl);
\n \/\/ \u83b7\u53d6\u8bf7\u6c42\u4e2d\u7684\u65b9\u6cd5\u548curi
\n websocketpp::http::parser::request request = conn->get_request();
\n std::string method = request.get_method();
\n std::string uri = request.get_uri();
\n \/\/ \u5224\u65ad\u662f\u4ec0\u4e48\u7c7b\u578b\u7684\u8bf7\u6c42
\n if(method == "POST" && uri == "\/register") \/\/ \u6ce8\u518c\u8bf7\u6c42
\n return Register(conn);
\n else if(method == "POST" && uri == "\/login") \/\/ \u767b\u5f55\u8bf7\u6c42
\n return Login(conn);
\n else if(method == "GET" && uri == "\/info") \/\/ \u6d88\u606f\u8bf7\u6c42
\n return Info(conn); \/\/ \u9759\u6001\u8d44\u6e90\u8bf7\u6c42
\n else
\n return File_Handler(conn); });
\n _server.set_open_handler([&server, this](websocketpp::connection_hdl hdl)
\n {
\n \/\/ websocket\u957f\u8fde\u63a5\u5efa\u7acb\u6210\u529f\u540e\u7684\u56de\u8c03\u51fd\u6570
\n \/\/ \u83b7\u53d6\u8bf7\u6c42uri
\n websocket_server::connection_ptr conn = server.get_con_from_hdl(hdl);
\n websocketpp::http::parser::request request = conn->get_request();
\n std::string uri = request.get_uri();
\n \/\/ \u901a\u8fc7uri\u5224\u65ad \u5927\u5385\/\u623f\u95f4 websocket\u8bf7\u6c42
\n if(uri == "\/hall") \/\/ \u5927\u5385websocket\u8bf7\u6c42
\n {
\n return WsOpen_Hall(conn);
\n }
\n else if(uri == "\/room") \/\/ \u623f\u95f4websocket\u8bf7\u6c42
\n {
\n return WsOpen_Room(conn);
\n } });
\n _server.set_close_handler([&server, this](websocketpp::connection_hdl hdl)
\n {
\n \/\/ websocket\u957f\u8fde\u63a5\u65ad\u5f00\u540e\u7684\u56de\u8c03\u51fd\u6570
\n \/\/ \u83b7\u53d6\u8bf7\u6c42uri
\n websocket_server::connection_ptr conn = server.get_con_from_hdl(hdl);
\n websocketpp::http::parser::request request = conn->get_request();
\n std::string uri = request.get_uri();
\n \/\/ \u901a\u8fc7uri\u5224\u65ad \u5927\u5385\/\u623f\u95f4 websocket\u8bf7\u6c42
\n if(uri == "\/hall") \/\/ \u5927\u5385websocket\u8bf7\u6c42
\n {
\n return WsClose_Hall(conn);
\n }
\n else if(uri == "\/room") \/\/ \u623f\u95f4websocket\u8bf7\u6c42
\n {
\n return WsClose_Room(conn);
\n } });
\n _server.set_message_handler([&server, this](websocketpp::connection_hdl hdl, websocket_server::message_ptr msg_ptr)
\n {
\n \/\/ websocket\u957f\u8fde\u63a5\u901a\u4fe1\u7684\u56de\u8c03\u51fd\u6570
\n \/\/ \u83b7\u53d6\u8bf7\u6c42uri
\n websocket_server::connection_ptr conn = server.get_con_from_hdl(hdl);
\n websocketpp::http::parser::request request = conn->get_request();
\n std::string uri = request.get_uri();
\n \/\/ \u901a\u8fc7uri\u5224\u65ad \u5927\u5385\/\u623f\u95f4 websocket\u8bf7\u6c42
\n if(uri == "\/hall") \/\/ \u5927\u5385websocket\u8bf7\u6c42
\n {
\n return WsMessage_Hall(conn, msg_ptr);
\n }
\n else if(uri == "\/room") \/\/ \u623f\u95f4websocket\u8bf7\u6c42
\n {
\n return WsMessage_Room(conn, msg_ptr);
\n } });
\n } <\/p>\n

\u6253\u5f00\u5927\u5385\u8bf7\u6c42<\/h3>\n

\u5f53\u7528\u6237\u8fdb\u5165\u5927\u5385\u65f6，\u9700\u8981\u5224\u65ad\u662f\u5426\u6709\u8be5\u7528\u6237\u7684Session，\u82e5\u6709，\u5c31\u5c06\u8be5\u7528\u6237\u52a0\u5165\u5728\u7ebf\u7528\u6237\u5927\u5385\u7ba1\u7406\u7ed3\u6784 \u540c\u65f6\u5c06Session\u65f6\u9650\u8bbe\u4e3a\u6c38\u4e45，\u9632\u6b62\u5728\u5927\u5385\u65f6\u5c31\u8fc7\u671f<\/p>\n

void WsOpen_Hall(websocket_server::connection_ptr conn) \/\/ \u8fdb\u5165\u5927\u5385\u7684\u5904\u7406
\n{
\n \/\/ 1. \u5224\u65ad\u5ba2\u6237\u7aef\u662f\u5426\u6210\u529f\u767b\u5f55
\n session_ptr ssp = Get_Session_From_Cookie(conn);
\n if (ssp.get() == nullptr)
\n return;
\n \/\/ 2. \u5224\u65ad\u5ba2\u6237\u7aef\u662f\u5426\u91cd\u590d\u767b\u5f55
\n if (_online.IsHall(ssp->Get_Ssid()) || _online.IsRoom(ssp->Get_Ssid()))
\n {
\n LOG(LogLv::ERROR, "\u8be5\u7528\u6237\u91cd\u590d\u767b\u5f55");
\n Send_WebSocket_Response(conn, Protocol::MakeHallReady(false, "\u73a9\u5bb6\u91cd\u590d\u767b\u5f55"));
\n return;
\n }
\n \/\/ 3. \u5c06\u5f53\u524d\u5ba2\u6237\u7aef\u8fde\u63a5\u52a0\u5165\u5230\u6e38\u620f\u5927\u5385\u7ba1\u7406\u7ed3\u6784
\n _online.EnterHall(ssp->Get_User(), conn);
\n \/\/ 4. \u7ed9\u5ba2\u6237\u7aef\u54cd\u5e94\u6e38\u620f\u5927\u5385\u8fde\u63a5\u6210\u529f
\n Send_WebSocket_Response(conn, Protocol::MakeHallReady(true));<\/p>\n

\/\/ 5. \u5c06\u8be5\u7528\u6237Session\u8bbe\u4e3a\u6c38\u4e45\u5b58\u5728
\n _session.Set_Session_ExpireTime(ssp->Get_Ssid(), SESSION_FOREVER);
\n} <\/p>\n

\u5173\u95ed\u5927\u5385\u8bf7\u6c42<\/h3>\n

\u5927\u5385\u5173\u95ed\u65f6，\u9700\u8981\u79fb\u51fa\u5728\u7ebf\u7528\u6237\u7ba1\u7406\u7ed3\u6784，\u5e76\u4e14\u5c06Session\u91cd\u65b0\u8bbe\u4e3a\u6709\u671f<\/p>\n

void WsClose_Hall(websocket_server::connection_ptr conn) \/\/ \u9000\u51fa\u5927\u5385\u7684\u5904\u7406
\n{
\n \/\/ \u83b7\u53d6\u5230\u8be5\u8fde\u63a5\u7684session
\n session_ptr ssp = Get_Session_From_Cookie(conn);
\n if (ssp.get() == nullptr)
\n return;
\n \/\/ \u5c06\u8be5\u8fde\u63a5\u79fb\u51fa\u5927\u5385
\n _online.ExitHall(ssp->Get_User());
\n \/\/ \u5c06\u8be5Session\u91cd\u65b0\u8bbe\u4e3a\u6709\u671f
\n \/\/if (!_online.IsRoom(ssp->Get_User()))
\n _session.Set_Session_ExpireTime(ssp->Get_Ssid(), SESSION_TIMEOUT);
\n} <\/p>\n

\u5927\u5385\u6d88\u606f\u8bf7\u6c42<\/h3>\n

\u5927\u5385\u7684\u6d88\u606f\u8bf7\u6c42\u5206\u4e3a\u4e24\u79cd：\u5f00\u59cb\u5339\u914d\u548c\u53d6\u6d88\u5339\u914d \u4e5f\u5c31\u662f\u5c06\u7528\u6237\u653e\u5165\/\u53d6\u51fa\u5339\u914d\u961f\u5217<\/p>\n

void WsMessage_Hall(websocket_server::connection_ptr conn, websocket_server::message_ptr msg_ptr) \/\/ \u5927\u5385\u6d88\u606f\u7684\u5904\u7406
\n{
\n \/\/ \u83b7\u53d6\u5230\u8be5\u8fde\u63a5\u7684session
\n session_ptr ssp = Get_Session_From_Cookie(conn);
\n if(ssp.get() == nullptr)
\n return;
\n \/\/ \u83b7\u53d6\u8bf7\u6c42\u6b63\u6587
\n std::string req_body_str = msg_ptr->get_payload();
\n Json::Value req_body_json;
\n if (Json_Util::Deserialization(req_body_str, req_body_json) == false)
\n {
\n LOG(LogLv::ERROR, "\u53cd\u5e8f\u5217\u5316\u5931\u8d25");
\n Send_WebSocket_Response(conn, Protocol::MakeHallError("\u8bf7\u6c42\u4fe1\u606f\u89e3\u6790\u5931\u8d25"));
\n return;
\n }
\n \/\/ \u82e5\u662f\u5f00\u59cb\u5339\u914d\u8bf7\u6c42：\u5c06\u7528\u6237\u6dfb\u52a0\u5230\u5339\u914d\u961f\u5217\u4e2d
\n if (!req_body_json["optype"].isNull() && req_body_json["optype"].asString() == "match_start")
\n {
\n _matcher.Add(ssp->Get_User());
\n Send_WebSocket_Response(conn, Protocol::MakeHallOperationResult("match_start", true));
\n return;
\n }
\n \/\/ \u82e5\u662f\u53d6\u6d88\u5339\u914d\u8bf7\u6c42：\u5c06\u7528\u6237\u4ece\u5339\u914d\u961f\u5217\u4e2d\u79fb\u51fa
\n else if (!req_body_json["optype"].isNull() && req_body_json["optype"].asString() == "match_stop")
\n {
\n _matcher.Del(ssp->Get_User());
\n Send_WebSocket_Response(conn, Protocol::MakeHallOperationResult("match_stop", true));
\n return;
\n }
\n \/\/ \u9519\u8bef\u8bf7\u6c42\u7c7b\u578b
\n else
\n {
\n Send_WebSocket_Response(conn, Protocol::MakeHallUnknownOperation());
\n return;
\n }
\n} <\/p>\n

\u6253\u5f00\u623f\u95f4\u8bf7\u6c42<\/h3>\n

\u5f53\u5339\u914d\u6210\u529f\u8fdb\u5165\u623f\u95f4\u540e，\u4ece\u4e00\u4e2awebsocket\u8fde\u63a5\u5207\u6362\u5230\u4e86\u53e6\u4e00\u4e2awebsocket\u8fde\u63a5 \u5c06\u8be5\u7528\u6237\u52a0\u5165\u5728\u7ebf\u7528\u6237\u623f\u95f4\u7ba1\u7406\u7ed3\u6784，\u5e76\u5c06Session\u8bbe\u4e3a\u6c38\u4e45<\/p>\n

void WsOpen_Room(websocket_server::connection_ptr conn) \/\/ \u8fdb\u5165\u623f\u95f4\u7684\u5904\u7406
\n{
\n Json::Value response;
\n \/\/ \u83b7\u53d6Session
\n session_ptr ssp = Get_Session_From_Cookie(conn);
\n if(ssp.get() == nullptr)
\n return;
\n \/\/ \u5224\u65ad\u662f\u5426\u91cd\u590d\u767b\u5f55(\u5728\u5927\u5385 | \u623f\u95f4)
\n if(_online.IsHall(ssp->Get_User()) || _online.IsRoom(ssp->Get_User()))
\n {
\n response["optype"] = "room_ready";
\n response["result"] = false;
\n response["reason"] = "\u73a9\u5bb6\u91cd\u590d\u767b\u5f55";
\n Send_WebSocket_Response(conn, response);
\n }
\n \/\/ \u5224\u65ad\u662f\u5426\u5df2\u7ecf\u521b\u597d\u4e86\u8be5\u7528\u6237\u7684\u623f\u95f4
\n room_ptr roomp = _room.Get_Room_FromUid(ssp->Get_User());
\n if(roomp.get() == nullptr)
\n {
\n response["optype"] = "room_ready";
\n response["result"] = false;
\n response["reason"] = "\u6ca1\u6709\u627e\u5230\u8be5\u7528\u6237\u7684\u623f\u95f4\u4fe1\u606f";
\n Send_WebSocket_Response(conn, response);
\n }
\n \/\/ \u5c06\u8be5\u7528\u6237\u5217\u5165\u5728\u7ebf\u7528\u6237\u7ba1\u7406（\u623f\u95f4）
\n _online.EnterRoom(ssp->Get_User(), conn);
\n \/\/ \u5c06Session\u8bbe\u4e3a\u6c38\u4e45
\n _session.Set_Session_ExpireTime(ssp->Get_Ssid(), SESSION_FOREVER);
\n \/\/ \u7ed9\u5ba2\u6237\u7aef\u8fd4\u56de\u54cd\u5e94
\n Send_WebSocket_Response(conn, Protocol::MakeRoomReady(
\n roomp->GetId(),
\n ssp->Get_User(),
\n roomp->GetUser_White(),
\n roomp->GetUser_Black()));
\n} <\/p>\n

\u5173\u95ed\u623f\u95f4\u8bf7\u6c42<\/h3>\n

\u5173\u95ed\u623f\u95f4\u65f6，\u9700\u8981\u5c06\u7528\u6237\u79fb\u51fa\u5728\u7ebf\u7528\u6237\u623f\u95f4\u7ba1\u7406\u7ed3\u6784，\u5e76\u4e14\u56e0\u4e3a\u65ad\u5f00\u4e86\u8fde\u63a5，\u6240\u4ee5\u8981\u91cd\u65b0\u5c06Session\u8bbe\u4e3a\u6709\u671f<\/p>\n

void WsClose_Room(websocket_server::connection_ptr conn)
\n{
\n \/\/ \u83b7\u53d6Session
\n session_ptr ssp = Get_Session_From_Cookie(conn);
\n if(ssp.get() == nullptr)
\n return;<\/p>\n

\/\/ \u5c06\u8be5\u7528\u6237\u79fb\u51fa\u5728\u7ebf\u7528\u6237\u7684\u623f\u95f4\u7ba1\u7406
\n _online.ExitRoom(ssp->Get_User());
\n \/\/ \u5c06\u8be5\u7528\u6237\u79fb\u51fa\u623f\u95f4
\n _room.Remove_RoomUser(ssp->Get_User());
\n \/\/ \u5c06Session\u8bbe\u7f6e\u4e3a\u6709\u671f
\n _session.Set_Session_ExpireTime(ssp->Get_Ssid(), SESSION_TIMEOUT);
\n} <\/p>\n

\u623f\u95f4\u6d88\u606f\u8bf7\u6c42<\/h3>\n

\u623f\u95f4\u5185\u7684\u6d88\u606f\u8bf7\u6c42，\u90fd\u8f6c\u7ed9\u623f\u95f4\u6d88\u606f\u5904\u7406\u603b\u501f\u53e3，\u8ba9\u5b83\u81ea\u884c\u5224\u65ad\u662f\u54ea\u79cd\u7c7b\u578b（\u4e0b\u68cb\u3001\u9000\u51fa\u3001\u804a\u5929）<\/p>\n

void WsMessage_Room(websocket_server::connection_ptr conn, websocket_server::message_ptr msg_ptr)
\n{
\n Json::Value response;
\n \/\/ \u83b7\u53d6Sesssion
\n session_ptr ssp = Get_Session_From_Cookie(conn);
\n if(ssp.get() == nullptr)
\n return;
\n \/\/ \u83b7\u53d6\u623f\u95f4\u4fe1\u606f
\n room_ptr roomp = _room.Get_Room_FromUid(ssp->Get_User());
\n if(roomp.get() == nullptr)
\n {
\n response["optype"] = "unknown";
\n response["result"] = false;
\n response["reason"] = "\u6ca1\u6709\u627e\u5230\u7528\u6237\u7684\u623f\u95f4\u4fe1\u606f";
\n return Send_WebSocket_Response(conn, response);
\n }
\n \/\/ \u5bf9\u8bf7\u6c42\u8fdb\u884c\u53cd\u5e8f\u5217\u5316
\n Json::Value request;
\n std::string body = msg_ptr->get_payload();
\n if(Json_Util::Deserialization(body, request) == false)
\n \/\/ \u53cd\u5e8f\u5217\u5316\u5931\u8d25
\n {
\n response["optype"] = "unknown";
\n response["result"] = false;
\n response["reason"] = "\u8bf7\u6c42\u89e3\u6790\u5931\u8d25";
\n return Send_WebSocket_Response(conn, response);
\n }
\n \/\/ \u4ea4\u7ed9\u623f\u95f4\u8bf7\u6c42\u7684\u603b\u5904\u7406\u63a5\u53e3
\n return roomp->Handle_Request(request, ssp->Get_User());<\/p>\n

} <\/p>\n

\u9879\u76ee\u603b\u7ed3<\/h2>\n

\u9879\u76ee\u540d\u79f0：\u5728\u7ebf\u4e94\u5b50\u68cb\u5bf9\u6218<\/p>\n

\u9879\u76ee\u7b80\u4ecb：\u5b9e\u73b0\u4e94\u5b50\u68cb\u670d\u52a1\u5668，\u80fd\u591f\u8ba9\u7528\u6237\u901a\u8fc7\u6d4f\u89c8\u5668\u8bbf\u95ee\u670d\u52a1\u5668，\u8fdb\u884c\u7528\u6237\u7684\u6ce8\u518c，\u767b\u5f55，\u5bf9\u6218\u5339\u914d，\u5b9e\u65f6\u5bf9\u6218，\u5b9e\u65f6\u804a\u5929\u7b49\u529f\u80fd\u3002<\/p>\n

\u5f00\u53d1\u73af\u5883：AlmaLinux，vim\/vscode\/g++\/gdb\/makefile<\/p>\n

\u9879\u76ee\u5b9e\u73b0：<\/p>\n