在數據采集的過程中,會有很多次請求.每個請求要發送的信息無外乎都有一個關鍵的KEY,多數是ID.

把這個ID寫入到一個棧里面

$redis->lpush("idlist",$id);

然后在PHP代碼里面寫一個死循環

public function getinfos(){
? ? while(true){
? ? ? ? $id = $redis->lpop("idlist");
? ? ? ? if($id){
? ? ? ? ? ? ?//do something here/
? ? ? ? }else{
? ? ? ? ? ? break;
? ? ? ? } ? ? ??
? ? }


}

然后再在外面這樣調用

function list_get_infos(){
? ? ? ? for($i=0;$i<10;$i++){
? ? ? ? ? ? exec("/usr/local/php/sbin/php","腳本地址");
? ? ? ? }
? ? }

如此一來,就會同時起10個進程來一起從這個redis的棧里面pop出id,并通過ID獲取想要的數據.

注意：

1,首先進入死循環后,如果用過的變量一定要注意適時的銷毀.也就是unset.否則可能會導致內存溢出.

2,代碼里要做合適的容錯處理,否則報錯的話會出現進程提前結束.

3,適當的輸出日志.方便錯誤的處理.并且可以通過查看redis的隊列長度來判斷程序的執行結果.

來源:http://blog.csdn.net/merlin_feng/article/details/42583443

總結

以上是生活随笔為你收集整理的Redis队列php多线程请求的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。