C++在Linux上如何实现网络通信

在Linux上使用C++实现网络通信

想在Linux环境下用C++搞定网络通信？绕不开的核心就是套接字（socket）编程。简单来说，套接字是网络通信的基石，它让不同机器上的进程能够通过互联网协议（IP）顺畅地交换数据。下面，咱们就一步步拆解在Linux上使用C++进行网络通信的基本流程。

1. 包含必要的头文件

第一步，得先把“工具箱”准备好。这些头文件提供了创建和管理套接字所需的所有函数和数据结构。

#include 
#include 
#include 
#include 
#include 
#include 

2. 创建套接字

万事开头难，创建套接字是通信的起点。这里我们创建一个用于TCP流式通信的套接字。

int sockfd = socket(AF_INET, SOCK_STREAM, 0);
if (sockfd < 0) {
    // 错误处理
    perror("socket creation failed");
    exit(EXIT_FAILURE);
}

3. 设置服务器地址

接下来，需要明确我们要连接的目标在哪里。通过填充 sockaddr_in 结构体，来指定服务器的地址族、端口和IP地址。

struct sockaddr_in serv_addr;
memset(&serv_addr, '0', sizeof(serv_addr));
serv_addr.sin_family = AF_INET;
serv_addr.sin_port = htons(8080); // 服务器端口
// 将IPv4地址从文本转换为二进制形式
if(inet_pton(AF_INET, "127.0.0.1", &serv_addr.sin_addr) <= 0) {
    // 错误处理
    perror("inet_pton failed");
    exit(EXIT_FAILURE);
}

4. 连接服务器（客户端）

对于客户端而言，创建好套接字并知道服务器地址后，最关键的一步就是发起连接。

if (connect(sockfd, (struct sockaddr *)&serv_addr, sizeof(serv_addr)) < 0) {
    // 错误处理
    perror("connect failed");
    exit(EXIT_FAILURE);
}

5. 发送和接收数据

连接建立成功，通信的“高速公路”就铺好了。这时，便可以开始核心的数据收发工作。

// 发送数据
const char *hello = "Hello from client";
send(sockfd, hello, strlen(hello), 0);
std::cout << "Hello message sent\n";
// 接收数据
char buffer[1024] = {0};
int valread = read(sockfd, buffer, 1024);
std::cout << buffer << std::endl;

6. 关闭套接字

通信完毕，务必记得关闭套接字，释放系统资源。这是一个好习惯。

close(sockfd);

以上是客户端的典型流程。那么，服务器端该怎么做呢？其实思路是相通的，只是角色和步骤略有不同：服务器需要使用 listen() 来监听特定端口，等待客户端的连接请求，然后用 accept() 来接受并建立具体的连接。下面是一个简单的服务器端示例：

1. 创建套接字（与客户端相同）

服务器同样需要先创建一个套接字，作为对外服务的“门户”。

2. 绑定套接字到地址和端口

创建好的套接字需要与一个具体的网络地址和端口号绑定，这样客户端才知道该连接到哪里。

if (bind(sockfd, (struct sockaddr *)&serv_addr, sizeof(serv_addr)) < 0) {
    // 错误处理
    perror("bind failed");
    exit(EXIT_FAILURE);
}

3. 监听套接字

绑定之后，套接字并不会自动接收连接。需要调用 listen() 将其设置为被动监听模式，并指定等待连接队列的长度。

if (listen(sockfd, 3) < 0) {
    // 错误处理
    perror("listen");
    exit(EXIT_FAILURE);
}

4. 接受客户端连接

当有客户端尝试连接时，accept() 函数会被调用。它会从监听队列中取出一个连接请求，并创建一个新的套接字专门用于和这个客户端通信。

int newsockfd;
struct sockaddr_in cli_addr;
socklen_t clilen = sizeof(cli_addr);
newsockfd = accept(sockfd, (struct sockaddr *)&cli_addr, &clilen);
if (newsockfd < 0) {
    // 错误处理
    perror("accept");
    exit(EXIT_FAILURE);
}

5. 发送和接收数据（与客户端相同）

通过新创建的 newsockfd，服务器就可以像客户端一样，使用 send() 和 read() 与特定的客户端进行数据交互了。

6. 关闭套接字（包括新的客户端套接字和监听套接字）

通信结束后，需要分别关闭用于与客户端通信的新套接字和最初用于监听的套接字。

需要特别提醒的是，上面的代码示例主要用于演示核心流程。在实际的项目开发中，必须加入更健壮的错误处理机制和资源管理逻辑。此外，如果项目复杂度上升，涉及到高性能或异步通信，那么直接使用底层的套接字API可能会显得力不从心。这时，不妨考虑使用更高级的库，比如 Boost.Asio，它封装了异步I/O等强大功能，能让你事半功倍。