C++基于socket编程实现聊天室功能 C++基于socket编程实现聊天室功

本文实例为大家分享了C++基于socket编程实现聊天室的具体代码，供大家参考，具体内容如下
【C++基于socket编程实现聊天室功能】服务端

// server.cpp : 此文件包含 "main" 函数。程序执行将在此处开始并结束。// #include "pch.h"#include #include "winsock2.h"#include "stdlib.h"#include "stdio.h"#include "string"#pragma comment (lib, "ws2_32.lib") using namespace std; SOCKET clientSocket[1024]; int k = 0; void communication(LPVOID n){ char buff[256]; int r; int i = (int)n; //cout << i << ":" << endl; while (1) { memset(buff, 0, 256); r = recv(clientSocket[i - 1], buff, 255, NULL); if (r > 0){cout << i << ":" << buff << endl; for (int j = 0; j < k; j++){send(clientSocket[j], buff, strlen(buff), NULL); }} }} int main(){ //加载socket库版本号 WSADATA wsaData; WSAStartup(MAKEWORD(2, 2), &wsaData) != 0; //成功==0 if (LOBYTE(wsaData.wVersion) != 2 || HIBYTE(wsaData.wVersion) != 2) {cout << "请求版本失败！\n" << endl; return -1; } cout << "请求版本成功!\n" << endl; //创建socket //sockSer = socket(AF_INET, SOCK_STREAM,IPPROTO_TCP); //AF=Address family ,ipv4,TCP,0 SOCKET serverSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); if (serverSocket == INVALID_SOCKET) {cout << "创建socket失败！\n" << endl; return -1; } cout << "创建socket成功！\n" << endl; //addrSer.sin_addr.S_un.S_addr SOCKADDR_IN addr = { 0 }; //初始化地址 addr.sin_addr.S_un.S_addr = inet_addr("127.0.0.1"); // htonl(INADDR_ANY); //inet_addr("192.168.0.13"); //dec--->2进制-->网络字节序 addr.sin_family = AF_INET; addr.sin_port = htons(10086); //端口号~65535 //绑定Socket int r = bind(serverSocket, (SOCKADDR*)&addr, sizeof(addr)); if (r == -1) {cout << "bind失败！\n" << endl; return -1; } cout << "bind成功！\n" << endl; //listen r = listen(serverSocket, 10); if (r == -1) {cout << "listen失败！\n" << endl; return -1; } cout << "listen成功！\n" << endl; //连接 //地址族 SOCKADDR_IN cAddr = { 0 }; int len = sizeof cAddr; //SOCKET clientSocket[1024]; int i = 0; while (i < 1024) {clientSocket[i++] = accept(serverSocket, (sockaddr*)&cAddr, &len); k++; if (clientSocket[i - 1] == SOCKET_ERROR){cout << "错误的客户端！\n" << endl; closesocket(serverSocket); WSACleanup(); return -1; }cout << "有客户端接入进来！" << inet_ntoa(cAddr.sin_addr) << endl; CreateThread(NULL, NULL, (LPTHREAD_START_ROUTINE)communication, (LPVOID)i, NULL, NULL); } //closesocket(clientSocket); //closesocket(serverSocket); //WSACleanup(); return 0; }

客户端

#include "pch.h"#include #include "winsock2.h"#include "stdlib.h"#include "stdio.h"#include "string"#pragma comment (lib, "ws2_32.lib") //#include "graphics.h" using namespace std; SOCKET serverSocket; //服务器 void recvAndShow(){ int r, i = 0; char buff[256]; //ofstream out; while (1) {memset(buff, 0, 256); r = recv(serverSocket, buff, 255, NULL); if (r > 0){// out.open("QQ.txt", ios::app||ios::_Nocreate); // out << buff << endl; //outtextxy(0, i * 20, buff); i++; //out.close(); } }} int main(){ //initgraph(300, 300, SHOWCONSOLE); //加载socket库版本号 WSADATA wsaData; WSAStartup(MAKEWORD(2, 2), &wsaData) != 0; //成功==0 if (LOBYTE(wsaData.wVersion) != 2 || HIBYTE(wsaData.wVersion) != 2) {cout << "请求版本失败！\n" << endl; return -1; } cout << "请求版本成功!\n" << endl; //创建socket serverSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); if (serverSocket == INVALID_SOCKET) {cout << "创建socket失败！\n" << endl; return -1; } cout << "创建socket成功！\n" << endl; //地址族 SOCKADDR_IN addr = { 0 }; //初始化地址 addr.sin_addr.S_un.S_addr = inet_addr("127.0.0.1"); // htonl(INADDR_ANY); //inet_addr("192.168.0.13"); //dec--->2进制-->网络字节序 addr.sin_family = AF_INET; addr.sin_port = htons(10086); //端口号~65535尽量大于1W //连接到服务器 int r = connect(serverSocket, (SOCKADDR*)&addr, sizeof addr); if (r == -1) {cout << "连接服务器失败！\n" << endl; return -1; } cout << "连接服务器成功！\n" << endl; CreateThread(NULL, NULL, (LPTHREAD_START_ROUTINE)recvAndShow, NULL, NULL, NULL); char buff[256]; while (1) {memset(buff, 0, 256); cout << "你要发啥？\n" << endl; cin >> buff; r = send(serverSocket, buff, strlen(buff), NULL); if (r > 0){cout << "发送" << r << "字节到服务器成功！\n" << endl; } } //closesocket(serverSocket); //WSACleanup(); return 0; }

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。