讲师中心 微信公众号
AI工具推荐 视频效率加速

利用 Nginx subrequest 机制在 Handler 模块中实现与 Redis 的全异步通信逻辑

云磊同学_8126

云磊同学_8126

发布时间:2026-04-15 17:51:16

|

368人浏览过

|

来源于php中文网

原创

Nginx Handler中不能直接调用同步Redis客户端,因其单线程事件模型会因系统调用阻塞整个worker;需通过subrequest委托给异步upstream模块(如redis2或lua-resty-redis)实现伪异步通信。

利用 nginx subrequest 机制在 handler 模块中实现与 redis 的全异步通信逻辑

在 Nginx Handler 模块中利用 subrequest 机制实现与 Redis 的全异步通信,本质上是一种“伪异步”设计——Nginx 本身不直接支持 Redis 协议的非阻塞 I/O,但可通过子请求将 Redis 交互委托给一个已封装好异步能力的 upstream 模块(如 ngx_http_redis2_module 或基于 lua-resty-redis 的 Lua 实现),从而在 Handler 中保持事件循环不被阻塞。

为什么不能在 Handler 中直接调用 Redis 同步客户端

Nginx 是单线程事件驱动模型(每个 worker 进程一个事件循环)。若在 Handler 中调用传统同步 Redis 客户端(如 libc 库直连),会引发系统调用阻塞(connect、read、write),导致整个 worker 暂停响应其他请求,彻底破坏高并发能力。Nginx 明确禁止在非协程/非 event-driven 上下文中做任何阻塞操作。

subrequest 是如何实现“异步转交”的

subrequest 并非真正的线程或协程,而是 Nginx 内部的轻量级请求调度机制:它把逻辑拆分为父子请求,父请求挂起等待,子请求进入标准 upstream 流程(含连接池、超时控制、事件注册),由 epoll/kqueue 驱动完成 I/O,完成后自动回调父请求的 subrequest done handler。关键点:

  • 子请求必须指向一个已支持异步 upstream 的 location(例如 location /redis { redis2_pass ...; })
  • 父 Handler 需调用 ngx_http_subrequest 注册子请求,并提供回调函数处理结果
  • 父请求需返回 NGX_AGAIN 让 Nginx 暂停执行,待子请求完成再通过回调恢复
  • 所有数据交换通过 ngx_http_request_t->parent 和 ctx 传递,不可依赖栈变量

典型 Handler + subrequest + Redis 的编码结构

以自定义模块中的 Handler 函数为例(C 语言):

redis-tools
redis-tools

按类别查找Redis命令、检测服务器连接、监控键数量和内存占用,支持离线速查表。

下载
static ngx_int_t my_handler(ngx_http_request_t *r) {
    ngx_int_t             rc;
    ngx_http_request_t   *sr;
    ngx_http_post_subrequest_t *psr;
<pre class='brush:php;toolbar:false;'>// 1. 分配子请求上下文(需持久化到 r->pool)
my_ctx_t *ctx = ngx_pcalloc(r->pool, sizeof(my_ctx_t));
if (ctx == NULL) return NGX_HTTP_INTERNAL_SERVER_ERROR;
ngx_http_set_ctx(r, ctx, my_module);

// 2. 发起 subrequest 到预定义的 redis location
rc = ngx_http_subrequest(r, &ngx_str("/redis/get"), NULL, &sr,
                          my_subrequest_done, NGX_HTTP_SUBREQUEST_IN_MEMORY);
if (rc != NGX_OK) return rc;

// 3. 父请求立即返回 NGX_AGAIN,交还控制权
return NGX_AGAIN;

}

// 子请求完成后的回调 static void my_subrequest_done(ngx_http_request_t r, void data, ngx_int_t rc) { my_ctx_t ctx = ngx_http_get_module_ctx(r->parent, my_module); ngx_buf_t b; ngx_chain_t *cl;

if (rc == NGX_OK && r->upstream && r->upstream->buffer.pos) {
    // 解析 Redis 响应(如 RESP 协议格式)
    parse_redis_response(r->upstream->buffer.pos, r->upstream->buffer.last, ctx);
}

// 将结果写入父响应体
b = ngx_create_temp_buf(r->parent->pool, 128);
ngx_snprintf(b->pos, 128, "Redis result: %V", &ctx->result);
b->last = ngx_snprintf(b->pos, 128, "Redis result: %V", &ctx->result);

cl = ngx_alloc_chain_link(r->parent->pool);
cl->buf = b;
cl->next = NULL;

r->parent->headers_out.status = NGX_HTTP_OK;
r->parent->headers_out.content_length_n = b->last - b->pos;
ngx_http_send_header(r->parent);
ngx_http_output_filter(r->parent, cl);

}

更推荐的实践路径:用 Lua + lua-resty-redis 替代纯 C Handler

手动编写 C 级 subrequest 回调逻辑复杂、易出内存错误、调试困难。生产环境更推荐:

  • 使用 nginx-lua-module(OpenResty)
  • 在 access_by_lua_block 或 content_by_lua_block 中调用 resty.redis
  • 其底层自动管理 cosocket 连接池和 epoll 事件,真正零阻塞
  • 代码简洁可读,支持 pipeline、自动重试、超时熔断等高级特性

例如:

local red = redis:new()<br>red:set_timeout(1000)<br>local ok, err = red:connect("127.0.0.1", 6379)<br>if not ok then ngx.exit(500) end<br>local res, err = red:get("mykey")

这段代码在 OpenResty 中是完全异步非阻塞的,且无需手动管理 subrequest 生命周期。

热门AI工具

更多
Seko
Seko Hot

一款AI视频创作工具,主要用于商汤科技推出的创编一体的AI短视频创作Agent,适合需要提升相关任务效率的用户。

超级麦吉

一款通过数字员工协作完成调研、数据分析与文档制作的AI办公平台。

立刻MV
立刻MV Hot

立刻MV是一款AI文本写作工具,AI 音乐视频(MV)创作工具。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

切问学术

切问学术是一款AI论文写作工具,复旦大学NLP团队推出的AI学术智能体。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

二狗PPT
二狗PPT Hot

一款AI演示文稿工具,主要用于专为中式职场打造的AI PPT生成工具,适合需要提升相关任务效率的用户。

WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

PixPix
PixPix Hot

PixPix是一款面向电商视觉生产的AI商品图生成工具。

相关专题

更多
nginx 重启
nginx 重启

nginx重启对于网站的运维来说是非常重要的,根据不同的需求,可以选择简单重启、平滑重启或定时重启等方式。本专题为大家提供nginx重启的相关的文章、下载、课程内容,供大家免费下载体验。

423

2023.07.27

nginx 配置详解
nginx 配置详解

Nginx的配置是指设置和调整Nginx服务器的行为和功能的过程。通过配置文件,可以定义虚拟主机、HTTP请求处理、反向代理、缓存和负载均衡等功能。Nginx的配置语法简洁而强大,允许管理员根据自己的需要进行灵活的调整。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

3887

2023.08.04

nginx配置详解
nginx配置详解

NGINX与其他服务类似,因为它具有以特定格式编写的基于文本的配置文件。本专题为大家提供nginx配置相关的文章,大家可以免费学习。

6685

2023.08.04

tomcat和nginx有哪些区别
tomcat和nginx有哪些区别

tomcat和nginx的区别:1、应用领域;2、性能;3、功能;4、配置;5、安全性;6、扩展性;7、部署复杂性;8、社区支持;9、成本;10、日志管理。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

601

2024.02.23

nginx报404怎么解决
nginx报404怎么解决

当访问 nginx 网页服务器时遇到 404 错误,表明服务器无法找到请求资源,可以通过以下步骤解决:1. 检查文件是否存在且路径正确;2. 检查文件权限并更改为 644 或 755;3. 检查 nginx 配置,确保根目录设置正确、没有冲突配置等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

1496

2024.07.09

Nginx报404错误解决方法
Nginx报404错误解决方法

解决方法:只需要加上这段配置:try_files $uri $uri/ /index.html;即可。想了解更多Nginx的相关内容,可以阅读本专题下面的文章。

3978

2024.08.07

nginx部署php项目教程汇总
nginx部署php项目教程汇总

本专题整合了nginx部署php项目教程汇总,阅读专题下面的文章了解更多详细内容。

122

2026.01.13

nginx配置文件详细教程
nginx配置文件详细教程

本专题整合了nginx配置文件相关教程详细汇总,阅读专题下面的文章了解更多详细内容。

537

2026.01.13

Vite 项目如何打包和部署
Vite 项目如何打包和部署

Vite项目打包部署专题汇集生产构建、产物预览、输出目录、资源路径、Nginx与GitHub Pages部署及常见白屏和路由404问题的已审核文章,帮助读者完成上线流程。

40

2026.10.28

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
phpEnv手册
phpEnv手册

共0课时 | 0人学习

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

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn