定时消费队列 演示swoole_timer_tick 消费redis 的队列

黄振国

原文地址:  https://segmentfault.com/a/1190000007527323


##入队操作##CLI模式执行 /usr/local/php/bin/php /data/www/www.54xinren.com/swooleDemo1.php

<?php
$redis=new Redis();

$redis->connect('127.0.0.1',6379);

//$redis->auth('tb');

for($i=0;$i<10;$i++){
  $res[]=$redis->lpush('lists',$i);
}
$len = $redis->llen('lists');   //显示队列长度
$list = $redis->lrange('lists', 0, $len);   //显示队列

var_dump($res);var_dump($list);

黄振国

##出队操作##CLI模式 /usr/local/php/bin/php /data/www/www.54xinren.com/swooleDemo2.php
<?php

class Customer
{
    private static $_instance;
    private static $host;
    private static $port;
    private static $password;
    private static $list;
    private static $redisObj;


    private function __construct()
    {

        $redis = new Redis();
        $redis->connect(self::$host, self::$port);
        $redis->auth = self::$password;
        self::$_instance = $this;
        self::$redisObj = $redis;
        return self::$_instance;
    }

    public static function instance(array $param)
    {
        self::$host = $param['host'];
        self::$port = $param['port'];
        self::$password = $param['password'];
        self::$list = $param['list'];
        if (!empty(self::$_instance)) {
            return self::$_instance;
        } else {
            return new self();
        }
    }

    public function getMsg()
    {
        return self::$redisObj->rPop(self::$list);
    }
}

//使用swoole的间隔出队
swoole_timer_tick('500',function(){
    $params['host']='127.0.0.1';
    $params['port']=6379;
    //$params['password']='tb';
    $params['list']='lists';
    $s=Customer::instance($params);
    var_dump( $s->getMsg());
});