eee

Client.php

@@ -2,6 +2,7 @@
 
 namespace Kiri;
 
+use Exception;
 use Swoole\Coroutine;
 
 
@@ -15,11 +16,11 @@ class Client
 	private CoroutineClient|CurlClient $abstracts;
 
 
-    /**
+	/**
-     * @param string $host
+	 * @param string $host
-     * @param int $port
+	 * @param int    $port
-     * @param bool $isSsl
+	 * @param bool   $isSsl
-     */
+	 */
 	public function __construct(string $host, int $port, bool $isSsl = false)
 	{
 		if (class_exists(Coroutine::class) && Coroutine::getCid() > -1) {
@@ -32,7 +33,7 @@ class Client
 
 	/**
 	 * @param string $name
-	 * @param array $arguments
+	 * @param array  $arguments
 	 * @return mixed
 	 */
 	public function __call(string $name, array $arguments)
@@ -40,4 +41,30 @@ class Client
 		return $this->abstracts->{$name}(...$arguments);
 	}
 
+
+
+	/**
+	 * @param string $name
+	 * @return mixed
+	 * @throws Exception
+	 */
+	public function __get(string $name)
+	{
+		// TODO: Implement __get() method.
+		$getter = 'get' . ucfirst($name);
+		if (method_exists($this->abstracts, $getter)) {
+			return $this->abstracts->$getter();
+		}
+
+		if (method_exists($this->abstracts, $name)) {
+			return $this->abstracts->$name();
+		}
+
+		if (property_exists($this->abstracts, $name)) {
+			return $this->abstracts->$name;
+		}
+
+		throw new Exception('Property|Method "' . $name . '" does not exist.');
+	}
+
 }

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->statusCode = -1;
-            $this->setBody(jTraceEx($exception));
+            $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->statusCode = $this->client->getStatusCode();
-            $this->setBody($this->client->getBody());
+            $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->statusCode = $this->client->statusCode;
-            $this->setBody($this->client->errMsg);
+            $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())) {
+        if (!empty($this->agent)) {
-            $this->withAddedHeader('User-Agent', $this->getAgent());
+            $this->withAddedHeader('User-Agent', $this->agent);
         }
-        $this->client->setHeaders($this->getHeader());
+        $this->client->setHeaders($this->header);
-        $this->client->setMethod(strtoupper($this->getMethod()));
+        $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())) {
+		if (!empty($this->ssl_key_file) && file_exists($this->ssl_key_file)) {
-			curl_setopt($this->client, CURLOPT_SSLKEY, $this->getSslKeyFile());
+			curl_setopt($this->client, CURLOPT_SSLKEY, $this->ssl_key_file);
 		}
-		if (!empty($this->getSslCertFile()) && file_exists($this->getSslCertFile())) {
+		if (!empty($this->ssl_cert_file) && file_exists($this->ssl_cert_file)) {
-			curl_setopt($this->client, CURLOPT_SSLCERT, $this->getSslCertFile());
+			curl_setopt($this->client, CURLOPT_SSLCERT, $this->ssl_cert_file);
 		}
-		if (!empty($this->getCa()) && file_exists($this->getCa())) {
+		if (!empty($this->ca) && file_exists($this->ca)) {
-			curl_setopt($this->client, CURLOPT_CAINFO, $this->getCa());
+			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_TIMEOUT, $this->timeout);                          // 超时设置
-		curl_setopt($resource, CURLOPT_CONNECTTIMEOUT, $this->getConnectTimeout());       // 超时设置
+		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())) {
+		if (!empty($this->agent)) {
-			curl_setopt($resource, CURLOPT_USERAGENT, $this->getAgent());
+			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->statusCode = curl_errno($this->client);
-			$this->setBody(curl_error($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->statusCode = curl_errno($this->client);
-			$this->setBody(curl_error($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->statusCode = $statusCode;
-			$this->setBody(substr($output, $headerSize));
+			$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;
 
 
-	/**
+	public null|string $body {
-	 * @return mixed
+		get;
-	 */
+	}
-	public function getBody(): mixed;
 }

TSwooleClient.php

@@ -11,16 +11,16 @@ trait TSwooleClient
 	 */
 	private function settings(): array
 	{
-		$sslCert = $this->getSslCertFile();
+		$sslCert = $this->ssl_cert_file;
-		$sslKey = $this->getSslKeyFile();
+		$sslKey = $this->ssl_key_file;
-		$sslCa = $this->getCa();
+		$sslCa = $this->ca;
 
 		$params = [];
-		if ($this->getConnectTimeout() > 0) {
+		if ($this->connect_timeout > 0) {
-			$params['timeout'] = $this->getConnectTimeout();
+			$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_host_name'] = $this->host;
-		$params['ssl_cert_file'] = $this->getSslCertFile();
+		$params['ssl_cert_file'] = $this->ssl_cert_file;
-		$params['ssl_key_file'] = $this->getSslKeyFile();
+		$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": "*"
   },