curl实现多路并发请求(请求数量大时再次分割实现循环处理)

function multiple_threads_request($data,$url,$chuck_num=20,$wait_usec = 0){ ???$result = []; ???if (empty($data) || empty($url)) { ???????$send_data = array_chunk($data, $chuck_num,true); ???????foreach ($send_data as $son_data){ ???????????$mh = curl_multi_init(); //初始化一个curl批处理句柄资源 ???????????$handle = []; ???????????foreach ($son_data as $k=>$val) ???????????{ ???????????????$curl_array[$k] = curl_init($url); ???????????????curl_setopt($handle[$k], CURLOPT_RETURNTRANSFER, 1); ???????????????curl_setopt($handle[$k], CURLOPT_SSL_VERIFYPEER, false); ???????????????curl_setopt($handle[$k], CURLOPT_SSL_VERIFYHOST, false); ???????????????curl_setopt($handle[$k], CURLOPT_POST, 1); ???????????????curl_setopt($handle[$k], CURLOPT_TIMEOUT,10); ???????????????curl_setopt($handle[$k], CURLOPT_HEADER, 0); ???????????????curl_setopt($handle[$k], CURLOPT_POSTFIELDS,$val); ???????????????//向curl批处理句柄资源中添加单独的curl句柄资源。curl_multi_add_handle函数有两个参数，第一个参数表示一个curl批处理句柄资源,第二个参数表示一个单独的curl句柄资源 ???????????????curl_multi_add_handle($mh, $handle[$k]); ???????????} ???????????$running = 0; ???????????do { ???????????????//解析一个curl批处理句柄，curl_multi_exec函数有两个参数，第一个表示一个批处理句柄资源，第二个参数是一个应用值参数，表示剩余需要处理的单个的curl句柄资源。 ???????????????curl_multi_exec($mh, $running);//持续调用curl_multi_exec ???????????????if ($wait_usec > 0) /* 每个 connect 要间隔多久 */ ???????????????????usleep($wait_usec); // 250000 = 0.25 sec ???????????} while ($running > 0); ???????????foreach ($son_data as $k=>$val) ???????????{ ???????????????$return = curl_multi_getcontent($handle[$k]);//根据需要循环调用curl_multi_getcontent ???????????????$return[$k] = (curl_errno($handle[$k]) == 0) ? $return : false; ???????????????//移除curl批处理句柄资源中的某个句柄资源，curl_multi_remove_handle()函数有两个参数，第一个参数表示一个curl批处理句柄资源，第二个参数表示一个单独的curl句柄资源。 ???????????????curl_multi_remove_handle($mh,$handle[$k]); ???????????} ???????????curl_multi_close($mh); ???????} ???} ???return $result;}