php使用redis队列操作一例

2. $redis = new Redis();
3. $redis->connect('127.0.0.1',6379);
4. while(True){
5. try{
6. $value = 'value_'.date('Y-m-d H:i:s');
7. $redis->LPUSH('key1',$value);
8. sleep(rand()%3);
9. echo $value."\n";
10. }catch(Exception $e){
11. echo $e->getMessage()."\n";
12. }
13. }
14. ?>

复制代码

例2，出队操作：

2. $redis = new Redis();
3. $redis->pconnect('127.0.0.1',6379);
4. while(True){
5. try{
6. echo $redis->LPOP('key1')."\n";
7. }catch(Exception $e){
8. echo $e->getMessage()."\n";
9. }
10. sleep(rand()%3);
11. }
12. ?>

复制代码