必须为每个租户建立独立协程上下文以防止数据泄露:在onRequest入口通过协程ID绑定租户标识;数据库连接池需按租户动态隔离;全局状态须重置并销毁单例;日志与监控需按租户打标和路由。

在Swoole协程环境下,多个租户请求共用同一进程和协程调度器,若未做隔离,租户间可能共享全局变量、DB连接、缓存上下文甚至日志句柄,导致数据泄露或状态污染。必须让每个租户拥有独立的协程生命周期上下文。
基于协程ID绑定租户上下文
第一步:在HTTP请求入口(如 onRequest 回调)中解析租户标识(域名/请求头/路径前缀),并将其写入当前协程的上下文。
使用 Swoole\Coroutine::getuid() 获取当前协程唯一ID,再通过 spl_object_hash($server) 或自定义 ContextManager::set($cid, $tenantId) 将租户ID映射存储——【必须在协程刚启动时立即绑定,延迟绑定会导致中间件或DB初始化使用默认租户】。
这一步操作起来很简单,直接把 tenant_id 存进 ContextManager::set(get_current_cid(), $tenant_id) 就行。
租户级数据库连接池隔离
方法一:按租户名动态生成 PDO 连接池实例
在 ContextManager::getTenantId() 可获取当前协程租户ID后,拼接为 pool_key = 'db_' . $tenant_id;再从 PoolManager::get($pool_key) 获取专属连接池。连接池初始化时,配置项(host/user/database)需从租户元数据表中实时查出——【不能复用主库连接池,否则不同租户会复用同一连接,事务和 SET SESSION 变量会相互覆盖】。
方法二:使用 Swoole\Table 预分配租户连接槽位
启动时创建 Swoole\Table,字段含 tenant_id、conn_count、max_conn;每次 getConnection() 前先检查该租户槽位是否已达上限,超限则 throw new TenantConnectionLimitException()。
Swoole 6.1.1 是一个专为 PHP 设计的高性能事件驱动并发网络引擎。作为稳定版,它修复了编译时对 zlib 依赖的缺失及 curl 模块的内存安全风险。该版本支持协程、多线程与多进程架构,内置 TCP/HTTP/WebSocket 服务器,能够显著提升 PHP 在微服务、实时通信等场景下的执行效率与并发能力。
协程内全局状态重置机制
① 在 onRequest 开始时,调用 TenantContext::reset() 清空静态属性、单例对象引用、DI容器绑定。
② 对 Laravel/Symfony 等框架,需 patch Container::getInstance()->forgetInstance('*'),否则 App::make('cache') 会返回上一个租户的 Redis 实例。
③ 所有租户敏感类(如 TenantAuth、TenantConfig)必须声明为 non-singleton,且构造函数强制依赖 TenantContext::current()。
这一步不可跳过。若只清空变量不销毁对象,__destruct() 不会被触发,Redis 连接、文件句柄等资源持续泄漏。
日志与监控打标隔离
替换默认 Logger 实现,在 write() 方法开头自动注入 [tenant:xxx] 前缀,并将日志通道按 tenant_id 分路由到不同文件或 Kafka topic。
使用 Swoole\Coroutine::defer() 注册协程退出钩子,在钩子中调用 Metrics::flush($tenant_id) 上报本次请求的 SQL 耗时、缓存命中率等指标。
注意:不要在 defer 中执行阻塞 IO,否则会卡住协程调度器。

















