phpredis提高消息队列的实时性方法(推荐)_网络技术

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

发布时间 - 2026-01-10 21:49:27 点击率：次

数据库存贮都用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 # 消息队列 # 详解PHP多个进程配合redis的有序集合实现大文件去重 # redis 队列操作的例子(php) # php中使用redis队列操作实例代码 # PHP使用php-resque库配合Redis实现MQ消息队列的教程 # php+redis消息队列实现抢购功能 # PHP实现电商订单自动确认收货redis队列 # php基于Redis消息队列实现的消息推送的方法 # PHP基于Redis消息队列实现发布微博的方法 # PHP+Redis 消息队列实现高并发下注册人数统计的实例 # PHP使用redis消息队列发布微博的方法示例 # PHP实现基于Redis的MessageQueue队列封装操作示例 # php使用redis的有序集合zset实现延迟队列应用示例 # 有个 # 都用 # 小编 # 大家多多 # 为空 # 没有了 # 列表中 # function # insertinfo # public # listkey # infos # insertinfos # mt_rand # pre # class # connect # list # phpredis

相关栏目：【网站优化151355 】【网络推广146373 】【网络技术251813 】【 AI营销90571 】

上一篇：Laravel怎么处理异常_Laravel自定义异常处理与错

下一篇：为什么php本地部署后css不生效_静态资源加载失败修复技巧

相关栏目网站优化
网络推广
网络技术
AI营销

最新文章 Sublime怎么一键压缩JS代码 Su sublime如何在搜索中使用正则表达式 Sublime如何设置透明窗口效果 Su mysql如何设计商品表结构_mysql css属性背景图不显示怎么办_通过检查路如何使用Golang实现排序_Golan 农历闰月是怎么回事_为合回归年加一月调整塑造《刺客信条》艾吉奥传奇的编剧离开育碧 1英里等于多少公里 1mile和km的换 css grid布局中行和列是如何定义的 PS批量旋转和翻转图片，快速校正图片方向 C# Swagger UI自定义方法 C OPPO手机九宫格和全键盘怎么切换_OP Go语言如何实现用户登录注册_Golan 1节飞行速度多少公里每小时 1节是多少公纸嫁衣8千子树第五章庙门怎么开启庙门 Laravel 多行数据编辑表单中实现逐明日之后如何提升钓鱼等级明日之后提升钓支付宝怎样查年度账单_支付宝年度账单查看 C# 多线程UI更新Dispatcher

上一篇：Laravel怎么处理异常_Laravel自定义异常处理与错

下一篇：为什么php本地部署后css不生效_静态资源加载失败修复技巧