polonskiy/mcurl

Simple and powerful curl_multi_* wrapper

MCurl

Simple and powerful wrapper for curl_multi_*, _(*1)

Install

download composer git clone, _(*2)

Usage

<?php

$threads = 20;
$options = array(
    'followlocation'  =>  true,  //CURLOPT_FOLLOWLOCATION
    'nobody'          =>  true,  //CURLOPT_NOBODY
);

$queue[] = array(
    'url'             =>  'http://example1.com',  //CURLOPT_URL
    'connecttimeout'  =>  20,                     //CURLOPT_CONNECTTIMEOUT
);
$queue[] = array(
    'url'             =>  'http://example2.com',  //CURLOPT_URL
    'connecttimeout'  =>  10,                     //CURLOPT_CONNECTTIMEOUT
);

$mcurl = new MCurl\Curl($options, $queue, $threads);
while ($response = $mcurl->exec()) {
    $message = "URL: $response->url\n";
    if ($response->error) {
        $message .= "ERROR: $response->error\n";
    } else {
        $message .= "RESPONSE CODE: $response->code\n";
        $message .= "RESPONSE BODY: $response->data\n";
    }
    echo "$message\n";
}

Options

Mcurl options is a array of [curl options][1], but in lowercase and without CURLOPT_ prefix., _(*3)

This options is defaults for all requests., _(*4)

<?php

$options = array(
    'connecttimeout'  =>  10,  //CURLOPT_CONNECTTIMEOUT
);

$mcurl = new MCurl\Curl($options);

//or

$mcurl = new MCurl\Curl;
$mcurl->options = $options;

Queue

MCurl queue is a php array with curl options., _(*5)

This options is specific for each requests., _(*6)

<?php

$queue[] = array(
    'url'             =>  'http://example1.com',  //CURLOPT_URL
    'followlocation'  =>  true,                   //CURLOPT_FOLLOWLOCATION
);

$queue[] = array(
    'url'             =>  'http://example2.com',  //CURLOPT_URL
    'followlocation'  =>  false,                  //CURLOPT_FOLLOWLOCATION
    'nobody'          =>  true,                   //CURLOPT_NOBODY
);

$defaultOptions = array();

$mcurl = new MCurl\Curl($defaultOptions, $queue);

//or

$mcurl = new MCurl\Curl;
$mcurl->queue = $queue;

Threads

Threads is a count of parallel connections used by curl., _(*7)

<?php

$threads = 20;

$mcurl = new MCurl\Curl($options, $queue, $threads);

//or

$mcurl = new MCurl\Curl;
$mcurl->threads = $threads;

Busy loop

add new urls, _(*8)

Response