PHP curl多线程

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了PHP curl多线程，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1780字，纯文字阅读大概需要3分钟。

内容图文

前言

使用PHP的curl函数调用多个外部HTTP接口时，默认情况下是需要一个一个执行的，第一个请求结束后才会发起第二个请求，这样会显得效率低。如果各个请求之间没有强依赖关系，可以使用curl的多线程函数来发起请求，这样可以节省很多时间，提高效率。

代码

<?php
function main() {
    $requests = [
        [
            'url' => 'https://www.baidu.com', // 请求URL
            'method' => 'GET', // 请求方法，支持GET和POST
            'header' => [], // 请求头
            'param' => ['i' => 0], // 请求参数
        ],
        [
            'url' => 'http://www.sdhaidhoasdhaihd.com',
            'method' => 'GET',
            'header' => [],
            'param' => ['i' => 1],
        ],
    ];
    $handles = [];

    foreach ($requests as $req) {
        $options = [
            CURLOPT_HEADER => false,
            CURLOPT_RETURNTRANSFER => true,
            CURLOPT_TIMEOUT => 30,
        ];
        if (!empty($req['header'])) {
            $options[CURLOPT_HTTPHEADER] = $req['header'];
        }

        switch ($req['method']) {
            case 'GET':
                $options[CURLOPT_URL] = "{$req['url']}?" . http_build_query($req['param']);
                break;
            case 'POST':
                $options[CURLOPT_URL] = $req['url'];
                $options[CURLOPT_POST] = true;
                $options[CURLOPT_POSTFIELDS] = http_build_query($req['param']);
                break;
            default:
                exit("Unsupported method:{$req['method']}");
        }

        $ch = curl_init();
        curl_setopt_array($ch, $options);
        $handles[] = $ch;
    }

    $mh = curl_multi_init();
    foreach ($handles as $ch) {
        curl_multi_add_handle($mh, $ch);
    }

    $running = null;
    do {
        curl_multi_exec($mh, $running);
        curl_multi_select($mh);
    } while ($running > 0);

    while ($info = curl_multi_info_read($mh)) {
        $ch = $info['handle'];
        if ($info['result'] != CURLM_OK) {
            $httpCode = $info['result'];
            $httpBody = curl_error($ch);
        } else {
            $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
            $httpBody = curl_multi_getcontent($ch);
        }
        $index = array_search($ch, $handles, true);
        $requests[$index]['response'] = [
            'code' => $httpCode,
            'body' => $httpBody,
        ];
        curl_multi_remove_handle($mh, $ch);
        curl_close($ch);
    }
    curl_multi_close($mh);

    var_dump($requests);
}

main();

内容总结

以上是互联网集市为您收集整理的PHP curl多线程全部内容，希望文章能够帮你解决PHP curl多线程所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端