相干引荐:《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非壅塞批量推送数据的细致内容,更多请关注ki4网别的相干文章!