Workerman 5.2.3怎么使用异步Redis客户端

老丽吖_6734

老丽吖_6734

2026-10-22

690人浏览

原创

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 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-tools
redis-tools

按类别查找Redis命令、检测服务器连接、监控键数量和内存占用,支持离线速查表。

下载
  • 不要全局复用 $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。

相关文章

PHP速学视频免费教程(入门到精通)
PHP速学视频免费教程(入门到精通)

PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

更多
常用的数据库软件
常用的数据库软件

常用的数据库软件有MySQL、Oracle、SQL Server、PostgreSQL、MongoDB、Redis、Cassandra、Hadoop、Spark和Amazon DynamoDB。更多关于数据库软件的内容详情请看本专题下面的文章。php中文网欢迎大家前来学习。

2023.11.02

4569

19

内存数据库有哪些
内存数据库有哪些

内存数据库有Redis、Memcached、Apache Ignite、VoltDB、TimesTen、H2 Database、Aerospike、Oracle TimesTen In-Memory Database、SAP HANA和ache Cassandra。更多关于内存数据库相关问题,详情请看本专题下面的文章。php中文网欢迎大家前来学习。

2023.11.14

4115

11

mongodb和redis哪个读取速度快
mongodb和redis哪个读取速度快

redis 的读取速度比 mongodb 更快。原因包括:1. redis 使用简单的键值存储,而 mongodb 存储 json 格式的数据,需要解析和反序列化。2. redis 使用哈希表快速查找数据,而 mongodb 使用 b-tree 索引。因此,redis 在需要高性能读取操作的应用程序中是一个更好的选择。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.04.02

7692

6

redis怎么做缓存服务器
redis怎么做缓存服务器

redis 作为缓存服务器的答案:redis 是一款开源、高性能、分布式的键值存储,可作为缓存服务器使用。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.04.07

643

6

redis怎么解决数据一致性
redis怎么解决数据一致性

redis 提供了两种一致性模型,以维护副本数据一致性:强一致性 (sync) 确保写操作仅在复制到所有从节点后才完成;最终一致性 (async) 则在主节点上写操作后认为已完成,牺牲一致性换取性能。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.04.07

756

6

mysql和redis怎么保证双写一致性
mysql和redis怎么保证双写一致性

确保 mysql 和 redis 双写一致性的技术包括:1、事务性更新:同时更新 mysql 和 redis,保证一致性;2、主从复制:mysql 主服务器更改同步到 redis 从服务器;3、基于事件的更新:mysql 记录更改并发送到 redis等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.04.07

7642

6

redis缓存一般存些什么数据
redis缓存一般存些什么数据

redis缓存中存储的数据类型包括:字符串、哈希、列表、集合、有序集合、位图、地理空间数据和hyperloglog。这些数据类型适用于存储各种数据,从简单信息到复杂对象和地理位置。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.04.07

1160

6

redis的8种数据类型有哪些
redis的8种数据类型有哪些

redis 提供 8 种数据类型:字符串(文本、数字、二进制)、哈希(键值对)、列表(有序集合)、集合(无序唯一元素)、有序集合(按分数排序)、地理空间(地理位置)、hyperloglog(估计大数据基数)和位图(位序列存储)。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.04.07

1136

6

redis主要作用有哪些
redis主要作用有哪些

redis 的主要作用包括:1. 缓存数据,提高访问速度;2. 充当消息队列,实现消息传递;3. 存储各种数据类型,如字符串、散列和集合;4. 管理会话信息,确保可靠性和可用性;5. 限制请求速率,防止服务器超载等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.04.07

6658

6

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
phpEnv手册
phpEnv手册

共0课时 | 0人学习