数据库存贮都用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));
}
读取 逻辑当redis key没有了 就读取数据库 然后重新写入list 有的话就读取redis数据
/*读取实例*/
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);
// 获取存储的数据并输出
$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);
// 获取存储的数据
$result = $redis->lrange($key, 0, 1);
if (empty($result)) {
$VModel = new HuanShanVoteModel();
$result = $VModel->query($sql);
//重新将缓存队列的形式放入数据库
foreach ($result as $k=>$v){
//这个地方要从右边插入 来保证跟数据库顺序一样
$redis->rpush($key,json_encode($v));
}
} else {
$result=0;
}
return $result;
}
以上就是小编为大家带来的phpredis提高消息队列的实时性方法(推荐)全部内容了，希望大家多多支持~
标签：
redis,消息队列
免责声明：本站文章均来自网站采集或用户投稿，网站不提供任何软件下载或自行开发的软件！
如有用户或公司发现本站内容信息存在侵权行为，请邮件告知！ 858582#qq.com
狼山资源网 Copyright www.pvsay.com
暂无“phpredis提高消息队列的实时性方法(推荐)”评论...
P70系列延期，华为新旗舰将在下月发布
3月20日消息，近期博主@数码闲聊站 透露，原定三月份发布的华为新旗舰P70系列延期发布，预计4月份上市。
而博主@定焦数码 爆料，华为的P70系列在定位上已经超过了Mate60，成为了重要的旗舰系列之一。它肩负着重返影像领域顶尖的使命。那么这次P70会带来哪些令人惊艳的创新呢？
根据目前爆料的消息来看，华为P70系列将推出三个版本，其中P70和P70 Pro采用了三角形的摄像头模组设计，而P70 Art则采用了与上一代P60 Art相似的不规则形状设计。这样的外观是否好看见仁见智，但辨识度绝对拉满。