nginx c模块中可通过异步subrequest机制实现微服务并行调用：需分配独立upstream配置、自定义完成回调、原子计数器管理生命周期，并注意请求体透传、超时隔离与内存安全。
在 Nginx C 模块中利用 subrequest 机制实现并行调用多个微服务接口，核心在于绕过 Nginx 默认的串行 subrequest 执行模型，借助异步事件驱动和共享上下文管理，让多个子请求真正并发发起并等待响应。这并非直接“开多个线程”，而是基于 Nginx 的 event loop 和 upstream 机制，在单线程内高效调度 I/O。
理解 subrequest 的本质与限制
Nginx 的 ngx_http_subrequest 默认是同步语义（逻辑上串行），但底层实际是异步的：它把子请求挂入当前请求的子请求链表，注册回调，并立即返回，不阻塞主请求处理。真正的限制来自两点：
- 所有 subrequest 共享父请求的
ngx_http_request_t*，而 upstream 连接、buffer 分配、超时控制等都绑定在该结构上； - 若多个 subrequest 目标相同 upstream（如同一 upstream 块），Nginx 默认启用连接复用和队列排队，容易造成隐式串行化。
实现并行的关键改造点
要达成实质并行，需在 C 模块中主动干预以下环节：
-
为每个 subrequest 分配独立 upstream 配置：避免共用 upstream 块导致的连接池竞争。可动态构造
ngx_http_upstream_conf_t或使用不同命名的 upstream 块（如upstream svc_a { ... },upstream svc_b { ... }）； -
显式控制 subrequest 生命周期：调用
ngx_http_subrequest后，不依赖默认的 post_subrequest 回调链，而是统一用一个自定义的subrequest_done_handler收集完成状态； -
引入轻量级计数器与 completion flag：在父请求的
ctx中维护pending_count和results[3]数组，每次 subrequest 完成时原子减计数，最后当计数归零时触发合并响应逻辑； -
禁用不必要的 body 缓存与重写：对微服务 JSON 接口，设置
r->request_body_no_buffering = 1、conf->preserve_response = 1（若使用 echo module 风格封装），减少内存拷贝。
典型代码结构示意
在 handler 函数中：
// 1. 创建 ctx 并初始化 pending_count = 3
my_ctx_t *ctx = ngx_pcalloc(r->pool, sizeof(my_ctx_t));
ctx->pending_count = 3;
ngx_http_set_ctx(r, ctx, my_module);
// 2. 并发发起三个 subrequest（目标不同 upstream）
ngx_http_subrequest(r, &uri_a, &args, &sr_a, NULL, NGX_HTTP_SUBREQUEST_IN_MEMORY);
ngx_http_subrequest(r, &uri_b, &args, &sr_b, NULL, NGX_HTTP_SUBREQUEST_IN_MEMORY);
ngx_http_subrequest(r, &uri_c, &args, &sr_c, NULL, NGX_HTTP_SUBREQUEST_IN_MEMORY);
// 3. 每个 subrequest 的 callback 中：
static void my_subrequest_callback(ngx_http_request_t *r, void *data, ngx_int_t rc) {
my_ctx_t *ctx = ngx_http_get_module_ctx(r->parent, my_module);
// 解析响应体、存入 ctx->results[i]，然后：
if (ngx_atomic_fetch_add(&ctx->pending_count, -1) == 1) {
finalize_and_reply(r->parent); // 所有完成，生成聚合响应
}
}
注意事项与避坑点
实际开发中易忽略但关键的问题：
-
subrequest 不继承 parent 的 request body：若需透传 POST 数据，必须手动读取
r->request_body->bufs并在 subrequest 中通过ngx_http_request_body_t重新构造； -
超时需单独配置：每个 subrequest 的
conf->read_timeout、send_timeout应独立设置，否则共用父请求 timeout 会导致早夭； - 错误码聚合策略：建议采用“任一失败即整体失败”或“按业务字段分级容错”，避免简单忽略 5xx；
-
内存生命周期严格匹配：subrequest 使用的 pool 来自 parent，但 response body buffer 若未及时 copy，可能在 parent 结束时被释放 —— 必须用
ngx_pmemdup或ngx_copy到持久 buffer。
不复杂但容易忽略。关键是把 subrequest 当作轻量异步任务调度单元，而非传统 HTTP 子调用。
