as2252258/kiri-client
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 8 Wiki Activity

ea

Browse Source
This commit is contained in:
whwyy
2025-11-26 07:52:46 +08:00
parent 345af9e727
commit 85067aa15d
1 changed files with 188 additions and 185 deletions
Download Patch File Download Diff File Expand all files Collapse all files
CurlClient.php
+15 -12
View File
@@ -6,6 +6,7 @@ namespace Kiri;
/** /**
* Class CurlClient * Class CurlClient
*
* @package Http\Handler\Client * @package Http\Handler\Client
*/ */
class CurlClient extends ClientAbstracts class CurlClient extends ClientAbstracts
@@ -16,6 +17,7 @@ class CurlClient extends ClientAbstracts
* @param string $method * @param string $method
* @param string $path * @param string $path
* @param array|string $params * @param array|string $params
*
* @return void * @return void
*/ */
public function request(string $method, string $path, array|string $params = []): void public function request(string $method, string $path, array|string $params = []): void
@@ -37,6 +39,7 @@ class CurlClient extends ClientAbstracts
* @param string $path * @param string $path
* @param string $method * @param string $method
* @param $params * @param $params
*
* @return void * @return void
*/ */
private function getCurlHandler(string $path, string $method, $params): void private function getCurlHandler(string $path, string $method, $params): void
@@ -88,6 +91,7 @@ class CurlClient extends ClientAbstracts
* @param mixed $resource * @param mixed $resource
* @param string $path * @param string $path
* @param string $method * @param string $method
*
* @return void * @return void
*/ */
private function do(mixed $resource, string $path, string $method): void private function do(mixed $resource, string $path, string $method): void
@@ -134,6 +138,7 @@ class CurlClient extends ClientAbstracts
/** /**
* @param string $path * @param string $path
*
* @return $this * @return $this
*/ */
public function withCAInfo(string $path): static public function withCAInfo(string $path): static
@@ -150,7 +155,7 @@ class CurlClient extends ClientAbstracts
{ {
$output = curl_exec($this->client); $output = curl_exec($this->client);
if ($output !== FALSE) { if ($output !== FALSE) {
$this->explode($output); $this->explode($this->client, $output);
} else { } else {
$this->setStatusCode(curl_errno($this->client)); $this->setStatusCode(curl_errno($this->client));
$this->setBody(curl_error($this->client)); $this->setBody(curl_error($this->client));
@@ -186,26 +191,24 @@ class CurlClient extends ClientAbstracts
/** /**
* @param string $output * @param string $output
*
* @return void * @return void
* @throws * @throws
*/ */
private function explode(string $output): void private function explode($ch, string $output): void
{ {
[$header, $body] = explode("\r\n\r\n", $output, 2); // 获取 HTTP 状态码
if ($header == 'HTTP/1.1 100 Continue') { $statusCode = +curl_getinfo($ch, CURLINFO_HTTP_CODE);
[$header, $body] = explode("\r\n\r\n", $body, 2);
}
$header = explode("\r\n", $header); // 获取 header 的大小（不包括最后的 \r\n\r\n 分隔符）
$status = explode(' ', array_shift($header)); $headerSize = curl_getinfo($ch, CURLINFO_HEADER_SIZE);
$header = substr($output, 0, $headerSize);
$statusCode = intval($status[1]);
if (in_array($statusCode, [502, 404])) { if (in_array($statusCode, [502, 404])) {
$this->retry(); $this->retry();
} else { } else {
$this->setStatusCode($statusCode); $this->setStatusCode($statusCode);
$this->setBody($body); $this->setBody(substr($output, $headerSize));
$this->setResponseHeader($header); $this->setResponseHeader(explode("\r\n", $header));
} }
} }