由於有一段程式碼要用到while 循環程式碼,一旦資料量大了就會失敗,求解決方案啊 ....
while($rows = $query->fetch_array()){
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 | <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()){
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 | <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取模進行分流多進程處理,思路類似以下的偽代碼
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 | <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個進程處理類似如下:
1 2 3 4 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){
一次取出部分資料處理,然後分批取出處理完成後跳出循環
}