Guzzle中的异步请求
Guzzle中的异步请求
使用Guzzle发起异步请求
Guzzle是一个PHP的HTTP客户端,它在发起http请求时不仅可以同步发起,还可以异步发起。
$client = new Client();
$request = new Request('GET', 'http://www.baidu.com');
$promise = $client->sendAsync($request)->then(function ($response) {echo $response->getBody();
});
// todo something
echo 1;
$promise->wait();
PHP发起HTTP请求的几种方式
curl
使用libcurl库,允许你与各种的服务器使用各种类型的协议进行连接和通讯。
stream
通过流的方式获取和发送远程文件,该功能需要ini配置allow_url_fopen=on。关于php的流更多参考PHP流(Stream)的概述与使用详解
在guzzle中可以兼容使用这两种的任意一种或者是用户自定义的http handler
function choose_handler()
{$handler = null;if (function_exists('curl_multi_exec') && function_exists('curl_exec')) {$handler = Proxy::wrapSync(new CurlMultiHandler(), new CurlHandler());} elseif (function_exists('curl_exec')) {$handler = new CurlHandler();} elseif (function_exists('curl_multi_exec')) {$handler = new CurlMultiHandler();}if (ini_get('allow_url_fopen')) {$handler = $handler? Proxy::wrapStreaming($handler, new StreamHandler()): new StreamHandler();} elseif (!$handler) {throw new \RuntimeException('GuzzleHttp requires cURL, the '. 'allow_url_fopen ini setting, or a custom HTTP handler.');}return $handler;
}
可以看出,guzzle会优先使用curl,然后选择使用stream,Proxy::wrapStreaming($handler, new StreamHandler())
是一个流包装器。
public static function wrapStreaming(callable $default,callable $streaming) {return function (RequestInterface $request, array $options) use ($default, $streaming) {return empty($options['stream'])? $default($request, $options): $streaming($request, $options);};}
什么是URI?URI的组成
URI,Uniform Resource Identifier,统一资源标识符。
scheme:[//[user:password@]host[:port]][/]path[?query][#fragment]
![1155692-865aa6e8904a0509.webp](https://imgconvert.csdnimg.cn/aHR0cHM6Ly9jZG4ubmxhcmsuY29tL3l1cXVlLzAvMjAyMC93ZWJwLzIzMDcwNC8xNTkxNjY2NzUxNzY3LWE5YWExZjdhLWQ0NmYtNGY4YS05N2Y1LTRjY2IzYzU0ZGMxYy53ZWJw?x-oss-process=image/format,png#align=left&display=inline&height=205&margin=[object Object]&name=1155692-865aa6e8904a0509.webp&originHeight=250&originWidth=918&size=15056&status=done&style=none&width=752)
请求的组装
Guzzle发起请求大致分为两个阶段,第一阶段负责将需要请求的uri组装成各种内部定义的类。
- Client类:这是一个发起客户端的调用者,后续所有的调用需要基于这个负责的类实现,它负责提供一个 handler ,这是一个客户端发起http请求的句柄,其中Guzzle实现curl和stream调用的无感知就是在这里实现的,同时开发者也可以自定义请求协议。
// 根据系统当前状态,选择一个发起Http请求的协议的方法句柄
function choose_handler()
{$handler = null;if (function_exists('curl_multi_exec') && function_exists('curl_exec')) {$handler = Proxy::wrapSync(new CurlMultiHandler(), new CurlHandler());} elseif (function_exists('curl_exec')) {$handler = new CurlHandler();} elseif (function_exists('curl_multi_exec')) {$handler = new CurlMultiHandler();}if (ini_get('allow_url_fopen')) {$handler = $handler? Proxy::wrapStreaming($handler, new StreamHandler()): new StreamHandler();} elseif (!$handler) {throw new \RuntimeException('GuzzleHttp requires cURL, the '. 'allow_url_fopen ini setting, or a custom HTTP handler.');}return $handler;
}
- Request类:负责定义一个uri
- Promise类:这个类负责承载类请求发起前的各种准备工作完成后的结果,还包括两个回调(请求成功回调、请求失败回调),同时请求发起中的队列,延迟等处理也是在这个类里。
其中组装阶段最重要的方法是私有方法 private function transfer(RequestInterface $request, array $options)
,它负责将用户通过各种方法传入的uri和client类的各种属性组合,然后使用这些属性生成一个新的类 Promise 类。
请求的发起
Client的各种属性组装完成后就可以使用得到的Promise类发起http请求了,这里主要是通过一个 wait() 方法。
同步调用与异步调用
在同步方法内部的调用,同步方法是在内部组装好一个Promise之后立刻发起wait()调用。
public function send(RequestInterface $request, array $options = []){$options[RequestOptions::SYNCHRONOUS] = true;return $this->sendAsync($request, $options)->wait();}
wait的实现
wait() 方法的实现逻辑也很简单,递归调用wait()方法,直到result属性不是PromiseInterface实现类或者state不是pending,然后将结果逐层输出。这里说一下这个state的pending状态,这是一个PromiseInterface实现类的初始化状态,表示改实现类还没有完成,需要继续wait。
public function wait($unwrap = true){$this->waitIfPending();$inner = $this->result instanceof PromiseInterface? $this->result->wait($unwrap): $this->result;if ($unwrap) {if ($this->result instanceof PromiseInterface|| $this->state === self::FULFILLED) {return $inner;} else {// It's rejected so "unwrap" and throw an exception.throw exception_for($inner);}}}
waitIfPending() : 如果promise类还处于pending状态就执行。主要是执行改实现类的waitFn方法。最外层promise执行完成后执行`queue()->run() ``` 这个方法内部循环执行队列内方法,直到队列为空。至此,Guzzle就能将组装进来的多个request,和各种方法执行完毕。
private function waitIfPending(){if ($this->state !== self::PENDING) {return;} elseif ($this->waitFn) {$this->invokeWaitFn();} elseif ($this->waitList) {$this->invokeWaitList();} else {// If there's not wait function, then reject the promise.$this->reject('Cannot wait on a promise that has '. 'no internal wait function. You must provide a wait '. 'function when constructing the promise to be able to '. 'wait on a promise.');}queue()->run();if ($this->state === self::PENDING) {$this->reject('Invoking the wait callback did not resolve the promise');}}public function run(){/** @var callable $task */while ($task = array_shift($this->queue)) {$task();}}
waitFn是什么
回到前面提到的transfer()
函数。
$handler = $options['handler'];
// 返回一个promise类,这个类有一个属性是waitFn
return Promise\promise_for($handler($request, $options));
这里我们看 KaTeX parse error: Expected group after '_' at position 100: …是 HandleStack->_̲_invoke、Redirec…fn($request, options);‘方法,经过前面的逐层处理,此时的options);` 方法,经过前面的逐层处理,此时的options);‘ 方法,经过前面的逐层处理,此时的fn就是HandleStack内部的Proxy包装的方法,无论使用哪种协议都会在各自的实现里实例化一个拥有waitFn的Promise的实例。
// curl的实现$promise = new Promise([$this, 'execute'],function () use ($id) {return $this->cancel($id);});
由此可以直到waitFn方法就是各自协议的实现类的请求发起方法。then() 方法会将promise本身再封装一层promise,并将原先的waitFn和then()的回调方法打包进waitFnList属性里。
queue() 是的入队时机
当请求执行完成后依次调用 processMessages()、promise->resolve()、settle()、FulfilledPromise->then(),将请求结果插入队列。
$queue->add(static function () use ($p, $value, $onFulfilled) {if ($p->getState() === self::PENDING) {try {$p->resolve($onFulfilled($value));} catch (\Throwable $e) {$p->reject($e);} catch (\Exception $e) {$p->reject($e);}}});
Guzzle中的异步请求相关推荐
- PHP guzzle异步请求数据,Guzzle中的异步请求
Guzzle中的异步请求 使用Guzzle发起异步请求 Guzzle是一个PHP的HTTP客户端,它在发起http请求时不仅可以同步发起,还可以异步发起. $client = new Client() ...
- php中jquery ajax请求参数,浅谈Jquery中Ajax异步请求中的async参数的作用
之前不知道这个参数的作用,上网找了前辈的博客,在此收录到自己的博客,希望能帮到更多的朋友: test.html asy.js function testAsync{ var temp; $.ajax( ...
- react中实现异步请求的方法一,react-thunk
写在前面: 在react中,dispatch是同步执行reducers生成新状态的,对于页面的操作没有问题:但是如果点击事件是请求了某个结果,需要等待结果响应后再更新视图呢?应该如何处理?这里就用到了 ...
- @async 没有异步_扒一扒VueCLI3.0中Axios异步请求同步化
前台经常会遇到请求同步和异步的问题,今天咱们来聊一聊vue中同步请求和异步请求那些事儿. 说到接口的请求同步和异步问题,最早接触Ajax中就存在,Ajax传递的参数有一个async,默认情况下是fal ...
- html中的异步请求数据格式,解决layui中table异步数据请求不支持自定义返回数据格式的问题...
使用版本 layui-v2.3.0 修改: 打开layui中table.js源码 在 Class.prototype.pullData 这个方法定义内部 //获得数据 Class.prototype. ...
- SpringMVC中的异步请求-跨域访问
发送异步请求: <%@page pageEncoding="UTF-8" language="java" contentType="text/h ...
- CAT中实现异步请求的调用链查看
CAT简介 CAT(Central Application Tracking),是美团点评基于 Java 开发的一套开源的分布式实时监控系统.美团点评基础架构部希望在基础存储.高性能通信.大规模在线访 ...
- jax-rs jax-ws_在JAX-RS中处理异步请求中的超时
jax-rs jax-ws JAX-RS 2.0在客户端和服务器端都支持异步编程范例. 这篇文章重点介绍了使用JAX-RS(2.0)API在服务器端执行异步REST请求时的超时功能 无需过多介绍,这里 ...
- 在JAX-RS中处理异步请求中的超时
JAX-RS 2.0在客户端和服务器端都支持异步编程范例. 这篇文章重点介绍了使用JAX-RS(2.0)API在服务器端执行异步REST请求时的超时功能 无需过多介绍,这里是一个快速概述. 为了以异步 ...
- 异步请求中jetty处理ServletRequestListener的坑
标题起得比较诡异,其实并不是坑,而是jetty似乎压根就没做对异步request的ServletRequestListener的特殊处理,如果文中有错误欢迎提出,可能自己有所疏漏了. 之前遇到了一个b ...
最新文章
- Linux 命令(记录)
- Flask----SQLAlchemy
- 利用JDK工具进行系统性能监测
- 终端服务器超过了 最大连接数
- app inventor离线版_小鸡漫画app手机版下载_小鸡漫画好看的漫画手机版下载
- 三国杀服务器改名 插图修改,《三国杀》大幅修改的武将——新旧两版,你更喜欢哪一位...
- 多个pdf合并成一个pdf_十秒教你将多个PDF如何合并成一个PDF
- 构建嵌入式LINUX的NFS【ZT】
- C# 6.0 新特性
- Android RxJava
- Angr安装与使用之使用篇(十三)
- 桃李春风一杯酒,江湖夜雨十年灯。—第十一天
- UG二次开发-程序视图根组
- PDF转换成Word转换器在线转换效果如何
- android自定义播放器按钮,android – 使用exo播放器添加全屏视频按钮
- 奥运五环的绘制-进阶
- Python-random函数用法
- 国产猫粮高端化难题不少,网易天成拿什么出众?
- Linux小技巧--提高cpu使用率
- Python字符串格式化的3种方法
热门文章
- kindle中html笔记,Kindle教程:如何导出笔记
- ASP.NET 5 Target framework dnx451 and dnxcore50
- 人脸识别技术及其各种用例
- CTID易捷开放平台赋能小微企业完成网络身份认证服务
- 采用汇编语言对c语言函数调用的方法求平均数 汇编实验报告,汇编措辞调用C措辞求平均数.doc...
- 软著申请模板,帮助了不少小伙伴少走弯路
- Ubuntu扩展系统根目录磁盘空间
- TikTok是圣诞节全球下载量最高的应用;奇瑞汽车连续18年保持中国品牌乘用车出口量第一 | 美通社头条...
- 某年的月初月末时间戳获取
- 精彩泄漏截图 2006最值得期待的游戏