PHP非阻塞批次推播資料

相關推薦：《PHP教學》

1、最簡單的辦法：

一個指令碼同時跑多次，用引數來跑指定範圍。假如要推播10000使用者，可以每100個使用者執行一個指令碼（指令碼邏輯就是迴圈遍歷100個使用者，序列的傳送資料，程式碼略），並且多個（100）指令碼同時執行。

類似：

php task.php 1 100 &
php task.php 101 200 &
php task.php 201 300 &
........

當然這個方法不是非阻塞的，但是可以批次操作，大大加快處理速度。

2、麻煩點的：如果想要非阻塞並且是HTTP協定的話

可以用下面的程式碼

<?php
// 建立一對cURL資源
$ch1 = curl_init();
$ch2 = curl_init();
 
// 設定URL和相應的選項
curl_setopt($ch1, CURLOPT_URL, "http://baidu.com/");
curl_setopt($ch1, CURLOPT_HEADER, 0);
curl_setopt($ch2, CURLOPT_URL, "http://baidu.com/");
curl_setopt($ch2, CURLOPT_HEADER, 0);
 
// 建立批次處理cURL控制代碼
$mh = curl_multi_init();
 
// 增加2個控制代碼
curl_multi_add_handle($mh,$ch1);
curl_multi_add_handle($mh,$ch2);
 
$active = null;
// 執行批次處理控制代碼
do {
    $mrc = curl_multi_exec($mh, $active);
} while ($mrc == CURLM_CALL_MULTI_PERFORM);
 
// 輪詢Server返回的結果
while ($active && $mrc == CURLM_OK) {
    if (curl_multi_select($mh) != -1) {
        do {
            $mrc = curl_multi_exec($mh, $active);
        } while ($mrc == CURLM_CALL_MULTI_PERFORM);
    }
}
 
// 匯總結果......
 
// 關閉全部控制代碼
curl_multi_remove_handle($mh, $ch1);
curl_multi_remove_handle($mh, $ch2);
curl_multi_close($mh);

3、非阻塞，並且不是HTTP協定的話，需要使用php的socket + stream_select

<?php
// uid陣列，每個uid傳送一個連結
$uids = array(1,2,3,4,5,6);
// 儲存socket的陣列
$sockets = array();
 
// 批次建立連結並行送資料
foreach($uids as $uid)
{
    // tcp://baidu.com 改成你要存取的ip或者域名
    if(!$socket = stream_socket_client("tcp://baidu.com:80", $errno, $errstr))
    {
        echo "$errstrn";
        continue;
    }
 
    // 根據自己的協定向伺服器端寫入資料，這裡模擬HTTP協定
    fwrite($socket, "GET / HTTP/1.1rnHost: www.baidu.comrnrn");
    // 設定成非阻塞
    stream_set_blocking($socket, 0);
    // 記錄陣列
    $sockets[(int)$socket] = $socket;
}
 
// 批次等待資料返回
while(count($sockets)>0)
{
    $read = $sockets;
    $write = $e = array();
    // 等待資料可讀
    if(stream_select($read, $write, $e, 10))
    {
        // 迴圈讀資料
        foreach($read as $socket)
        {
           // 這裡是伺服器端返回的資料，需要的話可以迴圈讀
           echo fread($socket, 8192);
           // 資料讀取完畢關閉連結，並刪除連結
           fclose($socket);
           unset($sockets[(int)$socket]);
        }
    }
}

以上就是PHP非阻塞批次推播資料的詳細內容，更多請關注TW511.COM其它相關文章！