eee

CoroutineClient.php

@@ -34,7 +34,7 @@ class CoroutineClient extends ClientAbstracts
             $path = '/' . $path;
         }
 
-        $host = $this->getHost();
+        $host = $this->host;
         if (!preg_match('/(\d{1,3}\.){3}\d{1,3}/', $host)) {
             $this->withAddedHeader('Host', $host);
         }
@@ -62,16 +62,15 @@ class CoroutineClient extends ClientAbstracts
     private function coroutine(string $url, array|string $data = []): void
     {
         try {
-            $this->generate_client($this->getHost(), $this->isSSL());
+            $this->generate_client($this->host, $this->isSSL);
             if ($this->client->statusCode < 0) {
                 throw new Exception($this->client->errMsg);
             }
 
             $this->execute($url, $data);
-
         } catch (\Throwable $exception) {
-            $this->setStatusCode(-1);
-            $this->setBody(jTraceEx($exception));
+            $this->statusCode = -1;
+            $this->body       = json_encode(['code' => 500, 'message' => $exception->getMessage()]);
         }
     }
 
@@ -87,8 +86,8 @@ class CoroutineClient extends ClientAbstracts
         if (in_array($this->client->getStatusCode(), [502, 404])) {
             $this->retry($path, $data);
         } else {
-            $this->setStatusCode($this->client->getStatusCode());
-            $this->setBody($this->client->getBody());
+            $this->statusCode = $this->client->getStatusCode();
+            $this->body       = $this->client->getBody();
             $this->setResponseHeader($this->client->headers);
         }
     }
@@ -106,8 +105,8 @@ class CoroutineClient extends ClientAbstracts
 
             $this->execute($path, $data);
         } else {
-            $this->setStatusCode($this->client->statusCode);
-            $this->setBody($this->client->errMsg);
+            $this->statusCode = $this->client->statusCode;
+            $this->body       = $this->client->errMsg;
         }
     }
 
@@ -117,17 +116,17 @@ class CoroutineClient extends ClientAbstracts
      */
     private function generate_client(string $host, bool $isHttps): void
     {
-        if ($isHttps || $this->isSSL()) {
+        if ($isHttps || $this->isSSL) {
             $this->client = new SwowClient($host, 443, true);
         } else {
             $this->client = new SwowClient($host, $this->getPort(), false);
         }
         $this->client->set($this->settings());
-        if (!empty($this->getAgent())) {
-            $this->withAddedHeader('User-Agent', $this->getAgent());
+        if (!empty($this->agent)) {
+            $this->withAddedHeader('User-Agent', $this->agent);
         }
-        $this->client->setHeaders($this->getHeader());
-        $this->client->setMethod(strtoupper($this->getMethod()));
+        $this->client->setHeaders($this->header);
+        $this->client->setMethod(strtoupper($this->method));
     }
 
 
@@ -138,7 +137,7 @@ class CoroutineClient extends ClientAbstracts
      */
     private function setParams(string $path, mixed $data): string
     {
-        $content = $this->getData();
+        $content = $this->_data;
         if (!empty($content)) {
             $this->client->setData($content);
         }

CurlClient.php

@@ -44,15 +44,15 @@ class CurlClient extends ClientAbstracts
 	 */
 	private function getCurlHandler(string $path, string $method, $params): void
 	{
-		$host = $this->isSSL() ? 'https://' . $this->getHost() : 'http://' . $this->getHost();
+		$host = $this->isSSL ? 'https://' . $this->host : 'http://' . $this->host;
 		if ($this->getPort() != 443 && $this->getPort() != 80) {
 			$host .= ':' . $this->getPort();
 		}
 		$this->do(curl_init($host . $path), $host . $path, $method);
-		if ($this->isSSL()) {
+		if ($this->isSSL) {
 			$this->curlHandlerSslSet();
 		}
-		$contents = $this->getData();
+		$contents = $this->_data;
 		if (empty($params) && empty($contents)) {
 			return;
 		}
@@ -75,14 +75,14 @@ class CurlClient extends ClientAbstracts
 	 */
 	private function curlHandlerSslSet(): void
 	{
-		if (!empty($this->getSslKeyFile()) && file_exists($this->getSslKeyFile())) {
-			curl_setopt($this->client, CURLOPT_SSLKEY, $this->getSslKeyFile());
+		if (!empty($this->ssl_key_file) && file_exists($this->ssl_key_file)) {
+			curl_setopt($this->client, CURLOPT_SSLKEY, $this->ssl_key_file);
 		}
-		if (!empty($this->getSslCertFile()) && file_exists($this->getSslCertFile())) {
-			curl_setopt($this->client, CURLOPT_SSLCERT, $this->getSslCertFile());
+		if (!empty($this->ssl_cert_file) && file_exists($this->ssl_cert_file)) {
+			curl_setopt($this->client, CURLOPT_SSLCERT, $this->ssl_cert_file);
 		}
-		if (!empty($this->getCa()) && file_exists($this->getCa())) {
-			curl_setopt($this->client, CURLOPT_CAINFO, $this->getCa());
+		if (!empty($this->ca) && file_exists($this->ca)) {
+			curl_setopt($this->client, CURLOPT_CAINFO, $this->ca);
 		}
 	}
 
@@ -97,8 +97,8 @@ class CurlClient extends ClientAbstracts
 	private function do(mixed $resource, string $path, string $method): void
 	{
 		curl_setopt($resource, CURLOPT_URL, $path);
-		curl_setopt($resource, CURLOPT_TIMEOUT, $this->getTimeout());                     // 超时设置
-		curl_setopt($resource, CURLOPT_CONNECTTIMEOUT, $this->getConnectTimeout());       // 超时设置
+		curl_setopt($resource, CURLOPT_TIMEOUT, $this->timeout);                          // 超时设置
+		curl_setopt($resource, CURLOPT_CONNECTTIMEOUT, $this->connect_timeout);           // 超时设置
 		curl_setopt($resource, CURLOPT_HEADER, TRUE);
 		curl_setopt($resource, CURLOPT_FAILONERROR, TRUE);
 		curl_setopt($resource, CURLOPT_HTTPHEADER, $this->parseHeaderMat());
@@ -107,8 +107,8 @@ class CurlClient extends ClientAbstracts
 		}
 		curl_setopt($resource, CURLOPT_FORBID_REUSE, FALSE);
 		curl_setopt($resource, CURLOPT_FRESH_CONNECT, FALSE);
-		if (!empty($this->getAgent())) {
-			curl_setopt($resource, CURLOPT_USERAGENT, $this->getAgent());
+		if (!empty($this->agent)) {
+			curl_setopt($resource, CURLOPT_USERAGENT, $this->agent);
 		}
 		curl_setopt($resource, CURLOPT_NOBODY, FALSE);
 		curl_setopt($resource, CURLOPT_RETURNTRANSFER, TRUE);//返回内容
@@ -117,7 +117,7 @@ class CurlClient extends ClientAbstracts
 		if ($method === self::POST || $method == self::UPLOAD) {
 			curl_setopt($resource, CURLOPT_POST, 1);
 		}
-		[$proxy, $port] = [$this->getProxyHost(), $this->getProxyPort()];
+		[$proxy, $port] = [$this->proxyHost, $this->proxyPort];
 		if (!empty($proxy) && $port > 0) {
 			curl_setopt($resource, CURLOPT_PROXYPORT, $port);
 			curl_setopt($resource, CURLOPT_PROXY, $proxy);
@@ -155,11 +155,12 @@ class CurlClient extends ClientAbstracts
 	{
 		$output = curl_exec($this->client);
 		if ($output !== FALSE) {
-			$this->explode($this->client, $output);
+			$this->explode($output);
 		} else {
-			$this->setStatusCode(curl_errno($this->client));
-			$this->setBody(curl_error($this->client));
+			$this->statusCode = curl_errno($this->client);
+			$this->body       = curl_error($this->client);
 		}
+		$this->close();
 	}
 
 
@@ -174,8 +175,8 @@ class CurlClient extends ClientAbstracts
 
 			$this->execute();
 		} else {
-			$this->setStatusCode(curl_errno($this->client));
-			$this->setBody(curl_error($this->client));
+			$this->statusCode = curl_errno($this->client);
+			$this->body       = curl_error($this->client);
 		}
 	}
 
@@ -185,7 +186,9 @@ class CurlClient extends ClientAbstracts
 	 */
 	public function close(): void
 	{
-		curl_close($this->client);
+		if (PHP_VERSION < '8.0') {
+			curl_close($this->client);
+		}
 	}
 
 
@@ -195,19 +198,19 @@ class CurlClient extends ClientAbstracts
 	 * @return void
 	 * @throws
 	 */
-	private function explode($ch, string $output): void
+	private function explode(string $output): void
 	{
 		// 获取 HTTP 状态码
-		$statusCode = +curl_getinfo($ch, CURLINFO_HTTP_CODE);
+		$statusCode = +curl_getinfo($this->client, CURLINFO_HTTP_CODE);
 
 		// 获取 header 的大小（不包括最后的 \r\n\r\n 分隔符）
-		$headerSize = curl_getinfo($ch, CURLINFO_HEADER_SIZE);
+		$headerSize = curl_getinfo($this->client, CURLINFO_HEADER_SIZE);
 		$header     = substr($output, 0, $headerSize);
 		if (in_array($statusCode, [502, 404])) {
 			$this->retry();
 		} else {
-			$this->setStatusCode($statusCode);
-			$this->setBody(substr($output, $headerSize));
+			$this->statusCode = $statusCode;
+			$this->body       = substr($output, $headerSize);
 			$this->setResponseHeader(explode("\r\n", $header));
 		}
 	}
@@ -219,7 +222,7 @@ class CurlClient extends ClientAbstracts
 	private function parseHeaderMat(): array
 	{
 		$headers = [];
-		foreach ($this->getHeader() as $key => $val) {
+		foreach ($this->header as $key => $val) {
 			$headers[$key] = $key . ': ' . $val;
 		}
 		return array_values($headers);

IClient.php

@@ -172,8 +172,7 @@ interface IClient
 	public function withContentType(string $contentType): static;
 
 
-	/**
-	 * @return mixed
-	 */
-	public function getBody(): mixed;
+	public null|string $body {
+		get;
+	}
 }

TSwooleClient.php

@@ -11,16 +11,16 @@ trait TSwooleClient
 	 */
 	private function settings(): array
 	{
-		$sslCert = $this->getSslCertFile();
-		$sslKey = $this->getSslKeyFile();
-		$sslCa = $this->getCa();
+		$sslCert = $this->ssl_cert_file;
+		$sslKey = $this->ssl_key_file;
+		$sslCa = $this->ca;
 
 		$params = [];
-		if ($this->getConnectTimeout() > 0) {
-			$params['timeout'] = $this->getConnectTimeout();
+		if ($this->connect_timeout > 0) {
+			$params['timeout'] = $this->connect_timeout;
 		}
 
-        [$proxy, $port] = [$this->getProxyHost(), $this->getProxyPort()];
+        [$proxy, $port] = [$this->proxyHost, $this->proxyPort];
         if (!empty($proxy) && $port > 0) {
             $params['http_proxy_host'] = $proxy;
             $params['http_proxy_port'] = $port;
@@ -29,9 +29,9 @@ trait TSwooleClient
 			return $params;
 		}
 
-		$params['ssl_host_name'] = $this->getHost();
-		$params['ssl_cert_file'] = $this->getSslCertFile();
-		$params['ssl_key_file'] = $this->getSslKeyFile();
+		$params['ssl_host_name'] = $this->host;
+		$params['ssl_cert_file'] = $this->ssl_cert_file;
+		$params['ssl_key_file'] = $this->ssl_key_file;
 		$params['ssl_verify_peer'] = TRUE;
 		$params['ssl_cafile'] = $sslCa;
 

composer.json

@@ -9,7 +9,7 @@
   ],
   "license": "MIT",
   "require": {
-    "php": ">=8.4",
+    "php": ">=8.5",
     "ext-json": "*",
     "ext-swoole": "*"
   },