欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  后端开发

php 实现 redis 队列,等待有新消息入列

程序员文章站 2022-05-14 14:26:49
...
1. 消息入列代码, t1.php:

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

while(1){
        try{
                $value = "value_".time();
                $redis->LPUSH('key1', $value);
                echo $value."\n";
                sleep(rand(1, 3));
        }catch(Exception $e){
                echo $e->getMessage(). "\n";
                exit;
        }
}

2. 消息出列代码:

$redis = new Redis();
$redis->pconnect('127.0.0.1', 6379);

while(1){
        try{
                $value = $redis->BLPOP('key1', 20);
                if(!empty($value)){
                        var_export( $value )."\n";
                }

        }catch(Exception $e){
                echo $e->getMessage(). "\n";
                exit;
        }
}

3. redis用到的函数讲解

1. connect 链接redis服务
2. pconnect不会主动关闭的链接
3. LPUSH
LPUSH key value [value ...]
将一个或多个值value插入到列表key的表头。

如果有多个value值,那么各个value值按从左到右的顺序依次插入到表头:比如对一个空列表(mylist)执行LPUSH mylist a b c,则结果列表为c b a,等同于执行执行命令LPUSH mylist a、LPUSH mylist b、LPUSH mylist c。

如果key不存在,一个空列表会被创建并执行LPUSH操作。

当key存在但不是列表类型时,返回一个错误。

时间复杂度:
O(1)
返回值:
执行LPUSH命令后,列表的长度。
 

注解:在Redis 2.4版本以前的LPUSH命令,都只接受单个value值。

4.BLPOP
BLPOP key [key ...] timeout
BLPOP是列表的阻塞式(blocking)弹出原语。

它是LPOP命令的阻塞版本,当给定列表内没有任何元素可供弹出的时候,连接将被BLPOP命令阻塞,直到等待超时或发现可弹出元素为止。

当给定多个key参数时,按参数key的先后顺序依次检查各个列表,弹出第一个非空列表的头元素。

以上就介绍了php 实现 redis 队列,等待有新消息入列,包括了方面的内容,希望对PHP教程有兴趣的朋友有所帮助。