數(shù)據(jù)庫(kù)存貯都用list形式 要存2個(gè)隊(duì)列 1個(gè)用作消息隊(duì)列保存到數(shù)據(jù) 還有個(gè) 就是用來實(shí)時(shí)讀取數(shù)據(jù)在redis
$redis->lpush($queenkey, json_encode($array));
$redis->lpush($listkey, json_encode($array));
/*消息隊(duì)列實(shí)例*/
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 服務(wù)
$redis = new \Redis();
$redis->connect('127.0.0.1', 6379);
//存儲(chǔ)數(shù)據(jù)到列表中
$redis->lpush($queenkey, json_encode($array));
$redis->lpush($listkey, json_encode($array));
}
讀取 邏輯當(dāng)redis key沒有了 就讀取數(shù)據(jù)庫(kù) 然后重新寫入list 有的話就讀取redis數(shù)據(jù)
/*讀取實(shí)例*/
public function getinfo()
{
$sql = 'select * from mobantestinfo';
$result = $this->getinfos('tutoriallist', $sql);
//redis key不為空 直接讀取redis
if(empty($result)){
//連接本地的 Redis 服務(wù)
$redis = new \Redis();
$redis->connect('127.0.0.1', 6379);
// 獲取存儲(chǔ)的數(shù)據(jù)并輸出
$result = $redis->lrange('tutoriallist', 0, -1);
foreach ($result as $k=>$v){
$result[$k]=json_decode($v,true);
}
print_r($result);
exit();
}
}
function getinfos($key, $sql)
{
//連接本地的 Redis 服務(wù)
$redis = new \Redis();
$redis->connect('127.0.0.1', 6379);
// 獲取存儲(chǔ)的數(shù)據(jù)
$result = $redis->lrange($key, 0, 1);
if (empty($result)) {
$VModel = new HuanShanVoteModel();
$result = $VModel->query($sql);
//重新將緩存隊(duì)列的形式放入數(shù)據(jù)庫(kù)
foreach ($result as $k=>$v){
//這個(gè)地方要從右邊插入 來保證跟數(shù)據(jù)庫(kù)順序一樣
$redis->rpush($key,json_encode($v));
}
} else {
$result=0;
}
return $result;
}
以上就是小編為大家?guī)淼膒hpredis提高消息隊(duì)列的實(shí)時(shí)性方法(推薦)全部?jī)?nèi)容了,希望大家多多支持腳本之家~
您可能感興趣的文章:- 詳解PHP多個(gè)進(jìn)程配合redis的有序集合實(shí)現(xiàn)大文件去重
- redis 隊(duì)列操作的例子(php)
- php中使用redis隊(duì)列操作實(shí)例代碼
- PHP使用php-resque庫(kù)配合Redis實(shí)現(xiàn)MQ消息隊(duì)列的教程
- php+redis消息隊(duì)列實(shí)現(xiàn)搶購(gòu)功能
- PHP實(shí)現(xiàn)電商訂單自動(dòng)確認(rèn)收貨redis隊(duì)列
- php基于Redis消息隊(duì)列實(shí)現(xiàn)的消息推送的方法
- PHP基于Redis消息隊(duì)列實(shí)現(xiàn)發(fā)布微博的方法
- PHP+Redis 消息隊(duì)列 實(shí)現(xiàn)高并發(fā)下注冊(cè)人數(shù)統(tǒng)計(jì)的實(shí)例
- PHP使用redis消息隊(duì)列發(fā)布微博的方法示例
- PHP實(shí)現(xiàn)基于Redis的MessageQueue隊(duì)列封裝操作示例
- php使用redis的有序集合zset實(shí)現(xiàn)延遲隊(duì)列應(yīng)用示例