php - 需要有关 BLPOP Predis PHP 的支持

Question

我正在使用 BLPOP 构建聊天消息系统长轮询。我使用 Predis PHP。当我运行 test/get -> 它以 30 秒超时运行 okie。

在运行 test/get 时，我尝试通过 test/push 推送数据，但它有问题。推送不会立即执行，除非 test/get 完成。 test/push 需要 30 秒。

我使用命令行推送数据:RPUSH message:test hello -> 它立即执行，非常好。

require './vendor/autoload.php';

class Test extends CI_Controller {
public $keyChat = 'message:test';
public function __construct() {
    parent::__construct();
}

public function push() {
    $redis = new Predis\Client(['host' => 'localhost','port' => 6379]);
    $redis->rpush($this->keyChat, 'hello you');
    $redis->expire($this->keyChat, 3600);
    echo "send message success";
}

    public function get() {
        $redis = new Predis\Client(['host' => '127.0.0.1','port' =>   6379]);
        $res = $redis->blpop($this->keyChat, 30);
        var_dump($res);
    }
}

Answer 1

如果你查看了BLPOP文档，你会发现这是一个阻塞操作，我想你正试图通过实例化另一个Redis客户端来推送，所以BLPOP可以找到值并返回它。

30 秒问题，是 BLPOP 解锁的超时时间，如下所示:

$redis->blpop($this->keyChat, 30);

当你从命令行推送它时它起作用的原因是它是一个不同的连接，我不确定 Predis 的情况，但我认为当你尝试 RPUSH 时返回相同的连接 ，这就是它给你这个问题的原因。