锐客网

  1. 首页 > it技术 > >

C++实现聊天小程序

【C++实现聊天小程序】C++写一个游戏聊天服务器，供大家参考，具体内容如下
最近学习网络编程写了个聊天小程序，写个博客记录下自己的代码
涉及的技术：

  • c++网络编程
  • c++多线程
  • c++ STL
设计原理
以一个结构体的形式存储客户端,用vector存取存在的客户端,开启多线程处理逻辑
服务器允许登陆多个客户端，允许公屏聊天也允许私聊，默认情况下属于公屏聊天，若想私聊，格式为“@用户名+要发送的消息”；运行效果如下图：
C++实现聊天小程序
文章图片

服务器实现
#include "stdafx.h"#include #include "windows.h" //一定要包含该头文件#include "process.h"#include #include #include using namespace std; #pragma comment(lib, "WS2_32.lib")//显示加载 ws2_32.dll ws2_32.dll就是最新socket版本int g_curPlayerNum = 0; //当前连接数const char*g_PlayerName[] =//假定的聊天者名字{ "aaaa", "bbbb", "cccc", "dddd",}; struct PlayerInfo //利用结构存储连接的客户端{ SOCKET sock; string name; }; vectorg_clientSockList; //利用vector存取已连接的客户端void process(void*param){ int index = *(int*)param; //当前子线程编号 while (1) {//服务器接收信息//int index = *(int*)param; char buf[2048] = { 0 }; //接收缓冲区int bytes; if ((bytes = recv(g_clientSockList[index].sock, buf, sizeof(buf), 0)) == SOCKET_ERROR){cout << "服务器接收数据失败！" << endl; }//服务器转发（含逻辑处理）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::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 << "发送数据失败 to" << it->name << endl; }break; }}}else//群聊cout << g_clientSockList[index].name << "对" << "所有人说：" << buf << endl; }}int main(){ cout << "-----------聊天室服务器-----------" << endl; //套接字初始化 WSADATA wsaData; //这个结构被用来存储被WSAStartup函数调用后返回的 Windows Sockets 数据。 WORD sockVersion = MAKEWORD(2, 2); //windows网络编程库的版本号信息 if (WSAStartup(sockVersion, &wsaData) != 0) //WSAStartup函数是在程序中初始化并加载Windows网络 {cout << "套接字初始化失败!" << endl; return 0; } //创建服务器套接字 SOCKET SeverSocket; if ((SeverSocket = socket(AF_INET, SOCK_STREAM, 0)) == SOCKET_ERROR) {cout << "套接字创建失败！" << endl; return 0; } struct sockaddr_in SeverAddress; //一个绑定地址:有IP地址,有端口号,有协议族 memset(&SeverAddress, 0, sizeof(sockaddr_in)); //初始化结构体 SeverAddress.sin_family = AF_INET; SeverAddress.sin_addr.S_un.S_addr = htonl(INADDR_ANY); //填入本机IP地址 SeverAddress.sin_port = htons(60000); //设定端口号 //绑定套接字指定绑定的IP地址和端口号 if (bind(SeverSocket, (sockaddr*)&SeverAddress, sizeof(SeverAddress)) == SOCKET_ERROR) {cout << "套接字绑定失败！"<
客户端
#include "stdafx.h"#include "windows.h"#include "iostream"#include "process.h"#include using namespace std; #pragma comment(lib, "ws2_32.lib")void Receive(void *param){ string msg; while (1) {//客户端接受来自服务器的数据SOCKET clientSocket = *(SOCKET*)(param); charrecvbuf[2048] = {}; //接收缓冲区if (recv(clientSocket, recvbuf, 2048, 0) == SOCKET_ERROR){cout << "数据接受失败" << 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 << "对你说：" << msg<
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。

    推荐阅读


    上一篇：Java并发编程之详解ConcurrentHashMap类

    下一篇：解决springboot整合cxf启动报错|解决springboot整合cxf启动报错,原因是版本问题