eee

CoroutineClient.php

@@ -68,10 +68,9 @@ class CoroutineClient extends ClientAbstracts
             }
 
             $this->execute($url, $data);
-
         } catch (\Throwable $exception) {
             $this->setStatusCode(-1);
-            $this->setBody(jTraceEx($exception));
+            $this->setBody(json_encode(['code' => 500, 'message' => $exception->getMessage()]));
         }
     }
 

CurlClient.php

@@ -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->close();
 	}
 
 
@@ -195,13 +196,13 @@ 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();