怎么样备份网站数据,wordpress固定衔接出错,网络营销方式的案例,网站建设不完整 审核概述
workerman/http-client 是一个异步http客户端组件。所有请求响应异步非阻塞#xff0c;内置连接池#xff0c;消息请求和响应符合PSR7规范。
Workerman 5.0 版本中的异步HTTP协程客户端组件是一个基于PHP协程的高性能HTTP客户端#xff0c;它能够充分利用PHP的异步特…概述
workerman/http-client 是一个异步http客户端组件。所有请求响应异步非阻塞内置连接池消息请求和响应符合PSR7规范。
Workerman 5.0 版本中的异步HTTP协程客户端组件是一个基于PHP协程的高性能HTTP客户端它能够充分利用PHP的异步特性来提高HTTP请求的效率和性能。这个组件允许开发者在编写PHP代码时以同步的方式发送异步HTTP请求从而使得编写的代码更加简洁易懂同时也能够处理大量的并发请求。
特点 异步非阻塞所有的请求和响应都是异步进行的不会阻塞主线程这意味着可以同时处理多个HTTP请求和响应。 内置连接池为了提高效率和性能该组件内置了连接池可以复用TCP连接减少建立和关闭连接的开销。 符合PSR-7规范消息请求和响应都符合PSR-7规范这使得它能够与遵循该规范的其他PHP组件和库无缝集成。 支持多种协议除了HTTP和HTTPS协议该组件还支持WebSocket、WSS等协议使其能够应对更多的应用场景。
安装
composer require workerman/http-client开源技术小栈 注意协程用法需要workerman5.0、workerman/http-client2.0.0 并安装 composer require revolt/event-loop ^1.0.0 启动webman
/var/www/webman/admin.webman.tinywan.com # php start.php start
Workerman[start.php] start in DEBUG mode
------------------------------------------------------- WORKERMAN --------------------------------------------------------
Workerman/5.0.0 PHP/8.2.10 (Jit off) Linux/5.15.167.4-microsoft-standard-WSL2
-------------------------------------------------------- WORKERS ---------------------------------------------------------
event-loop proto user worker listen count state
revolt tcp root webman http://0.0.0.0:8288 24 [OK]
revolt tcp root monitor none 1 [OK]
--------------------------------------------------------------------------------------------------------------------------协程用法
WorkerMan 中使用
declare(strict_types1);
use Workerman\Worker;require_once ../vendor/autoload.php;try {$worker new Worker();$worker-onWorkerStart function () {$http new Workerman\Http\Client();$response $http-get(https://www.tinywan.com/);var_dump($response-getStatusCode());echo $response-getBody() . PHP_EOL;$response $http-post(https://www.tinywan.com/, [key1 value1, key2 value2]);var_dump($response-getStatusCode());echo $response-getBody() . PHP_EOL;$response $http-request(https://www.tinywan.com/, [method GET,version 1.1,headers [Connection keep-alive],data [key1 value1, key2 value2],]);echo $response-getBody() . PHP_EOL;};Worker::runAll();
} catch (Throwable $throwable) {var_dump($throwable-getMessage());
}http-client 协程异步并发
?php
/*** desc 伪代码* author Tinywan(ShaoBo Wan)*/
declare(strict_types1);use Workerman\Worker;
use \Workerman\Connection\TcpConnection;
use \Workerman\Protocols\Http\Request;require_once ../vendor/autoload.php;// 创建一个Worker监听8217端口使用http协议通讯
$httpWorker new Worker(http://0.0.0.0:8217);// 启动8个进程对外提供服务
$httpWorker-count 8;// 接收到浏览器发送的数据时回复给浏览器
$httpWorker-onMessage function (TcpConnection $connection, Request $request) {$http new \Workerman\Http\Client();$count 50;$result [];while ($count--) {$startTime microtime(true);echo 开始时间 . $startTime . PHP_EOL;$response $http-get(https://api.tinywan.com/systems/website);$endTime microtime(true);echo 结束时间 . $endTime . PHP_EOL;$result[] sprintf(第%d个 | 耗时%s秒 | 状态码%d, $count, $endTime - $startTime, $response-getStatusCode());}$connection-send(json_encode($result));
};Worker::runAll();webman 中使用
如果你需要在webman中使用异步http请求并将结果返回给前端参考以下用法
?php
declare(strict_types1);namespace app\controller;use support\Request;
use support\Response;
use Throwable;
use Workerman\Protocols\Http\Chunk;class CoroutineController
{/*** param Request $request* return Response* throws Throwable*/public function index(Request $request): Response{$connection $request-connection;$http new \Workerman\Http\Client();$http-get(https://api.tinywan.com/website, function ($response) use ($connection) {$connection-send(new Chunk($response-getBody()-getContents()));$connection-send(new Chunk()); // 发送空的的chunk代表response结束});return response()-withHeaders([Transfer-Encoding chunked,Access-Control-Allow-Origin *]);}
}以上用法是先给客户端返回一个带chunked的http头然后将数据以chunk的方式发送给客户端。
