前言

本文章旨在对五子棋在线对战的代码进行实现的全过程，包括了代码的环境，前置知识的了解，和项目的整体架构。

1.Websocketpp

WebSocket是从HTML5开始⽀持的⼀种⽹⻚端和服务端保持⻓连接的消息推送机制。

1.1 使用Websocketpp的原因

传统的web程序都是一问一答的形式，就是客户端给服务器发送数据，服务器给客户端返回一个相应，这种情况下服务端是被动的一方，他无法主动的给客户端发送数据，
但是这个项目非常依赖消息推送，我们需要服务器主动的给客户端发送消息，如果只是使用原生的http协议，很难满足需求。

基于上述，就产⽣了WebSocket协议。WebSocket更接近于TCP这种级别的通信⽅式，⼀旦连接建⽴完成客⼾端或者服务器都可以主动的向对⽅发送数据。

1.2 Websocket常用接口

1.3 Websocket搭建服务器流程

int main(){// 1.使用websocketpp库创建服务器websocketsvr server;// 2.设置websocketpp库的日志级别// all表示打印全部级别日志// none表示什么日志都不打印server.set_access_channels(websocketpp::log::alevel::none);// 3.初始化asioserver.init_asio();// 4.注册http请求的处理函数server.set_http_handler(bind(&OnHttp, &server, ::_1));// 5.注册websocket请求的处理函数server.set_open_handler(bind(&OnOpen, &server, ::_1));server.set_close_handler(bind(&OnClose, &server, _1));server.set_message_handler(bind(&OnMessage,&server,_1,_2));// 6.监听8888端口server.listen(8888);// 7.开始接收tcp连接server.start_accept();// 8.开始运行服务器server.run();return 0;
}

2.JsonCpp

Json 是⼀种数据交换格式，它采⽤完全独⽴于编程语⾔的⽂本格式来存储和表⽰数据

//C语言
char *name = "xx";
int age = 18;
float score[3] = {88.5, 99, 58};//Json
{"姓名" : "xx","年龄" : 18,"成绩" : [88.5, 99, 58]
}[{"姓名":"小明", "年龄":18, "成绩":[23, 65, 78]},{"姓名":"小红", "年龄":19, "成绩":[88, 95, 78]}
]

2.1 Json 数据对象类的表示

class Json::Value{Value &operator=(const Value &other); //Value重载了[]和=，因此所有的赋值和获取数据都可以通过Value& operator[](const std::string& key); //简单的方式完成 val["name"] = "xx";Value& operator[](const char* key);Value removeMember(const char* key); //移除元素const Value& operator[](ArrayIndex index) const; //val["score"][0]Value& append(const Value& value); //添加数组元素val["score"].append(88);ArrayIndex size() const; //获取数组元素个数 val["score"].size();bool isNull();  //用于判断是否存在某个字段std::string asString() const; //转string string name = val["name"].asString();const char* asCString() const; //转char* char *name = val["name"].asCString();Int asInt() const; //转int int age = val["age"].asInt();float asFloat() const; //转float float weight = val["weight"].asFloat();bool asBool() const; //转 bool bool ok = val["ok"].asBool();
};

2.2序列化和反序列化的接口

2.3 演示代码

#include <iostream>
#include <string>
#include <sstream>
#include <jsoncpp/json/json.h>std::string serialize()
{// 1.将序列化的数据，存储在Json::Value中Json::Value root;root["name"] = "kang";root["age"] = 22;root["num"].append(120);root["num"].append(104);root["num"].append(111);// 2.实例化一个StreamWriterBuilder工厂类中Json::StreamWriterBuilder swb;// 3.通过StreamWriterBuilder工厂类对象生产一个StreamWriter对象Json::StreamWriter *sw = swb.newStreamWriter();// 4.使用StreamWriter对象，对存储在Json::Value中的数据进行序列化std::stringstream ss;int ret = sw->write(root, &ss);if (ret != 0){std::cout << "Json 序列化 faild" << std::endl;return nullptr;}std::cout << ss.str() << std::endl;delete sw;return ss.str();
}void unserialize(const std::string &str)
{//1.实例化一个CharReaderBuilder工厂类对象Json::CharReaderBuilder crb;//2.使用这个工厂类对象生产一个CharReader对象Json::CharReader *cr=crb.newCharReader();//3.定义一个Json::Value对象存储解析后的数据Json::Value root;std::string error;//4.使用CharReader对象进行Json格式字符串str的反序列化//parse(char* start, char* end, Json::Value *val, string *err)bool ret=cr->parse(str.c_str(),str.c_str()+str.size(),&root,&error);if(ret==false){std::cout<<"json unserialize failed"<<std::endl;return ;}//5.逐个元素去访问Json::Value的数据std::cout<<"name: "<<root["name"].asString()<<std::endl;std::cout<<"age: "<<root["age"].asInt()<<std::endl;int len=root["num"].size();for(int i=0;i<len;i++){std::cout<<"num: "<<root["num"][i].asFloat()<<std::endl;}delete cr;
}
int main()
{std::string str=serialize();unserialize(str);return 0;
}

3.Mysql

3.1 演示代码

#include <stdio.h>
#include <string.h>
#include <mysql/mysql.h>#define HOST "127.0.0.1"
#define PORT 3306
#define USER "root"
#define PASS "yangjuntao"
#define DBNAME "gobang"
int main()
{// 1. 初始化mysql操作句柄// MYSQL *mysql_init(MYSQL *mysql)MYSQL *mysql = mysql_init(NULL);if (mysql == NULL){printf("mysql init failed\n");return -1;}// 2. 连接mysql服务器// MYSQL *mysql_real_connect(mysql,host,user,pass,dbname,port,unix_socket,flag)if (mysql_real_connect(mysql, HOST, USER, PASS, DBNAME, PORT, NULL, 0) == NULL){printf("connect mysql server failed : %s \n", mysql_error(mysql));mysql_close(mysql);return -1;}// 3. 设置客户端的字符集// int mysql_set_character_set(mysql, "utf8");if (mysql_set_character_set(mysql, "utf8") != 0){printf("set client character failed : %s\n", mysql_error(mysql));mysql_close(mysql);return -1;}// 4. 选择想要操作的数据库// int mysql_select_db(mysql, dbname)// mysql_select_db(mysql, dbname);// 5. 执行sql语句// int mysql_query(MYSQL* mysql,char *sql);char* sql="insert stu values(null,'kangchu',24,23,25,19);";// char * sql="updata stu set ch=ch+40 where sn=1;";// char * sql="delete from stu where sn=1;";//char *sql = "select * from stu;";int ret = mysql_query(mysql, sql);if (ret != 0){printf("%s\n", sql);printf("mysql query,failed : %s\n", mysql_error(mysql));mysql_close(mysql);return -1;}// 6. 如果是查询语句则需要保存到本地// MYSQL_RES *mysql_store_result(MYSQL *mysql)MYSQL_RES *res = mysql_store_result(mysql);if (res == NULL){mysql_close(mysql);return -1;}// 7. 获取结果集中的结果条数目// int mysql_num_rows(MYSQL_RES *result)// int mysql_num_fields(MYSQL_RES *result)int num_row = mysql_num_rows(res);int num_col = mysql_num_fields(res);// 8. 遍历保存到本地的结果集// MYSQL_ROW mysql_fetch_row(MYSQL_RES *result)for (int i = 0; i < num_row; i++){MYSQL_ROW row = mysql_fetch_row(res);for (int i = 0; i < num_col; i++){printf("%s\t", row[i]);}printf("\n");}// 9. 释放结果集mysql_free_result(res);// 10. 关闭连接，释放句柄mysql_close(mysql);return 0;
}