Workerman 5.2.3 异步 Redis 需满足环境(Workerman≥5.0、workerman/redis≥2.0.0、Revolt、PHP≥8.1)和写法(每进程独立 Client、onMessage 中 await 调用)两个前提,否则会报 Fiber 或未定义函数错误。

Workerman 5.2.3 使用异步 Redis 客户端,核心是用 workerman/redis 组件配合协程运行时(Revolt),不是直接用 PHP 的 redis 扩展同步调用。它支持真正的非阻塞操作,但需满足环境和写法两个前提。
✅ 环境准备:必须全部满足
- Workerman ≥ 5.0(你用的 5.2.3 符合)
-
workerman/redis≥ 2.0.0(推荐^2.0.3或更高) - 已安装
revolt/event-loop ^1.0 - PHP ≥ 8.1(需支持 Fibers)
- 启动脚本顶部已引入自动加载:
require_once __DIR__ . '/vendor/autoload.php';
缺任何一项,await $redis->get() 会报错(如 Fiber not running 或 Call to undefined function Revolt\...),这不是代码问题,而是环境没配好。
✅ 协程用法(推荐):在 onMessage 中直接 await
这是最简洁、高效的方式,适用于 Workerman 5.x + 协程环境:
use Workerman\Worker;
use Workerman\Redis\Client;
use Workerman\Connection\TcpConnection;
$worker = new Worker('http://0.0.0.0:6161');
$worker->onWorkerStart = function () {
// 全局单例连接池管理,每个 Worker 进程一个 Client 实例
global $redis;
$redis = new Client('redis://127.0.0.1:6379');
};
$worker->onMessage = function (TcpConnection $connection, $data) {
global $redis;
try {
// ✅ 直接 await,不阻塞其他连接
$result = $redis->get('user:1001');
$connection->send("Redis value: " . ($result ?: 'null'));
// 可链式调用,比如 set + get
$redis->set('test:key', 'hello')->wait(); // wait() 仅用于调试,生产中应全 await
$val = $redis->get('test:key');
$connection->send("Got back: $val");
} catch (\Throwable $e) {
error_log('Redis error: ' . $e->getMessage());
$connection->send('Redis failed');
}
};
Worker::runAll();⚠️ 注意:
- 不要全局复用
$redis实例跨协程(比如在定时器里混用),Client实例本身是协程安全的,但不能跨进程共享连接;- 每个 Worker 进程应在
onWorkerStart中创建自己的$redis,避免多进程争抢连接;wait()是调试辅助方法,生产环境请统一用await。
✅ 回调用法(兼容旧习惯,不推荐新项目)
如果你暂时不想改写法,也可用回调风格(不依赖协程):
$redis->get('key', function ($result, $redis) use ($connection) {
$connection->send($result ?: 'not found');
});但这种方式无法享受协程的串行可读性,也不利于错误统一处理,适合过渡期或简单场景。
❌ 常见错误 & 规避方式
-
混用同步操作:如在
onMessage里调用sleep()、file_get_contents()或原生new Redis()->get(),会卡死整个 Worker 进程; -
全局单例 Redis 连接跨进程使用:多个 Worker 进程共用一个
$redis实例 → BRPOP 冲突、连接混乱; -
BRPOP 误用为轮询:异步客户端仍建议用
BRPOP消费队列,但必须在独立进程+独立连接下执行,超时设1秒; -
忽略错误处理:
$redis->get()失败不会抛异常,而是返回null或触发回调的$error参数,务必检查。
不复杂但容易忽略。关键就三点:环境对、实例分进程、调用走 await。


















