phpredis提高消息隊列的實時性方法(推薦)
更新時間:2016年12月14日 14:59:06 投稿:jingxian
下面小編就為大家?guī)硪黄猵hpredis提高消息隊列的實時性方法(推薦)。小編覺得挺不錯的,現(xiàn)在就分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
數(shù)據(jù)庫存貯都用list形式 要存2個隊列 1個用作消息隊列保存到數(shù)據(jù) 還有個 就是用來實時讀取數(shù)據(jù)在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); //存儲數(shù)據(jù)到列表中 $redis->lpush($queenkey, json_encode($array)); $redis->lpush($listkey, json_encode($array)); }
讀取 邏輯當redis key沒有了 就讀取數(shù)據(jù)庫 然后重新寫入list 有的話就讀取redis數(shù)據(jù)
/*讀取實例*/ public function getinfo() { $sql = 'select * from mobantestinfo'; $result = $this->getinfos('tutoriallist', $sql); //redis key不為空 直接讀取redis if(empty($result)){ //連接本地的 Redis 服務 $redis = new \Redis(); $redis->connect('127.0.0.1', 6379); // 獲取存儲的數(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 服務 $redis = new \Redis(); $redis->connect('127.0.0.1', 6379); // 獲取存儲的數(shù)據(jù) $result = $redis->lrange($key, 0, 1); if (empty($result)) { $VModel = new HuanShanVoteModel(); $result = $VModel->query($sql); //重新將緩存隊列的形式放入數(shù)據(jù)庫 foreach ($result as $k=>$v){ //這個地方要從右邊插入 來保證跟數(shù)據(jù)庫順序一樣 $redis->rpush($key,json_encode($v)); } } else { $result=0; } return $result; }
以上就是小編為大家?guī)淼膒hpredis提高消息隊列的實時性方法(推薦)全部內(nèi)容了,希望大家多多支持腳本之家~
您可能感興趣的文章:
- 詳解PHP多個進程配合redis的有序集合實現(xiàn)大文件去重
- redis 隊列操作的例子(php)
- php中使用redis隊列操作實例代碼
- PHP使用php-resque庫配合Redis實現(xiàn)MQ消息隊列的教程
- php+redis消息隊列實現(xiàn)搶購功能
- PHP實現(xiàn)電商訂單自動確認收貨redis隊列
- php基于Redis消息隊列實現(xiàn)的消息推送的方法
- PHP基于Redis消息隊列實現(xiàn)發(fā)布微博的方法
- PHP+Redis 消息隊列 實現(xiàn)高并發(fā)下注冊人數(shù)統(tǒng)計的實例
- PHP使用redis消息隊列發(fā)布微博的方法示例
- PHP實現(xiàn)基于Redis的MessageQueue隊列封裝操作示例
- php使用redis的有序集合zset實現(xiàn)延遲隊列應用示例
相關(guān)文章
Redis簡單動態(tài)字符串SDS的實現(xiàn)示例
Redis沒有直接復用C語言的字符串,而是新建了SDS,本文主要介紹了Redis簡單動態(tài)字符串SDS的實現(xiàn)示例,具有一定的參考價值,感興趣的可以了解一下2023-08-08Redis優(yōu)化token校驗主動失效的實現(xiàn)方案
在普通的token頒發(fā)和校驗中 當用戶發(fā)現(xiàn)自己賬號和密碼被暴露了時修改了登錄密碼后舊的token仍然可以通過系統(tǒng)校驗直至token到達失效時間,所以系統(tǒng)需要token主動失效的一種能力,所以本文給大家介紹了Redis優(yōu)化token校驗主動失效的實現(xiàn)方案,需要的朋友可以參考下2024-03-03nestjs使用redis實現(xiàn)ip限流的步驟詳解
如果使用nestjs開發(fā)接口并部署之后,我們通常需要考慮到接口是否會被惡意盜刷消耗過多的資源,一個簡單的方式就是限制在單位時間內(nèi)的訪問次數(shù),所以本文給大家介紹了nestjs使用redis實現(xiàn)ip限流的步驟,需要的朋友可以參考下2025-01-01