\u00a0 \u00a0 \u00a0 \u00a0 \u670d\u52a1\u5668\u6a21\u5757\u662f\u5bf9\u5f53\u524d\u6240\u6709\u5df2\u7ecf\u5b9e\u73b0\u7684\u6a21\u5757\u7684\u4e00\u4e2a\u6574\u5408，\u5e76\u8fdb\u884c\u670d\u52a1\u7684\u6a21\u5757\u3002\u4f7f\u7528websocket\u5e93\u7684\u63a5\u53e3\u6765\u642d\u5efa\u670d\u52a1\u5668\u7684\u57fa\u672c\u67b6\u6784，\u518d\u5b9e\u73b0\u56db\u4e2a\u4e3b\u8981\u7684\u63a5\u53e3：http\u8bf7\u6c42\u7684\u63a5\u53e3，\u5efa\u7acbwebsocket\u94fe\u63a5\u8bf7\u6c42，\u65ad\u5f00websocket\u94fe\u63a5\u8bf7\u6c42，websocket\u901a\u4fe1\u8bf7\u6c42\u3002<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u7528\u6237\u5728\u672a\u5efa\u7acbwebsocket\u957f\u8fde\u63a5\u5728\u524d\u9700\u8981\u901a\u8fc7http\u8fdb\u884c\u901a\u4fe1，\u7528\u6237\u7684\u8bf7\u6c42\u4e00\u5171\u5206\u4e3a：\u8bf7\u6c42\u9759\u6001\u8d44\u6e90\u3001\u6ce8\u518c\u7528\u6237\u3001\u7528\u6237\u767b\u5f55，\u5728\u7528\u6237\u767b\u5f55\u6210\u529f\u4e4b\u540e\u5c31\u9700\u8981\u83b7\u53d6\u6e38\u620f\u5927\u5385\u7684\u9875\u9762\u4ee5\u53ca\u7528\u6237\u4fe1\u606f\u548c\u5efa\u7acb\u6e38\u620f\u5927\u5385\u7684\u957f\u8fde\u63a5\u3002\u5176\u4e2d\u8bf7\u6c42\u9759\u6001\u8d44\u6e90\u53ea\u9700\u8981\u8fd4\u56de\u9875\u9762\u4fe1\u606f\u5373\u53ef，\u800c\u6ce8\u518c\u767b\u5f55\u4ee5\u53ca\u83b7\u53d6\u7528\u6237\u4fe1\u606f\u90fd\u9700\u8981\u8bbf\u95ee\u6570\u636e\u5e93\u3002<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u5176\u4e2d\u8bf7\u6c42\u548c\u54cd\u5e94\u7684\u65b9\u5f0f\u5982\u4e0b\u3002<\/p>\n
. \u6ce8\u518c\u2eda\u2faf\u8bf7\u6c42
\n \u8bf7\u6c42：GET \/register.html HTTP\/1.1
\n \u54cd\u5e94：
\n HTTP\/1.1 200 OK
\n Content-Length: xxx
\n Content-Type: text\/html<\/p>\n
register.html\u2f42\u4ef6\u7684\u5185\u5bb9\u6570\u636e<\/p>\n
2. \u767b\u5f55\u2eda\u2faf\u8bf7\u6c42
\n \u8bf7\u6c42：GET \/login.html HTTP\/1.1
\n 3. \u2f24\u5385\u2eda\u2faf\u8bf7\u6c42
\n \u8bf7\u6c42：GET \/game_hall.html HTTP\/1.1
\n 4. \u623f\u95f4\u2eda\u2faf\u8bf7\u6c42
\n \u8bf7\u6c42：GET \/game_room.html HTTP\/1.1<\/p>\n
\/\/\u6ce8\u518c\u7528\u6237\u8bf7\u6c42
\nPOST \/reg HTTP\/1.1
\n Content-Type: application\/json
\n Content-Length: 32<\/p>\n
{"username":"xiaobai", "password":"123123"}
\n #\u6210\u529f\u65f6\u7684\u54cd\u5e94
\n HTTP\/1.1 200 OK
\n Content-Type: application\/json
\n Content-Length: 15<\/p>\n
{"result":true}<\/p>\n
#\u5931\u8d25\u65f6\u7684\u54cd\u5e94
\n HTTP\/1.1 400 Bad Request
\n Content-Type: application\/json
\n Content-Length: 43<\/p>\n
{"result":false, "reason": "\u2f64\u6237\u540d\u5df2\u7ecf\u88ab\u5360\u2f64"}<\/p>\n
\/\/\u7528\u6237\u767b\u5f55\u8bf7\u6c42<\/p>\n
POST \/login HTTP\/1.1
\n Content-Type: application\/json
\n Content-Length: 32<\/p>\n
{"username":"xiaobai", "password":"123123"}
\n #\u6210\u529f\u65f6\u7684\u54cd\u5e94
\n HTTP\/1.1 200 OK
\n Content-Type: application\/json
\n Content-Length: 15<\/p>\n
{"result":true}<\/p>\n
#\u5931\u8d25\u65f6\u7684\u54cd\u5e94
\n HTTP\/1.1 400 Bad Request
\n Content-Type: application\/json
\n Content-Length: 43<\/p>\n
{"result":false, "reason": "\u2f64\u6237\u540d\u6216\u5bc6\u7801\u9519\u8bef"}<\/p>\n
\/\/\u83b7\u53d6\u7528\u6237\u4fe1\u606f\u8bf7\u6c42
\nGET \/userinfo HTTP\/1.1
\n Content-Type: application\/json
\n Content-Length: 0
\n #\u6210\u529f\u65f6\u7684\u54cd\u5e94
\n HTTP\/1.1 200 OK
\n Content-Type: application\/json
\n Content-Length: 58<\/p>\n
{"id":1, "username":"xiaobai", "score":1000, "total_count":4, "win_count":2}<\/p>\n
#\u5931\u8d25\u65f6\u7684\u54cd\u5e94
\n HTTP\/1.1 401 Unauthorized
\n Content-Type: application\/json
\n Content-Length: 43<\/p>\n
{"result":false, "reason": "\u2f64\u6237\u8fd8\u672a\u767b\u5f55"} <\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u56e0\u4e3awebsocket\u957f\u8fde\u63a5\u662f\u57fa\u4e8e\u9875\u9762\u7684，\u9875\u9762\u5173\u95ed\u94fe\u63a5\u5c31\u4f1a\u65ad\u5f00，\u6240\u4ee5\u8fdb\u5165\u65e0\u8bba\u662f\u5efa\u7acb\u94fe\u63a5\u8fd8\u662f\u5173\u95ed\u94fe\u63a5\u90fd\u9700\u8981\u533a\u5206\u662f\u6e38\u620f\u623f\u95f4\u7684\u8bf7\u6c42\u8fd8\u662f\u6e38\u620f\u5927\u5385\u7684\u8bf7\u6c42\u3002<\/p>\n
\/\/websocket\u957f\u8fde\u63a5\u534f\u8bae\u5207\u6362\u8bf7\u6c42(\u8fdb\u5165\u6e38\u620f\u5927\u5385)
\n\/* ws:\/\/localhost:9000\/hall *\/
\n GET \/hall HTTP\/1.1
\n Connection: Upgrade
\n Upgrade: WebSocket
\n ……
\n HTTP\/1.1 101 Switching
\n ……
\n\/\/WebSocket\u63e1\u2f3f\u6210\u529f\u540e\u7684\u56de\u590d：\u8868\u2f70\u6e38\u620f\u2f24\u5385\u5df2\u7ecf\u8fdb\u2f0a\u6210\u529f\u3002
\n {
\n "optype": "hall_ready",
\n "uid": 1
\n }<\/p>\n
\/\/websocket\u957f\u8fde\u63a5\u534f\u8bae\u5207\u6362\u8bf7\u6c42(\u8fdb\u5165\u6e38\u620f\u623f\u95f4)
\n\/* ws:\/\/localhost:9000\/room *\/
\n GET \/room HTTP\/1.1
\n Connection: Upgrade
\n Upgrade: WebSocket
\n ……
\n HTTP\/1.1 101 Switching
\n ……
\n\/\/WebSocket\u63e1\u2f3f\u6210\u529f\u540e\u7684\u56de\u590d：\u8868\u2f70\u6e38\u620f\u623f\u95f4\u5df2\u7ecf\u8fdb\u2f0a\u6210\u529f\u3002
\n \/*\u534f\u8bae\u5207\u6362\u6210\u529f， \u623f\u95f4\u5df2\u7ecf\u5efa\u2f74*\/
\n {
\n "optype": "room_ready",
\n "room_id": 222, \/\/\u623f\u95f4ID
\n "self_id": 1, \/\/\u2f83\u2f9dID
\n "white_id": 1, \/\/\u2f69\u68cbID
\n "black_id": 2, \/\/\u2fca\u68cbID
\n } <\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 websocket\u901a\u4fe1\u53c8\u53c8\u5206\u4e3a\u6e38\u620f\u5927\u5385\u7684\u8bf7\u6c42\u548c\u6e38\u620f\u623f\u95f4\u7684\u8bf7\u6c42，\u6e38\u620f\u5927\u5385\u7684\u8bf7\u6c42\u6709：\u5f00\u59cb\u5339\u914d\u3001\u53d6\u6d88\u5339\u914d，\u6e38\u620f\u623f\u95f4\u7684\u8bf7\u6c42\u6709：\u4e0b\u68cb\u3001\u804a\u5929\u3002\u6e38\u620f\u623f\u95f4\u7684\u8bf7\u6c42\u5728\u6210\u529f\u5b8c\u6210\u540e\u8fd8\u9700\u8981\u5e7f\u64ad\u7ed9\u623f\u95f4\u5185\u7684\u6240\u6709\u73a9\u5bb6\u3002<\/p>\n
\/\/\u2f9b\u68cb
\n {
\n "optype": "put_chess", \/\/ put_chess\u8868\u2f70\u5f53\u524d\u8bf7\u6c42\u662f\u4e0b\u68cb\u64cd\u4f5c
\n "room_id": 222, \/\/ room_id \u8868\u2f70\u5f53\u524d\u52a8\u4f5c\u5c5e\u4e8e\u54ea\u4e2a\u623f\u95f4
\n "uid": 1, \/\/ \u5f53\u524d\u7684\u4e0b\u68cb\u64cd\u4f5c\u662f\u54ea\u4e2a\u2f64\u2f3e\u53d1\u8d77\u7684
\n "row": 3, \/\/ \u5f53\u524d\u4e0b\u68cb\u4f4d\u7f6e\u7684\u2f8f\u53f7
\n "col": 2 \/\/ \u5f53\u524d\u4e0b\u68cb\u4f4d\u7f6e\u7684\u5217\u53f7
\n }
\n {
\n "optype": "put_chess",
\n "result": false
\n "reason": "\u2f9b\u68cb\u5931\u8d25\u5177\u4f53\u539f\u56e0…."
\n }
\n {
\n "optype": "put_chess",
\n "room_id": 222,
\n "uid": 1,
\n "row": 3,
\n "col": 2,
\n "result": true,
\n "reason": "\u5bf9\u2f45\u6389\u7ebf，\u4e0d\u6218\u2f7d\u80dc！" \/ "\u5bf9\u2f45\/\u2f30\u2f45\u4e94\u661f\u8fde\u73e0，\u6218\u2f46\u654c\/\u867d\u8d25\u72b9\u8363！",
\n "winner": 0 \/\/ 0-\u672a\u5206\u80dc\u8d1f， !0-\u5df2\u5206\u80dc\u8d1f (uid\u662f\u8c01，\u8c01\u5c31\u8d62\u4e86)
\n }
\n\/\/ \u804a\u5929
\n {
\n "optype": "chat",
\n "room_id": 222,
\n "uid": 1,
\n "message": "\u8d76\u7d27\u70b9"
\n }
\n {
\n "optype": "chat",
\n "result": false
\n "reason": "\u804a\u5929\u5931\u8d25\u5177\u4f53\u539f\u56e0….\u2f50\u5982\u6709\u654f\u611f\u8bcd…"
\n }
\n {
\n "optype": "chat",
\n "result": true,
\n "room_id": 222,
\n "uid": 1,
\n "message": "\u8d76\u7d27\u70b9"
\n } <\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u5177\u4f53\u5982\u4e0b\u3002<\/p>\n
#ifndef __M_SERVER_H__
\n#define __M_SERVER_H__
\n#include "room.hpp"
\n#include "matcher.hpp"
\n#include "session.hpp"<\/p>\n
#define WWWROOT ".\/wwwroot"
\nclass gobang_server
\n{
\nprivate:
\n websocket_server _wssrv;
\n std::string _web_root;
\n user_table _ut;
\n online_manage _om;
\n session_manage _sm;
\n room_manage _rm;
\n match _mm;<\/p>\n
private:
\n void file_handler(websocket_server::connection_ptr &conn)
\n {
\n websocketpp::http::parser::request req = conn->get_request();
\n std::string method = req.get_method();
\n std::string uri = req.get_uri();
\n std::string pathname = _web_root + uri;
\n if (uri == "\/")
\n {
\n pathname += "auth.html";
\n }
\n std::string body;
\n bool ret = file_util::read(pathname, body);
\n if (ret == false)
\n {
\n body.clear();
\n std::string x = _web_root + "404.html";
\n file_util::read(x, body);
\n conn->set_status(websocketpp::http::status_code::not_found);
\n }
\n else
\n {
\n conn->set_status(websocketpp::http::status_code::ok);
\n }
\n conn->set_body(body);
\n }
\n void login(websocket_server::connection_ptr &conn)
\n {
\n websocketpp::http::parser::request req = conn->get_request();
\n Json::Value login_json;
\n \/\/ \u83b7\u53d6\u6b63\u6587
\n std::string req_body = conn->get_request_body();
\n \/\/ \u53cd\u5e8f\u5217\u5316\u5f97\u5230\u7528\u6237\u540d\u548c\u5bc6\u7801
\n bool ret = json_util::Unserialization(req_body, login_json);
\n if (ret == false)
\n {
\n DLOG("\u53cd\u5e8f\u5217\u5316\u5931\u8d25");
\n return http_resp(false, websocketpp::http::status_code::bad_request, "\u8bf7\u6c42\u683c\u5f0f\u9519\u8bef！", conn);
\n }
\n if (login_json["username"].isNull() || login_json["password"].isNull())
\n {
\n DLOG("\u7528\u6237\u63d0\u4ea4\u4fe1\u606f\u4e0d\u5b8c\u5168");
\n return http_resp(false, websocketpp::http::status_code::bad_request, "\u8bf7\u8f93\u5165\u7528\u6237\u540d\/\u5bc6\u7801！", conn);
\n }
\n ret = _ut.login(login_json);
\n if (ret == false)
\n {
\n DLOG("\u7528\u6237\u8f93\u5165\u9519\u8bef\u7528\u6237\u540d\/\u547d\u540d");
\n return http_resp(false, websocketpp::http::status_code::bad_request, "\u7528\u6237\u540d\/\u5bc6\u7801\u9519\u8bef！", conn);
\n }
\n uint64_t uid = login_json["id"].asUInt64();
\n session_ptr ssp = _sm.create_session(uid, ONLOGIN);
\n if (ssp.get() == nullptr)
\n {
\n DLOG("\u521b\u5efa\u4f1a\u8bdd\u5931\u8d25");
\n return http_resp(false, websocketpp::http::status_code::internal_server_error, "\u521b\u5efa\u4f1a\u8bdd\u5931\u8d25！", conn);
\n }
\n _sm.set_session_time(ssp->get_ssid(), SESSION_TIME);
\n std::string cokie = "SSID=" + std::to_string(ssp->get_ssid()) + ";Path=\/";
\n conn->append_header("Set-Cookie", cokie);
\n return http_resp(true, websocketpp::http::status_code::ok, "\u767b\u9646\u6210\u529f", conn);
\n }
\n void http_resp(bool ret, websocketpp::http::status_code::value code,
\n const std::string &reason, websocket_server::connection_ptr &conn)
\n {
\n Json::Value resp_json;
\n resp_json["result"] = ret;
\n resp_json["reason"] = reason;
\n std::string resp_body;
\n json_util::Serialization(resp_json, resp_body);
\n conn->set_body(resp_body);
\n conn->set_status(code);
\n conn->append_header("Content-Type", "application\/json;charset=utf-8");
\n return;
\n }
\n void reg(websocket_server::connection_ptr &conn)
\n {
\n websocketpp::http::parser::request req = conn->get_request();
\n Json::Value login_json;
\n \/\/ \u83b7\u53d6\u6b63\u6587
\n std::string req_body = conn->get_request_body();
\n \/\/ \u53cd\u5e8f\u5217\u5316\u5f97\u5230\u7528\u6237\u540d\u548c\u5bc6\u7801
\n bool ret = json_util::Unserialization(req_body, login_json);
\n if (ret == false)
\n {
\n DLOG("\u53cd\u5e8f\u5217\u5316\u5931\u8d25");
\n return http_resp(false, websocketpp::http::status_code::bad_request, "\u8bf7\u6c42\u683c\u5f0f\u9519\u8bef！", conn);
\n }
\n if (login_json["username"].isNull() || login_json["password"].isNull())
\n {
\n DLOG("\u7528\u6237\u63d0\u4ea4\u4fe1\u606f\u4e0d\u5b8c\u5168");
\n return http_resp(false, websocketpp::http::status_code::bad_request, "\u8bf7\u8f93\u5165\u7528\u6237\u540d\/\u5bc6\u7801！", conn);
\n }
\n ret = _ut.insert(login_json);
\n if (ret == false)
\n {
\n DLOG("\u63d2\u5165\u6570\u636e\u5e93\u5931\u8d25");
\n return http_resp(false, websocketpp::http::status_code::bad_request, "\u7528\u6237\u540d\u88ab\u5360\u7528！", conn);
\n }
\n return http_resp(true, websocketpp::http::status_code::ok, "\u6ce8\u518c\u6210\u529f！", conn);
\n }
\n bool get_cookie_val(const std::string &cookie, const std::string &key, std::string &val)
\n {
\n std::string tmp_cookie = cookie;
\n \/\/ \u628a\u6240\u6709";"\u66ff\u6362\u6210"; "，\u89e3\u51b3\u5206\u53f7\u65e0\u7a7a\u683c\u5206\u5272\u5931\u8d25
\n size_t pos = 0;
\n while ((pos = tmp_cookie.find(';', pos)) != std::string::npos)
\n {
\n tmp_cookie.insert(pos + 1, " ");
\n pos += 2;
\n }<\/p>\n
std::string sep = "; ";
\n std::vector<std::string> cookie_arr;
\n string_util::split(tmp_cookie, sep, cookie_arr);<\/p>\n
auto trim = [](std::string &s)
\n {
\n s.erase(0, s.find_first_not_of(" \\\\t"));
\n s.erase(s.find_last_not_of(" \\\\t") + 1);
\n };<\/p>\n
for (auto &m : cookie_arr)
\n {
\n std::vector<std::string> tem;
\n string_util::split(m, "=", tem);
\n if (tem.size() != 2)
\n continue;<\/p>\n
trim(tem[0]);
\n trim(tem[1]);<\/p>\n
if (tem[0] == key)
\n {
\n val = tem[1];
\n return true;
\n }
\n }
\n return false;
\n }<\/p>\n
void info(websocket_server::connection_ptr &conn)
\n {
\n \/\/ \u83b7\u53d6cookie\u4fe1\u606f
\n std::string cookie_str = conn->get_request_header("Cookie");
\n if (cookie_str.empty())
\n {
\n DLOG("\u627e\u4e0d\u5230cookie\u4fe1\u606f");
\n return http_resp(false, websocketpp::http::status_code::bad_request, "\u627e\u4e0d\u5230cookie\u4fe1\u606f，\u8bf7\u91cd\u65b0\u767b\u5f55！", conn);
\n }
\n \/\/ \u83b7\u53d6ssid
\n std::string ssid_str;
\n bool ret = get_cookie_val(cookie_str, "SSID", ssid_str);
\n if (ret == false)
\n {
\n DLOG("\u627e\u4e0d\u5230ssid");
\n return http_resp(false, websocketpp::http::status_code::bad_request, "\u627e\u4e0d\u5230ssid\u4fe1\u606f，\u8bf7\u91cd\u65b0\u767b\u5f55！", conn);
\n }
\n \/\/ \u67e5\u627esession
\n session_ptr ssp = _sm.get_session_by_ssid(std::stoll(ssid_str));
\n if (ssp.get() == nullptr)
\n {
\n DLOG("session\u8fc7\u671f");
\n return http_resp(false, websocketpp::http::status_code::bad_request, "\u767b\u5f55\u8fc7\u671f，\u8bf7\u91cd\u65b0\u767b\u5f55！", conn);
\n }
\n \/\/ \u67e5\u8be2\u7528\u6237\u4fe1\u606f
\n Json::Value root;
\n uint64_t uid = ssp->get_uid();
\n ret = _ut.selete_by_id(uid, root);
\n if (ret == false)
\n {
\n return http_resp(false, websocketpp::http::status_code::bad_request, "\u627e\u4e0d\u5230\u7528\u6237\u4fe1\u606f，\u8bf7\u91cd\u65b0\u767b\u5f55！", conn);
\n }
\n \/\/ \u8fd4\u56de\u7528\u6237\u4fe1\u606f
\n std::string body;
\n json_util::Serialization(root, body);
\n conn->set_status(websocketpp::http::status_code::ok);
\n conn->set_body(body);
\n conn->append_header("Content-Type", "application\/json;charset=utf-8");
\n \/\/ \u5237\u65b0\u8fc7\u671f\u65f6\u95f4
\n _sm.set_session_time(ssp->get_ssid(), SESSION_TIME);
\n }
\n void http_callback(websocketpp::connection_hdl hdl)
\n {
\n websocket_server::connection_ptr conn = _wssrv.get_con_from_hdl(hdl);
\n websocketpp::http::parser::request req = conn->get_request();
\n std::string method = req.get_method();
\n std::string uri = req.get_uri();
\n if (method == "POST" && uri == "\/login")
\n {
\n return login(conn);
\n }
\n else if (method == "POST" && uri == "\/reg")
\n {
\n return reg(conn);
\n }
\n else if (method == "GET" && uri == "\/info")
\n {
\n return info(conn);
\n }
\n else
\n {
\n return file_handler(conn);
\n }
\n }
\n void ws_resp(websocket_server::connection_ptr conn, Json::Value &resp)
\n {
\n std::string body;
\n json_util::Serialization(resp, body);
\n conn->send(body);
\n }
\n session_ptr get_session_by_cookie(websocket_server::connection_ptr &conn)
\n {
\n Json::Value err_resp;
\n \/\/ \u83b7\u53d6cookie\u4fe1\u606f
\n std::string cookie_str = conn->get_request_header("Cookie");
\n if (cookie_str.empty())
\n {
\n DLOG("\u627e\u4e0d\u5230cookie\u4fe1\u606f");
\n err_resp["optype"] = "hall_ready";
\n err_resp["reason"] = "\u627e\u4e0d\u5230cookie\u4fe1\u606f，\u8bf7\u91cd\u65b0\u767b\u5f55!";
\n err_resp["result"] = false;
\n ws_resp(conn, err_resp);
\n return session_ptr();
\n }
\n \/\/ \u83b7\u53d6ssid
\n std::string ssid_str;
\n bool ret = get_cookie_val(cookie_str, "SSID", ssid_str);
\n if (ret == false)
\n {
\n DLOG("\u627e\u4e0d\u5230ssid");
\n err_resp["optype"] = "hall_ready";
\n err_resp["reason"] = "\u627e\u4e0d\u5230SSID\u4fe1\u606f，\u8bf7\u91cd\u65b0\u767b\u5f55!";
\n err_resp["result"] = false;
\n ws_resp(conn, err_resp);
\n return session_ptr();
\n }
\n \/\/ \u67e5\u627esession
\n session_ptr ssp = _sm.get_session_by_ssid(std::stoll(ssid_str));
\n if (ssp.get() == nullptr)
\n {
\n DLOG("session\u8fc7\u671f");
\n err_resp["optype"] = "hall_ready";
\n err_resp["reason"] = "\u627e\u4e0d\u5230session\u4fe1\u606f，\u8bf7\u91cd\u65b0\u767b\u5f55!";
\n err_resp["result"] = false;
\n ws_resp(conn, err_resp);
\n return session_ptr();
\n }
\n return ssp;
\n }
\n void wopen_hall(websocket_server::connection_ptr conn)
\n {
\n Json::Value err_resp;
\n session_ptr ssp = get_session_by_cookie(conn);
\n if (ssp.get() == nullptr)
\n {
\n return;
\n }
\n \/\/ \u662f\u5426\u91cd\u590d\u767b\u5f55
\n if (_om.is_in_game_hall(ssp->get_uid()) || _om.is_in_game_room(ssp->get_uid()))
\n {
\n err_resp["optype"] = "hall_ready";
\n err_resp["reason"] = "\u73a9\u5bb6\u91cd\u590d\u767b\u5f55!";
\n err_resp["result"] = false;
\n return ws_resp(conn, err_resp);
\n }
\n \/\/ \u5c06\u5ba2\u6237\u7aef\u53ca\u5176\u94fe\u63a5\u6dfb\u52a0\u5230\u6e38\u620f\u5927\u5385
\n _om.enter_game_hall(ssp->get_uid(), conn);
\n Json::Value resp_json;
\n resp_json["optype"] = "hall_ready";
\n resp_json["result"] = true;
\n ws_resp(conn, resp_json);
\n \/\/ \u5c31\u4ee5\u540esession\u8bbe\u7f6e\u4e3a\u6c38\u4e45\u5b58\u5728
\n _sm.set_session_time(ssp->get_ssid(), SESSION_PERMANENT);
\n }
\n void wopen_room(websocket_server::connection_ptr conn)
\n {
\n \/\/ \u83b7\u53d6\u7528\u6237session
\n Json::Value resp_json;
\n session_ptr ssp = get_session_by_cookie(conn);
\n if (ssp.get() == nullptr)
\n {
\n return;
\n }
\n \/\/ \u662f\u5426\u91cd\u590d\u767b\u5f55
\n if (_om.is_in_game_hall(ssp->get_uid()) || _om.is_in_game_room(ssp->get_uid()))
\n {
\n DLOG("\u73a9\u5bb6\u91cd\u590d\u767b\u5f55!");
\n resp_json["optype"] = "room_ready";
\n resp_json["reason"] = "\u73a9\u5bb6\u91cd\u590d\u767b\u5f55!";
\n resp_json["result"] = false;
\n return ws_resp(conn, resp_json);
\n }
\n \/\/ \u662f\u5426\u5df2\u7ecf\u6709\u623f\u95f4
\n room_ptr rm = _rm.get_room_by_uid(ssp->get_uid());
\n if (rm.get() == nullptr)
\n {
\n DLOG("\u627e\u4e0d\u5230\u73a9\u5bb6\u623f\u95f4\u4fe1\u606f!");
\n resp_json["optype"] = "room_ready";
\n resp_json["reason"] = "\u627e\u4e0d\u5230\u73a9\u5bb6\u623f\u95f4\u4fe1\u606f!";
\n resp_json["result"] = false;
\n return ws_resp(conn, resp_json);
\n }
\n \/\/ \u6dfb\u52a0\u5230\u5728\u7ebf\u7528\u6237\u623f\u95f4\u4e2d
\n _om.enter_game_room(ssp->get_uid(), conn);
\n \/\/ \u8bbe\u7f6esession\u6c38\u4e45\u5b58\u5728
\n _sm.set_session_time(ssp->get_ssid(), SESSION_PERMANENT);
\n resp_json["optype"] = "room_ready";
\n resp_json["result"] = true;
\n resp_json["room_id"] = (Json::UInt64)rm->get_room_id();
\n resp_json["uid"] = (Json::UInt64)ssp->get_uid();
\n resp_json["white_id"] = (Json::UInt64)rm->get_white_id();<\/p>\n
return ws_resp(conn, resp_json);
\n }
\n void wopen_callback(websocketpp::connection_hdl hdl)
\n {
\n websocket_server::connection_ptr conn = _wssrv.get_con_from_hdl(hdl);
\n websocketpp::http::parser::request req = conn->get_request();
\n std::string uri = req.get_uri();
\n if (uri == "\/hall")
\n {
\n \/\/ \u5efa\u7acb\u6e38\u620f\u5927\u5385\u957f\u8fde\u63a5
\n return wopen_hall(conn);
\n }
\n else if (uri == "\/room")
\n {
\n \/\/ \u5efa\u7acb\u6e38\u620f\u623f\u95f4\u957f\u8fde\u63a5
\n return wopen_room(conn);
\n }
\n }
\n void wclose_game_hall(websocket_server::connection_ptr conn)
\n {
\n session_ptr ssp = get_session_by_cookie(conn);
\n if (ssp.get() == nullptr)
\n {
\n return;
\n }
\n \/\/ \u5c06\u73a9\u5bb6\u4ece\u6e38\u620f\u5927\u5385\u4e2d\u79fb\u9664
\n _om.exit_game_hall(ssp->get_uid());
\n \/\/ \u8bbe\u7f6esession\u8fc7\u671f\u65f6\u95f4
\n _sm.set_session_time(ssp->get_ssid(), SESSION_TIME);
\n }
\n void wclose_game_room(websocket_server::connection_ptr conn)
\n {
\n session_ptr ssp = get_session_by_cookie(conn);
\n if (ssp.get() == nullptr)
\n {
\n return;
\n }
\n \/\/ \u5c06\u73a9\u5bb6\u4ece\u6e38\u620f\u623f\u95f4\u5728\u7ebf\u7528\u6237\u5217\u8868\u4e2d\u79fb\u9664
\n _om.exit_game_room(ssp->get_uid());
\n \/\/ \u8bbe\u7f6esession\u6c38\u4e0d\u8fc7\u671f
\n _sm.set_session_time(ssp->get_ssid(), SESSION_TIME);
\n \/\/ \u51cf\u5c11\u623f\u95f4\u4eba\u6570
\n _rm.remove_room_user(ssp->get_uid());
\n }
\n void wclose_callback(websocketpp::connection_hdl hdl)
\n {
\n websocket_server::connection_ptr conn = _wssrv.get_con_from_hdl(hdl);
\n websocketpp::http::parser::request req = conn->get_request();
\n std::string uri = req.get_uri();
\n if (uri == "\/hall")
\n {
\n \/\/ \u65ad\u5f00\u6e38\u620f\u5927\u5385\u957f\u8fde\u63a5
\n return wclose_game_hall(conn);
\n }
\n else if (uri == "\/room")
\n {
\n \/\/ \u65ad\u5f00\u6e38\u620f\u623f\u95f4\u957f\u8fde\u63a5
\n return wclose_game_room(conn);
\n }
\n }
\n void wmessage_game_hall(websocket_server::connection_ptr conn, websocket_server::message_ptr msg)
\n {
\n \/\/ \u9a8c\u8bc1\u8eab\u4efd
\n session_ptr ssp = get_session_by_cookie(conn);
\n if (ssp.get() == nullptr)
\n {
\n return;
\n }
\n \/\/ \u83b7\u53d6\u8bf7\u6c42\u4fe1\u606f
\n std::string resp_str = msg->get_payload();
\n Json::Value resp_json;
\n bool ret = json_util::Unserialization(resp_str, resp_json);
\n if (ret == false)
\n {
\n resp_json["reasont"] = "\u8bf7\u6c42\u89e3\u6790\u5931\u8d25";
\n resp_json["result"] = false;
\n return ws_resp(conn, resp_json);
\n }
\n if (!resp_json["optype"].isNull() && resp_json["optype"].asString() == "match_start")
\n {
\n \/\/ \u5c06\u73a9\u5bb6\u52a0\u5165\u5339\u914d\u961f\u5217
\n DLOG("\u5904\u7406\u4e86\u5339\u914d\u6d88\u606f");
\n _mm.add(ssp->get_uid());
\n resp_json["optype"] = "match_start";
\n resp_json["result"] = true;
\n return ws_resp(conn, resp_json);
\n }
\n else if (!resp_json["optype"].isNull() && resp_json["optype"].asString() == "match_stop")
\n {
\n \/\/ \u73a9\u5bb6\u4ece\u5339\u914d\u961f\u5217\u4e2d\u79fb\u9664
\n DLOG("\u5904\u7406\u4e86\u53d6\u6d88\u5339\u914d\u6d88\u606f");
\n _mm.del(ssp->get_uid());
\n resp_json["optype"] = "match_stop";
\n resp_json["result"] = true;
\n return ws_resp(conn, resp_json);
\n }
\n resp_json["optype"] = "unknown";
\n resp_json["result"] = false;
\n return ws_resp(conn, resp_json);
\n }
\n void wmessage_game_room(websocket_server::connection_ptr conn, websocket_server::message_ptr msg)
\n {
\n DLOG("wmessage_game_room \u5f00\u59cb\u5904\u7406");
\n Json::Value resp_json;
\n \/\/ \u83b7\u53d6session\u4fe1\u606f
\n session_ptr ssp = get_session_by_cookie(conn);
\n if (ssp.get() == nullptr)
\n {
\n return;
\n }
\n DLOG("wmessage_game_room: uid=%lu", ssp->get_uid());
\n \/\/\u83b7\u53d6\u623f\u95f4\u4fe1\u606f
\n room_ptr rm = _rm.get_room_by_uid(ssp->get_uid());
\n if (rm.get() == nullptr)
\n {
\n DLOG("\u627e\u4e0d\u5230\u73a9\u5bb6\u623f\u95f4\u4fe1\u606f!");
\n resp_json["optype"] = "unknown";
\n resp_json["reason"] = "\u627e\u4e0d\u5230\u73a9\u5bb6\u623f\u95f4\u4fe1\u606f!";
\n resp_json["result"] = false;
\n return ws_resp(conn, resp_json);
\n }
\n DLOG("\u627e\u5230\u623f\u95f4: room_id=%lu", rm->get_room_id());
\n \/\/ \u83b7\u53d6\u8bf7\u6c42\u4fe1\u606f
\n std::string resp_str = msg->get_payload();
\n DLOG("\u6536\u5230\u623f\u95f4\u6d88\u606f: %s", resp_str.c_str());
\n bool ret = json_util::Unserialization(resp_str, resp_json);
\n if(ret == false)
\n {
\n DLOG("\u8bf7\u6c42\u89e3\u6790\u5931\u8d25!");
\n resp_json["optype"] = "unknown";
\n resp_json["reason"] = "\u8bf7\u6c42\u89e3\u6790\u5931\u8d25";
\n resp_json["result"] = false;
\n return ws_resp(conn, resp_json);
\n }
\n DLOG("\u8c03\u7528 handle_request, optype=%s", resp_json["optype"].asString().c_str());
\n return rm->handle_request(resp_json);
\n }
\n void wmessage_callback(websocketpp::connection_hdl hdl, websocket_server::message_ptr msg)
\n {
\n websocket_server::connection_ptr conn = _wssrv.get_con_from_hdl(hdl);
\n websocketpp::http::parser::request req = conn->get_request();
\n std::string uri = req.get_uri();
\n if (uri == "\/hall")
\n {
\n \/\/ \u6536\u5230\u6e38\u620f\u5927\u5385\u6d88\u606f
\n DLOG("\u6536\u5230\u6e38\u620f\u5927\u5385\u6d88\u606f");
\n return wmessage_game_hall(conn, msg);
\n }
\n else if (uri == "\/room")
\n {
\n \/\/ \u6536\u5230\u6e38\u620f\u623f\u95f4\u6d88\u606f
\n DLOG("\u6536\u5230\u6e38\u620f\u623f\u95f4\u6d88\u606f");
\n return wmessage_game_room(conn,msg);
\n }
\n }<\/p>\n
public:
\n gobang_server(const std::string &host,
\n const std::string &user,
\n const std::string &password,
\n const std::string &db, unsigned int port = 3306,
\n const std::string &wwwroot = WWWROOT)
\n : _web_root(wwwroot), _ut(host, user, password, db, port), _sm(&_wssrv), _rm(&_ut, &_om), _mm(&_ut, &_om, &_rm)
\n {
\n _wssrv.set_access_channels(websocketpp::log::alevel::none);
\n _wssrv.init_asio();
\n _wssrv.set_reuse_addr(true);
\n _wssrv.set_open_handler(std::bind(&gobang_server::wopen_callback, this, std::placeholders::_1));
\n _wssrv.set_close_handler(std::bind(&gobang_server::wclose_callback, this, std::placeholders::_1));
\n _wssrv.set_message_handler(std::bind(&gobang_server::wmessage_callback, this, std::placeholders::_1, std::placeholders::_2));
\n _wssrv.set_http_handler(std::bind(&gobang_server::http_callback, this, std::placeholders::_1));
\n }
\n void start(int port)
\n {
\n _wssrv.listen(port);
\n _wssrv.start_accept();
\n _wssrv.run();
\n }
\n};<\/p>\n
#endif <\/p>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u7528\u6237\u8ba4\u8bc1\u6a21\u5757\u652f\u6301\u767b\u5f55\u548c\u6ce8\u518c\u529f\u80fd，\u5305\u542b\u8868\u5355\u975e\u7a7a\u6821\u9a8c，\u767b\u5f55\u4e0e\u6ce8\u518c\u8868\u5355\u652f\u6301Tab\u5207\u6362，\u767b\u5f55\u6210\u529f\u540e\u8df3\u8f6c\u6e38\u620f\u5927\u5385，\u6ce8\u518c\u6210\u529f\u540e\u63d0\u793a\u8fd4\u56de\u767b\u5f55\u3002<\/p>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u6e38\u620f\u5927\u5385\u6a21\u5757\u5c55\u793a\u7528\u6237\u4fe1\u606f，\u5305\u62ec\u7528\u6237\u540d\u3001\u79ef\u5206\u3001\u603b\u573a\u6b21\u548c\u80dc\u573a\u6570，\u652f\u6301\u5f00\u59cb\u5339\u914d\u548c\u53d6\u6d88\u5339\u914d，WebSocket\u8fde\u63a5\u5177\u5907\u81ea\u52a8\u91cd\u8fde\u673a\u5236，\u5339\u914d\u6210\u529f\u540e\u81ea\u52a8\u8fdb\u5165\u6e38\u620f\u623f\u95f4\u3002<\/p>\n
\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u6e38\u620f\u623f\u95f4\u6a21\u5757\u63d0\u4f9b15\u00d715\u6807\u51c6\u4e94\u5b50\u68cb\u68cb\u76d8，\u4f7f\u7528Canvas\u6e32\u67d3，\u652f\u6301\u9ed1\u767d\u68cb\u5b50\u4ea4\u66ff\u843d\u5b50，\u56de\u5408\u5236\u5bf9\u6218\u660e\u786e\u63d0\u793a\u5f53\u524d\u8f6e\u5230\u8c01\u843d\u5b50，\u5177\u5907\u80dc\u8d1f\u5224\u5b9a\u529f\u80fd\u3002\u623f\u95f4\u5185\u8fd8\u5305\u542b\u5b9e\u65f6\u804a\u5929\u529f\u80fd，\u6d88\u606f\u533a\u5206\u5df1\u65b9\u548c\u5bf9\u65b9，\u5bf9\u624b\u6389\u7ebf\u65f6\u81ea\u52a8\u5224\u80dc，\u8fde\u63a5\u65ad\u5f00\u65f6\u63d0\u4f9b\u8fd4\u56de\u5927\u5385\u5165\u53e3\u3002<\/p>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u56e0\u4e3a\u524d\u7aef\u90fd\u662f\u5b9e\u73b0\u4e00\u4e9b\u7b80\u5355\u7684\u529f\u80fd\u52a0\u4e0a\u5b57\u6570\u8fc7\u591a\u7684\u7f18\u6545\u5c31\u4e0d\u76f4\u63a5\u53d1\u51fa\u6765\u4e86，\u53ef\u4ee5\u53bb\u6587\u6863git\u91cc\u67e5\u770b\u30025\u6708\/26\/SourceCode\/server.hpp \u00b7 \u6d6a\u5ba2\u707f\u5fc3\/\u963f\u707f – \u7801\u4e91 – \u5f00\u6e90\u4e2d\u56fd\u3002<\/p>\n<\/p>\n<\/p>\n<\/p>\n<\/p>\n<\/p><\/p>\n","protected":false},"excerpt":{"rendered":"
1.\u901a\u4fe1\u63a5\u53e3\u8bbe\u8ba1 \u670d\u52a1\u5668\u6a21\u5757\u662f\u5bf9\u5f53\u524d\u6240\u6709\u5df2\u7ecf\u5b9e\u73b0\u7684\u6a21\u5757\u7684\u4e00\u4e2a\u6574\u5408，\u5e76\u8fdb\u884c\u670d\u52a1\u7684\u6a21\u5757\u3002\u4f7f\u7528websocket\u5e93\u7684\u63a5\u53e3\u6765\u642d\u5efa\u670d\u52a1\u5668\u7684\u57fa\u672c\u67b6\u6784，\u518d\u5b9e\u73b0\u56db\u4e2a\u4e3b\u8981\u7684\u63a5\u53e3：http\u8bf7\u6c42\u7684\u63a5\u53e3，\u5efa\u7acbwebsocket\u94fe\u63a5\u8bf7\u6c42，\u65ad\u5f00websocket\u94fe\u63a5\u8bf7\u6c42，websocket\u901a\u4fe1\u8bf7\u6c42\u3002 1.1http\u8bf7\u6c42\u63a5\u53e3 \u7528\u6237\u5728\u672a\u5efa\u7acbwebsocket\u957f\u8fde\u63a5\u5728\u524d\u9700\u8981\u901a\u8fc7http\u8fdb\u884c\u901a\u4fe1，\u7528\u6237\u7684\u8bf7\u6c42\u4e00\u5171\u5206\u4e3a<\/p>\n","protected":false},"author":2,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[55,114],"topic":[],"class_list":["post-81165","post","type-post","status-publish","format-standard","hentry","category-server","tag-c","tag-mysql"],"yoast_head":"\n