c++如何使用Boost.Asio进行异步网络编程_c++异步IO框架Boost.Asio使用教程

下次还敢

发布时间：2025-11-08 23:39:11

355人浏览过

来源于php中文网

原创

Boost.Asio通过io_context管理异步I/O，使用socket进行网络通信，结合回调处理连接、读写操作，需注意对象生命周期与事件循环调度。

c++如何使用boost.asio进行异步网络编程_c++异步io框架boost.asio使用教程

Boost.Asio 是一个功能强大且广泛使用的 C++ 库，用于处理网络和异步 I/O 操作。它支持同步和异步编程模型，尤其擅长构建高性能、可扩展的网络服务。下面介绍如何使用 Boost.Asio 进行异步网络编程，涵盖基本概念、核心组件和实际代码示例。

理解 Boost.Asio 的核心概念

在开始编码前，先了解几个关键概念：

io_context：这是所有异步操作的核心调度器，负责管理事件循环和分发回调。
socket：代表网络连接，如 tcp::socket，用于发送和接收数据。
异步操作：通过回调（通常为 lambda 或函数对象）在操作完成时被调用，不阻塞主线程。
strand：用于保证多个异步操作的执行顺序，避免竞态条件。

异步编程的关键是“发起操作 → 回调通知”，而不是等待结果。

实现一个简单的异步 TCP 客户端

下面是一个使用 Boost.Asio 编写的异步 TCP 客户端示例，连接到服务器并读取响应。

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

#include 
#include 
#include 

using boost::asio::ip::tcp;

int main() {
    try {
        boost::asio::io_context io_context;

        tcp::resolver resolver(io_context);
        tcp::resolver::results_type endpoints = resolver.resolve("127.0.0.1", "8080");

        tcp::socket socket(io_context);
        boost::asio::async_connect(socket, endpoints,
            [&](const boost::system::error_code& error, const tcp::endpoint&) {
                if (!error) {
                    std::cout << "Connected to server\n";

                    // 发起异步读取
                    std::array buf;
                    socket.async_read_some(boost::asio::buffer(buf),
                        [&](const boost::system::error_code& read_error, size_t bytes_transferred) {
                            if (!read_error) {
                                std::cout.write(buf.data(), bytes_transferred);
                                std::cout << "\n";
                            } else {
                                std::cerr << "Read error: " << read_error.message() << "\n";
                            }
                        });
                } else {
                    std::cerr << "Connect failed: " << error.message() << "\n";
                }
            });

        io_context.run();  // 启动事件循环
    }
    catch (std::exception& e) {
        std::cerr << "Exception: " << e.what() << "\n";
    }

    return 0;
}

注意：async_connect 和 async_read_some 都是非阻塞的，真正的逻辑在 lambda 回调中处理。必须调用 io_context::run() 来启动事件循环，否则回调不会执行。

bloop

快速查找代码，基于GPT-4的语义代码搜索

下载

编写异步 TCP 服务器

异步服务器需要能同时处理多个客户端连接。通常做法是为每个连接创建一个会话对象。

class session : public std::enable_shared_from_this {
public:
    session(tcp::socket socket) : socket_(std::move(socket)) {}

    void start() {
        do_read();
    }

private:
    void do_read() {
        auto self(shared_from_this());
        socket_.async_read_some(boost::asio::buffer(data_),
            [this, self](const boost::system::error_code& error, size_t length) {
                if (!error) {
                    do_write(length);
                }
            });
    }

    void do_write(size_t length) {
        auto self(shared_from_this());
        boost::asio::async_write(socket_, boost::asio::buffer(data_, length),
            [this, self](const boost::system::error_code& error, size_t /*length*/) {
                if (!error) {
                    do_read();  // 继续读取
                }
            });
    }

    tcp::socket socket_;
    std::array data_;
};

class server {
public:
    server(boost::asio::io_context& io_context, short port)
        : acceptor_(io_context, tcp::endpoint(tcp::v4(), port)) {
        do_accept();
    }

private:
    void do_accept() {
        acceptor_.async_accept(
            [this](const boost::system::error_code& error, tcp::socket socket) {
                if (!error) {
                    std::make_shared(std::move(socket))->start();
                }
                do_accept();  // 接受下一个连接
            });
    }

    tcp::acceptor acceptor_;
};

服务器通过 do_accept 循环接受新连接，并为每个连接创建一个 session 对象。使用 shared_from_this 确保对象生命周期在异步操作期间有效。

编译与依赖配置

Boost.Asio 大部分是头文件库，但部分功能（如协程、SSL）需要链接 Boost 系统库。

安装 Boost：可通过包管理器（如 apt、brew）或源码编译。
编译命令示例（Linux）：

g++ -std=c++17 client.cpp -o client -lboost_system

如果使用 CMake，添加：

find_package(Boost REQUIRED COMPONENTS system)
target_link_libraries(your_target Boost::system)

基本上就这些。掌握 Boost.Asio 的关键是理解异步模型和对象生命周期管理。只要确保回调持有必要的资源（如 socket、buffer），并正确使用 shared_ptr 延长对象生命期，就能写出稳定高效的网络程序。

c++如何编写动态链接库(DLL/so)_c++共享库的创建与使用【教程】

C++如何使用valgrind进行内存泄漏检测？（Linux工具）

c++如何处理Unicode和UTF-8编码_c++跨平台字符串处理

C++ Boost库怎么安装和使用？C++准标准库Boost入门指南【教程】

c++如何使用vcpkg管理第三方库_c++现代化包管理器入门

c++速学教程(入门到精通)

c++怎么学习？c++怎么入门？c++在哪学？c++怎么学才快？不用担心，这里为大家提供了c++速学教程(入门到精通)，有需要的小伙伴保存下载就能学习啦！

下载

相关专题

session失效的原因

session失效的原因有会话超时、会话数量限制、会话完整性检查、服务器重启、浏览器或设备问题等等。详细介绍：1、会话超时：服务器为Session设置了一个默认的超时时间，当用户在一段时间内没有与服务器交互时，Session将自动失效；2、会话数量限制：服务器为每个用户的Session数量设置了一个限制，当用户创建的Session数量超过这个限制时，最新的会覆盖最早的等等。

302

2023.10.17

session失效解决方法

session失效通常是由于 session 的生存时间过期或者服务器关闭导致的。其解决办法：1、延长session的生存时间；2、使用持久化存储；3、使用cookie；4、异步更新session；5、使用会话管理中间件。

704

2023.10.18

cookie与session的区别

本专题整合了cookie与session的区别和使用方法等相关内容，阅读专题下面的文章了解更详细的内容。

2025.08.19

lambda表达式

Lambda表达式是一种匿名函数的简洁表示方式，它可以在需要函数作为参数的地方使用，并提供了一种更简洁、更灵活的编码方式，其语法为“lambda 参数列表: 表达式”，参数列表是函数的参数，可以包含一个或多个参数，用逗号分隔，表达式是函数的执行体，用于定义函数的具体操作。本专题为大家提供lambda表达式相关的文章、下载、课程内容，供大家免费下载体验。

202

2023.09.15

python lambda函数

本专题整合了python lambda函数用法详解，阅读专题下面的文章了解更多详细内容。

187

2025.11.08

线程和进程的区别

线程和进程的区别：线程是进程的一部分，用于实现并发和并行操作，而线程共享进程的资源，通信更方便快捷，切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

465

2023.08.10

线程和进程的区别

465

2023.08.10

SSL检测工具介绍

SSL检测工具有SSL Labs、SSL Check、SSL Server Test、SSLMate、SSL/TLS Analyzer等。详细介绍：1、SSL Labs是一个由Qualys提供的在线SSL检测工具，可以评估服务器证书的部署情况、加密套件、协议支持等方面的安全性，它提供了一个详细的报告，包括证书的颁发者、有效期、安全性配置等；2、SSL Check等等。

324

2023.10.20