zoukankan      html  css  js  c++  java
  • php+redis实现消息队列

    个人理解在项目中使用消息队列一般是有如下几个原因:

    1. 把瞬间服务器的请求处理换成异步处理,缓解服务器的压力

    2. 实现数据顺序排列获取

    ​redis实现消息队列步骤如下:

    1).redis函数rpush,lpop

    2).建议定时任务入队列

    3)创建定时任务出队列

    文件:demo.php插入数据到redis队列

    <?php
     
    $redis = new Redis();
     
    $redis->connect('127.0.0.1',6379);
     
    $password = '123456';
     
    $redis->auth($password);
     
    $arr = array('h','e','l','l','o','w','o','r','l','d');
     
    foreach($arr as $k=>$v){
     
      $redis->rpush("mylist",$v);
     
    }

    ?>

    文件:index.php定时扫描出队列

    <?php
     
    $redis = new Redis();
     
    $redis->connect('127.0.0.1',6379);
     
    $password = '123456';
     
    $redis->auth($password);
     
    //list类型出队操作
     
    $value = $redis->lpop('mylist');
     
    if($value){
     
     echo "出队的值".$value;
     
    }else{
     
      echo "出队完成";
     
    }
     
    ?>

    建立定时任务

     */1 * * * * root php /wwwroot/workplace/redis/index.php

     */3 * * * * root php /wwwroot/workplace/redis/demo.php

    tail -f /var/log/cron  查看定时任务执行情况

    Nov  7 00:30:01 dongzi CROND[6888]: (root) CMD (php /wwwroot/workplace/redis/demo.php)

    Nov  7 00:30:01 dongzi CROND[6890]: (root) CMD (php /wwwroot/workplace/redis/index.php )

    定时任务执行队列写入结果如下

    127.0.0.1:6379> lrange mylist 0 -1
     
     1) "h"
     
     2) "e"
     
     3) "l"
     
     4) "l"
     
     5) "o"
     
     6) "w"
     
     7) "o"
     
     8) "r"
     
     9) "l"
     
    10) "d"

    定时任务执行出队列后:

    127.0.0.1:6379> lrange mylist 0 -1
    
    1) "e"
    
    2) "l"
    
    3) "l"
    
    4) "o"
    
    5) "w"
    
    6) "o"
    
    7) "r"
    
    8) "l"
    
    9) "d"
  • 相关阅读:
    相关术语随笔
    JDK简介和mac下安装和查看版本命令
    英语
    英语学习2
    英语学习-19.1
    为什么java是只有值传递而没有引用传递
    线程
    关于同步异步

    jdk动态代理实现原理总结
  • 原文地址:https://www.cnblogs.com/jierong12/p/10155032.html
Copyright © 2011-2022 走看看