求並發大俠給解決方案啊....

由於有一段程式碼要用到while 循環程式碼,一旦資料量大了就會失敗,求解決方案啊 ....

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

<code>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']);
    }
}</code>

回覆內容：

由於有一段程式碼要用到while 循環程式碼,一旦資料量大了就會失敗,求解決方案啊 ....

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

<code>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']);
    }
}</code>

1.能不能上完整版的程式碼？ SQL也不捨不得拿出來？
2.目測是SQL的結果集太多，記憶體可能溢出，而且操作可能耗時
3.解決方案：用redis佇列 或 MySQL佇列解決

循環操作的肯定不能再程式裡這樣寫啊。 。 。你可以新建一個sql表當佇列，或是直接用redis做佇列。 。然後新開一個服務或腳本專門處理這個任務

估計是處理速度過慢，導致伺服器無法回應新的請求，導致失敗。從程式碼來看，你的處理模式有問題，最好不要使用循環一個一個處理訂單，如果可以的話使用資料庫解決，例如預存程序就比較快。

你的 $rs 應該是大數組，而且你在循環中使用了mysql查詢，效率會很低。
建議運行一個cli模式的PHP來非同步處理

不想用隊列給你一個非常簡單暴力的多進程思路

對最大的那個查詢結果集根據ID取模進行分流多進程處理，思路類似以下的偽代碼

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

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

        }</code>

對所有ID根據資料量進行取模拆分，至於你是全部取出來進行拆分，還是直接開5個PHP進程SQL語句查詢的時候就進行拆分，要根據你的業務邏輯來具體分析了。

SQL語句拆5個進程處理類似如下：

<code>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;</code>

可以在while（1）{
一次取出部分資料處理，然後分批取出處理完成後跳出循環
}