如何用curl_multi_init将单线程curl请求改写成多线程并行处理?

如何用curl_multi_init将单线程curl请求改写成多线程并行处理?

curl_multi_init 单线程改多线程

问题:

如何将下列单线程 curl 请求改写为使用 curl_multi_init 实现多线程并行处理?

function post($url, $data = '', $head = 'application/x-www-form-urlencoded'){    $ch = curl_init();    curl_setopt($ch, curlopt_url, $url);    curl_setopt($ch, curlopt_httpheader, array("content-type:{$head};charset=utf-8;"));    curl_setopt($ch, curlopt_timeout, 30);    curl_setopt($ch, curlopt_returntransfer, 1);      curl_setopt($ch, curlopt_header, 0);    if (!empty($data)) {        curl_setopt($ch, curlopt_post, 1);        curl_setopt($ch, curlopt_postfields, $data);    }    $output = curl_exec($ch);    curl_close($ch);    return $output;}$url = 'http://localhost/test.php';$res = [];//模拟100条数据for ($i=0; $i < 100; $i++) {     $res[$key] = post($url, 'key='.$i);}var_dump($res);

解答:

将数据分组后,使用 curl_multi_init 创建多线程句柄集合,每个分组内的数据处理由独立的句柄负责,并行执行。

$newData = array_chunk($data, 10, true);foreach ($newData as $k => $tmp) {    $mh = curl_multi_init();    $chs = [];    foreach ($tmp as $key => $url) {        $ch = curl_init();        $chs[$key] = $ch;        curl_setopt($ch, CURLOPT_URL, $url);        curl_setopt($ch, CURLOPT_HTTPHEADER, array('Content-type:application/x-www-form-urlencoded;charset=utf-8;'));        curl_setopt($ch, CURLOPT_TIMEOUT, 30);        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);        curl_setopt($ch, CURLOPT_HEADER, 0);        curl_setopt($ch, CURLOPT_POST, 1);        curl_setopt($ch, CURLOPT_POSTFIELDS, $tmp);        curl_multi_add_handle($mh, $ch);    }    $active = null;    do {        $mrc = curl_multi_exec($mh, $active);    } while ($mrc == CURLM_CALL_MULTI_PERFORM);    while ($active && $mrc == CURLM_OK) {        if (curl_multi_select($mh) != -1) {            do {                $mrc = curl_multi_exec($mh, $active);            } while ($mrc == CURLM_CALL_MULTI_PERFORM);        }    }    foreach ($chs as $key => $ch) {        $res[$k][$key] = curl_multi_getcontent($ch);        curl_multi_remove_handle($mh, $ch);    }    curl_multi_close($mh);}var_dump($res);

以上就是如何用curl_multi_init将单线程curl请求改写成多线程并行处理?的详细内容,更多请关注创想鸟其它相关文章!

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/1250947.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2025年12月9日 22:42:08
下一篇 2025年12月8日 02:50:51

相关推荐

发表回复

登录后才能评论
关注微信