SwooleHttpClient
封装 Swoole HTTP Client, Response 响应使用psr7 对象, 支持 psr7 request .
Install / 安装
请使用 Composer 安装
{
"require": {
"moln/swoole-http-client": "^1.0.0"
}
}
Usage / 使用
Moln\SwooleHttpClient\Client
use Moln\SwooleHttpClient\Client;
$cli = new Client('192.168.11.5');
$cli->get('/test/1.php', function (\Psr\Http\Message\ResponseInterface $response) {
var_dump((string)$response->getBody());
});
Moln\SwooleHttpClient\ClientStatic
静态调用
use Moln\SwooleHttpClient\ClientStatic;
use Psr\Http\Message\ResponseInterface;
$cli = ClientStatic::get('http://192.168.11.5/test/1.php', function (ResponseInterface $response) {
var_dump((string)$response->getBody());
})->on('connect', function () {
var_dump('connect');
});
$cli = ClientStatic::post('http://192.168.11.5/test/1.php', ['key' => 'val'], function (ResponseInterface $response) {
var_dump((string)$response->getBody());
});
Moln\SwooleHttpClient\ClientChain
http 客户端链(复用 client 连接对象)
$client = new \Moln\SwooleHttpClient\ClientChain('192.168.11.5');
$client->on('connect', function ($client) {
var_dump(spl_object_hash($client));
});
//New 一个新的 Client
$client->get('/test/1.php?s=2&id=3', function ($response) use ($client) {
//复用 client 对象
var_dump(spl_object_hash($client->get('/test/1.php?s=1&id=5')));;
var_dump(spl_object_hash($client->get('/test/1.php?s=1&id=6')));;
});
//没有空闲Client 对象,再 new 一个 Client
$client->get('/test/1.php?s=1&id=4', function ($response) use ($client) {
});
Features / 特点
支持多个事件绑定,官方仅支持1个
use Moln\SwooleHttpClient\Client;
$cli = new Client('192.168.11.5');
$cli->setHeaders(['Connection' => 'close']);
$cli->on('connect', function () use ($cli) {
var_dump('connect event1', $cli->isConnected());
});
$cli->on('connect', function () use ($cli) {
var_dump('connect event2', $cli->isConnected());
});
$cli->on('error', function () use ($cli) {
var_dump('connect event2', $cli->isConnected());
});
响应的 Response 为 PSR7
use Moln\SwooleHttpClient\Client;
$cli = new Client('192.168.11.5');
$cli->get('/test/1.php', function (\Psr\Http\Message\ResponseInterface $response) {
var_dump((string)$response->getBody());
});
$cli->post('/test/1.php', ['a' => 1], function (\Psr\Http\Message\ResponseInterface $response) {
var_dump((string)$response->getBody());
});
支持PSR7 Request
use Moln\SwooleHttpClient\Client;
$cli = new Client('192.168.11.5');
$cli->send(new \GuzzleHttp\Psr7\Request('POST', '/test/1.php?s=1&id=2', ['X-xxx' => '123'], 'x=1'),
function ($response) {
var_dump((string)$response->getBody());
}
);
支持 Timeout 超时(连接超时,连接响应超时)
使用 Swoole\Timer::after
实现连接超时
use Moln\SwooleHttpClient\Client;
$cli = new Client('192.168.11.5');
$cli->setTimeout(4);
$cli->setHeaders(['Connection' => 'close']);
$cli->on('connect', function () use ($cli) {
var_dump('connect', $cli->isConnected());
});
$cli->on('error', function ($cli, $msg) {
//$cli->isConnected() 判断是连接超时,还是连接上了响应超时
var_dump('connect error', $msg, $cli->isConnected()); // $msg= 'timeout' ; $msg = 'error';
});