通过
搜索
搜索malickyeu / curl-easy
PHP的cURL包装器。支持并行和非阻塞请求。对于高速爬取，请参阅stil/curl-robot。
v0.1.0
2022-09-08 07:14 UTC
Requires
- symfony/event-dispatcher: ^4.4|^5.3|^6.0
Requires (Dev)
- phpunit/phpunit: ^6.1
This package is auto-updated.
Last update: 2024-09-08 11:31:56 UTC
README
目录
简介
描述
这是一个小巧但强大且稳健的库，可以加快处理速度。如果你厌倦了使用具有过程式接口的PHP cURL扩展，但又想保持对脚本执行的掌控 - 这是你不错的选择！如果你的项目中需要高速爬取，你可能对stil/curl-easy扩展感兴趣 - stil/curl-robot。
主要功能
- 广泛单元测试。
- 轻量级库，接口适度。它不是一站式库。
- 具有非常简单接口的并行/异步连接。
- 在运行时并行/分离请求！
- 支持回调，因此您可以控制执行过程。
- 智能设置器作为CURLOPT_*常量的替代方案。
- 如果您熟悉cURL PHP扩展，您不必从头学习
安装
为了使用cURL-PHP库，您需要安装“libcurl”包。
使用以下命令将此库作为Composer包安装
composer require stil/curl-easy
示例
单个阻塞请求
<?php // We will check current Bitcoin price via API. $request = new \cURL\Request('https://bitpay.com/rates/USD'); $request->getOptions() ->set(CURLOPT_TIMEOUT, 5) ->set(CURLOPT_RETURNTRANSFER, true); $response = $request->send(); $feed = json_decode($response->getContent(), true); echo "Current Bitcoin price: " . $feed['data']['rate'] . " " . $feed['data']['code'] . "\n";
上面的示例将输出
Current Bitcoin price: 1999.97 USD
单个非阻塞请求
<?php // We will check current Bitcoin price via API. $request = new \cURL\Request('https://bitpay.com/rates/USD'); $request->getOptions() ->set(CURLOPT_TIMEOUT, 5) ->set(CURLOPT_RETURNTRANSFER, true); $request->addListener('complete', function (\cURL\Event $event) { $response = $event->response; $feed = json_decode($response->getContent(), true); echo "\nCurrent Bitcoin price: " . $feed['data']['rate'] . " " . $feed['data']['code'] . "\n"; }); while ($request->socketPerform()) { usleep(1000); echo '*'; }
上面的示例将输出
********************
Current Bitcoin price: 1997.48 USD
并行请求
<?php // We will download Bitcoin rates for both USD and EUR in parallel. // Init requests queue. $queue = new \cURL\RequestsQueue; // Set default options for all requests in queue. $queue->getDefaultOptions() ->set(CURLOPT_TIMEOUT, 5) ->set(CURLOPT_RETURNTRANSFER, true); // Set function to execute when request is complete. $queue->addListener('complete', function (\cURL\Event $event) { $response = $event->response; $json = $response->getContent(); // Returns content of response $feed = json_decode($json, true); echo "Current Bitcoin price: " . $feed['data']['rate'] . " " . $feed['data']['code'] . "\n"; }); $request = new \cURL\Request('https://bitpay.com/rates/USD'); // Add request to queue $queue->attach($request); $request = new \cURL\Request('https://bitpay.com/rates/EUR'); $queue->attach($request); // Execute queue $timeStart = microtime(true); $queue->send(); $elapsedMs = (microtime(true) - $timeStart) * 1000; echo 'Elapsed time: ' . round($elapsedMs) . " ms\n";
上面的示例将输出
Current Bitcoin price: 1772.850062 EUR
Current Bitcoin price: 1987.01 USD
Elapsed time: 284 ms
并行非阻塞请求
<?php // We will download Bitcoin rates for both USD and EUR in parallel. // Init requests queue. $queue = new \cURL\RequestsQueue; // Set default options for all requests in queue. $queue->getDefaultOptions() ->set(CURLOPT_TIMEOUT, 5) ->set(CURLOPT_RETURNTRANSFER, true); // Set function to execute when request is complete. $queue->addListener('complete', function (\cURL\Event $event) { $response = $event->response; $json = $response->getContent(); // Returns content of response $feed = json_decode($json, true); echo "\nCurrent Bitcoin price: " . $feed['data']['rate'] . " " . $feed['data']['code'] . "\n"; }); $request = new \cURL\Request('https://bitpay.com/rates/USD'); // Add request to queue $queue->attach($request); $request = new \cURL\Request('https://bitpay.com/rates/EUR'); $queue->attach($request); // Execute queue $timeStart = microtime(true); while ($queue->socketPerform()) { usleep(1000); echo '*'; } $elapsedMs = (microtime(true) - $timeStart) * 1000; echo 'Elapsed time: ' . round($elapsedMs) . " ms\n";
上面的示例将输出类似的内容
*****************************************************************************************************************************************************
Current Bitcoin price: 1772.145208 EUR
************************************************************************
Current Bitcoin price: 1986.22 USD
Elapsed time: 374 ms
在某一时刻最多执行2个请求的同时处理多个请求的队列
$requests = []; $currencies = ['USD', 'EUR', 'JPY', 'CNY']; foreach ($currencies as $code) { $requests[] = new \cURL\Request('https://bitpay.com/rates/' . $code); } $queue = new \cURL\RequestsQueue; $queue ->getDefaultOptions() ->set(CURLOPT_RETURNTRANSFER, true); $queue->addListener('complete', function (\cURL\Event $event) use (&$requests) { $response = $event->response; $json = $response->getContent(); // Returns content of response $feed = json_decode($json, true); echo "Current Bitcoin price: " . $feed['data']['rate'] . " " . $feed['data']['code'] . "\n"; if ($next = array_pop($requests)) { $event->queue->attach($next); } }); $queue->attach(array_pop($requests)); $queue->attach(array_pop($requests)); $queue->send();
上面的示例将输出类似的内容
Current Bitcoin price: 220861.025 JPY
Current Bitcoin price: 13667.81675 CNY
Current Bitcoin price: 1771.0567 EUR
Current Bitcoin price: 1985 USD
智能选项设置
将CURLOPT_*替换为set*()，您将收到方法名。示例
$opts = new \cURL\Options; $opts->set(CURLOPT_URL, $url); // it is equivalent to // $opts->setUrl($url); $opts->set(CURLOPT_RETURNTRANSFER, true); // it is equivalent to // $opts->setReturnTransfer(true); // or // $opts->setReTURNTranSFER(true); // character case does not matter $opts->set(CURLOPT_TIMEOUT, 5); // it is equivalent to // $opts->setTimeout(5); // then you can assign options to Request $request = new \cURL\Request; $request->setOptions($opts); // or make it default in RequestsQueue $queue = new \cURL\RequestsQueue; $queue->setDefaultOptions($opts);
错误处理
您可以在Response类中访问cURL错误代码。示例
$request = new \cURL\Request('http://non-existsing-page/'); $response = $request->send(); if ($response->hasError()) { $error = $response->getError(); echo 'Error code: ' . $error->getCode() . "\n"; echo 'Message: "' . $error->getMessage() . '"' . "\n"; }
可能上面的示例将输出
Error code: 6
Message: "Could not resolve host: non-existsing-page; Host not found"
您可以在这里找到所有CURLE_*错误代码。