您好,欢迎访问一九零五行业门户网

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

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. lpushlpush 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.blpopblpop key [key ...] timeoutblpop是列表的阻塞式(blocking)弹出原语。它是lpop命令的阻塞版本,当给定列表内没有任何元素可供弹出的时候,连接将被blpop命令阻塞,直到等待超时或发现可弹出元素为止。当给定多个key参数时,按参数key的先后顺序依次检查各个列表,弹出第一个非空列表的头元素。
以上就介绍了php 实现 redis 队列,等待有新消息入列,包括了方面的内容,希望对php教程有兴趣的朋友有所帮助。
其它类似信息

推荐信息