如何将单线程的curl_multi_init改造成多线程并发请求？

各位小伙伴们，大家好呀！看看今天我又给各位带来了什么文章？本文标题是《如何将单线程的curl_multi_init改造成多线程并发请求？》，很明显是关于文章的文章哈哈哈，其中内容主要会涉及到等等，如果能帮到你，觉得很不错的话，欢迎各位多多点评和分享！

curl_multi_init单线程改多线程实现

原来单线程的curl实现如下：

function post($url, $data = '', $head = 'application/x-www-form-urlencoded')
{
    // ...
    $output = curl_exec($ch);
    curl_close($ch);
    return $output;
}

现在要将其改为多线程，思路是将数据数组分成小块，然后对每一块都创建一个单独的curl句柄。

$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_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改造成多线程并发请求？》的详细介绍，大家都掌握了吧！如果想要继续提升自己的能力，那么就来关注golang学习网公众号吧！