C++如何实现简单聊天程序 socket网络通信基础

P粉602998670

发布时间：2025-07-02 09:24:07

305人浏览过

来源于php中文网

原创

要实现一个简单的c++++聊天程序，核心在于利用socket进行网络通信。服务器端步骤包括：1. 创建socket；2. 绑定地址；3. 监听连接；4. 接受连接；5. 收发数据；6. 关闭socket。客户端步骤包括：1. 创建socket；2. 连接服务器；3. 收发数据；4. 关闭socket。并发连接可通过多线程、多进程或异步i/o实现，消息完整性可通过固定长度、消息头+消息体或分隔符方式处理，安全性则需使用加密协议、输入验证、权限限制等措施保障。

C++如何实现简单聊天程序 socket网络通信基础

要实现一个简单的C++聊天程序，核心在于利用Socket进行网络通信。简单来说，就是客户端和服务器端通过Socket“握手”，然后互相发送和接收消息。

Socket编程是基础，需要理解TCP/IP协议栈的一些基本概念，比如端口、IP地址等。

解决方案

立即学习“C++免费学习笔记（深入）”；

服务器端：
- 创建Socket：使用socket()函数创建一个监听Socket。
- 绑定地址：使用bind()函数将Socket绑定到特定的IP地址和端口。
- 监听连接：使用listen()函数开始监听客户端连接请求。
- 接受连接：使用accept()函数接受客户端的连接请求，创建一个新的Socket用于与该客户端通信。
- 接收和发送数据：使用recv()和send()函数通过Socket与客户端进行数据交换。
- 关闭Socket：使用close()函数关闭Socket。
客户端：
- 创建Socket：使用socket()函数创建一个Socket。
- 连接服务器：使用connect()函数连接服务器的IP地址和端口。
- 接收和发送数据：使用recv()和send()函数通过Socket与服务器进行数据交换。
- 关闭Socket：使用close()函数关闭Socket。

一个简化版的代码示例（只展示核心逻辑）：

服务器端：

#include 
#include 
#include 
#include 
#include 

int main() {
    int server_fd, new_socket;
    struct sockaddr_in address;
    int addrlen = sizeof(address);
    char buffer[1024] = {0};
    const int PORT = 8080; // 选择一个合适的端口

    // 创建socket
    if ((server_fd = socket(AF_INET, SOCK_STREAM, 0)) == 0) {
        perror("socket failed");
        exit(EXIT_FAILURE);
    }

    address.sin_family = AF_INET;
    address.sin_addr.s_addr = INADDR_ANY;
    address.sin_port = htons( PORT );

    // 绑定地址
    if (bind(server_fd, (struct sockaddr *)&address, sizeof(address)) < 0) {
        perror("bind failed");
        exit(EXIT_FAILURE);
    }

    // 监听连接
    if (listen(server_fd, 3) < 0) {
        perror("listen");
        exit(EXIT_FAILURE);
    }

    std::cout << "Server listening on port " << PORT << std::endl;

    // 接受连接
    if ((new_socket = accept(server_fd, (struct sockaddr *)&address, (socklen_t*)&addrlen)) < 0) {
        perror("accept");
        exit(EXIT_FAILURE);
    }

    // 接收数据
    read( new_socket , buffer, 1024);
    std::cout << "Received: " << buffer << std::endl;

    // 发送数据
    const char* message = "Hello from server";
    send(new_socket , message , strlen(message) , 0 );
    std::cout << "Hello message sent\n";

    close(new_socket);
    close(server_fd);
    return 0;
}

客户端：

#include 
#include 
#include 
#include 
#include 

int main() {
    int sock = 0;
    struct sockaddr_in serv_addr;
    char buffer[1024] = {0};
    const int PORT = 8080;

    if ((sock = socket(AF_INET, SOCK_STREAM, 0)) < 0) {
        std::cout << "\n Socket creation error \n";
        return -1;
    }

    serv_addr.sin_family = AF_INET;
    serv_addr.sin_port = htons(PORT);

    // Convert IPv4 and IPv6 addresses from text to binary form
    if(inet_pton(AF_INET, "127.0.0.1", &serv_addr.sin_addr)<=0) {
        std::cout << "\nInvalid address/ Address not supported \n";
        return -1;
    }

    if (connect(sock, (struct sockaddr *)&serv_addr, sizeof(serv_addr)) < 0) {
        std::cout << "\nConnection Failed \n";
        return -1;
    }

    const char* message = "Hello from client";
    send(sock , message , strlen(message) , 0 );
    std::cout << "Hello message sent\n";
    read( sock , buffer, 1024);
    std::cout << "Received: " << buffer << std::endl;
    close(sock);
    return 0;
}

这段代码只是一个最简示例，没有错误处理和并发处理。实际应用中，需要考虑更多细节。例如，使用多线程或多进程处理多个客户端的连接，以及更完善的错误处理机制。