~

Author: goghcrow

.zan-ide-helper.php

@@ -139,6 +139,15 @@ public function release($connObj, int $conStatus = self::SWOOLE_CONNNECT_OK){}
      * destroy 释放连接池对象，调用此接口前，需要将连接对象全部释放
      */
     public function destroy() { }
+
+    /**
+     * @return  array
+     * [
+     *  "all_conn_obj" => 0,
+     *  "idle_conn_obj" => 0,
+     * ]
+     */
+    public function getStatInfo() { }
 }
 
 /**

src/Network/Connection/ConnectionManager.php

@@ -129,12 +129,7 @@ public function monitorTick()
         }
 
         foreach (self::$poolExMap as $poolKey => $pool) {
-            $info = $pool->getStatInfo();
-            $hawk->add(Constant::BIZ_CONNECTION_POOL,
-                [
-                    'free'  => $info["idle_conn_obj"],
-                    'active' => $info["all_conn_obj"] - $info["idle_conn_obj"],
-                ], [
+            $hawk->add(Constant::BIZ_CONNECTION_POOL, $pool->getStatInfo(), [
                     'pool_name' => $poolKey,
                 ]
             );

src/Network/Connection/PoolEx.php

@@ -100,4 +100,15 @@ public function release($conn, $close = false)
             return $this->poolEx->release($conn, \swoole_connpool::SWOOLE_CONNNECT_OK);
         }
     }
+
+    public function getStatInfo()
+    {
+        $info = $this->poolEx->getStatInfo();
+
+        return [
+            "all" => $info["all_conn_obj"],
+            "active" => $info["all_conn_obj"] - $info["idle_conn_obj"],
+            "free" => $info["idle_conn_obj"],
+        ];
+    }
 }