您当前的位置： 首页 > 慢生活 > 程序人生 网站首页程序人生

workerman-redis-blPop, brPop

发布时间：2021-12-28 21:44:47编辑：雪饮阅读（）

 blPop, brPop

移出并获取列表的第一个元素/最后一个元素， 如果列表没有元素会阻塞列表直到等待超时或发现可弹出元素为止。
先看blPop
實例：
<?php
use Workerman\Worker;
use Workerman\Redis\Client;
use Workerman\Connection\TcpConnection;
use Workerman\Timer;
require_once __DIR__ . '/vendor/autoload.php';
 
$worker = new Worker('http://0.0.0.0:6161');
global  $offset;
$worker->onWorkerStart = function() {
    global  $offset;
    $offset=0;
};
 
$worker->onMessage = function(TcpConnection $connection, $data) {
    $redis = new Client('redis://127.0.0.1:6379');
    $redis2 = new Client('redis://127.0.0.1:6379');
 
    $redis->blPop(['key1', 'key2'], 10, function ($r) {
        var_export($r); // array ( 0 => 'key1',1 => 'a')
    });
 
 
    Timer::add(1, function () use ($redis2) {
        $redis2->lpush('key1', 'a');
    });
};
 
Worker::runAll();
實例運行并有http請求訪問時：
[root@localhost www.fpm.com]# /usr/local/php734/bin/php channelServer.php start
Workerman[channelServer.php] start in DEBUG mode
----------------------------------------- WORKERMAN -----------------------------------------
Workerman version:4.0.22          PHP version:7.3.4
------------------------------------------ WORKERS ------------------------------------------
proto   user            worker          listen                 processes    status
tcp     root            none            http://0.0.0.0:6161    1             [OK]
---------------------------------------------------------------------------------------------
Press Ctrl+C to stop. Start success.
array (
  0 => 'key1',
  1 => 'a',
)
接下來再來看看brpop
實例：
<?php
use Workerman\Worker;
use Workerman\Redis\Client;
use Workerman\Connection\TcpConnection;
use Workerman\Timer;
require_once __DIR__ . '/vendor/autoload.php';
 
$worker = new Worker('http://0.0.0.0:6161');
global  $offset;
$worker->onWorkerStart = function() {
    global  $offset;
    $offset=0;
};
 
$worker->onMessage = function(TcpConnection $connection, $data) {
    $redis = new Client('redis://127.0.0.1:6379');
    $redis2 = new Client('redis://127.0.0.1:6379');
 
    $redis->brPop(['key1', 'key2'], 10, function ($r) {
        var_export($r); // array ( 0 => 'key1',1 => 'a')
    });
 
 
    Timer::add(1, function () use ($redis2) {
        $redis2->lpush('key1', 'a');
    });
};
 
Worker::runAll();
實例運行并有hettp客戶端請求時：
[root@localhost www.fpm.com]# /usr/local/php734/bin/php channelServer.php start
Workerman[channelServer.php] start in DEBUG mode
----------------------------------------- WORKERMAN -----------------------------------------
Workerman version:4.0.22          PHP version:7.3.4
------------------------------------------ WORKERS ------------------------------------------
proto   user            worker          listen                 processes    status
tcp     root            none            http://0.0.0.0:6161    1             [OK]
---------------------------------------------------------------------------------------------
Press Ctrl+C to stop. Start success.
array (
  0 => 'key1',
  1 => 'a',
)
 
其實看起來差不多啦，可能是因爲目前list列表數據比較少的原因吧，redis的這個知識點，不是很熟的。。。。