Ego_HttpAsync.php

gehe zur Dokumentation dieser Datei

<?php
class Ego_HttpAsync {
    private $maxAsync;
 
    private $maxLoad;
 
    public $verifySSL = true;
 
    private $handles = [];
 
    private $queue = [];
 
    private $multiHandle;
 
    private $progress;
 
    private $start;
 
    private $finish;
 
    private $load;
 
    public function __construct($async = 0, $load = 0.0) {
        $this->maxAsync = $async;
        $this->maxLoad = $load;
        $this->multiHandle = curl_multi_init();
        $this->verifySSL = empty($GLOBALS['egotec_conf']['proxy']['insecure']);
    }
 
    public function __destruct() {
        curl_multi_close($this->multiHandle);
    }
 
    public function setProgress($callback) {
        $this->progress = $callback;
    }
 
    public function setStart($callback) {
        $this->start = $callback;
    }
 
    public function setFinish($callback) {
        $this->finish = $callback;
    }
 
    public function setLoad($callback) {
        $this->load = $callback;
    }
 
    private function next() {
        if ($handle = array_shift($this->queue)) {
            $this->handles[] = $handle;
            if (is_callable($function = $this->start)) {
                $function($handle['meta']);
            }
            curl_multi_add_handle($this->multiHandle, $handle['resource']);
            return true;
        }
        return false;
    }
 
    public function run() {
        if (!empty($this->handles)) {
            $running = 0;
 
            do {
                if ($this->maxLoad > 0) {
                    $load = Ego_System::getLoadAverage();
                    if (is_callable($function = $this->load)) {
                        $function($load);
                    }
 
                    if ($load >= $this->maxLoad) {
                        sleep(5);
                    }
                }
 
                if (curl_multi_select($this->multiHandle) == -1) {
                    usleep(100);
                }
                do {
                    $status = curl_multi_exec($this->multiHandle, $running);
                } while ($status == CURLM_CALL_MULTI_PERFORM);
 
                while (($info = curl_multi_info_read($this->multiHandle)) !== false) {
                    foreach ($this->handles as $index => $handle) {
                        if ($handle['resource'] == $info['handle']) {
                            array_splice($this->handles, $index, 1);
                            curl_multi_remove_handle($this->multiHandle, $handle['resource']);
                            if (is_callable($function = $this->finish)) {
                                $function($handle['meta'], sizeof($this->handles), sizeof($this->queue));
                            }
                            break;
                        }
                    }
                }
 
                // Den nächsten wartenden Aufruf in die auszuführende Liste setzen
                if (($this->maxAsync == 0 || $running < $this->maxAsync) && $this->next()) {
                    $running++;
                }
            } while ($running > 0 && $status == CURLM_OK);
        }
    }
 
    public function add($url, $meta = []) {
        $handle = curl_init();
 
        curl_setopt($handle, CURLOPT_URL, $url);
        curl_setopt($handle, CURLOPT_HEADER, 0);
        curl_setopt($handle, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($handle, CURLOPT_COOKIE, EGOTEC . '=' . session_id());
 
        // SSL Zertifikat nicht verifizieren
        if (!$this->verifySSL) {
            curl_setopt($handle, CURLOPT_SSL_VERIFYPEER, false);
            curl_setopt($handle, CURLOPT_SSL_VERIFYHOST, false);
        }
 
        // Der User-Agent kann auf "EGOCMS" abgefragt werden, um die Ausgabe zu manipulieren
        curl_setopt($handle, CURLOPT_HTTPHEADER, [
            'User-Agent: EGOCMS'
        ]);
 
        // Callback Funktion ausführen
        curl_setopt($handle, CURLOPT_WRITEFUNCTION, function($handle, $data) {
            if (is_callable($function = $this->progress)) {
                foreach ($this->handles as $handle) {
                    if ($handle == $handle['resource']) {
                        $function($data, $handle['meta']);
                        break;
                    }
                }
            }
 
            return strlen($data);
        });
 
        // Alle URL Parameter werden als Meta-Daten weitergereicht
        parse_str(parse_url($url, PHP_URL_QUERY), $params);
 
        $this->queue[] = [
            'resource' => $handle,
            'meta' => array_merge($params, $meta)
        ];
 
        // Aufruf direkt in die auszuführende Liste setzen
        if ($this->maxAsync == 0 || sizeof($this->handles) < $this->maxAsync) {
            $this->next();
        }
    }
}