PHP发起异步请求

古城微笑少年丶 2022-06-17 03:36 251阅读 0赞

当我们要与第三方接口进行交互的时候，经常会使用到curl来调取接口。但是，我们会面临到一个问题，就是一个页面可能需要调取多个接口，这个时候，用curl的效率可能会有点低，因为是同步调取的。

如果能够可以实现异步调取接口，那是最好的。

这时，我发现了curl\_multi函数，用这个函数可以实现异步调取接口。代码奉上：

自己亲测，服务器端接收请求的结果中返回时间戳，可以看到服务器端接收请求时的时间戳是一模一样的。

也就是说请求是同时到达的。

但是，踩坑开始了。

不知道为何，当我一次性发起请求的时候，有时候会出现很奇葩的情况，服务器端接口接收到的参数混乱了，即接口2接收到了接口1的参数。

这个问题找了很久，都没有找到解决办法。

于是，决定换代码。

于是我又发现了guzzleHttp这个东西。guzzle的介绍是这样的。http://guzzle-cn.readthedocs.io/zh\_CN/latest/index.html

![Image 1][]

这正是我需要的。guzzle的使用很简单，不管是使用同步还是异步。

可是使用guzzle之后，上面的问题还是存在。不晓得是服务器端的问题还是php异步自身的问题。

于是想了个办法，当发现请求结果为空的时候，再次发起一次同步请求。（虽然效率不高的说，但是总得获取到数据啊）

奉上代码：

use GuzzleHttp\Client;
    use GuzzleHttp\Promise;
    use GuzzleHttp\Exception\RequestException;
    use Monolog\Logger;
    use Monolog\Handler\StreamHandler;
    
    function rolling_request($data) {
        $client = new Client();
         $logger = new Logger('name');    $logger_path = 'test.log';
        // Initiate each request but do not block    $promises = [];    $logger->pushHandler(new StreamHandler($log_path), Logger::INFO);    $logger->addInfo('============================BEGIN REQUEST=========================');        foreach($data as $key => $item) {        $logger->addInfo('url: '.$item['url']);        $logger->addInfo('data:'.json_encode($item['params']));        try {            $promises[$key] = $client->requestAsync('POST', $item['url'], ['connect_timeout' => 6, 'http_errors' => false, 'form_params' => $item['params']]);            $promises[$key]->then(                function (ResponseInterface $res) {                },                function (RequestException $e) {                }            );        } catch (RequestException $e) {            //ToDO: 异常处理 $logger->addError('RequestException: '.$e->getMessage());        }    }    // Wait on all of the requests to complete.    try {        $results = Promise\unwrap($promises);    } catch (RequestException $e) {        //ToDO: 异常处理 $logger->addError('RequestException: '.$e->getMessage());    }    $return = [];    if($results) {        foreach($results as $key => $value) {            $content = $value->getBody()->getContents();            //STANGE：不知道为什么，发起异步请求的时候，服务器端接收到的参数有时候会对不上，为了避免这种情况，多做一个判断            //        当返回结果为空的时候，再发起一个同步请求            if($content && $content['code'] == 'SUCCESS' && empty($content['result'])) {                //echo '---又有空的东西啦---<br />';                $logger->addWarning('content:'.$key.': 异步请求失败，将此请求转换成同步请求');                //TODO: 另外写一个同步请求的程序，重新请求 } else {                $return[$key] = $content;            }        }    }        $logger->addInfo('============================END MULTI REQUEST===========================');    $logger->addInfo('');    //exit;    return $return;}

为了测试同步和异步的区别，特意价格服务器端接口地址改为不可用的地址，超时都设置为6秒，一次性发起4个请求。

在同步的情况下，整个页面返回会消耗24秒多。

在异步的情况下，整个页面返回只需要消耗6秒多。

另，上面用到了Monolog来记录日志，在接口调试中一定要做好。

[Image 1]: