redis实现队列操作

<?php
class Task{
//一个成员
protected $redis;
/**
* 初始化
*/
public function __construct(){
$this->redis = new \Redis();
$this->redis->connect('127.0.0.1' , '6379');
}

/**
* 创建任务
* @return [type] [description]
*/
public function createTask($data = array()){
//处理数据
//加入队列，注意task是一个唯一的键，value可以为json数据，
//lpush是redis 的列表
$this->redis->lpush('task' , json_encode($data));
//如果有需要可以设置key过期时间，过期时间为30秒
//$this->redis->expire('user' , 30);
}

/**
* 执行任务
* @return [type] [description]
*/
public function execTask(){
//处理队列
//统计长度
$length = $this->redis->llen('task');
for($i = 0 ; $i < $length ; $i ++){
//取出最后一个
$item = $this->redis->rpop('task');
//处理一系列的逻辑
var_dump($item);
//可以选择睡眠一秒
//sleep(1);
}
}
}

<?php
require_once 'task.php';
$task = new \Task();
$task->createTask(array('uid' => 1 , 'content' => '谢谢你的花'));
$task->createTask(array('uid' => 2 , 'content' => '我来看看'));

<?php
require_once 'task.php';
$task = new \Task();
$task->execTask();

string(52) "{"uid":1,"content":"\u8c22\u8c22\u4f60\u7684\u82b1"}"
string(46) "{"uid":2,"content":"\u6211\u6765\u770b\u770b"}"