发布订阅

简介

Redis 的列表类型键可以用来实现队列,并且支持阻塞式读取,所以 Redis 能够非常容易的实现一个高性能的优先队列。同时在更高层面上,Redis 还支持“发布/订阅”的消息模式,可以基于此构建一个聊天系统。

发布示例

发布(Publish)即将消息发布到频道中。示例代码:

// 发送消息
Redis::publish('chan-1', 'Hello, World!');
// 发送消息
Redis::publish('chan-2', 'Hello, Swoft!');

参数说明:

  • $channel:目标频道
  • $message:消息内容

订阅示例

订阅(Subscribe)即从频道中接收消息。示例代码:

function f($redis, $chan, $msg) {
    switch($chan) {
        case 'chan-1':
            // TODO:
            break;

        case 'chan-2':
            // TODO:
            break;

        case 'chan-2':
            // TODO:
            break;
    }
}

// 订阅 3 个频道
Redis::subscribe(['chan-1', 'chan-2', 'chan-3'], 'f');

参数说明:

  • $channels:目标频道。字符串数组
  • $callback:回调函数,接收 3 个参数
    • $redis:Redis 实例
    • $chan:频道名称
    • $msg:接收消息内容

匹配模式

使用 psubscribe 方法支持以通配符的方式订阅频道,可以用来获取所有所有频道上的消息。

Redis::psubscribe(['*'], function ($redis, $pattern, $chan, $msg) {
    echo "Pattern: $pattern\n";
    echo "Channel: $chan\n";
    echo "Payload: $msg\n";
});

Redis::psubscribe(['users.*'], function ($redis, $pattern, $chan, $msg) {
   echo "Pattern: $pattern\n";
   echo "Channel: $chan\n";
   echo "Payload: $msg\n";
});

参数说明:

  • $patterns:匹配规则数组
  • $callback:回调函数,接收 4 个参数
    • $redis:Redis 实例
    • $pattern:匹配规则
    • $chan:频道名称
    • $msg:接收消息内容

Socket 断连问题

由于订阅功能源自原生 phredis,使用过程中可能会有 Socket 断连问题,所以在开启发布订阅前应加大 PHP 配置中 default_socket_timeout 的值或设置为 -1(永不超时)。该值默认为 60 秒。

ini_set('default_socket_timeout', -1);

Redis::psubscribe(['users.*'], function ($redis, $pattern, $chan, $msg) {
    echo "Pattern: $pattern\n";
    echo "Channel: $chan\n";
    echo "Payload: $msg\n";
});

关于 default_socket_timeout,请参考:PHP: 运行时配置 - Manual

上一页
下一页