php 实现 redis 队列,等待有新消息入列
2016-01-20 18:52
716 查看
1. 消息入列代码, t1.php:
2. 消息出列代码:
3. redis用到的函数讲解
$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的先后顺序依次检查各个列表,弹出第一个非空列表的头元素。
相关文章推荐
- 负载均衡之Nginx+tomcat+redis实现session共享的负载均衡
- 2.Redis常用命令
- Redis企业集群工具RLEC
- Redis 哈希(Hash)
- redis list
- Redis Key 过期策略
- redis键空间通知消息详解和例子
- linux服务器查看redis版本:
- Redis学习记录之Sentinel(二十九)
- Redis学习记录之Replication(二十八)
- Redis学习记录之集群教程(二十七)
- Redis 字符串(String)
- 基于 redis实现含有冻结时间的mq队列
- linux下redis安装
- 使用AOP 实现Redis缓存注解,支持SPEL(转)
- Redis添加访问密码
- ABP中使用Redis Cache(1)
- Ubuntu安装redis和php5-redis扩展
- Redis "MISCONF Redis is configured to save RDB snapshots, but is currently not able to persist on di
- Redis学习记录之集群规范(二十六)