基于C++多线程实现简易即时通信程序

Mia

发布时间：2026-10-13| 3人浏览过

原创

本文详细介绍了如何使用C++语言结合Winsock库和多线程技术，开发一个简易的即时通信软件。内容涵盖服务器端的并发连接处理与消息广播逻辑，以及客户端的连接建立与发送机制，提供了完整的可编译代码示例。

目标：构建基础IM通讯原型

本示例旨在通过C++实现一个无界面的即时通信模型，核心功能包括：服务器能够同时接受多个客户端连接，并将接收到的消息转发给其他在线用户（或简单回显）；客户端能够发送文本信息并与服务器保持会话。该示例展示了TCP/IP协议下Socket编程的标准流程。

准备条件

开发环境：Visual Studio (VS) 或其他支持Windows C++编译器的IDE。
依赖库：Windows SDK中的 ws2_32.lib，用于支持Winsock 2.2协议。
网络设置：确保服务器与客户端处于同一局域网或通过公网IP连通，注意防火墙允许端口通信。

第1步：配置服务器端并发处理

服务器端的核心职责是监听端口并接受来自客户端的连接请求。为了支持多人聊天，需要为每个接入的客户端创建独立线程进行通信管理。

在初始化Winsock后，服务器需执行绑定（Bind）和监听（Listen）操作。当有客户端连接时，通过 accept() 获取客户端Socket，并利用 CreateThread 启动新线程调用 chat() 函数来处理该客户端的数据收发。

// TcpServer_plus.exe
// 服务器端核心逻辑片段

#include<stdio.h>
#include <Winsock2.h>
#include<WS2tcpip.h>
#pragma comment(lib,"ws2_32.lib")
#include<iostream>
using namespace std;
#include<windows.h>

SOCKADDR_IN cAddr = { 0 };
int len = sizeof cAddr;
SOCKET clientSocket[1001];//定义数组存储最大1000个客户端连接

// 单线程处理函数：持续接收指定索引的客户端数据
void chat(int n) {
	char buff[1024];
	int r;
	while (1) {
		r = recv(clientSocket[n], buff, 1023, NULL);
		if (r > 0) {
			buff[r] = 0;
			printf("%s发来的信息：%s\n", inet_ntop(AF_INET, (void*)&cAddr.sin_addr, buff, 1023), buff);
			// 实际应用中，此处应将buff转发给其他clientSocket
		}
	}
}

int main() {
	// 1. 初始化Winsock
	WSADATA wsadata;
	WSAStartup(MAKEWORD(2, 2), &wsadata);
	
	// 2. 创建TCP Socket
	SOCKET serverSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
	SOCKADDR_IN addr = { 0 };
	addr.sin_family = AF_INET;
	inet_pton(AF_INET, "192.168.31.100", (void*)&addr.sin_addr.S_un.S_addr); // 替换为实际服务器IP
	addr.sin_port = htons(9999); // 监听端口

	bind(serverSocket, (struct sockaddr*)&addr, sizeof addr);
	listen(serverSocket, 10); // 等待队列长度

	// 3. 循环接受连接并创建线程
	for (int i = 0; i < 1001; i++) {
		clientSocket[i] = accept(serverSocket, (sockaddr*)&cAddr, &len);
		if (clientSocket[i] == SOCKET_ERROR) break;
		// 为新客户端创建线程处理消息
		CreateThread(NULL, NULL, (LPTHREAD_START_ROUTINE)chat, (LPVOID)i, NULL, NULL);
	}

	// 清理资源
	closesocket(serverSocket);
	WSACleanup();
	return 0;
}

第2步：配置客户端连接与发送

客户端较为简单，主要任务是连接到服务器的指定IP和端口，并通过标准输入输出与用户交互。每次运行 TcpClient.exe 代表一个新用户上线，可同时开启多个实例模拟多对一通信。

// TcpClient.exe
// 客户端核心逻辑

#include<stdio.h>
#include <Winsock2.h>
#include<WS2tcpip.h>
#pragma comment(lib,"ws2_32.lib")
#include<iostream>
using namespace std;
#include<windows.h>

int main() {
	WSADATA wsadata;
	WSAStartup(MAKEWORD(2, 2), &wsadata);

	SOCKET clientSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
	SOCKADDR_IN addr = { 0 };
	addr.sin_family = AF_INET;
	inet_pton(AF_INET, "192.168.31.100", (void*)&addr.sin_addr.S_un.S_addr);
	addr.sin_port = htons(9999);

	connect(clientSocket, (sockaddr*)&addr, sizeof addr);
	
	// 消息循环
	char buff[1024];
	while (1) {
		cin >> buff;
		send(clientSocket, buff, strlen(buff), NULL);
	}

	closesocket(clientSocket);
	WSACleanup();
	return 0;
}