Http::sendAsyncRequest() - Code Metrics - majiameng/chinaums-php - Measure and Improve Code Quality continuously with Scrutinizer

Http::sendAsyncRequest() C
last analyzed 2025-04-09 08:27 UTC

↳ Parent: Http

Complexity

Conditions	13
Paths	144

Size

Total Lines	44
Code Lines	30

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	1

Metric	Value
eloc	30
c	1
b	0
f	1
dl	0
loc	44
rs	6.25
cc	13
nc	144
nop	3

How to fix Complexity

<?php

namespace tinymeng\Chinaums\Tools;

/**
 * Http 请求类
 */
class Http
{

    /**
     * 发送一个POST请求
     * @param string $url     请求URL
     * @param array  $params  请求参数
     * @param array  $options 扩展参数
     * @return mixed|string
     */
    public static function post($url, $params = [], $options = [])
    {
        $req = self::sendRequest($url, $params, 'POST', $options);
        return $req['ret'] ? $req['msg'] : '';
    }

    /**
     * 发送一个GET请求
     * @param string $url     请求URL
     * @param array  $params  请求参数
     * @param array  $options 扩展参数
     * @return mixed|string
     */
    public static function get($url, $params = [], $options = [])
    {
        $req = self::sendRequest($url, $params, 'GET', $options);
        return $req['ret'] ? $req['msg'] : '';
    }

    /**
     * CURL发送Request请求,含POST和REQUEST
     * @param string $url     请求的链接
     * @param mixed  $params  传递的参数
     * @param string $method  请求的方法
     * @param mixed  $options CURL的参数
     * @return array
     */
    public static function sendRequest($url, $params = [], $method = 'POST', $options = [])
    {
        $method = strtoupper($method);
        $protocol = substr($url, 0, 5);
        $query_string = is_array($params) ? http_build_query($params) : $params;

        $ch = curl_init();
        $defaults = [];
        if ('GET' == $method) {
            $geturl = $query_string ? $url . (stripos($url, "?") !== false ? "&" : "?") . $query_string : $url;
            $defaults[CURLOPT_URL] = $geturl;
        } else {
            $defaults[CURLOPT_URL] = $url;
            if ($method == 'POST') {
                $defaults[CURLOPT_POST] = 1;
            } else {
                $defaults[CURLOPT_CUSTOMREQUEST] = $method;
            }
            $defaults[CURLOPT_POSTFIELDS] = $params;
        }

        $defaults[CURLOPT_HEADER] = false;
        $defaults[CURLOPT_USERAGENT] = "Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/45.0.2454.98 Safari/537.36";
        $defaults[CURLOPT_FOLLOWLOCATION] = true;
        $defaults[CURLOPT_RETURNTRANSFER] = true;
        $defaults[CURLOPT_CONNECTTIMEOUT] = 3;
        $defaults[CURLOPT_TIMEOUT] = 3;

        // disable 100-continue
        curl_setopt($ch, CURLOPT_HTTPHEADER, array('Expect:'));

        if ('https' == $protocol) {
            $defaults[CURLOPT_SSL_VERIFYPEER] = false;
            $defaults[CURLOPT_SSL_VERIFYHOST] = false;
        }

        curl_setopt_array($ch, (array)$options + $defaults);
        $ret = curl_exec($ch);
        $err = curl_error($ch);
        if (false === $ret || !empty($err)) {
            $errno = curl_errno($ch);
            $info = curl_getinfo($ch);
            curl_close($ch);
            return [
                'ret'   => false,
                'errno' => $errno,
                'msg'   => $err,
                'info'  => $info,
            ];
        }

        curl_close($ch);

        return [
            'ret' => true,
            'msg' => $ret,
        ];
    }

    /**
     * 异步发送一个请求
     * @param string $url    请求的链接
     * @param mixed  $params 请求的参数
     * @param string $method 请求的方法
     * @return boolean TRUE
     */
    public static function sendAsyncRequest($url, $params = [], $method = 'POST')
    {
        $method = strtoupper($method);
        $method = $method == 'POST' ? 'POST' : 'GET';
        //构造传递的参数
        if (is_array($params)) {
            $post_params = [];
            foreach ($params as $k => &$v) {
                if (is_array($v)) {
                    $v = implode(',', $v);
                }
                $post_params[] = $k . '=' . urlencode($v);
            }
            $post_string = implode('&', $post_params);
        } else {
            $post_string = $params;
        }
        $parts = parse_url($url);
        //构造查询的参数
        if ($method == 'GET' && $post_string) {
            $parts['query'] = isset($parts['query']) ? $parts['query'] . '&' . $post_string : $post_string;
            $post_string = '';
        }
        $parts['query'] = isset($parts['query']) && $parts['query'] ? '?' . $parts['query'] : '';
        //发送socket请求,获得连接句柄
        $fp = fsockopen($parts['host'], isset($parts['port']) ? $parts['port'] : 80, $errno, $errstr, 3);
        if (!$fp) {

            return false;
        }
        //设置超时时间
        stream_set_timeout($fp, 3);
        $out = "{$method} {$parts['path']}{$parts['query']} HTTP/1.1\r\n";
        $out .= "Host: {$parts['host']}\r\n";
        $out .= "Content-Type: application/x-www-form-urlencoded\r\n";
        $out .= "Content-Length: " . strlen($post_string) . "\r\n";
        $out .= "Connection: Close\r\n\r\n";
        if ($post_string !== '') {
            $out .= $post_string;
        }
        fwrite($fp, $out);
        //不用关心服务器返回结果
        //echo fread($fp, 1024);
        fclose($fp);
        return true;
    }

    /**
     * 发送文件到客户端
     * @param string $file
     * @param bool   $delaftersend
     * @param bool   $exitaftersend
     */
    public static function sendToBrowser($file, $delaftersend = true, $exitaftersend = true)
    {
        if (file_exists($file) && is_readable($file)) {
            header('Content-Description: File Transfer');
            header('Content-Type: application/octet-stream');
            header('Content-Disposition: attachment;filename = ' . basename($file));
            header('Content-Transfer-Encoding: binary');
            header('Expires: 0');
            header('Cache-Control: must-revalidate, post-check = 0, pre-check = 0');
            header('Pragma: public');
            header('Content-Length: ' . filesize($file));
            ob_clean();
            flush();
            readfile($file);
            if ($delaftersend) {
                unlink($file);
            }
            if ($exitaftersend) {
                exit;

            }
        }
    }
}


1			<?php
2
3			namespace tinymeng\Chinaums\Tools;
4
5			/**
6			* Http 请求类
7			*/
8			class Http
9			{
10
11			/**
12			* 发送一个POST请求
13			* @param string $url 请求URL
14			* @param array $params 请求参数
15			* @param array $options 扩展参数
16			* @return mixed\|string
17			*/
18			public static function post($url, $params = [], $options = [])
19			{
20			$req = self::sendRequest($url, $params, 'POST', $options);
21			return $req['ret'] ? $req['msg'] : '';
22			}
23
24			/**
25			* 发送一个GET请求
26			* @param string $url 请求URL
27			* @param array $params 请求参数
28			* @param array $options 扩展参数
29			* @return mixed\|string
30			*/
31			public static function get($url, $params = [], $options = [])
32			{
33			$req = self::sendRequest($url, $params, 'GET', $options);
34			return $req['ret'] ? $req['msg'] : '';
35			}
36
37			/**
38			* CURL发送Request请求,含POST和REQUEST
39			* @param string $url 请求的链接
40			* @param mixed $params 传递的参数
41			* @param string $method 请求的方法
42			* @param mixed $options CURL的参数
43			* @return array
44			*/
45			public static function sendRequest($url, $params = [], $method = 'POST', $options = [])
46			{
47			$method = strtoupper($method);
48			$protocol = substr($url, 0, 5);
49			$query_string = is_array($params) ? http_build_query($params) : $params;
50
51			$ch = curl_init();
52			$defaults = [];
53			if ('GET' == $method) {
54			$geturl = $query_string ? $url . (stripos($url, "?") !== false ? "&" : "?") . $query_string : $url;
55			$defaults[CURLOPT_URL] = $geturl;
56			} else {
57			$defaults[CURLOPT_URL] = $url;
58			if ($method == 'POST') {
59			$defaults[CURLOPT_POST] = 1;
60			} else {
61			$defaults[CURLOPT_CUSTOMREQUEST] = $method;
62			}
63			$defaults[CURLOPT_POSTFIELDS] = $params;
64			}
65
66			$defaults[CURLOPT_HEADER] = false;
67			$defaults[CURLOPT_USERAGENT] = "Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/45.0.2454.98 Safari/537.36";
68			$defaults[CURLOPT_FOLLOWLOCATION] = true;
69			$defaults[CURLOPT_RETURNTRANSFER] = true;
70			$defaults[CURLOPT_CONNECTTIMEOUT] = 3;
71			$defaults[CURLOPT_TIMEOUT] = 3;
72
73			// disable 100-continue
74			curl_setopt($ch, CURLOPT_HTTPHEADER, array('Expect:'));
75
76			if ('https' == $protocol) {
77			$defaults[CURLOPT_SSL_VERIFYPEER] = false;
78			$defaults[CURLOPT_SSL_VERIFYHOST] = false;
79			}
80
81			curl_setopt_array($ch, (array)$options + $defaults);
82			$ret = curl_exec($ch);
83			$err = curl_error($ch);
84			if (false === $ret \|\| !empty($err)) {
85			$errno = curl_errno($ch);
86			$info = curl_getinfo($ch);
87			curl_close($ch);
88			return [
89			'ret' => false,
90			'errno' => $errno,
91			'msg' => $err,
92			'info' => $info,
93			];
94			}
95
96			curl_close($ch);
97
98			return [
99			'ret' => true,
100			'msg' => $ret,
101			];
102			}
103
104			/**
105			* 异步发送一个请求
106			* @param string $url 请求的链接
107			* @param mixed $params 请求的参数
108			* @param string $method 请求的方法
109			* @return boolean TRUE
110			*/
111			public static function sendAsyncRequest($url, $params = [], $method = 'POST')
112			{
113			$method = strtoupper($method);
114			$method = $method == 'POST' ? 'POST' : 'GET';
115			//构造传递的参数
116			if (is_array($params)) {
117			$post_params = [];
118			foreach ($params as $k => &$v) {
119			if (is_array($v)) {
120			$v = implode(',', $v);
121			}
122			$post_params[] = $k . '=' . urlencode($v);
123			}
124			$post_string = implode('&', $post_params);
125			} else {
126			$post_string = $params;
127			}
128			$parts = parse_url($url);
129			//构造查询的参数
130			if ($method == 'GET' && $post_string) {
131			$parts['query'] = isset($parts['query']) ? $parts['query'] . '&' . $post_string : $post_string;
132			$post_string = '';
133			}
134			$parts['query'] = isset($parts['query']) && $parts['query'] ? '?' . $parts['query'] : '';
135			//发送socket请求,获得连接句柄
136			$fp = fsockopen($parts['host'], isset($parts['port']) ? $parts['port'] : 80, $errno, $errstr, 3);
137			if (!$fp) {
			0 ignored issues – show introduced 2025-03-09 07:34 UTC by Report Bug Copy Issue Report `$fp` is of type `resource`, thus it always evaluated to `false`. Loading history...
138			return false;
139			}
140			//设置超时时间
141			stream_set_timeout($fp, 3);
142			$out = "{$method} {$parts['path']}{$parts['query']} HTTP/1.1\r\n";
143			$out .= "Host: {$parts['host']}\r\n";
144			$out .= "Content-Type: application/x-www-form-urlencoded\r\n";
145			$out .= "Content-Length: " . strlen($post_string) . "\r\n";
146			$out .= "Connection: Close\r\n\r\n";
147			if ($post_string !== '') {
148			$out .= $post_string;
149			}
150			fwrite($fp, $out);
151			//不用关心服务器返回结果
152			//echo fread($fp, 1024);
153			fclose($fp);
154			return true;
155			}
156
157			/**
158			* 发送文件到客户端
159			* @param string $file
160			* @param bool $delaftersend
161			* @param bool $exitaftersend
162			*/
163			public static function sendToBrowser($file, $delaftersend = true, $exitaftersend = true)
164			{
165			if (file_exists($file) && is_readable($file)) {
166			header('Content-Description: File Transfer');
167			header('Content-Type: application/octet-stream');
168			header('Content-Disposition: attachment;filename = ' . basename($file));
169			header('Content-Transfer-Encoding: binary');
170			header('Expires: 0');
171			header('Cache-Control: must-revalidate, post-check = 0, pre-check = 0');
172			header('Pragma: public');
173			header('Content-Length: ' . filesize($file));
174			ob_clean();
175			flush();
176			readfile($file);
177			if ($delaftersend) {
178			unlink($file);
179			}
180			if ($exitaftersend) {
181			exit;
			0 ignored issues – show Best Practice introduced 2025-03-09 07:34 UTC by Report Bug Copy Issue Report Using `exit` here is not recommended. In general, usage of exit should be done with care and only when running in a scripting context like a CLI script. Loading history...
182			}
183			}
184			}
185			}
186

majiameng / chinaums-php

Http::sendAsyncRequest() C last analyzed 2025-04-09 08:27 UTC

Complexity

Size

Duplication

Importance

How to fix Complexity

Long Method

Duplication Side-by-Side

Filter issues like

Http::sendAsyncRequest() C
last analyzed 2025-04-09 08:27 UTC