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

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

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

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

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

    1).redis函数rpush,lpop

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

    3)创建定时任务出队列

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

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    <?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定时扫描出队列

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    <?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 )

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

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    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"
    复制代码
  • 相关阅读:
    sql server 中各个系统表的作用==== (转载)
    后台动态设置前台标签内容和属性
    利用C#编写一个简单的抓网页应用程序
    如何创建和使用Web Service代理类
    jdbc如何取得存储过程return返回值
    子窗口和父窗口的函数或对象能否相互访问 (转载)
    把aspx文件编译成DLL文件
    C#中的类型转换
    c#中对文件的操作小结
    转贴一篇 自定义数据库 希望对你有帮助
  • 原文地址:https://www.cnblogs.com/liliuguang/p/10112236.html
Copyright © 2011-2022 走看看