当前位置：首页 > article >正文

Boost.Asio 的 TCP 通信教程

article 2025/1/9 3:45:51

一、引言

本教程将详细介绍如何使用 Boost.Asio 库实现一个简单的 TCP 通信示例，包括服务器端和客户端的代码编写、编译以及运行流程。同时，我们会对通信过程中的各个关键步骤进行详细讲解，帮助读者理解 TCP 通信在 Boost.Asio 中的实现方式。后续如果需要扩展功能，例如并发处理多个客户端连接或使用异步通信等，可以在此基础上进行修改。

二、准备工作

确保系统中已安装 Boost 库。
确保编译器（如 g++）能够正常识别并使用 Boost 的头文件和链接库。
Boost.Asio 是头文件库，但需要链接 Boost.System 库，因此编译时需加入 -lboost_system 参数。

三、服务器端代码讲解

（一）创建 `io_context`

在服务器端代码中，首先需要创建一个 io_context 对象，它是 Boost.Asio 用于调度 I/O 操作的核心对象。

// Step 1: 创建 io_context
boost::asio::io_context ios;

ios 对象是 I/O 操作的调度中心，后续操作都依赖于它。

（二）创建并绑定 `acceptor`

为了监听指定端口等待客户端连接，需要创建并绑定一个 ip::tcp::acceptor 对象。

// Step 2: 创建并绑定 acceptor
boost::asio::ip::tcp::acceptor acceptor(ios, boost::asio::ip::tcp::endpoint(boost::asio::ip::tcp::v4(), 3333));
std::cout << "Server is listening on port 3333..." << std::endl;

上述代码将 acceptor 对象绑定到 IPv4 协议的本地地址（127.0.0.1）和端口 3333。

（三）等待客户端连接

通过 acceptor 对象的 accept 方法等待并接收客户端的连接请求。当有客户端连接时，会生成一个与客户端通信的 socket 对象。

// Step 3: 等待客户端连接
boost::asio::ip::tcp::socket socket(ios);
acceptor.accept(socket);
std::cout << "Client connected!" << std::endl;

（四）接收数据

通过 socket 接收客户端发送的数据。

// Step 4: 接收数据
char data[1024] = {0};
size_t length = socket.read_some(boost::asio::buffer(data));
std::cout << "Received from client: " << std::string(data, length) << std::endl;

read_some 是同步操作，读取的数据会存入 data 缓冲区。

（五）发送数据

服务器可以通过 socket 向客户端发送数据。

// Step 5: 发送数据
std::string message = "Hello from server!";
boost::asio::write(socket, boost::asio::buffer(message));

boost::asio::write 是同步写操作，将 message 内容发送给客户端。

（六）关闭 `socket`

通信结束后，关闭 socket 释放资源。

// Step 6: 关闭 socket
socket.close();
std::cout << "Connection closed!" << std::endl;

为提高程序的健壮性，以上代码应放在 try-catch 块中捕获异常。

完整的服务器端代码如下：

#include <boost/asio.hpp>
#include <iostream>

int main() {
    try {
        boost::asio::io_context ios;
        boost::asio::ip::tcp::acceptor acceptor(ios, boost::asio::ip::tcp::endpoint(boost::asio::ip::tcp::v4(), 3333));
        std::cout << "Server is listening on port 3333..." << std::endl;

        boost::asio::ip::tcp::socket socket(ios);
        acceptor.accept(socket);
        std::cout << "Client connected!" << std::endl;

        char data[1024] = {0};
        size_t length = socket.read_some(boost::asio::buffer(data));
        std::cout << "Received from client: " << std::string(data, length) << std::endl;

        std::string message = "Hello from server!";
        boost::asio::write(socket, boost::asio::buffer(message));

        socket.close();
        std::cout << "Connection closed!" << std::endl;
    } catch (std::exception& e) {
        std::cerr << "Error: " << e.what() << std::endl;
    }

    return 0;
}

四、客户端代码讲解

（一）创建 `io_context`

客户端首先需要创建一个 io_context 对象。

// Step 1: 创建 io_context
boost::asio::io_context ios;

（二）创建 `socket` 并连接到服务器

通过 socket 对象的 connect 方法连接到服务器。

// Step 2: 创建 socket 并连接到服务器
boost::asio::ip::tcp::socket socket(ios);
boost::asio::ip::tcp::endpoint endpoint(boost::asio::ip::address::from_string("127.0.0.1"), 3333);
socket.connect(endpoint);
std::cout << "Connected to server!" << std::endl;

（三）发送数据

客户端可以通过 socket 向服务器发送数据。

// Step 3: 发送数据
std::string message = "Hello from client!";
boost::asio::write(socket, boost::asio::buffer(message));

（四）接收数据

客户端接收服务器发送的回复。

// Step 4: 接收数据
char data[1024] = {0};
size_t length = socket.read_some(boost::asio::buffer(data));
std::cout << "Received from server: " << std::string(data, length) << std::endl;

（五）关闭 `socket`

通信结束后，关闭 socket 连接。

// Step 5: 关闭 socket
socket.close();
std::cout << "Connection closed!" << std::endl;

完整的客户端代码如下：

#include <boost/asio.hpp>
#include <iostream>

int main() {
    try {
        boost::asio::io_context ios;
        boost::asio::ip::tcp::socket socket(ios);
        boost::asio::ip::tcp::endpoint endpoint(boost::asio::ip::address::from_string("127.0.0.1"), 3333);
        socket.connect(endpoint);
        std::cout << "Connected to server!" << std::endl;

        std::string message = "Hello from client!";
        boost::asio::write(socket, boost::asio::buffer(message));

        char data[1024] = {0};
        size_t length = socket.read_some(boost::asio::buffer(data));
        std::cout << "Received from server: " << std::string(data, length) << std::endl;

        socket.close();
        std::cout << "Connection closed!" << std::endl;
    } catch (std::exception& e) {
        std::cerr << "Error: " << e.what() << std::endl;
    }

    return 0;
}