swlib / saber
Swoole coroutine HTTP client
Installs: 124 322
Dependents: 33
Suggesters: 1
Security: 0
Stars: 979
Watchers: 40
Forks: 124
Open Issues: 28
Requires
- php: >=7.1
- swlib/http: ^1.0
- swlib/util: ^1.0
Requires (Dev)
- phpunit/phpunit: ~7
This package is auto-updated.
Last update: 2024-10-26 03:58:04 UTC
README
简介
HTTP军刀(呆毛王), Swoole人性化组件库
之PHP高性能HTTP客户端, 基于Swoole原生协程, 支持多种风格操作, 底层提供高性能解决方案, 让开发者专注于功能开发, 从传统同步阻塞且配置繁琐的Curl中解放.
- 基于Swoole协程Client开发
- 人性化使用风格, ajax.js/axios.js/requests.py用户福音, 同时支持PSR风格操作
- 浏览器级别完备的Cookie管理机制, 完美适配爬虫/API代理应用
- 请求/响应/异常拦截器
- 多请求并发, 并发重定向优化
- 连接池, 自动化复用长连接
- 通道池(Chan): 最大连接数限制+无阻塞
- HTTPS连接, CA证书自动化支持
- HTTP/Socks5 Proxy支持
- WebSocket连接支持
- 毫秒级超时定时器
- 自动化 编码请求/解析响应 数据
- 响应报文自动编码转换
- 异步超大文件上传/下载, 断点重传
- 自动重试机制
- 单次并发数控制
- 多模式/超细粒度异常处理机制
- (=)浏览器级别缓存机制
- (=)随机UA生成器
安装
最好的安装方法是通过 Composer 包管理器 :
composer require swlib/saber
依赖
- PHP71 or later
- Swoole 2.1.2 or later
- Swoole 4 is the best
协程调度
Swoole底层实现协程调度, 业务层无需感知, 开发者可以无感知的用同步的代码编写方式达到异步IO的效果和超高性能,避免了传统异步回调所带来的离散的代码逻辑和陷入多层回调中导致代码无法维护.
需要在onRequet
, onReceive
, onConnect
等事件回调函数中使用, 或是使用go关键字包裹 (swoole.use_shortname
默认开启).
go(function () { echo SaberGM::get('http://httpbin.org/get'); })
目录
例子
静态方法
数据自动打包: 传入的data会自动转换成content-type所指定的类型格式
默认为
x-www-form-urlencoded
, 也支持json
等其它格式
SaberGM
:= Saber Global Manager
, 如果觉得类名有点长, 可以使用class_alias
自己取别名, 推荐服务中使用生成实例的方式使用, 而把SaberGM
作为快捷方式.
SaberGM::get('http://httpbin.org/get'); SaberGM::delete('http://httpbin.org/delete'); SaberGM::post('http://httpbin.org/post', ['foo' => 'bar']); SaberGM::put('http://httpbin.org/put', ['foo' => 'bar']); SaberGM::patch('http://httpbin.org/patch', ['foo' => 'bar']);
生成实例
适用API代理服务
$saber = Saber::create([ 'base_uri' => 'http://httpbin.org', 'headers' => [ 'Accept-Language' => 'en,zh-CN;q=0.9,zh;q=0.8', 'Content-Type' => ContentType::JSON, 'DNT' => '1', 'User-Agent' => null ] ]); echo $saber->get('/get'); echo $saber->delete('/delete'); echo $saber->post('/post', ['foo' => 'bar']); echo $saber->patch('/patch', ['foo' => 'bar']); echo $saber->put('/put', ['foo' => 'bar']);
生成会话
Session会自动保存cookie信息, 其实现是浏览器级别完备的
$session = Saber::session([ 'base_uri' => 'http://httpbin.org', 'redirect' => 0 ]); $session->get('/cookies/set?foo=bar&k=v&apple=banana'); $session->get('/cookies/delete?k'); echo $session->get('/cookies')->body;
并发请求
注意: 此处使用了并发重定向优化方案, 多个重定向总是依旧并发的而不会退化为队列的单个请求
$responses = SaberGM::requests([ ['uri' => 'http://github.com/'], ['uri' => 'http://github.com/'], ['uri' => 'https://github.com/'] ]); echo "multi-requests [ {$responses->success_num} ok, {$responses->error_num} error ]:\n" ."consuming-time: {$responses->time}s\n"; // multi-requests [ 3 ok, 0 error ]: // consuming-time: 0.79090881347656s
// 别名机制可以省略参数书写参数名 $saber = Saber::create(['base_uri' => 'http://httpbin.org']); echo $saber->requests([ ['get','/get'], ['post','/post'], ['patch','/patch'], ['put','/put'], ['delete','/delete'] ]);
数据解析
目前支持json
,xml
,html
,url-query
四种格式的数据快速解析
[$json, $xml, $html] = SaberGM::list([ 'uri' => [ 'http://httpbin.org/get', 'http://www.w3school.com.cn/example/xmle/note.xml', 'http://httpbin.org/html' ] ]); var_dump($json->getParsedJsonArray()); var_dump($json->getParsedJsonObject()); var_dump($xml->getParsedXmlArray()); var_dump($xml->getParsedXmlObject(true)); var_dump($html->getParsedDomObject()->getElementsByTagName('h1')->item(0)->textContent);
网络代理
支持HTTP和SOCKS5代理
$uri = 'http://myip.ipip.net/'; echo SaberGM::get($uri, ['proxy' => 'http://127.0.0.1:1087'])->body; echo SaberGM::get($uri, ['proxy' => 'socks5://127.0.0.1:1086'])->body;
文件上传
底层自动协程调度, 可支持异步发送超大文件, 断点续传
同时上传三个文件(三种参数风格
string
|array
|object
)
$file1 = __DIR__ . '/black.png'; $file2 = [ 'path' => __DIR__ . '/black.png', 'name' => 'white.png', 'type' => ContentType::MAP['png'], 'offset' => null, //re-upload from break 'size' => null //upload a part of the file ]; $file3 = new SwUploadFile( __DIR__ . '/black.png', 'white.png', ContentType::MAP['png'] ); echo SaberGM::post('http://httpbin.org/post', null, [ 'files' => [ 'image1' => $file1, 'image2' => $file2, 'image3' => $file3 ] ] );
超大文件下载
Download收到数据后会直接异步写入到磁盘, 而不是在内存中对HttpBody进行拼接. 因此download仅使用小量内存, 就可以完成超大文件的下载. 且支持断点续传, 通过设置offset参数来进行断点下载.
异步下载Saber壁纸
$download_dir = '/tmp/saber.jpg'; $response = SaberGM::download( 'https://ws1.sinaimg.cn/large/006DQdzWly1fsr8jt2botj31hc0wxqfs.jpg', $download_dir ); if ($response->success) { exec('open ' . $download_dir); }
自动重试
在爬虫项目中, 请求失败自动重试是非常常见的需求, 比如会话过期后重新登录.
而Saber
内置了此功能, 并可使用拦截器
来强化它.
如未设置retry_time
而设置了retry
拦截器, 则retry_time
会置为1, 如retry
拦截器的回调方法返回了false
, 无论retry_time
是多少, 都会在返回false
时终止重试.
$uri = 'http://eu.httpbin.org/basic-auth/foo/bar'; $res = SaberGM::get( $uri, [ 'exception_report' => 0, 'retry_time' => 3, 'retry' => function (Saber\Request $request) { echo "retry...\n"; $request->withBasicAuth('foo', 'bar'); //发现失败后添加验证信息 if ('i don not want to retry again') { return false; // shutdown } } ] ); echo $res;
缓存机制
有时候HTTP资源并不会总是变更, 我们可以学习浏览器缓存不会变动的资源, 来加快请求效率, 由Saber
自动化地完成且不必自己维护缓存逻辑(CURD或文件读写), 协程的调度使得其不论如何都不会阻塞服务器, Saber
没有使用中间件机制因为它和Swoole是强相关的, 但是缓存可以使用 内存/文件/数据库
等多种方式, 所以虽然它尚未实现, 但它将会列入Saber
的后续路线图中.
PSR风格
$bufferStream = new BufferStream(); $bufferStream->write(json_encode(['foo' => 'bar'])); $response = SaberGM::psr() ->withMethod('POST') ->withUri(new Uri('http://httpbin.org/post?foo=bar')) ->withQueryParams(['foo' => 'option is higher-level than uri']) ->withHeader('content-type', ContentType::JSON) ->withBody($bufferStream) ->exec()->recv(); echo $response->getBody();
WebSocket
可以通过websocketFrame数据帧的__toString方法直接打印返回数据字符串
$websocket = SaberGM::websocket('ws://127.0.0.1:9999'); while (true) { echo $websocket->recv(1) . "\n"; $websocket->push("hello"); co::sleep(1); }
极限压力测试
测试机器为最低配MacBookPro, 请求服务器为本地echo服务器
0.9秒完成6666个请求, 成功率100%.
co::set(['max_coroutine' => 8191]); go(function () { $requests = []; for ($i = 6666; $i--;) { $requests[] = ['uri' => 'http://127.0.0.1']; } $res = SaberGM::requests($requests); echo "use {$res->time}s\n"; echo "success: $res->success_num, error: $res->error_num"; }); // on MacOS // use 0.91531705856323s // success: 6666, error: 0
列式请求集
在实际项目中, 经常会存在使用URL列表来配置请求的情况, 因此提供了list方法来方便使用:
echo SaberGM::list([ 'uri' => [ 'https://www.qq.com/', 'https://www.baidu.com/', 'https://www.swoole.com/', 'http://httpbin.org/' ] ]);
单次并发控制
在实际爬虫项目中, 我们往往要限制单次并发请求数量以防被服务器防火墙屏蔽, 而一个max_co
参数就可以轻松地解决这个问题, max_co
会将请求根据上限量分批将请求压入队列并执行收包.
// max_co is the max number of concurrency request once, it's very useful to prevent server-waf limit. $requests = array_fill(0, 10, ['uri' => 'https://www.qq.com/']); echo SaberGM::requests($requests, ['max_co' => 5])->time."\n"; echo SaberGM::requests($requests, ['max_co' => 1])->time."\n";
高性能无极限协程连接池
在常驻内存的服务器中使用时, 一定要手动开启连接池选项:
$swoole = Saber::create([ 'base_uri' => 'https://www.swoole.com/', 'use_pool' => true ]);
在通过该实例使用时, 就会启用连接池特性, 即底层与www.swoole.com
网站的连接客户端将会用一个全局连接池存取, 避免了每次使用创建/连接的开销.
无限连接池
在参数为true
时, 该网站的连接池容量是无限的, 一般情况下没有问题, 且无限容量的连接池性能更好.
定容连接池
但如果你使用其作为爬虫代理服务, 遭遇大量请求时, 连接池中的客户端数量就会不可控制地快速上升, 甚至超出你所请求的源网站的最大允许连接数, 这时候你就需要将use_pool
设置为一个理想数值(int), 此时, 底层会使用Channel作为连接池, 在连接池创建的客户端超出数量且不够取用时, 挂起需要取用客户端的协程, 并等待正在使用客户端的协程归还客户端, 协程等待和切换几乎没有多大的性能消耗, 是一种非常先进的解决方式.
动态变容
需要注意的是, 连接池是绑定服务器IP+端口
的, 即如果你有多个实例面向的是同一个服务器IP+端口
, 他们之间使用的连接池也是同一个.
所以你在重复创建服务器IP+端口
的实例时, 新创建的实例指定的use_pool
是允许覆盖之前数值的, 即连接池底层是自动变容的, 容量增加时底层会重新创建新的连接池并转移客户端, 容量减少时也会销毁在连接池内的多余的客户端.
注意事项
注册你所希望的配置
除了一定要记得配备连接池以外, 异常处理的方式也需要注意是符合你的编程习惯的, Saber
默认的异常处理是最主流且严谨的抛出异常
, 但Saber
也支持静默地使用错误码
和状态位
, 可能更符合很多人的口味.
SaberGM::exceptionReport(0); // 关闭抛出异常报告, 在业务代码之前注册即可全局生效 $saber->exceptionReport(0); //也可以单独设置某个实例
同理, 你所希望的配置都可以在业务代码之前如onWorkerStart
甚至是swoole_server
启动之前预先配置.
SaberGM::default([ 'exception_report' => 0 'use_pool' => true ]);
像这样配置你所期望的选项可以让你获得更好的使用体验!
注意在一次性脚本中释放连接池
go(function(){ // your code with pool... saber_pool_release(); // and this script will exit });
如果你在一次性脚本中使用的连接池, 由于协程客户端是存在池中的, 引用计数为1无法释放, 就会导致swoole一直处于事件循环中, 脚本就无法退出, 你需要手动调用saber_pool_release
或saber_exit
或swoole_event_exit
来正常退出, 也可以使用exit强制退出当前脚本(不要在server中使用exit).
配置参数表
|
符号分割多种可选值
配置参数别名
为了使用方便与容错, 配置项的键值具有别名机制, 建议尽量使用本名:
拦截器
拦截器是Saber的一个非常强大的特性, 它可以让你非常方便地处理各种事情, 比如打印dev日志:
SaberGM::get('http://twosee.cn/', [ 'before' => function (Saber\Request $request) { $uri = $request->getUri(); echo "log: request $uri now...\n"; }, 'after' => function (Saber\Response $response) { if ($response->success) { echo "log: success!\n"; } else { echo "log: failed\n"; } echo "use {$response->time}s"; } ]); // log: request http://twosee.cn/ now... // log: success! // use 0.52036285400391s
甚至连异常自定义处理函数
,会话
都是通过拦截器来实现的.
拦截器可以有多个, 会依照注册顺序执行, 并且你可以为拦截器命名, 只需要使用数组包裹并指定key值, 如果你要删除这个拦截器, 给它覆盖一个null值即可.
[ 'after' => [ 'interceptor_new' => function(){}, 'interceptor_old' => null ] ]
拦截器可以使用四种方式注册(4种PHP回调函数):
callable: function(){} string: 'function_name' string: 'ClassName::method_name' array: [$object, 'method_name']
Cookies
Cookie的实现是浏览器级别完备的, 它具体参考了Chrome浏览器的实现, 并遵循其相关规则.
属性
Cookies是一堆Cookie的集合, 而每个Cookie具有以下属性:
name
, value
, expires
, path
, session
, secure
, httponly
, hostonly
任意格式互转
并且Cookies类支持多种格式互转, 如
-
foo=bar; foz=baz; apple=banana
-
Set-Cookie: logged_in=no; domain=.github.com; path=/; expires=Tue, 06 Apr 2038 00:00:00 -0000; secure; HttpOnly
-
['foo'=>'bar', 'foz'=>'baz']
等格式转到Cookie类, 或是Cookie类到该几种格式的序列化.
域名路径和过期时限校验
Cookie也支持域名和时限校验, 不会丢失任何信息, 如domain是github.com
cookie, 不会出现在help.github.com
, 除非domain不是hostonly的(.github.com
通配).
如果是session-cookie(没有过期时间,浏览器关闭则过期的), expires属性会设置为当前时间, 你可以通过拦截器来对其设置具体的时间.
持久化存储
通过读取Cookies的raw属性, 可以轻松地将其持久化到数据库中, 非常适合登录类爬虫应用.
更多详情具体请参考Swlib/Http库文档和例子.
异常机制
Saber遵循将业务与错误分离的守则, 当请求任意环节失败时, 默认都将会抛出异常.
强大的是, Saber的异常处理也是多样化的, 且和PHP的原生的异常处理一样完善.
异常的命名空间位于Swlib\Http\Exception
除一般异常方法外, 所有HTTP异常类还拥有以下方法 :
捕获例子
try { echo SaberGM::get('http://httpbin.org/redirect/10'); } catch (TooManyRedirectsException $e) { var_dump($e->getCode()); var_dump($e->getMessage()); var_dump($e->hasResponse()); echo $e->getRedirectsTrace(); } // int(302) // string(28) "Too many redirects occurred!" // bool(true) #0 http://httpbin.org/redirect/10 #1 http://httpbin.org/relative-redirect/9 #2 http://httpbin.org/relative-redirect/8
异常报告级别控制
同时, Saber亦支持以温和的方式来对待异常, 以免使用者陷入在不稳定的网络环境下, 必须在每一步都使用try包裹代码的恐慌中:
设定errorReport级别, 它是全局生效的, 对已创建的实例不会生效.
// 启用所有异常但忽略重定向次数过多异常 SaberGM::exceptionReport( HttpExceptionMask::E_ALL ^ HttpExceptionMask::E_REDIRECT );
掩码表
下面的值(数值或者符号)用于建立一个二进制位掩码,来制定要报告的错误信息。可以使用按位运算符来组合这些值或者屏蔽某些类型的错误。标志位与掩码
异常自定义处理函数
本函数可以用你自己定义的方式来处理HTTP请求中产生的错误, 可以更加随心所欲地定义你想要捕获/忽略的异常.
注意: 除非函数返回 TRUE (或其它真值),否则异常会继续抛出而不是被自定义函数捕获.
SaberGM::exceptionHandle(function (\Exception $e) { echo get_class($e) . " is caught!"; return true; }); SaberGM::get('http://httpbin.org/redirect/10'); //output: Swlib\Http\Exception\TooManyRedirectsException is caught!
Road Map
Why not Http2 ?
As the main HTTP/2 benefit is that it allows multiplexing many requests within a single connection, thus [almost] removing the limit on number of simultaneous requests - and there is no such limit when talking to your own backends. Moreover, things may even become worse when using HTTP/2 to backends, due to single TCP connection being used instead of multiple ones, so Http2 Will not be a priority. (#ref)
IDE Helper
将本项目源文件加入到IDE的 Include Path
中.
(使用composer安装,则可以包含整个vendor文件夹, PHPStorm会自动包含)
良好的注释书写使得Saber完美支持IDE自动提示, 只要在对象后书写箭头符号即可查看所有对象方法名称, 名称都十分通俗易懂, 大量方法都遵循PSR规范或是参考Guzzle项目(感谢)而实现.
对于底层Swoole相关类的IDE提示则需要引入eaglewu的swoole-ide-helper(composer在dev环境下会默认安装), 但是该项目为手动维护, 不太完整, 也可以使用swoft-ide-helper或:
Swoole官方的ide-helper.
重中之重
欢迎提交issue和PR.
附录
Saber API
由于无法在魔术方法中使用协程(__call, __callStatic), 源码中的方法都是手动定义.
为了使用方便,已为所有支持的请求方法提供了别名。
Swlib\SaberGM
public static function psr(array $options = []): Swlib\Saber\Request public static function wait(): Swlib\Saber public static function request(array $options = []) public static function get(string $uri, array $options = []) public static function delete(string $uri, array $options = []) public static function head(string $uri, array $options = []) public static function options(string $uri, array $options = []) public static function post(string $uri, $data = null, array $options = []) public static function put(string $uri, $data = null, array $options = []) public static function patch(string $uri, $data = null, array $options = []) public static function download(string $uri, string $dir, int $offset, array $options = []) public static function requests(array $requests, array $default_options = []): Swlib\Saber\ResponseMap public static function list(array $options, array $default_options = []): Swlib\Saber\ResponseMap public static function websocket(string $uri) public static function default(?array $options = null): array public static function exceptionReport(?int $level = null): int public static function exceptionHandle(callable $handle): void
Swlib\Saber
public static function create(array $options = []): self public static function session(array $options = []): self public static function websocket(string $uri): WebSocket public function request(array $options) public function get(string $uri, array $options = []) public function delete(string $uri, array $options = []) public function head(string $uri, array $options = []) public function options(string $uri, array $options = []) public function post(string $uri, $data = null, array $options = []) public function put(string $uri, $data = null, array $options = []) public function patch(string $uri, $data = null, array $options = []) public function download(string $uri, string $dir, int $offset, array $options = []) public function requests(array $requests, array $default_options = []): ResponseMap public function list(array $options, array $default_options = []): ResponseMap public function upgrade(?string $path = null): WebSocket public function psr(array $options = []): Request public function wait(): self public function exceptionReport(?int $level = null): int public function exceptionHandle(callable $handle): void public static function getAliasMap(): array public function setOptions(array $options = [], ?Swlib\Saber\Request $request = null): self public static function getDefaultOptions(): array public static function setDefaultOptions(array $options = [])
Swlib\Saber\Request
public function getExceptionReport(): int public function setExceptionReport(int $level): self public function isWaiting(): bool public function getPool() public function withPool($bool_or_max_size): self public function tryToRevertClientToPool(bool $connect_failed = false) public function getSSL(): int public function withSSL(int $mode = 2): self public function getCAFile(): string public function withCAFile(string $ca_file = __DIR__ . '/cacert.pem'): self public function getSSLCertFile(): string public function withSSLCertFile(string $cert_file): self public function getSSLKeyFile(): string public function withSSLKeyFile(string $key_file): self public function withSSLVerifyPeer(bool $verify_peer = false, ?string $ssl_host_name = ''): self public function withSSLAllowSelfSigned(bool $allow = true): self public function getSSLConf() public function getKeepAlive() public function withKeepAlive(bool $enable): self public function withBasicAuth(?string $username = null, ?string $password = null): self public function withXHR(bool $enable = true) public function getProxy(): array public function withProxy(string $host, int $port): self public function withSocks5(string $host, int $port, ?string $username, ?string $password): self public function withoutProxy(): self public function getBindAddress(): ?string public function withBindAddress(string $address): self public function getBindPort(): ?int public function withBindPort(int $port): self public function getTimeout(): float public function withTimeout(float $timeout): self public function getRedirect(): int public function getName() public function withName($name): self public function withRedirect(int $time): self public function isInQueue(): bool public function withInQueue(bool $enable): self public function getRetryTime(): int public function withRetryTime(int $time): self public function withAutoIconv(bool $enable): self public function withExpectCharset(string $source = 'auto', string $target = 'utf-8', bool $use_mb = false): self public function withDownloadDir(string $dir): self public function withDownloadOffset(int $offset): self public function resetClient($client) public function exec() public function recv() public function getRequestTarget(): string public function withRequestTarget($requestTarget): self public function getMethod(): string public function withMethod($method): self public function getUri(): Psr\Http\Message\UriInterface public function withUri(?Psr\Http\Message\UriInterface $uri, $preserveHost = false): self public function getCookieParams(): array public function getCookieParam(string $name): string public function withCookieParam(string $name, ?string $value): self public function withCookieParams(array $cookies): self public function getQueryParam(string $name): string public function getQueryParams(): array public function withQueryParam(string $name, ?string $value): self public function withQueryParams(array $query): self public function getParsedBody(?string $name = null) public function withParsedBody($data): self public function getUploadedFile(string $name): Psr\Http\Message\UploadedFileInterface public function getUploadedFiles(): array public function withUploadedFile(string $name, ?Psr\Http\Message\UploadedFileInterface $uploadedFile): self public function withoutUploadedFile(string $name): self public function withUploadedFiles(array $uploadedFiles): self public function __toString() public function getProtocolVersion(): string public function withProtocolVersion($version): self public function hasHeader($name): bool public function getHeader($name): array public function getHeaderLine($name): string public function getHeaders(bool $implode = false, bool $ucwords = false): array public function getHeadersString(bool $ucwords = true): string public function withHeader($raw_name, $value): self public function withHeaders(array $headers): self public function withAddedHeaders(array $headers): self public function withAddedHeader($raw_name, $value): self public function withoutHeader($name): self public function getBody(): Psr\Http\Message\StreamInterface public function withBody(?Psr\Http\Message\StreamInterface $body): self public function getCookies() public function setCookie(array $options): self public function unsetCookie(string $name, string $path = '', string $domain = ''): self public function withInterceptor(string $name, array $interceptor) public function withAddedInterceptor(string $name, array $functions): self public function withoutInterceptor(string $name): self public function callInterceptor(string $name, $arguments) public function getSpecialMark(string $name = 'default') public function withSpecialMark($mark, string $name = 'default'): self
Swlib\Saber\Response
public function isSuccess(): bool public function getUri(): Psr\Http\Message\UriInterface public function getTime(): float public function getRedirectHeaders(): array public function getStatusCode() public function withStatus($code, $reasonPhrase = '') public function getReasonPhrase() public function __toString() public function getProtocolVersion(): string public function withProtocolVersion($version): self public function hasHeader($name): bool public function getHeader($name): array public function getHeaderLine($name): string public function getHeaders(bool $implode = false, bool $ucwords = false): array public function getHeadersString(bool $ucwords = true): string public function withHeader($raw_name, $value): self public function withHeaders(array $headers): self public function withAddedHeaders(array $headers): self public function withAddedHeader($raw_name, $value): self public function withoutHeader($name): self public function getBody(): Psr\Http\Message\StreamInterface public function withBody(?Psr\Http\Message\StreamInterface $body): self public function getCookies() public function setCookie(array $options): self public function unsetCookie(string $name, string $path = '', string $domain = ''): self public function getSpecialMark(string $name = 'default') public function withSpecialMark($mark, string $name = 'default'): self public function getParsedJsonArray(bool $reParse = false): array public function getParsedJsonObject(bool $reParse = false): object public function getParsedQueryArray(bool $reParse = false): array public function getParsedXmlArray(bool $reParse = false): array public function getParsedXmlObject(bool $reParse = false): SimpleXMLElement public function getParsedDomObject(bool $reParse = false): DOMDocument public function getDataRegexMatch(string $regex, $group = null, int $fill_size) public function getDataRegexMatches(string $regex, int $flag): array public function isExistInData(string $needle, int $offset)
Swlib\Saber\RequestQueue
public function enqueue($request) public function getMaxConcurrency(): int public function withMaxConcurrency(int $num = -1): self public function recv(): Swlib\Saber\ResponseMap public function withInterceptor(string $name, array $interceptor) public function withAddedInterceptor(string $name, array $functions): self public function withoutInterceptor(string $name): self public function callInterceptor(string $name, $arguments)
Swlib\Saber\ResponseMap
public $time = 0.0; public $status_map = []; public $success_map = []; public $success_num = 0; public $error_num = 0; public function offsetSet($index, $response) public function __toString()
Swlib\Saber\WebSocket
public function withMock(bool $ssl): self public function recv(float $timeout = -1) public function push(string $data, int $opcode = 1, bool $finish = true): bool public function close(): bool
Swlib\Saber\WebSocketFrame
public $finish = true; public $opcode = null; public $data = null; public function getOpcodeDefinition() public function getOpcode() public function getData() public function __toString()