README

Scylla是一个可以同时执行多个请求的curl客户端。

安装

使用以下命令安装最新版本：

$ composer require retrinko/scylla

依赖

此库需要php的curl扩展才能工作。

日志记录

您可以使用您首选的PSR-3兼容的日志记录器与该库一起使用（请参阅基本用法部分）。

基本用法

简单请求

<?php

use Retrinko\Scylla\Client;
use Retrinko\Scylla\Request\Requests\DefaultRequest;
use Retrinko\Scylla\Util\HttpCodes;

require_once __DIR__.'/../vendor/autoload.php';
date_default_timezone_set('UTC');

$logger = new Monolog\Logger('test');
$logger->pushHandler(new \Monolog\Handler\StreamHandler('php://stdout'));

try
{
    // Instance new client
    $client = new Client();
    // Configure your client
    $client->setLogger($logger);
    // Configure your requests
    $sampleRequest = new DefaultRequest('https://httpbin.org/html');
    $sampleRequest->verificatePeersSSLCertificate(true);
    // Execute requests
    $responsesCollection = $client->exec($sampleRequest);
    // Get current response
    /** @var \Retrinko\Scylla\Response\ResponseInterface $response */
    $response = $responsesCollection->current();
    // Check http code and read response data or error message
    $code = $response->getCode();
    if (false == HttpCodes::isError($code))
    {
        $logger->notice('Execution success!');
        // Get response body
        $resposeBody = $response->getDecodedContent();
        var_dump($resposeBody);
    }
    else
    {
        // Get response message (error)
        $logger->error($response->getMessage());
    }
}
catch (\Exception $e)
{
    $logger->alert($e->getMessage());
}

多请求

<?php

use Retrinko\Scylla\Client;
use Retrinko\Scylla\Request\Requests\JsonRequest;
use Retrinko\Scylla\Request\RequestsCollection;
use Retrinko\Scylla\Response\Factories\JsonResponsesFactory;
use Retrinko\Scylla\Response\ResponseInterface;
use Retrinko\Scylla\Util\HttpCodes;

require_once __DIR__ . '/../vendor/autoload.php';
date_default_timezone_set('UTC');

$logger = new Monolog\Logger('test');
$logger->pushHandler(new \Monolog\Handler\StreamHandler('php://stdout'));

try
{
    // Instance new client
    $client = new Client();
    // Configure your client
    $client->setLogger($logger);
    $client->setResponsesFactory(new JsonResponsesFactory());
    $client->usePipelining(true);

    // Create requests
    $urls = ['ip' => 'https://httpbin.org/ip',
             'userAgent' => 'https://httpbin.org/user-agent',
             'get' => 'https://httpbin.org/get'];
    $requestsCollection = new RequestsCollection();
    foreach ($urls as $id => $url)
    {
        // Configure request
        $request = new JsonRequest($url);
        $request->setId($id);
        // Add request to requests collecction
        $requestsCollection->add($request);
    }

    // Execute requests
    $responsesCollection = $client->exec($requestsCollection);
    // Get responses
    foreach ($responsesCollection as $requestId => $response)
    {
        /** @var ResponseInterface $response */
        // Check http code and read response data or error message
        $code = $response->getCode();
        if (false == HttpCodes::isError($code))
        {
            $logger->notice('Execution success!', ['requestId' => $requestId]);
            // Get response body
            $data = $response->getDecodedContent();
            var_dump($data);
        }
        else
        {
            // Get response message (error)
            $logger->error($response->getMessage(), ['requestId' => $requestId]);
        }
    }

}
catch (\Exception $e)
{
    $logger->alert($e->getMessage());
}