PHP非阻塞大量推送数据

今天看到论坛里面有人问如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 "$errstr\n";
        continue;
    }
 
    // 按照本人的和谈向效劳端写入数据，这里模拟HTTP和谈
    fwrite($socket, "GET / HTTP/1.1\r\nHost: www.baidu.com\r\n\r\n");
    // 设定成非堵塞
    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非堵塞大量推送数据的具体内容，更多请关注百分百源码网其它相关文章！