C++實(shí)現(xiàn)聊天小程序
C++寫一個(gè)游戲聊天服務(wù)器,供大家參考,具體內(nèi)容如下
最近學(xué)習(xí)網(wǎng)絡(luò)編程寫了個(gè)聊天小程序,寫個(gè)博客記錄下自己的代碼
涉及的技術(shù):
- c++網(wǎng)絡(luò)編程
- c++多線程
- c++ STL
設(shè)計(jì)原理
以一個(gè)結(jié)構(gòu)體的形式存儲(chǔ)客戶端,用vector存取存在的客戶端,開啟多線程處理邏輯
服務(wù)器允許登陸多個(gè)客戶端,允許公屏聊天也允許私聊,默認(rèn)情況下屬于公屏聊天,若想私聊,格式為“@用戶名+要發(fā)送的消息”;運(yùn)行效果如下圖:
服務(wù)器實(shí)現(xiàn)
#include "stdafx.h" #include <iostream> #include "windows.h" //一定要包含該頭文件 #include "process.h" #include <string> #include <vector> #include <algorithm> using namespace std; #pragma comment(lib, "WS2_32.lib") //顯示加載 ws2_32.dll ws2_32.dll就是最新socket版本 int g_curPlayerNum = 0; //當(dāng)前連接數(shù) const char*g_PlayerName[] = //假定的聊天者名字 { "aaaa", "bbbb", "cccc", "dddd", }; struct PlayerInfo //利用結(jié)構(gòu)存儲(chǔ)連接的客戶端 { SOCKET sock; string name; }; vector<PlayerInfo>g_clientSockList; //利用vector存取已連接的客戶端 void process(void*param) { int index = *(int*)param; //當(dāng)前子線程編號(hào) while (1) { //服務(wù)器接收信息 //int index = *(int*)param; char buf[2048] = { 0 }; //接收緩沖區(qū) int bytes; if ((bytes = recv(g_clientSockList[index].sock, buf, sizeof(buf), 0)) == SOCKET_ERROR) { cout << "服務(wù)器接收數(shù)據(jù)失??!" << endl; } //服務(wù)器轉(zhuǎn)發(fā)(含邏輯處理) if (buf[0] == '@') { //私聊 string Buf(buf); string recvPlayerName = Buf.substr(1, 4); //分離出接收者名字 copy(g_clientSockList[index].name.begin(), g_clientSockList[index].name.end(), &buf[1]); for (vector<PlayerInfo>::iterator it = g_clientSockList.begin(); it != g_clientSockList.end(); it++) { if (it->name == recvPlayerName) { if (send(it->sock, buf, strlen(buf), 0) == SOCKET_ERROR) { cout << "發(fā)送數(shù)據(jù)失敗 to" << it->name << endl; } break; } } } else //群聊 cout << g_clientSockList[index].name << "對(duì)" << "所有人說:" << buf << endl; } } int main() { cout << "-----------聊天室服務(wù)器-----------" << endl; //套接字初始化 WSADATA wsaData; //這個(gè)結(jié)構(gòu)被用來存儲(chǔ)被WSAStartup函數(shù)調(diào)用后返回的 Windows Sockets 數(shù)據(jù)。 WORD sockVersion = MAKEWORD(2, 2); //windows網(wǎng)絡(luò)編程庫的版本號(hào)信息 if (WSAStartup(sockVersion, &wsaData) != 0) //WSAStartup函數(shù)是在程序中初始化并加載Windows網(wǎng)絡(luò) { cout << "套接字初始化失敗!" << endl; return 0; } //創(chuàng)建服務(wù)器套接字 SOCKET SeverSocket; if ((SeverSocket = socket(AF_INET, SOCK_STREAM, 0)) == SOCKET_ERROR) { cout << "套接字創(chuàng)建失??!" << endl; return 0; } struct sockaddr_in SeverAddress; //一個(gè)綁定地址:有IP地址,有端口號(hào),有協(xié)議族 memset(&SeverAddress, 0, sizeof(sockaddr_in)); //初始化結(jié)構(gòu)體 SeverAddress.sin_family = AF_INET; SeverAddress.sin_addr.S_un.S_addr = htonl(INADDR_ANY);//填入本機(jī)IP地址 SeverAddress.sin_port = htons(60000);//設(shè)定端口號(hào) //綁定套接字 指定綁定的IP地址和端口號(hào) if (bind(SeverSocket, (sockaddr*)&SeverAddress, sizeof(SeverAddress)) == SOCKET_ERROR) { cout << "套接字綁定失敗!"<<endl; return 0; } //服務(wù)器監(jiān)聽 if (listen(SeverSocket, SOMAXCONN) == SOCKET_ERROR) //監(jiān)聽的第二個(gè)參數(shù)就是:能存放多少個(gè)客戶端請(qǐng)求,到并發(fā)編程的時(shí)候很有用 { cout << "監(jiān)聽失??!" << endl; return 0; } else cout << "服務(wù)器等待連接......" << endl; while (1) { //服務(wù)器接受連接請(qǐng)求 sockaddr_in revClientAddress; //套接字的地址,端口 SOCKET revClientSocket = INVALID_SOCKET; //用來接收客戶端連接 //memset(&revClientAddress, 0, sizeof(revClientAddress)); int addlen = sizeof(revClientAddress); if ((revClientSocket = accept(SeverSocket, (sockaddr*)&revClientAddress, &addlen)) == INVALID_SOCKET) { cout << "接受客戶端連接失敗!" << endl; return 0; } PlayerInfo stPlayerInfo; stPlayerInfo.sock = revClientSocket; stPlayerInfo.name = g_PlayerName[g_curPlayerNum]; g_clientSockList.push_back(stPlayerInfo); int temp = g_curPlayerNum; _beginthread(process, 0, &temp); //創(chuàng)建子線程來收發(fā)數(shù)據(jù) g_curPlayerNum++; cout << stPlayerInfo.name << "上線啦!" << endl; } return 0; }
客戶端
#include "stdafx.h" #include "windows.h" #include "iostream" #include "process.h" #include <string> using namespace std; #pragma comment(lib, "ws2_32.lib") void Receive(void *param) { string msg; while (1) { //客戶端接受來自服務(wù)器的數(shù)據(jù) SOCKET clientSocket = *(SOCKET*)(param); char recvbuf[2048] = {}; //接收緩沖區(qū) if (recv(clientSocket, recvbuf, 2048, 0) == SOCKET_ERROR) { cout << "數(shù)據(jù)接受失敗" << endl; } else { msg = recvbuf; char sendPlayerName[5] = { 0 }; int len = strlen(recvbuf); //消息長度 copy(&recvbuf[1], &recvbuf[5], sendPlayerName); //分離出名字 msg = msg.substr(5, len - 5); cout << sendPlayerName << "對(duì)你說:" << msg<<endl; } } } void Send(void *param) { while (1) { //客戶端發(fā)送數(shù)據(jù)給服務(wù)器 SOCKET clientSocket = *(SOCKET*)(param); char sendbuf[2048] = {}; //發(fā)送緩沖區(qū) cin.getline(sendbuf, 2048); if (send(clientSocket, sendbuf, strlen(sendbuf), 0) == SOCKET_ERROR) { cout << "發(fā)送消息失??!"; } else cout << "發(fā)送消息成功" << endl; } } int main() { cout << "-----------個(gè)人客戶端-----------" << endl; WSADATA wsa; if (WSAStartup(MAKEWORD(2, 2), &wsa) != 0) { cout << "套接字初始化失敗!"<<endl; } SOCKET clientSocket; if ((clientSocket = socket(AF_INET, SOCK_STREAM, 0)) == SOCKET_ERROR) { cout << "套接字創(chuàng)建失敗!"<<endl; } Sleep(30); struct sockaddr_in ClientAddress; //一個(gè)綁定地址:有IP地址,有端口號(hào),有協(xié)議族 memset(&ClientAddress, 0, sizeof(sockaddr_in)); //初始化結(jié)構(gòu)體 ClientAddress.sin_family = AF_INET; ClientAddress.sin_addr.S_un.S_addr = htonl(INADDR_ANY);//填入本機(jī)IP地址 //ClientAddress.sin_port = htons(60001);//設(shè)定端口號(hào) //綁定套接字 指定綁定的IP地址和端口號(hào) if (bind(clientSocket, (sockaddr*)&ClientAddress, sizeof(ClientAddress)) == SOCKET_ERROR) { cout << "套接字綁定失?。? << endl; return 0; } struct sockaddr_in SeverAddress; //服務(wù)器地址 也就是即將要連接的目標(biāo)地址 memset(&SeverAddress, 0, sizeof(sockaddr_in)); SeverAddress.sin_family = AF_INET; SeverAddress.sin_addr.S_un.S_addr = inet_addr("127.0.0.1"); //127.0.0.1表示本機(jī)ip地址 SeverAddress.sin_port = htons(60000);//設(shè)定端口號(hào) //開始連接 if (connect(clientSocket, (sockaddr*)&SeverAddress, sizeof(SeverAddress)) == SOCKET_ERROR) { cout << "客戶端:和服務(wù)器連接失?。?<<endl; return 0; } else cout << "與服務(wù)器連接成功!" << endl; //創(chuàng)建兩個(gè)子線程 _beginthread(Receive, 0, &clientSocket); _beginthread(Send, 0, &clientSocket); Sleep(INFINITE); //這里采用另外一種技術(shù)避免主線程執(zhí)行完退出——使其無限期休眠 // 關(guān)閉socket if (clientSocket != INVALID_SOCKET) { closesocket(clientSocket); clientSocket = INVALID_SOCKET; } return 0; }
以上就是本文的全部內(nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
數(shù)據(jù)結(jié)構(gòu)串的操作實(shí)例詳解
這篇文章主要介紹了數(shù)據(jù)結(jié)構(gòu)串的操作實(shí)例詳解的相關(guān)資料,需要的朋友可以參考下2017-07-07C語言從猜數(shù)字游戲中理解數(shù)據(jù)結(jié)構(gòu)
猜數(shù)字是興起于英國的益智類小游戲,起源于20世紀(jì)中期,一般由兩個(gè)人或多人玩,也可以由一個(gè)人和電腦玩。游戲規(guī)則為一方出數(shù)字,一方猜,今天我們來用這個(gè)游戲案例理解數(shù)據(jù)結(jié)構(gòu)2022-04-04C++?opencv學(xué)習(xí)之圖像像素的邏輯操作
圖像的像素操作包括讀寫操作、算數(shù)操作、邏輯運(yùn)算操作等,下面這篇文章主要給大家介紹了關(guān)于C++?opencv學(xué)習(xí)之圖像像素的邏輯操作的相關(guān)資料,文中通過實(shí)例代碼介紹的非常詳細(xì),需要的朋友可以參考下2022-11-11C++實(shí)現(xiàn)TCP客戶端及服務(wù)器Recv數(shù)據(jù)篩選處理詳解
這篇文章主要為大家介紹了C++實(shí)現(xiàn)TCP客戶端及服務(wù)器Recv數(shù)據(jù)篩選處理詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2022-10-10C++中賦值運(yùn)算符與逗號(hào)運(yùn)算符的用法詳解
這篇文章主要介紹了C++中賦值運(yùn)算符與逗號(hào)運(yùn)算符的用法詳解,是C++入門學(xué)習(xí)中的基礎(chǔ)知識(shí),需要的朋友可以參考下2015-09-09C++保存HBITMAP為位圖文件的實(shí)現(xiàn)方法
這篇文章主要介紹了C++保存HBITMAP為位圖文件的實(shí)現(xiàn)方法,幫助大家更好的理解和使用c++,感興趣的朋友可以了解下2021-01-01C語言實(shí)現(xiàn)學(xué)生個(gè)人消費(fèi)管理系統(tǒng)
這篇文章主要為大家詳細(xì)介紹了C語言學(xué)生個(gè)人消費(fèi)管理系統(tǒng)開發(fā),文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2022-08-08C語言詳解數(shù)據(jù)結(jié)構(gòu)與算法中枚舉和模擬及排序
枚舉和模擬其實(shí)是沒什么算法可言的,大多數(shù)都是按照題目意思去寫,這里提供快排和歸并的兩個(gè)模板,感興趣的朋友來看看吧2022-04-04