ParallelCurl с CURLOPT_WRITEFUNCTION - PullRequest
Новая
       4

ParallelCurl с CURLOPT_WRITEFUNCTION

0 голосов
/ 28 марта 2011

Я пытаюсь использовать ParallelCurl с обратным вызовом , когда cURL получает данные от сервера , к которому он подключен.Вот код, который у меня сейчас есть: 

function request_finished($content, $url, $ch, $user_data) {
    echo "Request Finished: ", $content, "\n";
}

$pc=new ParallelCurl();
$servers=Server::loadNewAllFromDB();  //Returns an array of 'Server' objects which store connection information

foreach ($servers as $server) {

    $pc->setOptions(
        array(
            CURLOPT_USERAGENT=>'My UserAgent String',
            CURLOPT_WRITEFUNCTION=>
                function ($ch, $string) {
                    echo "WRITEFUNCTION Called!  |  ", $string; 
                    return strlen($string); 
                }
        )
    );
    //print_r($pc->options);
    $pc->startRequest(
        'http://' . $server->address . ':' . $server->portbase . '/someurl'), 
        'request_finished'
    );

}

$pc->finishAllRequests();

Теперь я ожидаю, что моя анонимная функция будет вызываться, когда у cURL есть данные для вывода.Вместо этого он просто игнорирует тот факт, что CURLOPT_WRITEFUNCTION установлен вообще.

Обратите внимание, что если я не использую ParallelCurl, я могу установить ту же анонимную функцию, что и CURLOPT_WRITEFUNCTION, просто отлично.Как будто моя функция переопределяется где-то позже.Я также проверил, что это на самом деле устанавливается.Вы можете видеть строку, которую я закомментировал, //print_r($pc->options).Он выводит мой объект замыкания.

Любые мысли по этому поводу будут наиболее цениться.Спасибо.

1 Ответ

0 голосов
/ 28 марта 2011

Это оказалось ошибкой либо с ParallelCurl, либо с curl_set_opt_array ().Вот функция в ParallelCurl как есть: 

// Start a fetch from the $url address, calling the $callback function passing the optional
// $user_data value. The callback should accept 3 arguments, the url, curl handle and user
// data, eg on_request_done($url, $ch, $user_data);
public function startRequest($url, $callback, $user_data = array(), $post_fields=null) {

    if( $this->max_requests > 0 )
        $this->waitForOutstandingRequestsToDropBelow($this->max_requests);

    $ch = curl_init();
    curl_setopt_array($ch, $this->options);

    curl_setopt($ch, CURLOPT_URL, $url);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, TRUE);

    if (isset($post_fields)) {
        curl_setopt($ch, CURLOPT_POST, TRUE);
        curl_setopt($ch, CURLOPT_POSTFIELDS, $post_fields);
    }



    curl_multi_add_handle($this->multi_handle, $ch);

    $this->outstanding_requests[$ch] = array(
        'url' => $url,
        'callback' => $callback,
        'user_data' => $user_data,
    );

    $this->checkForCompletedRequests();
}

Теперь проблема заключается в том, где находится curl_setopt_array($ch, $this->options).Если я перемещу его ниже всех остальных curl_setopt(), то он будет работать нормально.Забавно, что мой параметр User-Agent, который я передаю в тот же массив , что и CURLPOT_WRITEFUNCTION, работал нормально.Таким образом, кажется, что curl_setpot_array() ведет себя по-разному, когда данные объекты в качестве значений в массиве.Во всяком случае, простое перемещение вызова работало нормально.Моя измененная функция: 

// Start a fetch from the $url address, calling the $callback function passing the optional
// $user_data value. The callback should accept 3 arguments, the url, curl handle and user
// data, eg on_request_done($url, $ch, $user_data);
public function startRequest($url, $callback, $user_data = array(), $post_fields=null) {

    if( $this->max_requests > 0 )
        $this->waitForOutstandingRequestsToDropBelow($this->max_requests);

    $ch = curl_init();


    curl_setopt($ch, CURLOPT_URL, $url);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, TRUE);

    if (isset($post_fields)) {
        curl_setopt($ch, CURLOPT_POST, TRUE);
        curl_setopt($ch, CURLOPT_POSTFIELDS, $post_fields);
    }

     curl_setopt_array($ch, $this->options);

    curl_multi_add_handle($this->multi_handle, $ch);

    $this->outstanding_requests[$ch] = array(
        'url' => $url,
        'callback' => $callback,
        'user_data' => $user_data,
    );

    $this->checkForCompletedRequests();
}
...