PHP实现非阻塞批量推送数据的方法-创新互联

PHP是一种通用开源脚本语言。语法吸收了C语言、Java和Perl的特点，利于学习，使用广泛，主要适用于Web开发领域。PHP 独特的语法混合了C、Java、Perl以及PHP自创的语法。它可以比CGI或者Perl更快速地执行动态网页。

创新互联长期为上千客户提供的网站建设服务，团队从业经验10年，关注不同地域、不同群体，并针对不同对象提供差异化的产品和服务；打造开放共赢平台，与合作伙伴共同营造健康的互联网生态环境。为隆昌企业提供专业的成都网站制作、成都网站建设，隆昌网站改版等技术服务。拥有十多年丰富建站经验和众多成功案例,为您定制开发。

今天看到论坛里面有人问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资源
$ch2 = curl_init();
$ch3 = curl_init();
 
// 设置URL和相应的选项
curl_setopt($ch2, CURLOPT_URL, "http://baidu.com/");
curl_setopt($ch2, CURLOPT_HEADER, 0);
curl_setopt($ch3, CURLOPT_URL, "http://baidu.com/");
curl_setopt($ch3, CURLOPT_HEADER, 0);
 
// 创建批处理cURL句柄
$mh = curl_multi_init();
 
// 增加2个句柄
curl_multi_add_handle($mh,$ch2);
curl_multi_add_handle($mh,$ch3);
 
$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, $ch2);
curl_multi_remove_handle($mh, $ch3);
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实现非阻塞批量推送数据的方法的详细内容，更多请关注创新互联成都网站设计公司其它相关文章！

另外有需要云服务器可以了解下创新互联scvps.cn，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。

网页名称：PHP实现非阻塞批量推送数据的方法-创新互联
URL网址：https://www.cdcxhl.com/article32/ceoipc.html

成都网站建设公司_创新互联，为您提供动态网站、网站营销、网站设计、网站维护、网站建设、网站制作

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源：创新互联

猜你还喜欢下面的内容