• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

phpredis提高消息队列的实时性方法(推荐)

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

数据库存贮都用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提高消息队列的实时性方法(推荐)全部内容了,希望大家多多支持极客世界~


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
解决MySQL存储时间出现不一致的问题发布时间:2022-02-08
下一篇:
Oracle数据库服务器修改操作系统时间的注意事项详解发布时间:2022-02-08
热门推荐
热门话题
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap