Swoole协程上下文管理应该怎么实现

在Swoole协程里，用全局变量、静态属性或者$_SERVER这类超全局数组，是引发数据错乱的“重灾区”。两个并发请求一到，后一个很容易就把前一个的用户ID、trace_id给覆盖了，结果就是日志对不上、鉴权失败、链路追踪断掉——这些坑，做高并发服务的应该都不陌生。

所以，为每个协程隔离出一块专属的数据存储空间，是必须要做好的基本功。说白了，就是要用Co::getContext()来管理上下文。

原生Swoole协程上下文基础用法

这一步其实不复杂，核心就是拿到当前协程的“专属容器”，然后往里放东西、取东西。

第一步：在协程启动后，立刻获取上下文对象。

直接调Co::getContext()就行，不传参数它默认返回当前协程上下文。有一点必须注意：不能在onStart、onWorkerStart这类非协程环境里调用，否则会报Warning: Coroutine is not running。

第二步：往这个容器里存键值对。

写法很灵活，可以用$ctx->set('user_id', 1001)，或者直接像数组一样赋值$ctx['user_id'] = 1001。一个小建议：键名别用纯数字，否则取值时可能返回null，容易让人摸不着头脑。

第三步：在别的地方读取数据。

在后续的任意协程里（包括用go()创建的子协程），再次调Co::getContext()->get('user_id')就能拿到值了。这里有个继承规则：父协程设的值，子协程默认能读到，但子协程改了也不会影响父协程——这种设计很合理，能避免很多意外的副作用。

ThinkPHP集成场景下的安全写法

ThinkPHP本身对协程是“无感知”的，如果还按照传统思路直接调Request::instance()，拿到的往往是上一个协程缓存的单例实例——这在高并发下就是数据串改的根源。

方法一：利用think-swoole封装的Context类。

可以在app\middleware\InitContext.php中间件里写：Context::set('request', $request);。之后在控制器里统一用app('request')来获取请求对象，而不是Request::instance()。这里要特别强调一点：如果还继续用Request::instance()，那上下文隔离就等于白做了。

方法二：手动将Request绑定到协程上下文。

这种方法更直接，在Swoole Http Server的onRequest回调里操作：先把当前请求对象存到Co::getContext()里，比如$ctx->set('tp_request', $request)。后续在控制器里，通过Co::getContext()->get('tp_request')来取，保证每次拿到的都是本协程专属的实例，不会混淆。

多实例类的安全上下文封装

当一个类需要支持多个对象同时运行——比如多个Redis连接池管理器——就不能共用一个键名来存数据了，否则肯定会互相覆盖。这个问题的解法也很清晰。

① 获取对象的唯一标识。

用spl_object_id($this)可以生成一个当前进程内恒定不变的整数ID，这个ID就是对象的“身份证”。

② 构建嵌套的上下文结构。

代码里要先检查$ctx[spl_object_id($this)]是否存在，不存在的话就初始化成一个new ArrayObject()或者空数组。这么做能避免直接写$ctx[$oid]['count']++时触发undefined index警告，让代码更健壮。

③ 封装成可复用的Trait。

最优雅的方式是定义一个trait CoroutineContextAware，里面实现一个protected function getContext(): ArrayObject方法。各业务类直接use这个trait后，用$this->getContext()->user_id = 123来操作上下文，既清晰又安全。

资源自动清理与defer配合

协程结束时，上下文会被自动销毁，但打开的文件句柄、数据库连接、临时缓存这些“外部资源”，不会跟着自动释放。这部分必须手动处理。

最佳的实践是：在协程入口处就注册好清理逻辑。

举个例子，用Co::defer(function () { ... })来注册一个回调，里面检查并关闭文件句柄：if ($fp && is_resource($fp)) { fclose($fp); }。

defer函数的优点是，无论协程是正常退出还是因为异常终止，它都会执行。有两件事需要留心：一是不要在defer里再创建新协程，这可能导致死循环或内存泄漏；二是设置上下文后要立即注册defer，顺序不能搞反，否则很可能$ctx还未初始化，清理逻辑就失效了。