phpredis提高消息队列的实时性方法

phpredis提高消息队列的实时性方法

数据库存贮都用list形式 要存2个队列 1个用作消息队列保存到数据  还有个 就是用来实时读取数据在redis

$redis->lpush($queenkey, json_encode($array));
$redis->lpush($listkey, json_encode($array));

public function insertinfo()
{
$infos =  array('info1' => mt_rand(10,100), 'info2' => mt_rand(10,100));
$this->insertinfos($infos, 'tutorial-list','tutoriallist');
}

public function insertinfos($array, $queenkey,$listkey)
{
//连接本地的 Redis 服务
$redis = new \Redis();
$redis->connect('127.0.0.1', 6379);
//存储数据到列表中$redis->lpush($queenkey, json_encode($array));
$redis->lpush($listkey, json_encode($array));
}

public function getinfo()
{
$sql = 'select * from mobantestinfo';
$result = $this->getinfos('tutoriallist', $sql);
print_r($result);
exit();
}

function getinfos($key, $sql)
{
//连接本地的 Redis 服务
$redis = new \Redis();
$redis->connect('127.0.0.1', 6379);

// 获取存储的数据
$result = $redis->lrange($key, 0, 1);

if (empty($result)) {
$VModel = new HuanShanVoteModel();
$result = $VModel->query($sql);

//重新将缓存队列的形式放入数据库
foreach ($result as $k=>$v){
$redis->lpush($key,json_encode($v));
}
} else {
//连接本地的 Redis 服务
$redis = new \Redis();
$redis->connect('127.0.0.1', 6379);
// 获取存储的数据并输出
$result = $redis->lrange($key, 0, -1);
foreach ($result as $k=>$v){
$result[$k]=json_decode($v,true);
}
}

return $result;
}