workerman/http-client

说明

workerman/http-client是一个异步http客户端组件。所有请求响应异步非阻塞，内置连接池，消息请求和响应符合PSR7规则。

安装：

  1. composer config -g repo.packagist composer https://mirrors.aliyun.com/composer/
  2. composer require workerman/http-client

示例：

  1. use Workerman\Worker;
  3. require_once __DIR__ . '/vendor/autoload.php';
  5. $worker = new Worker();
  6. $worker->onWorkerStart = function () {
  7.     $http = new Workerman\Http\Client();
  9.     $http->get('https://example.com/', function ($response) {
  10.         var_dump($response->getStatusCode());
  11.         echo $response->getBody();
  12.     }, function ($exception) {
  13.         echo $exception;
  14.     });
  16.     $http->post('https://example.com/', ['key1' => 'value1', 'key2' => 'value2'], function ($response) {
  17.         var_dump($response->getStatusCode());
  18.         echo $response->getBody();
  19.     }, function ($exception) {
  20.         echo $exception;
  21.     });
  23.     $http->request('https://example.com/', [
  24.         'method' => 'POST',
  25.         'version' => '1.1',
  26.         'headers' => ['Connection' => 'keep-alive'],
  27.         'data' => ['key1' => 'value1', 'key2' => 'value2'],
  28.         'success' => function ($response) {
  29.             echo $response->getBody();
  30.         },
  31.         'error' => function ($exception) {
  32.             echo $exception;
  33.         }
  34.     ]);
  35. };
  36. Worker::runAll();

Optinons 选项

  1. <?php
  2. require __DIR__ . '/vendor/autoload.php';
  3. use Workerman\Worker;
  4. $worker = new Worker();
  5. $worker->onWorkerStart = function(){
  6.     $options = [
  7.         'max_conn_per_addr' => 128, // 每个地址最多维持多少并发连接
  8.         'keepalive_timeout' => 15,  // 连接多长时间不通讯就关闭
  9.         'connect_timeout'   => 30,  // 连接超时时间
  10.         'timeout'           => 30,  // 等待响应的超时时间
  11.     ];
  12.     $http = new Workerman\Http\Client($options);
  14.     $http->get('http://example.com/', function($response){
  15.         var_dump($response->getStatusCode());
  16.         echo $response->getBody();
  17.     }, function($exception){
  18.         echo $exception;
  19.     });
  20. };
  21. Worker::runAll();

注意：

1、项目首先要加载require __DIR__ . '/vendor/autoload.php';

2、所有的异步编码必须在onXXX回调中编写

3、支持基于workerman开发的所有项目，包括GatewayWorker、PHPSocket.io等