From e15df4e3c771a182783eb3256bbab5419c175f43 Mon Sep 17 00:00:00 2001
From: lingling <lingling@qq.com>
Date: Fri, 7 Mar 2025 17:30:44 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E4=BC=98=E5=8C=96=20SendCode=20?=
 =?UTF-8?q?=E7=B1=BB=EF=BC=8C=E5=A2=9E=E5=8A=A0=20Guzzle=20=E5=AE=A2?=
 =?UTF-8?q?=E6=88=B7=E7=AB=AF=E5=8D=95=E4=BE=8B=E5=A4=8D=E7=94=A8=EF=BC=8C?=
 =?UTF-8?q?=E6=8F=90=E5=8D=87=E6=80=A7=E8=83=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/Utils/API/SendCode.php | 33 ++++++++++++++++++++++++++++-----
 process/Task2.php          |  3 +--
 2 files changed, 29 insertions(+), 7 deletions(-)

diff --git a/app/Utils/API/SendCode.php b/app/Utils/API/SendCode.php
index 67550d8..b7512d3 100644
--- a/app/Utils/API/SendCode.php
+++ b/app/Utils/API/SendCode.php
@@ -12,6 +12,29 @@ class SendCode
 {
 
     protected static  $token = 'druid_ccefa62b-243a-4bdb-8460-89f3b36e79f8';
+    //单例复用http客户端
+    public static $client = null;
+    /**
+     * 获取 Guzzle 客户端
+     * 用于复用 客户端常驻内存
+     *
+     * @return object
+     */
+    public static function get_client()
+    {
+        if (self::$client == null) {
+            self::$client = new Client([
+                'curl' => [
+                    CURLOPT_FRESH_CONNECT => false,
+                    CURLOPT_FORBID_REUSE => false,
+                ],
+                'headers' => [
+                    'Connection' => 'keep-alive',
+                ],
+            ]);
+        }
+        return self::$client;
+    }
     /**
      * 发送验证码
      * code  状态码  0 成功  1 token无效或已过期  2 端口不足  3 账号已存在 int
@@ -19,7 +42,7 @@ class SendCode
      */
     public static function send_code($phone)
     {
-        $client = new Client(); // 创建 Guzzle 客户端
+        $client = self::get_client(); // 创建 Guzzle 客户端
         // 请求数据
         $data = [
             "token" => self::$token,
@@ -42,7 +65,7 @@ class SendCode
      */
     public static function get_code($phone)
     {
-        $client = new Client(); // 创建 Guzzle 客户端
+        $client = self::get_client();
 
         // 请求数据
         $data = [
@@ -66,12 +89,12 @@ class SendCode
      *  code 0 成功 1token无效 2WS号不存在
      *  status 当code=0时返回，0表示在线 1表示离线
      * 返回 0在线 1离线 2 token无效 3 ws号不存在
+     * 对象注入解决tcp 复用问题
      */
     public static function get_ws_status($phone)
     {
 
-        $client = new Client(); // 创建 Guzzle 客户端
-
+        $client = self::get_client();
 
         $url = "https://dx1.rocketgo.vip/ex-api/biz/api/wsStatus?wsNumber=" . $phone . "&token=".self::$token;
         // 发送 POST 请求
@@ -99,7 +122,7 @@ class SendCode
     public static function delWS($phone)
     {
 
-        $client = new Client(); // 创建 Guzzle 客户端
+        $client = self::get_client();
 
         // 请求数据
         $data = [
diff --git a/process/Task2.php b/process/Task2.php
index dd08d40..28eaec3 100644
--- a/process/Task2.php
+++ b/process/Task2.php
@@ -8,7 +8,7 @@ use app\model\UserPhone;
 use app\dao\UserRewardDao;
 use support\Log;
 use Workerman\Crontab\Crontab;
-
+use GuzzleHttp\Client;
 /**
  * 查询用户是否在线类
  */
@@ -20,7 +20,6 @@ class Task2
         new Crontab('0 */1 * * * *', function () {
             $phones = UserPhone::where('status' ,'!=', 2)->get();
             $start_time = time();
-
             foreach ($phones as $key => $value) {
                 
                 try {