首页 > 其他 > 详细

redis异步处理

时间:2019-03-01 18:52:50      阅读:280      评论:0      收藏:0      [点我收藏+]
$reids = new Redis;
$redis->connect(‘localhost‘,6379);
$redis->auth(‘‘);
//将数组转换成字符串再存到redis中
$str = serialize($_POST);  //$_POST是表单提交的数据,这里省略客户端代码
$key = ‘users‘;
//列表存储
$res = $redis->lpush($key,$str);

if($res){
    echo ‘保存数据成功‘;  //这里提示用户数据成功保存 (存在redis中,之后再插入mysql)
}else{
    echo ‘失败‘;
}

新建一个文件,用来处理redis数据插入mysql。因为redis中的数据是不断的更新的,所以把redis中的数据存到mysql中也是需要持续不断的进行,那么就需要while死循环。

技术分享图片
$reids = new Redis;
$redis->connect(‘localhost‘,6379);
$redis->auth(‘‘);
$key = ‘users‘;
$pdo = new PDO(‘mysql:host=localhost;dbname=user;charset=utf8‘,‘root‘,‘‘);

//因为挪动数据是需要不停地做    
while (true) {
    //判断redis中是否有数据插入mysql
    if($redis->llen($key)>0){
        //读取数据
        $data = $redis->rpop($key);
        //将之前串行化数据转换成数组
        $arr = unserialize($data);
        //将数据插入mysql
        $stmt = $pdo->prepare(‘insert into users (username,password,email) values (:username,:password,:email)‘);
        //执行
        $stmt->execute($arr);
        $res = $stmt->rowCount();  //获取受影响行数

    }else{
        //当没有数据需要插入mysql的时候,就暂停休息
        sleep(10); //休息10秒
    }
}
View Code

需要知道一点:不管客户端浏览器是否关闭,服务器端的死循环都是一直执行的(前提是PHP代码不会超时)。(PHP有个代码超时时间,可以通过set_time_limit()设置超时时间)。如果想要停止脚本执行,需要重启Apache服务器。

redis异步处理

原文:https://www.cnblogs.com/bneglect/p/10458116.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!