xs/kuxin/helper/http.php

<?php

namespace Kuxin\Helper;

use Kuxin\Config;
use Kuxin\Log;

/**
 * Class Http
 *
 * @package Kuxin\Helper
 * @author  Pakey <pakey@qq.com>
 */
class Http
{


    /**
     * @param        $url
     * @param array  $params
     * @param string $method
     * @param array  $header
     * @param array  $option
     * @return bool|mixed
     */
    public static function curl($url, $params = [], $method = 'GET', $header = [], $option = [])
    {
        $opts = [
            CURLOPT_TIMEOUT        => Config::get('http.timeout', 15),
            CURLOPT_CONNECTTIMEOUT => Config::get('http.timeout', 15),
            CURLOPT_RETURNTRANSFER => 1,
            CURLOPT_FOLLOWLOCATION => 1,
            CURLOPT_HEADER         => 0,
            //CURLOPT_FILETIME       => true,
            //CURLOPT_FRESH_CONNECT  => false,
            //CURLOPT_MAXREDIRS      => 5,
            CURLOPT_USERAGENT      => Config::get('http.user_agent', 'PTCMS Framework Http Client'),
            CURLOPT_REFERER        => isset($header['referer']) ? $header['referer'] : $url,
            CURLOPT_NOSIGNAL       => 1,
            CURLOPT_ENCODING       => 'gzip, deflate',
            CURLOPT_SSL_VERIFYPEER => false,
            CURLOPT_SSL_VERIFYHOST => false,
        ];

        if (Config::get('http.proxy.power')) {
            $opts[CURLOPT_PROXY]     = Config::get('http.proxy.host');
            $opts[CURLOPT_PROXYPORT] = Config::get('http.proxy.port');
            $opts[CURLOPT_PROXYTYPE] = Config::get('http.proxy.type');
            if (!empty($user = Config::get('http.proxy.username')) && !empty($pwd = Config::get('http.proxy.password'))) {
                $opts[CURLOPT_PROXYUSERPWD] = "{$user}:{$pwd}";
            }
        }

        if (isset($header['cookie'])) {
            $opts[CURLOPT_COOKIE] = $header['cookie'];
            unset($header['cookie']);
        }

        if (isset($header['useragent'])) {
            $opts[CURLOPT_USERAGENT] = $header['useragent'];
            unset($header['useragent']);
        }

        if (isset($header['showheader'])) {
            $opts[CURLOPT_HEADER] = true;
            unset($header['showheader']);
        }

        if (!empty($header)) {
            foreach ($header as $key => $item) {
                $opts[CURLOPT_HTTPHEADER][] = $key . ': ' . $item;
            }
        }
        //补充配置
        foreach ($option as $k => $v) {
            $opts[$k] = $v;
        }
        $opts[CURLOPT_URL] = $url;
        /* 根据请求类型设置特定参数 */
        switch (strtoupper($method)) {
            case 'GET':
                if ($params) {
                    if (is_array($params)) {
                        $params = http_build_query($params);
                    }
                    if (strpos($url, '?')) {
                        $url .= '&' . $params;
                    } else {
                        $url .= '?' . $params;
                    }
                    $opts[CURLOPT_URL] = $url;
                }
                break;
            case 'POST':
                //判断是否传输文件
                $opts[CURLOPT_POST]       = 1;
                $opts[CURLOPT_POSTFIELDS] = $params;
                break;
            case 'PUT':
                $opts[CURLOPT_CUSTOMREQUEST] = 'PUT';
                $opts[CURLOPT_POSTFIELDS]    = $params;
                break;
            case 'HEAD':
                $opts[CURLOPT_CUSTOMREQUEST] = 'HEAD';
                $opts[CURLOPT_NOBODY]        = 1;
                break;
            case 'DELETE':
                $opts[CURLOPT_CUSTOMREQUEST] = 'DELETE';
                $opts[CURLOPT_POSTFIELDS]    = $params;
                break;
            default:
                exit('不支持的请求方式！');
        }
        /* 初始化并执行curl请求 */
        $ch = curl_init();
        curl_setopt_array($ch, $opts);
        $data  = curl_exec($ch);
        $error = curl_error($ch);
        $errno = curl_errno($ch);
        curl_close($ch);
        if ($error && $errno !== 28) {
            if (Config::get('app.debug')) {
                trigger_error('Curl获取远程内容错误！原因：' . $error . ' 地址：' . $url);
            } else {
                Log::record('Curl获取远程内容错误！原因：' . $error . ' 地址：' . $url);
            }
            return false;
        }
        return $data;
    }

    public static function get($url, $data = [], $header = [], $option = [])
    {
        return self::curl($url, $data, 'GET', $header, $option);
    }

    public static function post($url, $data = [], $header = [], $option = [])
    {
        return self::curl($url, $data, 'POST', $header, $option);
    }

    public static function getJson($url, $data = [])
    {
        return Json::decode(trim(self::curl($url, $data, 'GET')));
    }

    public static function postJson($url, $data = [], $header = [])
    {
        return Json::decode(trim(self::curl($url, $data, 'POST', $header)));
    }

    /**
     * 触发url
     *
     * @param $url
     */
    public static function trigger($url)
    {
        if (stripos($url, 'http') === 0) {
            if (defined('CURLOPT_TIMEOUT_MS')) {
                self::curl($url, [], 'GET', [], [
                    CURLOPT_TIMEOUT_MS        => 300,
                    CURLOPT_CONNECTTIMEOUT_MS => 300,
                ]);
            } elseif (function_exists('file_get_contents')) {
                $context        = [
                    'http' => [
                        'timeout' => 0,
                    ],
                ];
                $stream_context = stream_context_create($context);
                file_get_contents($url, false, $stream_context);
            } else {
                stream_context_set_default(
                    [
                        'http' => [
                            'method' => 'HEAD',
                        ],
                    ]
                );
                get_headers($url);
            }
        }
    }

    /**
     * 解析头部内容
     * @param $response
     * @return array
     */
    public static function parse_headers($response)
    {
        $result  = [];
        $headers = explode("\r\n\r\n", $response, 2)[0];
        $headers = explode("\n", $headers);
        array_shift($headers);
        foreach ($headers as $header) {
            list($key, $value) = explode(':', $header, 2);
            $result[strtolower($key)] = trim($value);
        }
        return $result;
    }

    /**
     * 解析内容
     * @param $response
     * @return array
     */
    public static function parse_content($response)
    {
        return explode("\r\n\r\n", $response, 2)[1];
    }
}