TCP/IP套接字编程是C++实现网络通信的常用方式,基于TCP协议可以保证数据传输的可靠性和有序性,适合对数据完整性要求较高的场景。Socket作为网络通信的端点,是应用程序与网络协议栈交互的接口,通过它可以完成数据的发送和接收操作。
TCP/IP与Socket基础概念
TCP是面向连接的传输层协议,通信前需要先建立连接,传输过程中会进行数据校验和重传,确保数据准确到达。Socket本质是IP地址和端口的组合,用于标识网络中的通信端点,分为流式Socket(SOCK_STREAM)和数据报Socket(SOCK_DGRAM),TCP通信通常使用流式Socket。
不同操作系统下的Socket API略有差异,Windows需要依赖Winsock库,Linux则直接使用系统提供的socket相关函数,两者的核心逻辑是一致的。
Windows环境实现步骤
环境准备
Windows下使用Socket需要先初始化Winsock库,编译时链接ws2_32.lib库,如果是使用Visual Studio开发,可以在项目属性中配置链接器输入添加该库。
TCP服务端实现
服务端的核心流程是创建Socket、绑定端口、监听连接、接受客户端连接、收发数据、关闭连接,以下是完整示例代码:
#include <iostream>
#include <winsock2.h>
#pragma comment(lib, "ws2_32.lib") // 链接Winsock库
int main() {
// 初始化Winsock
WSADATA wsaData;
if (WSAStartup(MAKEWORD(2, 2), &wsaData) != 0) {
std::cout << "WSAStartup failed" << std::endl;
return 1;
}
// 创建服务端Socket
SOCKET serverSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
if (serverSocket == INVALID_SOCKET) {
std::cout << "socket create failed" << std::endl;
WSACleanup();
return 1;
}
// 配置服务端地址
sockaddr_in serverAddr;
serverAddr.sin_family = AF_INET;
serverAddr.sin_addr.s_addr = INADDR_ANY; // 监听所有网卡
serverAddr.sin_port = htons(8888); // 端口号,需要转换为网络字节序
// 绑定Socket到地址
if (bind(serverSocket, (sockaddr*)&serverAddr, sizeof(serverAddr)) == SOCKET_ERROR) {
std::cout << "bind failed" << std::endl;
closesocket(serverSocket);
WSACleanup();
return 1;
}
// 开始监听,最大等待连接数为5
if (listen(serverSocket, 5) == SOCKET_ERROR) {
std::cout << "listen failed" << std::endl;
closesocket(serverSocket);
WSACleanup();
return 1;
}
std::cout << "Server start, listening port 8888" << std::endl;
// 接受客户端连接
sockaddr_in clientAddr;
int clientAddrLen = sizeof(clientAddr);
SOCKET clientSocket = accept(serverSocket, (sockaddr*)&clientAddr, &clientAddrLen);
if (clientSocket == INVALID_SOCKET) {
std::cout << "accept failed" << std::endl;
closesocket(serverSocket);
WSACleanup();
return 1;
}
std::cout << "Client connected" << std::endl;
// 接收客户端数据
char recvBuf[1024] = {0};
int recvLen = recv(clientSocket, recvBuf, sizeof(recvBuf), 0);
if (recvLen > 0) {
std::cout << "Receive data: " << recvBuf << std::endl;
// 向客户端发送响应
char sendBuf[] = "Hello from server";
send(clientSocket, sendBuf, sizeof(sendBuf), 0);
}
// 关闭Socket,清理Winsock
closesocket(clientSocket);
closesocket(serverSocket);
WSACleanup();
return 0;
}
TCP客户端实现
客户端的流程是创建Socket、连接服务端、收发数据、关闭连接,示例代码如下:
#include <iostream>
#include <winsock2.h>
#pragma comment(lib, "ws2_32.lib")
int main() {
WSADATA wsaData;
if (WSAStartup(MAKEWORD(2, 2), &wsaData) != 0) {
std::cout << "WSAStartup failed" << std::endl;
return 1;
}
// 创建客户端Socket
SOCKET clientSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
if (clientSocket == INVALID_SOCKET) {
std::cout << "socket create failed" << std::endl;
WSACleanup();
return 1;
}
// 配置服务端地址
sockaddr_in serverAddr;
serverAddr.sin_family = AF_INET;
serverAddr.sin_port = htons(8888);
// 这里连接本地服务端,如果是其他地址可以替换为对应IP
serverAddr.sin_addr.s_addr = inet_addr("127.0.0.1");
// 连接服务端
if (connect(clientSocket, (sockaddr*)&serverAddr, sizeof(serverAddr)) == SOCKET_ERROR) {
std::cout << "connect failed" << std::endl;
closesocket(clientSocket);
WSACleanup();
return 1;
}
std::cout << "Connect server success" << std::endl;
// 向服务端发送数据
char sendBuf[] = "Hello from client";
send(clientSocket, sendBuf, sizeof(sendBuf), 0);
// 接收服务端响应
char recvBuf[1024] = {0};
int recvLen = recv(clientSocket, recvBuf, sizeof(recvBuf), 0);
if (recvLen > 0) {
std::cout << "Receive response: " << recvBuf << std::endl;
}
// 关闭Socket
closesocket(clientSocket);
WSACleanup();
return 0;
}
Linux环境实现步骤
Linux下不需要初始化额外的库,直接使用系统提供的socket函数即可,编译时不需要额外链接库,核心流程与Windows一致,只是部分函数返回值处理和头文件不同。
Linux下TCP服务端示例
#include <iostream>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <cstring>
int main() {
// 创建Socket
int serverSocket = socket(AF_INET, SOCK_STREAM, 0);
if (serverSocket == -1) {
std::cout << "socket create failed" << std::endl;
return 1;
}
// 配置地址
sockaddr_in serverAddr;
memset(&serverAddr, 0, sizeof(serverAddr));
serverAddr.sin_family = AF_INET;
serverAddr.sin_addr.s_addr = INADDR_ANY;
serverAddr.sin_port = htons(8888);
// 绑定地址,需要强制转换sockaddr_in到sockaddr*
if (bind(serverSocket, (sockaddr*)&serverAddr, sizeof(serverAddr)) == -1) {
std::cout << "bind failed" << std::endl;
close(serverSocket);
return 1;
}
// 监听
if (listen(serverSocket, 5) == -1) {
std::cout << "listen failed" << std::endl;
close(serverSocket);
return 1;
}
std::cout << "Server start, listening port 8888" << std::endl;
// 接受连接
sockaddr_in clientAddr;
socklen_t clientAddrLen = sizeof(clientAddr);
int clientSocket = accept(serverSocket, (sockaddr*)&clientAddr, &clientAddrLen);
if (clientSocket == -1) {
std::cout << "accept failed" << std::endl;
close(serverSocket);
return 1;
}
std::cout << "Client connected" << std::endl;
// 收发数据
char recvBuf[1024] = {0};
int recvLen = recv(clientSocket, recvBuf, sizeof(recvBuf), 0);
if (recvLen > 0) {
std::cout << "Receive data: " << recvBuf << std::endl;
char sendBuf[] = "Hello from server";
send(clientSocket, sendBuf, sizeof(sendBuf), 0);
}
// 关闭Socket
close(clientSocket);
close(serverSocket);
return 0;
}
Linux下TCP客户端示例
#include <iostream>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <cstring>
int main() {
int clientSocket = socket(AF_INET, SOCK_STREAM, 0);
if (clientSocket == -1) {
std::cout << "socket create failed" << std::endl;
return 1;
}
sockaddr_in serverAddr;
memset(&serverAddr, 0, sizeof(serverAddr));
serverAddr.sin_family = AF_INET;
serverAddr.sin_port = htons(8888);
serverAddr.sin_addr.s_addr = inet_addr("127.0.0.1");
if (connect(clientSocket, (sockaddr*)&serverAddr, sizeof(serverAddr)) == -1) {
std::cout << "connect failed" << std::endl;
close(clientSocket);
return 1;
}
std::cout << "Connect server success" << std::endl;
char sendBuf[] = "Hello from client";
send(clientSocket, sendBuf, sizeof(sendBuf), 0);
char recvBuf[1024] = {0};
int recvLen = recv(clientSocket, recvBuf, sizeof(recvBuf), 0);
if (recvLen > 0) {
std::cout << "Receive response: " << recvBuf << std::endl;
}
close(clientSocket);
return 0;
}
常见注意事项
- 端口号需要选择1024以上的未被占用的端口,避免与系统保留端口冲突
- 网络字节序和主机字节序的转换需要使用htons、htonl、ntohs、ntohl等函数,端口和IP地址都需要转换
- 收发数据时需要注意返回值,返回值小于等于0时表示连接出现异常,需要处理错误情况
- 程序退出前需要关闭所有打开的Socket,避免资源泄露
- 如果是多客户端通信,服务端需要使用多线程或者IO多路复用技术处理多个连接