0

0

C++利用协程如何封装非阻塞的Redis异步驱动?(数据库访问优化)

穿越時空

穿越時空

发布时间:2026-03-11 17:07:20

|

155人浏览过

|

来源于php中文网

原创

协程封装redis异步驱动的核心是桥接hiredis与asio事件循环,将socket可读/可写等待协程化;需绑定唯一stream_descriptor、设置连接/断连回调、深拷贝reply、校验fd有效性并快照错误状态。

c++利用协程如何封装非阻塞的redis异步驱动?(数据库访问优化)

协程封装 Redis 异步驱动的核心约束

不能直接把 hiredisredisAsyncConnect 塞进协程里就完事——它本身不挂起,也不返回 std::suspend_always。真正能协程化的,是「等待事件循环通知连接就绪/命令回复到达」这个动作。所以必须桥接异步 I/O 库(如 libuvboost::asio)和协程调度器,让 co_await 等在 socket 可读/可写上,而不是等线程 sleep。

boost::asio + redisAsyncContext 绑定协程等待点

hiredis 的异步 API 依赖用户自己提供事件循环回调;boost::asioio_context 正好能接管这个职责。关键不是重写 hiredis,而是把它的 socket fd 注册进 asio::posix::stream_descriptor,再用 async_waitasync_read_some 封装等待逻辑。

  • 必须调用 redisAsyncSetConnectCallbackredisAsyncSetDisconnectCallback,否则连接成功后协程收不到通知
  • 每个 redisAsyncContext* 要绑定唯一一个 asio::posix::stream_descriptor,重复绑定会触发 Bad file descriptor
  • 不要在协程里直接调用 redisAsyncCommand 后立刻 co_await——它只是发请求,不保证发送完成;得等 AE_WRITABLE 事件确认 socket 可写且缓冲区有空位
  • 示例等待连接建立:
    co_await async_wait_descriptor(desc, asio::posix::stream_descriptor::wait_write);
    实际中还要检查 context->err 是否为 0

协程返回值与错误传播的常见翻车点

很多人想让 co_await redis_get("key") 直接返回 std::string,但 hiredis 的 reply 是 redisReply*,生命周期由回调函数管理,协程挂起时 reply 可能已被释放。

纳米漫剧流水线
纳米漫剧流水线

360推出的国内首个工业级AI漫剧生产平台

下载
  • 必须在回调里深拷贝 redisReply 字段(如 strlen),或用 redisGetReply 配合同步上下文——但这会阻塞线程,违背初衷
  • 推荐用 std::optional<:string></:string> 作返回类型,std::nullopt 表示网络错误或空值,避免裸指针逃逸
  • 如果用了 redisAsyncCommandArgv,参数 argv 数组必须在协程整个生命周期内有效——建议用 std::vector<:string></:string> 持有,传 argv.data() 时确保 vector 不 realloc
  • 超时不能只靠协程内部计时器:hiredisredisAsyncSetTimeout 才真正控制 socket 层超时,协程侧的 std::chrono::steady_clock 只能做兜底

连接池与协程调度器的生命周期对齐

协程可能跨多个 io_context.run() 调用,而 redisAsyncContext 关联的 socket fd 在 disconnect 后失效。若连接池复用 context 但没重置 fd,下次 co_await 会卡死或触发 Bad file descriptor

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

  • 每次从连接池取 context 前,必须检查 context->c.fd != -1 && context->err == 0,否则重建连接
  • 不要把 io_context 对象放在栈上并传给协程——协程可能被挂起,io_context 析构后所有 pending await 都会崩溃
  • 若用 boost::asio::thread_pool,确保所有 Redis 协程都在同一个 io_context 上调度,混用不同上下文会导致事件丢失
  • 连接池 size 不宜过大:每个 redisAsyncContext 占一个 socket fd + 回调注册开销,Linux 默认单进程 1024 fd 限制下,20 个连接就占满一半

最麻烦的其实是错误上下文丢失:hiredis 把错误码存在 context->err 里,但协程恢复时这个值可能已被后续命令覆盖。真要可靠,得在每次回调里立刻把 errerrstr 快照进 promise 的局部状态。

相关文章

驱动精灵
驱动精灵

驱动精灵基于驱动之家十余年的专业数据积累,驱动支持度高,已经为数亿用户解决了各种电脑驱动问题、系统故障,是目前有效的驱动软件,有需要的小伙伴快来保存下载体验吧!

下载

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
string转int
string转int

在编程中,我们经常会遇到需要将字符串(str)转换为整数(int)的情况。这可能是因为我们需要对字符串进行数值计算,或者需要将用户输入的字符串转换为整数进行处理。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

1010

2023.08.02

堆和栈的区别
堆和栈的区别

堆和栈的区别:1、内存分配方式不同;2、大小不同;3、数据访问方式不同;4、数据的生命周期。本专题为大家提供堆和栈的区别的相关的文章、下载、课程内容,供大家免费下载体验。

443

2023.07.18

堆和栈区别
堆和栈区别

堆(Heap)和栈(Stack)是计算机中两种常见的内存分配机制。它们在内存管理的方式、分配方式以及使用场景上有很大的区别。本文将详细介绍堆和栈的特点、区别以及各自的使用场景。php中文网给大家带来了相关的教程以及文章欢迎大家前来学习阅读。

605

2023.08.10

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

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

764

2023.08.10

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

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

764

2023.08.10

promise的用法
promise的用法

“promise” 是一种用于处理异步操作的编程概念,它可以用来表示一个异步操作的最终结果。Promise 对象有三种状态:pending(进行中)、fulfilled(已成功)和 rejected(已失败)。Promise的用法主要包括构造函数、实例方法(then、catch、finally)和状态转换。

335

2023.10.12

html文本框类型介绍
html文本框类型介绍

html文本框类型有单行文本框、密码文本框、数字文本框、日期文本框、时间文本框、文件上传文本框、多行文本框等等。详细介绍:1、单行文本框是最常见的文本框类型,用于接受单行文本输入,用户可以在文本框中输入任意文本,例如用户名、密码、电子邮件地址等;2、密码文本框用于接受密码输入,用户在输入密码时,文本框中的内容会被隐藏,以保护用户的隐私;3、数字文本框等等。

427

2023.10.12

常用的数据库软件
常用的数据库软件

常用的数据库软件有MySQL、Oracle、SQL Server、PostgreSQL、MongoDB、Redis、Cassandra、Hadoop、Spark和Amazon DynamoDB。更多关于数据库软件的内容详情请看本专题下面的文章。php中文网欢迎大家前来学习。

1005

2023.11.02

C# ASP.NET Core微服务架构与API网关实践
C# ASP.NET Core微服务架构与API网关实践

本专题围绕 C# 在现代后端架构中的微服务实践展开,系统讲解基于 ASP.NET Core 构建可扩展服务体系的核心方法。内容涵盖服务拆分策略、RESTful API 设计、服务间通信、API 网关统一入口管理以及服务治理机制。通过真实项目案例,帮助开发者掌握构建高可用微服务系统的关键技术,提高系统的可扩展性与维护效率。

3

2026.03.11

热门下载

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

精品课程

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

共94课时 | 11.1万人学习

C 教程
C 教程

共75课时 | 5.3万人学习

C++教程
C++教程

共115课时 | 21.4万人学习

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

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