Swoole怎么在协程中使用Redis的发布订阅-Swoole-PHP中文网

Swoole怎么在协程中使用Redis的发布订阅

穿越時空

发布： 2025-09-27 15:42:02

原创

881人浏览过

答案：在Swoole协程中使用Redis发布订阅需采用Swoole\Coroutine\Redis客户端。1. 订阅操作应在独立协程中进行，通过subscribe方法监听频道，连接进入订阅状态后不可执行其他命令，使用recv()接收消息并解析类型、频道和数据。2. 发布消息可通过另一协程或请求触发，调用publish方法发送。3. 建议订阅与发布使用独立连接，避免冲突；将订阅逻辑置于独立worker中提升稳定性；实现断线重连机制；不在事件回调中直接订阅，确保协程调度正常。

swoole怎么在协程中使用redis的发布订阅

在 Swoole 协程中使用 Redis 的发布订阅功能，不能直接使用传统的同步 Redis 客户端，因为会阻塞协程调度。必须使用 Swoole 提供的 协程版 Redis 客户端（Swoole\Coroutine\Redis），并采用非阻塞方式处理订阅逻辑。

1. 使用 Swoole 协程 Redis 订阅消息

在协程环境中，可以通过 subscribe 或 psubscribe 方法监听频道。由于这些操作是长连接行为，需确保在独立协程中运行，避免阻塞其他协程。

注意：一旦调用 subscribe，该连接进入订阅状态，不能再执行普通命令。

示例代码：

小绿鲸英文文献阅读器

英文文献阅读器，专注提高SCI阅读效率

199

查看详情

$server = new Swoole\WebSocket\Server("0.0.0.0", 9502);

$server->on('start', function () {
    go(function () {
        $redis = new Swoole\Coroutine\Redis();
        $redis->connect('127.0.0.1', 6379);

        // 订阅指定频道
        $redis->subscribe(['channel1']);

        while (true) {
            $msg = $redis->recv(); // 接收推送消息
            if ($msg && $msg[0] === 'message') {
                [$type, $channel, $data] = $msg;
                echo "收到消息 [$channel]: $data\n";
            }
        }
    });
});

$server->start();

2. 发布消息到 Redis 频道

发布消息可以放在另一个协程或客户端请求中进行，使用同一个 Redis 实例或新连接均可。

示例：通过 CLI 脚本或 HTTP 请求触发发布

go(function () {
    $redis = new Swoole\Coroutine\Redis();
    if (!$redis->connect('127.0.0.1', 6379)) {
        echo "无法连接 Redis\n";
        return;
    }

    $result = $redis->publish('channel1', 'Hello from Swoole');
    echo "发送了 $result 个接收者\n";
});