本日看到论坛内里有人问如PHP何批量非壅塞向服务器推送数据，这里也许总结下。
相干引荐：《PHP教程》
1、最简朴的要领：
一个剧本同时跑屡次，用参数来跑指定局限。假如要推送10000用户，能够每100个用户运转一个剧本(剧本逻辑就是轮回遍历100个用户，串行的发送数据，代码略)，而且多个(100)剧本同时运转。
相似：
php task.php 1 100 &
php task.php 101 200 &
php task.php 201 300 &
........
固然这个要领不黑白壅塞的，然则能够批量操纵，大大加速处置惩罚速率。
2、贫苦点的：假如想要非壅塞而且是HTTP协定的话
能够用下面的代码
// 建立一对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
// 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非壅塞批量推送数据的细致内容，更多请关注ki4网别的相干文章！
收藏 | 0
