源码链接：game
效果可能没有那么好，大家可以给点建议。
效果展示
game.h
#include <stdio.h>
#include <stdlib.h>
#include <time.h>#define ROW 3
#define COL 3void InitBoard(char board[ROW][COL], int row, int col)
{int i = 0;for (i = 0; i < row; i++){int j = 0;for (j = 0; j < col; j++){board[i][j] = ' ';}}
}void DisplayBoard(char board[ROW][COL], int row, int col)
{int i = 0;for (i = 0; i < row; i++){//打印数据int j = 0;for (j = 0; j < col; j++){printf(" %c ", board[i][j]);if (j < col - 1)printf("|");}printf("\n");//打印分割的行if (i < row - 1){for (j = 0; j < col; j++){printf("---");if (j < col - 1)printf("|");}printf("\n");}}
}void player_move(char board[ROW][COL], int row, int col)
{int x = 0;int y = 0;printf("玩家下棋\n");while (1){printf("请输入坐标:>");scanf("%d %d", &x, &y);if (x >= 1 && x <= row && y >= 1 && y <= col){//下棋if (board[x - 1][y - 1] == ' '){board[x - 1][y - 1] = '*';break;}else{printf("该坐标被占用，请重新输入\n");}}else{printf("坐标非法，请重新输入\n");}}
}void computer_move(char board[ROW][COL], int row, int col)
{int x = 0;int y = 0;printf("电脑下棋:>\n");while (1){x = rand() % row;//0~2y = rand() % col;//0~2if (board[x][y] == ' '){board[x][y] = '#';break;}}
}static int if_full(char board[ROW][COL], int row, int col)
{int i = 0;for (i = 0; i < row; i++){int j = 0;for (j = 0; j < col; j++){if (board[i][j] == ' '){return 0;//没满}}}return 1;//满了
}char is_win(char board[ROW][COL], int row, int col)
{int i = 0;//判断行for (i = 0; i < row; i++){if (board[i][0] == board[i][1] && board[i][1] == board[i][2] && board[i][1] != ' '){return board[i][1];}}//判断列for (i = 0; i < col; i++){if (board[0][i] == board[1][i] && board[1][i] == board[2][i] && board[1][i] != ' '){return board[1][i];}}//对角线if (board[0][0] == board[1][1] && board[1][1] == board[2][2] && board[1][1] != ' '){return board[1][1];}if (board[0][2] == board[1][1] && board[1][1] == board[2][0] && board[1][1] != ' '){return board[1][1];}//判断平局if (if_full(board, row, col) == 1){return 'Q';}//继续return 'C';
}tcp_client.cc
#include <iostream>
#include <string>
#include <cstring>
#include <cstdio>
#include <unistd.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include "game.h"void menu()
{printf("********************************\n");printf("********* 1. play *********\n");printf("********* 0. exit *********\n");printf("********************************\n");
}void game()
{char ret = 0;// 存放下棋的数据char board[ROW][COL] = {0};// 初始化棋盘为全空格InitBoard(board, ROW, COL);// 打印棋盘DisplayBoard(board, ROW, COL);while (1){// 玩家下棋player_move(board, ROW, COL);DisplayBoard(board, ROW, COL);// 判断输赢ret = is_win(board, ROW, COL);if (ret != 'C'){break;}// 电脑下棋computer_move(board, ROW, COL);// 随机下棋DisplayBoard(board, ROW, COL);ret = is_win(board, ROW, COL);if (ret != 'C'){break;}}if (ret == '*'){printf("恭喜你赢了\n");}else if (ret == '#'){printf("很遗憾你输了\n");}else{printf("平局\n");}
}void Usage(std::string proc)
{std::cout << "\nUsage: " << proc << " serverIp serverPort\n"<< std::endl;
}void Print(int &sock, std::string &line)
{ssize_t s = send(sock, line.c_str(), line.size(), 0);if (s > 0){char buffer[1024];ssize_t s = recv(sock, buffer, sizeof(buffer) - 1, 0);if (s > 0){buffer[s] = 0;std::cout << "server 回应# " << buffer << std::endl;}else if (s == 0){close(sock);}}else{close(sock);}
}int main(int argc, char *argv[])
{if (argc != 3){Usage(argv[0]);exit(1);}std::string serverip = argv[1];uint16_t serverport = atoi(argv[2]);int sock = 0;std::string line;sock = socket(AF_INET, SOCK_STREAM, 0);if (sock < 0){std::cerr << "socket error" << std::endl;exit(2);}struct sockaddr_in server;memset(&server, 0, sizeof(server));server.sin_family = AF_INET;server.sin_port = htons(serverport);server.sin_addr.s_addr = inet_addr(serverip.c_str());if (connect(sock, (struct sockaddr *)&server, sizeof(server)) < 0) // 连接服务器{std::cerr << "connect error" << std::endl;exit(3);}std::cout << "connect success" << std::endl;int input = 0;srand((unsigned int)time(NULL));do{menu();printf("请选择:>");scanf("%d", &input);switch (input){case 1:line = "start";Print(sock, line);game(); // 游戏break;case 0:line = "quit";Print(sock, line);break;default:printf("选择错误\n");break;}} while (input);if (line == "quit"){exit(0);}return 0;
}tcp_server.cc
#include "tcp_server.hpp"
#include <memory>static void Usage(std::string proc)
{std::cout << "\nUsage" << proc << " port\n" << std::endl;
}int main(int argc, char* argv[])
{if(argc != 2){Usage(argv[0]);exit(1);}uint16_t port = atoi(argv[1]);std::unique_ptr<Tcp_Server> svr(new Tcp_Server(port));svr->InitServer();svr->Start();return 0;
}tcp_server.hpp
#pragma once#include <iostream>
#include <string>
#include <cstring>
#include <strings.h>
#include <assert.h>
#include <unistd.h>
#include <signal.h>
#include <memory>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <pthread.h>
#include <sys/wait.h>
#include "threadPool/log.hpp"
#include "threadPool/thread.hpp"
#include "threadPool/threadPool.hpp"
#include "threadPool/Task.hpp"
#include "game.h"static void play(int sock, const std::string &clientip, const uint16_t &clientport, const std::string &thread_name)
{char buffer[1024];while (true){ssize_t s = read(sock, buffer, sizeof(buffer) - 1);std::string message;if (s > 0){buffer[s] = 0;std::cout << thread_name << "|" << clientip << ":" << clientport << "# " << buffer << std::endl;if (strcmp(buffer, "start") == 0){message = "玩家请开始游戏";}if (strcmp(buffer, "quit") == 0){message = "玩家退出游戏成功";}write(sock, message.c_str(), message.size());}else if (s == 0) // 对端关闭连接{logMessage(NORMAL, "%s:%d 玩家已退出游戏,我也退出", clientip.c_str(), clientport);break;}else{logMessage(ERROR, "read socket error, %d:%s", errno, strerror(errno));break;}}close(sock);
}class Tcp_Server
{
private:const static int gbacklog = 20;public:Tcp_Server(uint16_t port, std::string ip = ""): _port(port), _ip(ip), listensock(-1), _threadpool_ptr(ThreadPool<Task>::getThreadPool()){}~Tcp_Server(){}void InitServer(){// 1.创建socketlistensock = socket(AF_INET, SOCK_STREAM, 0);if (listensock < 0){// 创建socket失败logMessage(FATAL, "create socket error, %d:%S", errno, strerror(errno));exit(2);}logMessage(NORMAL, "create socket success, listensock:%d", listensock);// 2.bindstruct sockaddr_in local;memset(&local, 0, sizeof local);local.sin_family = AF_INET;local.sin_port = htons(_port);local.sin_addr.s_addr = _ip.empty() ? INADDR_ANY : inet_addr(_ip.c_str()); // INADDR_ANY：任意IPif (bind(listensock, (struct sockaddr *)&local, sizeof(local)) < 0){// bind失败logMessage(FATAL, "bind error, %d:%s", errno, strerror(errno));exit(3);}// 3.建立连接if (listen(listensock, gbacklog) < 0){// 建立连接失败logMessage(FATAL, "listen error, %d:%s", errno, strerror(errno));exit(4);}logMessage(NORMAL, "init server success");}void Start(){_threadpool_ptr->run();while (true){// 4.获取连接struct sockaddr_in src;socklen_t len = sizeof(src);int servicesock = accept(listensock, (struct sockaddr *)&src, &len);// 获取连接失败if (servicesock < 0){logMessage(ERROR, "accept error, %d:%s", errno, strerror(errno));continue;}// 获取连接成功uint16_t client_port = ntohs(src.sin_port);std::string client_ip = inet_ntoa(src.sin_addr);logMessage(NORMAL, "link success, servicesock: %d | %s : %d |\n", servicesock, client_ip.c_str(), client_port);// 5.开始通信// 线程池版Task t(servicesock, client_ip, client_port, play);_threadpool_ptr->pushTask(t);}}private:uint16_t _port;std::string _ip;int listensock;std::unique_ptr<ThreadPool<Task>> _threadpool_ptr;
};
