Laravel10x怎样使用phpredis发布订阅-php教程-PHP中文网

确认phpredis已启用且被laravel识别：运行php -m | grep redis有输出；config/database.php中'redis.client'设为'phpredis'；.env中redis_client=phpredis；调用redis::connection()返回原生redis实例。

laravel10x怎样使用phpredis发布订阅

确认 php redis 扩展已启用且被 Laravel 识别

Laravel 默认优先使用 phpredis（而非 predis），但前提是 PHP 环境中已安装并启用该扩展。运行 php -m | grep redis 确认输出含 redis；若无，需用 pecl install redis 安装并确保 extension=redis.so 在 php.ini 中启用。

检查 config/database.php 中 redis.client 值是否为 'phpredis'（不是字符串 "predis"）：

 'redis' => [
    'client' => env('REDIS_CLIENT', 'phpredis'),
    // ...
]

如果误设为 predis，即使系统有 phpredis，Laravel 也会强制走 Composer 包逻辑，失去原生性能和部分方法支持（比如 psubscribe 的参数签名差异）。

直接调用 phpredis 原生命令实现 Pub/Sub

不经过 Laravel 广播系统时，可直接在 Artisan 命令或服务中使用 Redis Facade 或底层连接对象。注意：Laravel 的 Redis::connection() 返回的是 Predis\Client 实例（当 client=predis）或 Redis 实例（当 client=phpredis），二者 API 不兼容。

为确保调用的是 phpredis 原生方法（如 subscribe、psubscribe），推荐显式获取底层连接：

用 app('redis')->connection()->client 可能返回 Predis\Client，不可靠
应改用 app('redis')->connection()->getConnection()->getClient() —— 这个 get_client() 方法在 phpredis 模式下返回原生 Redis 对象

示例（发布端）：

 $redis = app('redis')->connection()->getConnection()->getClient();
$redis->publish('order.created', json_encode(['id' => 123, 'user_id' => 456]));

示例（订阅端，需常驻运行）：

 $redis = app('redis')->connection()->getConnection()->getClient();
$redis->subscribe(['order.created', 'user.login'], function ($redis, $channel, $message) {
    $data = json_decode($message, true);
    \Log::info("Received on {$channel}: ", $data);
});

⚠️ 常见坑：subscribe 是阻塞调用，必须配合 set_time_limit(0) 和后台进程管理（如 nohup php artisan sub:orders &），否则超时退出。

Laravel Creem Agent

Creem 支付商店助理 — 查询订阅、客户、交易、产品，执行心跳检查，管理本地 Laravel支付商店。

下载

用 psubscribe 匹配动态频道名时的通配符限制

phpredis 的 psubscribe 支持 * 和 ?，但不支持 ** 或正则。例如 order.* 可匹配 order.created、order.shipped；但 order.*.failed 不合法 —— phpredis 要求通配符只能出现在末尾。

正确写法：

order.* ✅
user:*:notify ❌（中间有冒号+星号，phpredis 不识别）
user.* ✅（只允许尾部通配）

回调函数签名也不同：psubscribe 的闭包接收四个参数：($redis, $pattern, $channel, $message)，而 subscribe 是 ($redis, $channel, $message)。漏掉 $pattern 会导致参数错位、$channel 变成 null。

与 Laravel 广播系统共存时的 database 隔离问题

如果你同时用 phpredis 手动 publish 和 Laravel 的 ShouldBroadcast 事件广播，必须确保它们操作的是同一个 Redis database。否则消息发出去，queue:work 里的广播监听器收不到。

检查点：

config/database.php 中 redis.default.database 值（比如 0）
config/broadcasting.php 中 redis.options.database 必须一致（默认是 null，会 fallback 到 default 的 database）
不要在 .env 里设 REDIS_DB=0 却在 config/broadcasting.php 里硬编码 'database' => 1