paulzi / multicurl
MultiCurl. A wrapper over curl_multi_init.
v0.1.0
2016-10-14 07:59 UTC
Requires
- php: >=5.4.0
- ext-curl: *
This package is auto-updated.
Last update: 2024-12-12 23:01:16 UTC
README
A wrappers over curl_multi_init.
This provide two class:
- MultiCurl - simple wrapper over curl_multi_init with events
- MultiCurlQueue - extended version of MultiCurl, with queue of requests, retry failed requests and multithreading.
Install
Install via Composer:
composer require paulzi/multicurl:~0.1.0
or add
"paulzi/multicurl" : "~0.1.0"
to the require
section of your composer.json
file.
Usage
function generateCurl($url) { $curl = curl_init(); curl_setopt($curl, CURLOPT_URL, $url); curl_setopt($curl, CURLOPT_HEADER, false); curl_setopt($curl, CURLOPT_RETURNTRANSFER, true); curl_setopt($curl, CURLOPT_ENCODING, ''); return $curl; } // usage MultiCurl $request = new MultiCurlRequest(); $request->curl = generateCurl('https://google.com'); $request->onSuccess = function($request, $response, $content) { var_dump('Success', $content); }; $request->onError = function($request, $response, $content, $errCode, $errMsg) { var_dump('Error', $errMsg); }; $loader = new MultiCurl(); $loader->add($request); $loader->run(); // usage MultiCurlQueue $request1 = new MultiCurlRequest(); $request1->curl = generateCurl('https://google.com'); $request1->onSuccess = function($request, $response, $content) { var_dump('Request1 Success', $content); }; $request1->onRetry = function($request, $response, $content, $errCode, $errMsg) { var_dump('Request1 Retry', $errMsg); }; $request1->onError = function($request, $response, $content, $errCode, $errMsg) { var_dump('Request1 Error', $errMsg); }; $request2 = new MultiCurlRequest(); $request2->curl = generateCurl('http://none.noexist'); $request2->onSuccess = function($request, $response, $content) { var_dump('Request2 Success', $content); }; $request2->onRetry = function($request, $response, $content, $errCode, $errMsg) { var_dump('Request2 Retry', $errMsg); }; $request2->onError = function($request, $response, $content, $errCode, $errMsg) { var_dump('Request2 Error', $errMsg); }; $loader = new MultiCurlQueue(); $loader->threads = 2; $loader->retry = 3; $loader->run([$request1, $request2]);
Documentation
MultiCurl
add($request)
- add request to jobrun()
- execute requestsonBefore($request)
- on before execute request eventonSuccess($request, $response, $content)
- on success request eventonError($request, $response, $content, $errCode, $errMsg)
- on error request eventonAlways($request, $response, $content)
- on always request event
MultiCurlQueue
run($requests)
- execute requestsonBefore($request)
- on before execute request eventonSuccess($request, $response, $content)
- on success request eventonError($request, $response, $content, $errCode, $errMsg)
- on error request eventonAlways($request, $response, $content)
- on always request eventonRetry($request, $response, $content, $errCode, $errMsg, $retryIndex, $retryTotal)
- on retry request event
MultiCurlRequest
$curl
- curl resource$onBefore
- on before execute request callback$onSuccess
- on success request callback$onError
- on error request callback$onAlways
- on always request callback$onRetry
- on retry request callback