当前位置:Gxlcms > PHP教程 > 求并发大侠给解决方案啊....

求并发大侠给解决方案啊....

时间:2021-07-01 10:21:17 帮助过:15人阅读

由于有一段代码要用到while 循环代码,一旦数据量大了就会失败,求解决方案啊 ....

while($rows = $query->fetch_array()){

if($rows['mingxi_1']=='1'){
    $ds = Ssc_Ds($rs['ball_1']);
    $dx = Ssc_Dx($rs['ball_1']);
    if($rows['mingxi_2']==$rs['ball_1'] || $rows['mingxi_2']==$ds || $rows['mingxi_2']==$dx){
     
        $msql="update c_bet set js=1 where id='".$rows['id']."'";
        $mysqli->query($msql) or die ("修改订单状态失败!!!".$rows['id']);
        //给会员账户增加奖金
        $msql="update k_user set money=money+".$rows['win']." where uid=".$rows['uid']."";
        $mysqli->query($msql) or die ("修改失败!!!".$rows['id']);
    }else{
        //注单未中奖,修改注单内容
        $msql="update c_bet set win=0,js=1 where id=".$rows['id']."";
        $mysqli->query($msql) or die ("修改失败!!!".$rows['id']);
    }
}

回复内容:

由于有一段代码要用到while 循环代码,一旦数据量大了就会失败,求解决方案啊 ....

while($rows = $query->fetch_array()){

if($rows['mingxi_1']=='1'){
    $ds = Ssc_Ds($rs['ball_1']);
    $dx = Ssc_Dx($rs['ball_1']);
    if($rows['mingxi_2']==$rs['ball_1'] || $rows['mingxi_2']==$ds || $rows['mingxi_2']==$dx){
     
        $msql="update c_bet set js=1 where id='".$rows['id']."'";
        $mysqli->query($msql) or die ("修改订单状态失败!!!".$rows['id']);
        //给会员账户增加奖金
        $msql="update k_user set money=money+".$rows['win']." where uid=".$rows['uid']."";
        $mysqli->query($msql) or die ("修改失败!!!".$rows['id']);
    }else{
        //注单未中奖,修改注单内容
        $msql="update c_bet set win=0,js=1 where id=".$rows['id']."";
        $mysqli->query($msql) or die ("修改失败!!!".$rows['id']);
    }
}

1.能不能上完整版的代码?SQL也不舍不得拿出来?
2.目测是SQL的结果集太多,内存可能溢出,而且操作可能耗时
3.解决方案:用redis队列 或者 MySQL队列解决

循环操作的肯定不能再程序里这样写啊。。。你可以新建一个sql表当队列,或者直接用redis做队列。。然后新开一个服务或者脚本专门处理这个任务

估计是处理速度过慢,导致服务器无法响应新的请求,导致失败。从代码看,你的处理模式有问题,最好不使用循环一个一个处理订单,如果可以的话使用数据库解决,比如存储过程就比较快。

你的 $rs 应该是大数组,而且你在循环中使用了mysql查询,效率会很低。
建议运行一个cli模式的PHP来异步处理

不想用队列给你一个非常简单暴力的多进程思路

对最大的那个查询结果集根据ID取模进行分流多进程处理,思路类似以下的伪代码

        for ($i=1;$i<=100;$i++){

            if($i%5==0){
                echo 'mod 1 : '.$i.'
'; } if($i%5==1){ echo 'mod 2 : '.$i.'
'; } if($i%5==2){ echo 'mod 3 : '.$i.'
'; } if($i%5==3){ echo 'mod 4 : '.$i.'
'; } if($i%5==4){ echo 'mod 5 : '.$i.'
'; } }

对所有ID根据数据量进行取模拆分,至于你是全部取出来进行拆分,还是直接开5个PHP进程SQL语句查询的时候就进行拆分,要根据你的业务逻辑来具体分析了。

SQL语句拆5个进程处理类似如下:

SELECT * FROM member where member_id%5=0;
SELECT * FROM member where member_id%5=1;
SELECT * FROM member where member_id%5=2;
SELECT * FROM member where member_id%5=3;
SELECT * FROM member where member_id%5=4;

可以在while(1){
一次性取出部分数据处理,然后分批取出处理完成后跳出循环
}

人气教程排行