0

0

C++怎么使用Asio进行异步网络编程_C++网络编程与Asio异步方法

下次还敢

下次还敢

发布时间:2025-11-23 18:20:02

|

873人浏览过

|

来源于php中文网

原创

Asio是C++中高效的异步网络编程库,核心为io_context事件循环,支持回调、协程等编程模型,可用于实现TCP客户端/服务端的非阻塞通信,结合Boost或独立使用,适用于高并发场景。

c++怎么使用asio进行异步网络编程_c++网络编程与asio异步方法

在C++中进行异步网络编程,Asio是一个功能强大且广泛使用的库。它支持同步和异步操作,尤其擅长处理高并发的网络任务。Asio既可以独立使用,也可以通过Boost.Asio获得更广泛的兼容性。从C++17开始,Asio的部分功能也被纳入标准库(std::experimental::net),但目前主流仍以Boost.Asio或独立Asio为主。

1. 安装与配置 Asio

你可以通过以下方式使用Asio:

  • 使用 Boost.Asio:安装 Boost 库,包含头文件 即可。
  • 使用 standalone Asio:从 GitHub 获取独立版本的 Asio(https://github.com/chriskohlhoff/asio),它是纯头文件库,无需编译。

确保项目中包含 Asio 头文件路径,并链接必要的系统库(如 pthread、ws2_32 等,取决于平台)。

2. 核心概念:io_context 与 异步操作

io_context 是 Asio 的核心调度器,负责管理所有异步操作的执行。你需要创建一个或多个 io_context 实例,并调用其 run() 方法来启动事件循环。

立即学习C++免费学习笔记(深入)”;

异步操作通过回调(lambda、函数指针或仿函数)来处理完成事件,不会阻塞主线程。

示例:异步等待定时器

#include 
#include 

int main() {
    asio::io_context io;

    asio::steady_timer timer(io, asio::chrono::seconds(3));
    timer.async_wait([](const asio::error_code& ec) {
        if (!ec) {
            std::cout << "Timer expired!\n";
        }
    });

    std::cout << "Waiting asynchronously...\n";
    io.run(); // 启动事件循环
    return 0;
}

3. 异步 TCP 客户端示例

下面是一个简单的异步 TCP 客户端,连接到服务器并读取数据。

PixVerse
PixVerse

PixVerse是一款强大的AI视频生成工具,可以轻松地将多种输入转化为令人惊叹的视频。

下载

#include 
#include 
#include 

using asio::ip::tcp;

class TcpClient {
public:
    TcpClient(asio::io_context& io) : socket_(io) {}

    void start(const std::string& host, const std::string& port) {
        tcp::resolver resolver(socket_.get_executor().context());
        resolver.async_resolve(host, port,
            [this](const asio::error_code& ec, tcp::resolver::results_type endpoints) {
                if (!ec) {
                    asio::async_connect(socket_, endpoints,
                        [this](const asio::error_code& ec, const tcp::endpoint&) {
                            if (!ec) {
                                std::cout << "Connected!\n";
                                do_read();
                            } else {
                                std::cerr << "Connect failed: " << ec.message() << "\n";
                            }
                        });
                }
            });
    }

private:
    void do_read() {
        socket_.async_read_some(asio::buffer(data_, max_len),
            [this](const asio::error_code& ec, size_t length) {
                if (!ec) {
                    std::cout.write(data_, length);
                    do_read(); // 继续读
                } else {
                    std::cerr << "Read error: " << ec.message() << "\n";
                }
            });
    }

    tcp::socket socket_;
    enum { max_len = 1024 };
    char data_[max_len];
};

int main() {
    asio::io_context io;
    TcpClient client(io);
    client.start("httpbin.org", "80");

    // 发送 HTTP 请求(连接成功后需手动发送)
    // 这里省略写操作,可在连接后添加 async_write

    io.run();
    return 0;
}

4. 异步 TCP 服务端结构

服务端通常使用 acceptor 监听连接,并为每个客户端创建独立会话对象处理通信。

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

    void start() {
        do_read();
    }

private:
    void do_read() {
        auto self = shared_from_this();
        socket_.async_read_some(asio::buffer(data_, max_len),
            [this, self](const asio::error_code& ec, size_t len) {
                if (!ec) {
                    asio::async_write(socket_, asio::buffer(data_, len),
                        [self](const asio::error_code& ec, size_t) {
                            if (!ec) self->do_read();
                        });
                }
            });
    }

    tcp::socket socket_;
    char data_[1024];
};

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

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

    tcp::acceptor acceptor_;
};

5. 使用协程简化异步流程(C++20 coroutine)

Asio 支持基于 C++20 协程的 async_await 风格,让异步代码看起来像同步一样清晰。

启用方式(需编译器支持):

  • 使用 asio::awaitable
  • 配合 co_awaitco_spawn

这能极大提升代码可读性,避免回调嵌套。

基本上就这些。掌握 io_context、异步操作模型、连接管理与资源生命周期控制,就能构建高效稳定的网络应用。Asio 虽初学稍复杂,但一旦理解事件驱动机制,开发灵活性非常高。

相关专题

更多
lambda表达式
lambda表达式

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

204

2023.09.15

python lambda函数
python lambda函数

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

190

2025.11.08

Python lambda详解
Python lambda详解

本专题整合了Python lambda函数相关教程,阅读下面的文章了解更多详细内容。

47

2026.01.05

线程和进程的区别
线程和进程的区别

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

480

2023.08.10

线程和进程的区别
线程和进程的区别

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

480

2023.08.10

http与https有哪些区别
http与https有哪些区别

http与https的区别:1、协议安全性;2、连接方式;3、证书管理;4、连接状态;5、端口号;6、资源消耗;7、兼容性。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

1976

2024.08.16

C++ 单元测试与代码质量保障
C++ 单元测试与代码质量保障

本专题系统讲解 C++ 在单元测试与代码质量保障方面的实战方法,包括测试驱动开发理念、Google Test/Google Mock 的使用、测试用例设计、边界条件验证、持续集成中的自动化测试流程,以及常见代码质量问题的发现与修复。通过工程化示例,帮助开发者建立 可测试、可维护、高质量的 C++ 项目体系。

6

2026.01.16

java数据库连接教程大全
java数据库连接教程大全

本专题整合了java数据库连接相关教程,阅读专题下面的文章了解更多详细内容。

28

2026.01.15

Java音频处理教程汇总
Java音频处理教程汇总

本专题整合了java音频处理教程大全,阅读专题下面的文章了解更多详细内容。

12

2026.01.15

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Git 教程
Git 教程

共21课时 | 2.7万人学习

Git版本控制工具
Git版本控制工具

共8课时 | 1.5万人学习

Git中文开发手册
Git中文开发手册

共0课时 | 0人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号