首页
登录 | 注册

PHP Request请求封装

/**
 * Request请求封装
 * Class Request
 * @package tool
 */
class Request
{

    // curl 请求错误码
    protected static $list_errno = [
        1 => 'CURLE_UNSUPPORTED_PROTOCOL (1) – 您传送给 libcurl 的网址使用了此 libcurl 不支持的协议。 可能是您没有使用的编译时选项造成了这种情况(可能是协议字符串拼写有误,或没有指定协议 libcurl 代码)。',
        2 => 'CURLE_FAILED_INIT (2) – 非常早期的初始化代码失败。 可能是内部错误或问题。',
        3 => 'CURLE_URL_MALFORMAT (3) – 网址格式不正确。',
        5 => 'CURLE_COULDNT_RESOLVE_PROXY (5) – 无法解析代理服务器。 指定的代理服务器主机无法解析。',
        6 => 'CURLE_COULDNT_RESOLVE_HOST (6) – 无法解析主机。 指定的远程主机无法解析。',
        7 => 'CURLE_COULDNT_CONNECT (7) – 无法通过 connect() 连接至主机或代理服务器。',
        8 => 'CURLE_FTP_WEIRD_SERVER_REPLY (8) – 在连接到 FTP 服务器后,libcurl 需要收到特定的回复。 此错误代码表示收到了不正常或不正确的回复。 指定的远程服务器可能不是正确的 FTP 服务器。',
        9 => 'CURLE_REMOTE_ACCESS_DENIED (9) – 我们无法访问网址中指定的资源。 对于 FTP,如果尝试更改为远程目录,就会发生这种情况。',
        11 => 'CURLE_FTP_WEIRD_PASS_REPLY (11) – 在将 FTP 密码发送到服务器后,libcurl 需要收到正确的回复。 此错误代码表示返回的是意外的代码。',
        13 => 'CURLE_FTP_WEIRD_PASV_REPLY (13) – libcurl 无法从服务器端收到有用的结果,作为对 PASV 或 EPSV 命令的响应。 服务器有问题。',
        14 => 'CURLE_FTP_WEIRD_227_FORMAT (14) – FTP 服务器返回 227 行作为对 PASV 命令的响应。如果 libcurl 无法解析此行,就会返回此代码。',
        15 => 'CURLE_FTP_CANT_GET_HOST (15) – 在查找用于新连接的主机时出现内部错误。',
        17 => 'CURLE_FTP_COULDNT_SET_TYPE (17) – 在尝试将传输模式设置为二进制或 ascii 时发生错误。',
        18 => 'CURLE_PARTIAL_FILE (18) – 文件传输尺寸小于或大于预期。当服务器先报告了一个预期的传输尺寸,然后所传送的数据与先前指定尺寸不相符时,就会发生此错误。',
        19 => 'CURLE_FTP_COULDNT_RETR_FILE (19) – ‘RETR’ 命令收到了不正常的回复,或完成的传输尺寸为零字节。',
        21 => 'CURLE_QUOTE_ERROR (21) – 在向远程服务器发送自定义 “QUOTE” 命令时,其中一个命令返回的错误代码为 400 或更大的数字(对于 FTP),或以其他方式表明命令无法成功完成。',
        22 => 'CURLE_HTTP_RETURNED_ERROR (22) – 如果 CURLOPT_FAILONERROR 设置为 TRUE,且 HTTP 服务器返回 >= 400 的错误代码,就会返回此代码。 (此错误代码以前又称为 CURLE_HTTP_NOT_FOUND。)',
        23 => 'CURLE_WRITE_ERROR (23) – 在向本地文件写入所收到的数据时发生错误,或由写入回调 (write callback) 向 libcurl 返回了一个错误。',
        25 => 'CURLE_UPLOAD_FAILED (25) – 无法开始上传。 对于 FTP,服务器通常会拒绝执行 STOR 命令。错误缓冲区通常会提供服务器对此问题的说明。 (此错误代码以前又称为 CURLE_FTP_COULDNT_STOR_FILE。)',
        26 => 'CURLE_READ_ERROR (26) – 读取本地文件时遇到问题,或由读取回调 (read callback) 返回了一个错误。',
        27 => 'CURLE_OUT_OF_MEMORY (27) – 内存分配请求失败。此错误比较严重,若发生此错误,则表明出现了非常严重的问题。',
        28 => 'CURLE_OPERATION_TIMEDOUT (28) – 操作超时。 已达到根据相应情况指定的超时时间。',
        30 => 'CURLE_FTP_PORT_FAILED (30) – FTP PORT 命令返回错误。 在没有为 libcurl 指定适当的地址使用时,最有可能发生此问题。 请参阅 CURLOPT_FTPPORT。',
        31 => 'CURLE_FTP_COULDNT_USE_REST (31) – FTP REST 命令返回错误。如果服务器正常,则应当不会发生这种情况。',
        33 => 'CURLE_RANGE_ERROR (33) – 服务器不支持或不接受范围请求。',
        34 => 'CURLE_HTTP_POST_ERROR (34) – 此问题比较少见,主要由内部混乱引发。',
        35 => 'CURLE_SSL_CONNECT_ERROR (35) – 同时使用 SSL/TLS 时可能会发生此错误。您可以访问错误缓冲区查看相应信息,其中会对此问题进行更详细的介绍。可能是证书(文件格式、路径、许可)、密码及其他因素导致了此问题。',
        36 => 'CURLE_FTP_BAD_DOWNLOAD_RESUME (36) – 尝试恢复超过文件大小限制的 FTP 连接。',
        37 => 'CURLE_FILE_COULDNT_READ_FILE (37) – 无法打开 FILE:// 路径下的文件。原因很可能是文件路径无法识别现有文件。 建议您检查文件的访问权限。',
        38 => 'CURLE_LDAP_CANNOT_BIND (38) – LDAP 无法绑定。LDAP 绑定操作失败。',
        39 => 'CURLE_LDAP_SEARCH_FAILED (39) – LDAP 搜索无法进行。',
        41 => 'CURLE_FUNCTION_NOT_FOUND (41) – 找不到函数。 找不到必要的 zlib 函数。',
        42 => 'CURLE_ABORTED_BY_CALLBACK (42) – 由回调中止。 回调向 libcurl 返回了 “abort”。',
        43 => 'CURLE_BAD_FUNCTION_ARGUMENT (43) – 内部错误。 使用了不正确的参数调用函数。',
        45 => 'CURLE_INTERFACE_FAILED (45) – 界面错误。 指定的外部界面无法使用。 请通过 CURLOPT_INTERFACE 设置要使用哪个界面来处理外部连接的来源 IP 地址。 (此错误代码以前又称为 CURLE_HTTP_PORT_FAILED。)',
        47 => 'CURLE_TOO_MANY_REDIRECTS (47) – 重定向过多。 进行重定向时,libcurl 达到了网页点击上限。请使用 CURLOPT_MAXREDIRS 设置上限。',
        48 => 'CURLE_UNKNOWN_TELNET_OPTION (48) – 无法识别以 CURLOPT_TELNETOPTIONS 设置的选项。 请参阅相关文档。',
        49 => 'CURLE_TELNET_OPTION_SYNTAX (49) – telnet 选项字符串的格式不正确。',
        51 => 'CURLE_PEER_FAILED_VERIFICATION (51) – 远程服务器的 SSL 证书或 SSH md5 指纹不正确。',
        52 => 'CURLE_GOT_NOTHING (52) – 服务器未返回任何数据,在相应情况下,未返回任何数据就属于出现错误。',
        53 => 'CURLE_SSL_ENGINE_NOTFOUND (53) – 找不到指定的加密引擎。',
        54 => 'CURLE_SSL_ENGINE_SETFAILED (54) – 无法将选定的 SSL 加密引擎设为默认选项。',
        55 => 'CURLE_SEND_ERROR (55) – 无法发送网络数据。',
        56 => 'CURLE_RECV_ERROR (56) – 接收网络数据失败。',
        58 => 'CURLE_SSL_CERTPROBLEM (58) – 本地客户端证书有问题',
        59 => 'CURLE_SSL_CIPHER (59) – 无法使用指定的密钥',
        60 => 'CURLE_SSL_CACERT (60) – 无法使用已知的 CA 证书验证对等证书',
        61 => 'CURLE_BAD_CONTENT_ENCODING (61) – 无法识别传输编码',
        62 => 'CURLE_LDAP_INVALID_URL (62) – LDAP 网址无效',
        63 => 'CURLE_FILESIZE_EXCEEDED (63) – 超过了文件大小上限',
        64 => 'CURLE_USE_SSL_FAILED (64) – 请求的 FTP SSL 级别失败',
        65 => 'CURLE_SEND_FAIL_REWIND (65) – 进行发送操作时,curl 必须回转数据以便重新传输,但回转操作未能成功',
        66 => 'CURLE_SSL_ENGINE_INITFAILED (66) – SSL 引擎初始化失败',
        67 => 'CURLE_LOGIN_DENIED (67) – 远程服务器拒绝 curl 登录(7.13.1 新增功能)',
        68 => 'CURLE_TFTP_NOTFOUND (68) – 在 TFTP 服务器上找不到文件',
        69 => 'CURLE_TFTP_PERM (69) – 在 TFTP 服务器上遇到权限问题',
        70 => 'CURLE_REMOTE_DISK_FULL (70) – 服务器磁盘空间不足',
        71 => 'CURLE_TFTP_ILLEGAL (71) – TFTP 操作非法',
        72 => 'CURLE_TFTP_UNKNOWNID (72) – TFTP 传输 ID 未知',
        73 => 'CURLE_REMOTE_FILE_EXISTS (73) – 文件已存在,无法覆盖',
        74 => 'CURLE_TFTP_NOSUCHUSER (74) – 运行正常的 TFTP 服务器不会返回此错误',
        75 => 'CURLE_CONV_FAILED (75) – 字符转换失败',
        76 => 'CURLE_CONV_REQD (76) – 调用方必须注册转换回调',
        77 => 'CURLE_SSL_CACERT_BADFILE (77) – 读取 SSL CA 证书时遇到问题(可能是路径错误或访问权限问题)',
        78 => 'CURLE_REMOTE_FILE_NOT_FOUND (78) – 网址中引用的资源不存在',
        79 => 'CURLE_SSH (79) – SSH 会话中发生无法识别的错误',
        80 => 'CURLE_SSL_SHUTDOWN_FAILED (80) – 无法终止 SSL 连接'
    ];

    /**
     * curl模拟提交
     * @param $url
     * @param array $params
     * @param array $header
     * @param string $method
     * @param array $options
     * @return array|mixed
     */
    public static function curl_request($url, $params=[], $header=[], $method='post', $options=[])
    {

        if(!function_exists('curl_init')){
            return [
                'code' => 0,
                'msg' => 'Do not support CURL function.',
                'data' => [],
            ];
        }
        if(!filter_var($url, FILTER_VALIDATE_URL)){
            return [
                'code' => 0,
                'msg' => self::$list_errno[3],
                'data' => [],
            ];
        }
        unset($parts);

        // 请求参数格式转换成数组
//        if('json' !== strtolower($method)){
//            $params = self::format_params($params);
//        }

        // 头部格式转换
        $header = self::format_header($header);

        // 参数格数转换与请求头设置
        switch (strtolower($method)){
            case 'get':
                $options[CURLOPT_POST] = false; //GET提交方式
                if(!empty($params)){
                    $params = is_array($params) ? http_build_query($params) : $params;
                    $url .= (strstr($url,'?') ? '&' : '?') . $params;
                    $params = [];
                }
                break;
            case 'post':
                $options[CURLOPT_POST] = true; //post提交方式
                break;
            case 'json':
                $options[CURLOPT_POST] = true; //post提交方式

                if(!empty($params) && is_array($params)) $params = json_encode($params);
                if(!is_array($header)) $header = [];
                $check = false;
                if(!empty($header)){
                    foreach ($header as $value){
                        if(false !== stripos($value,'application/json')){
                            $check = true;
                            break;
                        }
                    }
                }
                if(!$check){
                    if(!empty($params)){
                        array_unshift($header, 'Content-Length: '.strlen($params));
                    }
                    array_unshift($header, 'Accept: application/json');
                    array_unshift($header, 'Content-Type: application/json; charset=utf-8');
                }
                break;
            case 'form':
                $options[CURLOPT_POST] = true; //post提交方式
                // 伪造来源referer
                if(!isset($options[CURLOPT_REFERER])){
                    $options[CURLOPT_REFERER] = isset($_SERVER['HTTP_REFERER']) ? $_SERVER['HTTP_REFERER'] : $_SERVER['REQUEST_SCHEME'] . '://'. $_SERVER['HTTP_HOST'];
                }

                if(!empty($params) && is_array($params)) $params = http_build_query($params);
                if(!is_array($header)) $header = [];
                $check = false;
                if(!empty($header)){
                    foreach ($header as $value){
                        if(false !== stripos($value,'application/x-www-form-urlencoded')){
                            $check = true;
                            break;
                        }
                    }
                }
                if(!$check){
                    if(!empty($params)){
                        array_unshift($header, 'Content-Length: '.strlen($params));
                    }
                    array_unshift($header, 'Content-Type: application/x-www-form-urlencoded; charset=utf-8');
                }
                break;
            default:
                $options[CURLOPT_POST] = true; //post提交方式
        }

        $ch = curl_init(); //初始化curl

        $setopt = [];
        if(false !== stripos($url,'https://')){
            $setopt[CURLOPT_SSL_VERIFYPEER] = false; // 禁止curl验证证书
            $setopt[CURLOPT_SSL_VERIFYHOST] = false; // 禁止检测主机
            $setopt[CURLOPT_SSLVERSION] = true; // CURL_SSLVERSION_TLSv1
        }
        $setopt[CURLOPT_URL] = $url; //抓取指定网页
        $setopt[CURLOPT_POST] = true; //是否POST提交方式
        $setopt[CURLOPT_USERAGENT] = isset($_SERVER['HTTP_USER_AGENT']) ? $_SERVER['HTTP_USER_AGENT'] : 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_13_6) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/68.0.3440.106 Safari/537.36'; //模拟浏览器代理
        $setopt[CURLOPT_RETURNTRANSFER] = true; //设置获取的信息以文件流的形式返回,而不是直接输出
        $setopt[CURLOPT_NOBODY] = false; //不显示body
        $setopt[CURLOPT_HEADER] = false; //设置头文件的信息作为数据流输出

//        $header[] = 'CLIENT-IP: 8.8.8.8';
//        $header[] = 'X-FORWARDED-FOR: 8.8.8.8'; // 伪造IP来源

        if(!empty($header)){
            $setopt[CURLOPT_HTTPHEADER] = $header; //请求头设置
        }

//        $setopt[CURLOPT_REFERER] = 60; //伪造来源referer

//        $setopt[CURLOPT_CONNECTTIMEOUT] = 60; //超时设置
//        $setopt[CURLOPT_FOLLOWLOCATION] = true; //根据服务器返回 HTTP 头中的'Location:'重定向
//        $setopt[CURLOPT_MAXREDIRS] = 3; //最大重定向次数

//        $setopt[CURLOPT_HTTPPROXYTUNNEL] = true; //是否通过http代理来传输
//        $setopt[CURLOPT_PROXY] = 'ip:端口号'; //是否通过http代理来传输
//        $setopt[CURLOPT_PROXYUSERPWD] = 'user:password'; //如果要密码的话,加上这个

        // cookie设置
//        $setopt[CURLOPT_COOKIE] = ''; //cookie

        //curl上传或者下载,获取curl传输进度
//        $setopt[CURLOPT_NOPROGRESS] = false; //是否关闭传输进度,默认是true
//        $setopt[CURLOPT_PROGRESSFUNCTION] = 'callback'; //回调函数,curl传输过程中,会每隔一段时间自动调用该函数

        if(!empty($params)){
            $setopt[CURLOPT_POSTFIELDS] = $params; //提交数据
        }
        if (function_exists('curl_file_create')){ // php >= 5.5
            $setopt[CURLOPT_SAFE_UPLOAD] = true; //文件上传
        }else {
            if (defined('CURLOPT_SAFE_UPLOAD')){
                $setopt[CURLOPT_SAFE_UPLOAD] = false; //文件上传
            }
        }
        if(!empty($options) && is_array($options)) $setopt = $options + $setopt;

        curl_setopt_array($ch, $setopt);
        unset($url, $params, $header, $method, $setopt);

        $response = curl_exec($ch); //运行curl
        $errno = curl_errno($ch); //返回最后一次的错误号
        $http_code = curl_getinfo($ch,CURLINFO_HTTP_CODE); //状态码
        curl_close($ch);

        if (0 !== $errno) {
            return [
                'code' => 0,
                'msg'   => isset(self::$list_errno[$errno]) ? self::$list_errno[$errno] : $errno,
                'data'  => $response,
            ];
        }

        try {
            $result = json_decode($response,true) ?: (200 === $http_code ? $response : ['code' => 0, 'msg' => "请求状态码为:{$http_code}", 'data' => $response]);
        } catch (\Exception $e) {
            $result = $response;
        }

        unset($response, $errno, $http_code);

        return $result;
    }

    /**
     * get提交
     * @param $url
     * @param array $params
     * @param array $header
     * @param int $timeout
     * @return mixed
     */
    public static function get($url, $params=[], $header=[], $timeout=60)
    {

        $response = self::curl_request($url, $params, $header, 'get', [CURLOPT_CONNECTTIMEOUT => $timeout]);

        unset($url, $params, $header, $timeout);

        return $response;
    }

    /**
     * post提交
     * @param $url
     * @param array $params
     * @param array $header
     * @param int $timeout
     * @return mixed
     */
    public static function post($url, $params=[], $header=[], $timeout=60)
    {

        $response = self::curl_request($url, $params, $header, 'post', [CURLOPT_CONNECTTIMEOUT => $timeout]);

        unset($url, $params, $header, $timeout);

        return $response;
    }

    /**
     * json提交
     * @param $url
     * @param array $params
     * @param array $header
     * @param int $timeout
     * @return mixed
     */
    public static function json($url, $params=[], $header=[], $timeout=60)
    {

        $response = self::curl_request($url, $params, $header, 'json', [CURLOPT_CONNECTTIMEOUT => $timeout]);

        unset($url, $params, $header, $timeout);

        return $response;
    }

    /**
     * form表单提交
     * @param $url
     * @param array $params
     * @param array $header
     * @param int $timeout
     * @return array|mixed
     */
    public static function form($url, $params=[], $header=[], $timeout=60){

        $response = self::curl_request($url, $params, $header, 'form', [CURLOPT_CONNECTTIMEOUT => $timeout]);

        unset($url, $params, $header, $timeout);

        return $response;
    }


    /**
     * 组装form表单跳转
     * @param $url
     * @param $params
     * @param string $method
     */
    public static function createForm($url, $params, $method='post'){
        $html = '<!doctype html>';
        $html .= '<html>';
        $html .= '<head>';
        $html .= '<meta charset="utf8">';
        $html .= '<title>正在跳转...</title>';
        $html .= '</head>';
        $html .= '<body onLoad="document.form.submit()">';
        $html .= '<form action="' . $url . '" method="' . $method . '" name="form">';
        if(is_array($params) && !empty($params)){
            foreach ($params as $key=>$value){
                $html .= '<input type="hidden" name="' . $key . '" value="' . $value . '">';
            }
        }
        $html .= '</form>';
        $html .= '</body>';
        $html .= '</html>';

        return $html;
    }

 


相关文章

  • 高并发请求的缓存设计策略
    前几天,我司出了个篓子.当时正值某喜闻乐见的关键比赛结束,一堆人打开我司app准备看点东西,结果从来没有感受到过这么多关注量的该功能瞬间幸福到眩晕,触发了熔断,结果就是大量兴致冲冲打开app准备看该比赛结果的人被迫刷了十分钟三天前的野外跑酷 ...
  • 补习系列(20)-大话 WebSocket 与 &quot;尬聊&quot;的实现
    目录 一.聊聊 WebSocket 二.Stomp 是个什么鬼 三.SpringBoot 整合 WebSocket A. 引入依赖 B. WebSocket 配置 C. 控制器 D. 前端实现 四.参考文档 一.聊聊 WebSocket 从 ...
  • 机器学习web服务化实战:一次吐血的服务化之路
    背景 在公司内部,我负责帮助研究院的小伙伴搭建机器学习web服务,研究院的小伙伴提供一个机器学习本地接口,我负责提供一个对外服务的HTTP接口. 说起人工智能和机器学习,python是最擅长的,其以开发速度快,第三方库多而广受欢迎,以至于现 ...
  • 从 docker 到 runC
    笔者在前文<RunC 简介>和<Containerd 简介>中分别介绍了 runC 和 containerd.本文我们将结合 docker 中的其它组件探索 docker 是如何把这些组件组织起来协调工作的. Doc ...
  •   中间件是被用到管道(pipeline)上来处理请求(request)和响应的(response). asp.net core 本身提供了一些内置的中间件,但是有一些场景,你可能会需要写一些自定义的中间件.   1. 创建一个中间件组件的 ...
  • 1.什么是跨越? 一个网页向另一个不同域名/不同协议/不同端口的网页请求资源,这就是跨域. 跨域原因产生:在当前域名请求网站中,默认不允许通过ajax请求发送其他域名. 2.为什么会产生跨域请求? 因为浏览器使用了同源策略 3.什么是同源策 ...

2020 cecdns.com webmaster#cecdns.com
12 q. 0.074 s.
京ICP备10005923号