如何在Hyperf中使用协程上下文实现请求链路追踪_利用Context::set传递TraceId-php教程-PHP中文网

Context::set不能跨协程传递TraceId，因其仅作用于当前协程局部存储，协程切换后新协程无继承；需手动调用Context::copy()并在Co::create或go中显式传入上下文。

如何在hyperf中使用协程上下文实现请求链路追踪_利用context::set传递traceid

Hyperf协程上下文里Context::set为什么不能跨协程传递TraceId

因为Context::set写入的是当前协程的局部存储，协程切换（比如await一个go启动的子协程、或调用Co::sleep后恢复）时，新协程没有继承原上下文。常见现象是：主协程设了Context::set('trace_id', 'abc')，进到go(function () { var_dump(Context::get('trace_id')); })里就变成null。

根本原因不是Context用错了，而是没在子协程启动前显式拷贝上下文：

Hyperf默认不自动透传上下文，需手动调用Context::copy()
go()和defer()这类协程创建函数，必须包裹Context::copy($context)才能延续TraceId
HTTP中间件中设置的TraceId，只对当前协程有效；下游RPC、Redis、MySQL等异步操作若新开协程，必须主动透传

在HTTP中间件中正确注入并透传TraceId

别在__invoke里直接Context::set完就结束——那只是挂载到当前协程，后续异步调用全丢失。要配合Context::copy + go参数透传：

// app/Middleware/TraceMiddleware.php
public function process(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface
{
    $traceId = $request->getHeaderLine('X-Trace-ID') ?: uniqid('trc_', true);
    Context::set('trace_id', $traceId);
<pre class="brush:php;toolbar:false;">// 关键：把当前上下文传给后续协程
$context = Context::copy();

return $handler->handle($request)->withAddedHeader('X-Trace-ID', $traceId);

}

注意：这个$context变量本身不会自动生效，它只是快照。真正起作用的是你在调用go时显式传入：

写法正确：go(function () use ($context) { Context::set($context); /* 后续逻辑 */ });
写法错误：go(function () { /* 没传$context，Context::get('trace_id')为null */ });
Hyperf 3.0+ 推荐用Co::create替代go，支持直接传入上下文：Co::create($callback, $context)

Redis/MySQL/HTTP客户端调用时TraceId丢失怎么办

Hyperf封装的Redis、Db、HttpClient底层都可能开启新协程（尤其连接池复用、异步重试场景），导致TraceId断链。不能依赖“中间件设了就万事大吉”。

Hyperframes Creative

HyperFrames视频非动画创意指导，包括设计规范（frame.md/design.md）处理、配色、字体设计、旁白及节奏规划等。

下载

解决方案分两层：

对自定义协程任务：统一用Co::create($fn, Context::copy())启动
对组件调用：利用Hyperf的CoroutineInterceptor机制，在关键方法入口自动注入TraceId（例如重写Redis::execCommand，先Context::get('trace_id')再塞进命令日志）
更轻量做法：在config/autoload/tracer.php中启用OpenTracing扩展，它会自动拦截协程I/O并透传上下文，比手写Context::copy更可靠

示例（手动补日志）：

$redis = ApplicationContext::getContainer()->get(Redis::class);
$traceId = Context::get('trace_id', 'unknown');
$redis->set('key', 'val', ['trace_id' => $traceId]); // 假设你封装了带trace_id的调用