增加连接池释放机制

src/LayerInterface.php

@@ -1,6 +1,17 @@
 <?php
 namespace Bee\Db;
 
+/**
+ * 数据连接对象接口
+ *
+ * @package Bee\Db
+ */
 interface LayerInterface
 {
+    /**
+     * 释放数据连接
+     *
+     * @return mixed
+     */
+    public function clean();
 }

src/MySQL.php

@@ -181,4 +181,13 @@ public function delete(string $sql, array $params = [], float $timeout = 0)
     {
         return $this->master($sql, $params, $timeout);
     }
+
+    /**
+     * 释放数据连接
+     */
+    public function clean()
+    {
+        $this->masterPool->clean();
+        $this->slavePool->clean();
+    }
 }

src/MySQL/Pool.php

@@ -51,7 +51,7 @@ public function get() : Item
         $item = $this->pool->pop($this->timeout);
 
         if ($item === false) {
-            throw new Exception('Get Item instance timeout, all connection is used!');
+            throw new Exception('Get mysql connection instance timeout, pool: ' . $this->getLength());
         }
 
         return $item;
@@ -64,4 +64,14 @@ public function getLength() : int
     {
         return $this->pool->length();
     }
+
+    /**
+     * 清空数据库连接池（释放数据连接）
+     */
+    public function clean()
+    {
+        while ($item = $this->pool->pop($this->timeout)) {
+            $item->close();
+        }
+    }
 }

src/PoolInterface.php

@@ -1,7 +1,6 @@
 <?php
 namespace Bee\Db;
 
-
 /**
  * Interface PoolInterface
  *
@@ -10,13 +9,24 @@
 interface PoolInterface
 {
     /**
+     * 放回数据连接实例
+     *
      * @param \Bee\Db\MySQL\Item|\Bee\Db\Redis\Item $item
      * @return bool
      */
     public function put($item);
 
     /**
+     * 获取数据连接实例
+     *
      * @return \Bee\Db\MySQL\Item|\Swoole\Coroutine\Redis
      */
     public function get();
+
+    /**
+     * 清空数据库连接池（释放数据连接）
+     *
+     * @return mixed
+     */
+    public function clean();
 }

src/Redis.php

@@ -182,4 +182,13 @@ public function putSlaveConnect($item)
     {
         $this->slavePool->put($item);
     }
+
+    /**
+     * 释放数据连接
+     */
+    public function clean()
+    {
+        $this->masterPool->clean();
+        $this->slavePool->clean();
+    }
 }

src/Redis/Pool.php

@@ -51,7 +51,7 @@ public function get()
         $item = $this->pool->pop($this->timeout);
 
         if ($item === false) {
-            throw new Exception('Get Item instance timeout, all connection is used!');
+            throw new Exception('Get redis connection instance timeout, pool: ' . $this->getLength());
         }
 
         return $item;
@@ -64,4 +64,14 @@ public function getLength() : int
     {
         return $this->pool->length();
     }
+
+    /**
+     * 清空数据库连接池（释放数据连接）
+     */
+    public function clean()
+    {
+        while ($item = $this->pool->pop($this->timeout)) {
+            $item->close();
+        }
+    }
 }