PHPackages                             dybee/saber - PHPackages - PHPackages  [Skip to content](#main-content)[PHPackages](/)[Directory](/)[Categories](/categories)[Trending](/trending)[Leaderboard](/leaderboard)[Changelog](/changelog)[Analyze](/analyze)[Collections](/collections)[Log in](/login)[Sign up](/register)

1. [Directory](/)
2. /
3. [HTTP & Networking](/categories/http)
4. /
5. dybee/saber

ActiveLibrary[HTTP & Networking](/categories/http)

dybee/saber
===========

Swoole coroutine HTTP client

v2.0.2(2y ago)0173Apache-2.0PHPPHP >=7.1

Since Jul 25Pushed 2y agoCompare

[ Source](https://github.com/doyu2020/saber)[ Packagist](https://packagist.org/packages/dybee/saber)[ RSS](/packages/dybee-saber/feed)WikiDiscussions v1.x Synced 1mo ago

READMEChangelog (1)Dependencies (3)Versions (4)Used By (0)

Saber
=====

[](#saber)

[![Latest Version](https://camo.githubusercontent.com/899c298b006b03502e2b28c609a3d4827ed4d1741e5591ffc656737e5c57cbd3/68747470733a2f2f696d672e736869656c64732e696f2f6769746875622f72656c656173652f73776c69622f73616265722e737667)](https://github.com/swlib/saber/releases)[![PHPUnit for Saber](https://github.com/swlib/saber/workflows/PHPUnit%20for%20Saber/badge.svg)](https://github.com/swlib/saber/actions)[![Php Version](https://camo.githubusercontent.com/c197ef1e57a32c886b2a54d02ead7dbc035f18b3f39a642703b9372eef7819f9/68747470733a2f2f696d672e736869656c64732e696f2f62616467652f7068702d2533453d372e312d627269676874677265656e2e7376673f6d61784167653d32353932303030)](https://secure.php.net/)[![Swoole Version](https://camo.githubusercontent.com/5f51ec804098b72ea73375ef1e26431790778149effa36ffe807f0e251d34d8c/68747470733a2f2f696d672e736869656c64732e696f2f62616467652f73776f6f6c652d2533453d322e312e322d627269676874677265656e2e7376673f6d61784167653d32353932303030)](https://github.com/swoole/swoole-src)[![Saber License](https://camo.githubusercontent.com/1c419f89412ea6c234c184ad6d85decb127c18584858d3707ae7d8e2131eccc4/68747470733a2f2f696d672e736869656c64732e696f2f686578706d2f6c2f706c75672e7376673f6d61784167653d32353932303030)](https://github.com/swlib/saber/blob/master/LICENSE)

简介
--

[](#简介)

HTTP军刀(呆毛王), `Swoole人性化组件库`之PHP高性能HTTP客户端, 基于Swoole原生协程, 支持多种风格操作, 底层提供高性能解决方案, 让开发者专注于功能开发, 从传统同步阻塞且配置繁琐的Curl中解放.

> **[English Document](./README-EN.md)**

- 基于Swoole协程Client开发
- 人性化使用风格, ajax.js/axios.js/requests.py用户福音, 同时支持PSR风格操作
- 浏览器级别完备的Cookie管理机制, 完美适配爬虫/API代理应用
- 请求/响应/异常拦截器
- 多请求并发, 并发重定向优化
- 连接池, 自动化复用长连接
- 通道池(Chan): 最大连接数限制+无阻塞
- HTTPS连接, CA证书自动化支持
- HTTP/Socks5 Proxy支持
- WebSocket连接支持
- 毫秒级超时定时器
- 自动化 编码请求/解析响应 数据
- 响应报文自动编码转换
- 异步超大文件上传/下载, 断点重传
- 自动重试机制
- 单次并发数控制
- 多模式/超细粒度异常处理机制
- (=)浏览器级别缓存机制
- (=)随机UA生成器

---

安装
--

[](#安装)

最好的安装方法是通过 [Composer](http://getcomposer.org/) 包管理器 :

```
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');
})
```

---

目录
--

[](#目录)

- [例子](#例子)
    - [静态方法](#静态方法)
    - [生成实例](#生成实例)
    - [生成会话](#生成会话)
    - [并发请求](#并发请求)
    - [数据解析](#数据解析)
    - [网络代理](#网络代理)
    - [文件上传](#文件上传)
    - [超大文件下载](#超大文件下载)
    - [自动重试](#自动重试)
    - [缓存机制](#缓存机制)
    - [PSR风格](#psr风格)
    - [WebSocket](#websocket)
    - [极限压力测试](#极限压力测试)
    - [列式请求集](#列式请求集)
    - [单次并发控制](#单次并发控制)
    - [高性能无极限协程连接池](#高性能无极限协程连接池)
        - [无限连接池](#无限连接池)
        - [定容连接池](#定容连接池)
        - [动态变容](#动态变容)
- [注意事项](#注意事项)
    - [注册你所希望的配置](#注册你所希望的配置)
        - [注意在一次性脚本中释放连接池](#注意在一次性脚本中释放连接池)
- [配置参数表](#配置参数表)
    - [配置参数别名](#配置参数别名)
- [拦截器](#拦截器)
- [Cookies](#cookies)
    - [属性](#属性)
    - [任意格式互转](#任意格式互转)
    - [域名路径和过期时限校验](#域名路径和过期时限校验)
    - [持久化存储](#持久化存储)
- [异常机制](#异常机制)
    - [捕获例子](#捕获例子)
    - [异常报告级别控制](#异常报告级别控制)
        - [掩码表](#掩码表)
    - [异常自定义处理函数](#异常自定义处理函数)
- [Road Map](#road-map)
    - [Why not Http2 ?](#why-not-http2-)
- [IDE Helper](#ide-helper)
- [重中之重](#重中之重)
- [附录](#附录)
    - [Saber API](#saber-api)
        - [Swlib\\SaberGM](#swlibsabergm)
        - [Swlib\\Saber](#swlibsaber)
        - [Swlib\\Saber\\Request](#swlibsaberrequest)
        - [Swlib\\Saber\\Response](#swlibsaberresponse)
        - [Swlib\\Saber\\RequestQueue](#swlibsaberrequestqueue)
        - [Swlib\\Saber\\ResponseMap](#swlibsaberresponsemap)
        - [Swlib\\Saber\\WebSocket](#swlibsaberwebsocket)
        - [Swlib\\Saber\\WebSocketFrame](#swlibsaberwebsocketframe)

---

例子
--

[](#例子)

### 静态方法

[](#静态方法)

> 数据自动打包: 传入的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信息, 其实现是[**浏览器级别完备**](#cookies)的

```
$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风格

[](#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

[](#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).

---

配置参数表
-----

[](#配置参数表)

> `|`符号分割多种可选值

keytypeintroductionexampleremarkprotocol\_versionstringHTTP协议版本1.1HTTP2还在规划中base\_uristring基础路径`http://httpbin.org`将会与uri按照rfc3986合并uristring资源标识符`http://httpbin.org/get` | `/get` | `get`可以使用绝对路径和相对路径uri\_querystring|array请求信息`['foo' => 'bar']`非字符串会自动转换methodstring请求方法`get` | `post` | `head` | `patch` | `put` | `delete`底层自动转换为大写headersarray请求报头`['DNT' => '1']` | `['accept' => ['text/html'], ['application/xml']]`字段名不区分大小写, 但会保留设定时的原始大小写规则, 底层每个字段值会根据PSR-7自动分割为数组cookies`array`|`string``['foo '=> 'bar']` | `'foo=bar; foz=baz'`底层自动转化为Cookies对象, 并设置其domain为当前的uri, 具有[浏览器级别的完备属性](#cookies).useragentstring用户代理`curl-1.0`默认为macos平台的chromerefererstring来源地址`https://www.google.com`默认为空redirectint最大重定向次数5默认为3, 为0时不重定向.keep\_alivebool是否保持连接`true` | `false`默认为true, 重定向时会自动复用连接content\_typestring发送的内容编码类型`text/plain` | `Swlib\Http\ContentType::JSON`默认为application/x-www-form-urlencodeddata`array` | `string`发送的数据`'foo=bar&dog=cat'` |` ['foo' => 'bar']`会根据content\_type自动编码数据before`callable` | `array`请求前拦截器`function(Request $request){}`[具体参考拦截器一节](#%E6%8B%A6%E6%88%AA%E5%99%A8)after`callable` | `array`响应后拦截器`function(Response $response){}`[具体参考拦截器一节](#%E6%8B%A6%E6%88%AA%E5%99%A8)before\_redirect`callable` | `array`重定向后拦截器`function(Request $request, Response $response){}`[具体参考拦截器一节](#%E6%8B%A6%E6%88%AA%E5%99%A8)timeoutfloat超时时间0.5默认5s, 支持毫秒级超时bind\_addressstring绑定地址192.168.1.1 或 eth0默认不设置bind\_portint绑定端口80默认不设置proxystring代理`http://127.0.0.1:1087` | `socks5://127.0.0.1:1087`支持http和socks5sslint是否开启ssl连接`0=关闭` `1=开启` `2=自动`默认自动cafilestringca文件`__DIR__ . '/cacert.pem'`默认自带ssl\_verify\_peerbool验证服务器端证书`false` | `true`默认关闭ssl\_allow\_self\_signedbool允许自签名证书`true` | `false`默认允许ssl\_cert\_filestringcert 证书`__DIR__ . '/ssl.cert'`默认不设置ssl\_key\_filestringkey 私钥`__DIR__ . '/ssl.key'`默认不设置iconvarray指定编码转换`['gbk', 'utf-8']`共三个参数为`from,to,use_mb`, 默认自动识别exception\_reportint异常报告级别HttpExceptionMask::E\_ALL默认汇报所有异常exception\_handlecallable|array异常自定义处理函数`function(Exception $e){}`函数返回true时可忽略错误retrycallable自动重试拦截器`function(Request $request, Response $response){}`位于发生错误后及重试之前retry\_timeint自动重试次数默认不重试use\_poolbool|int连接池`true``false`pool\_keycallable|array连接池的key`function(Request $request):string { return $key; }`默认为请求地址的`host:port`### 配置参数别名

[](#配置参数别名)

为了使用方便与容错, 配置项的键值具有别名机制, 建议尽量使用本名:

keyaliasmethod0uri`1` | `url`data`2` | `body`base\_uribase\_urlaftercallbackcontent\_type`content-type` | `contentType`cookiescookieheadersheaderredirectfollowuseragent`ua` | `user-agent`exception\_report`error_report` | `report`before\_retryretryreferer`ref` | `referrer`
---

拦截器
---

[](#拦截器)

拦截器是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回调函数](http://twosee.cn/2018/01/04/PHP-callback/)):

```
callable: function(){}
string: 'function_name'
string: 'ClassName::method_name'
array: [$object, 'method_name']
```

---

Cookies
-------

[](#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](https://github.com/swlib/http/)库文档和例子.

---

异常机制
----

[](#异常机制)

Saber遵循将**业务与错误**分离的守则, 当请求任意环节失败时, **默认都将会抛出异常**.

强大的是, Saber的异常处理也是多样化的, 且和PHP的原生的异常处理一样完善.

异常的命名空间位于`Swlib\Http\Exception`

ExceptionIntrosceneRequestException请求失败请求配置错误ConnectException连接失败如无网络连接, DNS查询失败, 超时等, errno的值等于Linux errno。可使用swoole\_strerror将错误码转为错误信息。TooManyRedirectsException重定向次数超限重定向的次数超过了设定的限制, 抛出的异常将会打印重定向追踪信息ClientException客户端异常服务器返回了4xx错误码ServerException服务器异常服务器返回了5xx错误码BadResponseException未知的获取响应失败服务器无响应或返回了无法识别的错误码除一般异常方法外, 所有HTTP异常类还拥有以下方法 :

MethodIntrogetRequest获取请求实例hasResponse是否获得响应getResponse获取响应实例getResponseBodySummary获取响应主体的摘要内容#### 捕获例子

[](#捕获例子)

```
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://twosee.cn/2018/04/06/mask-code/)

MaskValueIntroE\_NONE0忽略所有异常E\_REQUEST1对应RequestExceptionE\_CONNECT2对应RequestExceptionE\_REDIRECT4对应RequestExceptionE\_BAD\_RESPONSE8对应BadRExceptionE\_CLIENT16对应ClientExceptionE\_SERVER32对应ServerExceptionE\_ALL63所有异常### 异常自定义处理函数

[](#异常自定义处理函数)

本函数可以用你自己定义的方式来处理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
--------

[](#road-map)

File Upload ✔WebSocket ✔AutoParser✔AutoRetry✔BigFile Download✔CacheClientPoolRandom UA4 (High-priority)321.5.5.5.175#### Why not Http2 ?

[](#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](https://www.zhihu.com/question/268666424/answer/347026835))

---

IDE Helper
----------

[](#ide-helper)

将本项目源文件加入到IDE的 `Include Path` 中.

(使用composer安装,则可以包含整个vendor文件夹, PHPStorm会自动包含)

良好的注释书写使得Saber完美支持IDE自动提示, 只要在对象后书写箭头符号即可查看所有对象方法名称, 名称都十分通俗易懂, 大量方法都遵循**PSR**规范或是参考[Guzzle](https://github.com/guzzle/guzzle)项目(感谢)而实现.

对于底层Swoole相关类的IDE提示则需要引入eaglewu的[swoole-ide-helper](https://github.com/eaglewu/swoole-ide-helper)(composer在dev环境下会默认安装), 但是该项目为手动维护, 不太完整, 也可以使用[swoft-ide-helper](https://github.com/swoft-cloud/swoole-ide-helper)或:

**Swoole官方的[ide-helper](https://github.com/swoole/ide-helper).**

---

重中之重
----

[](#重中之重)

**欢迎提交issue和PR.**

---

附录
--

[](#附录)

### Saber API

[](#saber-api)

> 由于无法在魔术方法中使用协程(\_\_call, \_\_callStatic), 源码中的方法都是手动定义.

为了使用方便，已为所有支持的请求方法提供了别名。

#### Swlib\\SaberGM

[](#swlibsabergm)

```
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

[](#swlibsaber)

```
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

[](#swlibsaberrequest)

```
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

[](#swlibsaberresponse)

```
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

[](#swlibsaberrequestqueue)

```
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

[](#swlibsaberresponsemap)

```
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

[](#swlibsaberwebsocket)

```
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

[](#swlibsaberwebsocketframe)

```
public $finish = true;
public $opcode = null;
public $data = null;
public function getOpcodeDefinition()
public function getOpcode()
public function getData()
public function __toString()
```

###  Health Score

22

—

LowBetter than 22% of packages

Maintenance20

Infrequent updates — may be unmaintained

Popularity10

Limited adoption so far

Community14

Small or concentrated contributor base

Maturity41

Maturing project, gaining track record

 Bus Factor1

Top contributor holds 78.1% of commits — single point of failure

How is this calculated?**Maintenance (25%)** — Last commit recency, latest release date, and issue-to-star ratio. Uses a 2-year decay window.

**Popularity (30%)** — Total and monthly downloads, GitHub stars, and forks. Logarithmic scaling prevents top-heavy scores.

**Community (15%)** — Contributors, dependents, forks, watchers, and maintainers. Measures real ecosystem engagement.

**Maturity (30%)** — Project age, version count, PHP version support, and release stability.

###  Release Activity

Cadence

Every ~4 days

Total

4

Last Release

1014d ago

Major Versions

v1.x-dev → v2.0.22023-08-07

### Community

Maintainers

![](https://www.gravatar.com/avatar/4074f28be23ee548d7d0740cb84d14c56d87719cf795866e6c2ddb070b1835ee?d=identicon)[doyu2020](/maintainers/doyu2020)

---

Top Contributors

[![twose](https://avatars.githubusercontent.com/u/25978241?v=4)](https://github.com/twose "twose (157 commits)")[![fdreamsu](https://avatars.githubusercontent.com/u/9639344?v=4)](https://github.com/fdreamsu "fdreamsu (16 commits)")[![sy-records](https://avatars.githubusercontent.com/u/33931153?v=4)](https://github.com/sy-records "sy-records (15 commits)")[![doyu2020](https://avatars.githubusercontent.com/u/74026499?v=4)](https://github.com/doyu2020 "doyu2020 (3 commits)")[![amuluowin](https://avatars.githubusercontent.com/u/19545561?v=4)](https://github.com/amuluowin "amuluowin (3 commits)")[![ihipop](https://avatars.githubusercontent.com/u/423077?v=4)](https://github.com/ihipop "ihipop (2 commits)")[![wudi](https://avatars.githubusercontent.com/u/3753615?v=4)](https://github.com/wudi "wudi (1 commits)")[![ruesin](https://avatars.githubusercontent.com/u/8240739?v=4)](https://github.com/ruesin "ruesin (1 commits)")[![shenzhe](https://avatars.githubusercontent.com/u/916634?v=4)](https://github.com/shenzhe "shenzhe (1 commits)")[![simpleKalvin](https://avatars.githubusercontent.com/u/18275521?v=4)](https://github.com/simpleKalvin "simpleKalvin (1 commits)")[![alebedev80](https://avatars.githubusercontent.com/u/777096?v=4)](https://github.com/alebedev80 "alebedev80 (1 commits)")

---

Tags

httpphpclientcurlpsr7swoolecoroutineajaxrequestsaxios

###  Code Quality

TestsPHPUnit

### Embed Badge

![Health badge](/badges/dybee-saber/health.svg)

```
[![Health](https://phpackages.com/badges/dybee-saber/health.svg)](https://phpackages.com/packages/dybee-saber)
```

###  Alternatives

[swlib/saber

Swoole coroutine HTTP client

985145.0k27](/packages/swlib-saber)[khr/php-mcurl-client

wrap curl client (http client) for PHP 5.3; using php multi curl, parallel request and write asynchronous code

71219.8k6](/packages/khr-php-mcurl-client)[swoole/grpc

Grpc PHP Client base on Swoole Http2 Coroutine

19718.9k1](/packages/swoole-grpc)[swoole/etcd-client

Grpc PHP Client base on Swoole Http2 Coroutine

1973.2k1](/packages/swoole-etcd-client)[swlib/http

Swlib-HTTP base class repository, PSR implementation

11145.4k4](/packages/swlib-http)[swoft/http-client

HTTP Client Component for Swoft

1139.3k4](/packages/swoft-http-client)

PHPackages © 2026

[Directory](/)[Categories](/categories)[Trending](/trending)[Changelog](/changelog)[Analyze](/analyze)