你認為的.NET資料庫連線池，真的是全部嗎？

一般我們的專案中會使用1到2個數據庫連線配置，同程藝龍的資料庫連線配置被收攏到統一的配置中心，由DBA統一配置和維護，業務方通過某個字串配置拿到的是Connection物件。

DBA能在對業務方無侵入的情況下，給業務方切換備份資料庫，之後DBA要求舊連線池必須立即被清空，那麼問題來了： dotnet能不能立即清空連線池？，注意我用得是清空，而不是釋放連線。

如果有同學不知道DBA做這個要求的目的，那我囉嗦一下：

應用程式不再使用舊連線時，理論上你的連線池要被完全清空，因為單純的釋放連線，只會讓連線池中的Connection處於Sleep狀態，依舊維持了短時間的物理連線，這個短時間其實是不必要的佔用，影響了舊連線資料庫的吞吐量。

前置知識背景

回答這個問題之前，我們還是先研究一下.NET資料庫連線池。

1. .NET資料庫連線池的背景

資料庫連線是一個耗時的行為，大多數應用程式只使用1到幾種資料庫連線，為了最小化開啟連線的成本，ado.net使用了一種稱為連線池的優化技術。

2. .NET 資料庫連線池的表現

資料庫連線池減少了必須開啟新連線的次數，池程式維護了資料庫物理連線。

通過為每個特定的連線配置保持一組活動的連線物件來管理連線。

每當應用程式嘗試Open連線，池程式就會在池中找到可用的連線，如果有則返回給呼叫者；

應用程式Close連線物件時，池程式將連線物件返回到池中(Sleep), 這個連線可以在下一次Open呼叫中重用。

看黑板，下面是這次的重點：

3. .NET是如何形成資料庫連線池的?

只有相同的連線配置才能被池化，.NET為不同的配置維護了不同的連線池。

相同的配置限制為：

程序相同、

連線字串相同、

連線字串關鍵key順序相同。

(同一連線提供的關鍵字順序不同將被分到不同的池)。

連線池中的可用連線的數量由連線字串Max Pool Size決定。

在一個應用程式中，有如下程式碼：

using (SqlConnection connection = new SqlConnection(

  "Integrated Security=SSPI;Initial Catalog=Northwind"))

    {

        connection.Open();

        // Pool A is created.

    }  

using (SqlConnection connection = new SqlConnection(

  "Integrated Security=SSPI;Initial Catalog=pubs"))

    {

        connection.Open();

        // Pool B is created because the connection strings differ.

    }  

using (SqlConnection connection = new SqlConnection(

  "Integrated Security=SSPI;Initial Catalog=Northwind"))

    {

        connection.Open();

        // The connection string matches pool A.

    }

上面建立了三個Connection物件，但是隻形成了兩個資料庫連線池。

還是以上程式碼，如果有兩個相同的應用程式，理論上就形成了四個資料庫連線池。

4. 連線池中的連線什麼時候被移除？

連線池中的連線空閒4-8 分鐘，池程式會移除這個連線。

應用程式下線，連線池直接被清空。

.NET 如何清空連線池？

有了以上知識背景

我們再來回顧一下 DBA的要求，切換原連線配置的時候，清空連線池。

我從官方文件找到

.NET提供了

ClearAllPools、ClearPool靜態方法用於清空連線池。

ClearAllPools：清空與這個DBProvider相關的所有連線池
ClearPool(DBConnection conn) 清空與這個連線物件相關的連線池

很明顯，我們這次要使用ClearPool(DBConnection conn) 方法。

光說不練不驗證，不是我的風格。

天錘壓測/queryapi 產生一個包含大量連線物件的連線池；

適當的時候，/clearpoolapi清空連線池。

 public class MySqlController : Controller

    {

        // GET: MySql

        [Route("query")]

        public string Index()

        {

            var s = "User ID=teinfra_neo_netreplay;Password=123456;DataBase=teinfra_neo_netreplay;Server=10.100.41.196;Port=3980;Min Pool Size=1;Max Pool Size=28;CharSet=utf8;";

            using (var conn = new MySqlConnection(s))

            {

                var comm = conn.CreateCommand();

                comm.CommandText = "select count(*) from usertest;";

                conn.Open();

                var ret = comm.ExecuteScalar();

                comm.CommandText = "select count(*) from information_schema.PROCESSLIST WHERE HOST like  '10.22.12.245%';";

                var len = comm.ExecuteScalar();

                return $"查詢結果:{ret} ,順便查一下當前連線池的連線物件個數: {len}";

            };

        }

        [Route("clearpool")]

        public string Switch()

        {

            var s = "User ID=teinfra_neo_netreplay;Password=123456;DataBase=teinfra_neo_netreplay;Server=10.100.41.196;Port=3980;Min Pool Size=1;Max Pool Size=28;CharSet=utf8;";

            using (var conn = new MySqlConnection(s))

            {

                conn.Open();

                MySqlConnection.ClearPool(conn);

            };

            using (var conn = new MySqlConnection(s))

            {

                conn.Open();

                var comm = conn.CreateCommand();

                comm.CommandText = "select count(*) from information_schema.PROCESSLIST WHERE HOST like  '10.22.12.245%';";

                var len = comm.ExecuteScalar();

                return $"之前已經清空連線池， 此次查詢連線池有 {v1}  個連線物件";

            }

        }

    }

1. 經過壓測工具

2. mysql資料庫對比

mysql的連線數查詢命令， (host是web伺服器IP)：

select * from information_schema.PROCESSLIST WHERE HOST like '10.22.12.245%';

3. 呼叫`/clearpool`api，清空連線池

bingo，清空連線池的理論得到驗證。

乾貨旁白

這是我在同程藝龍最近爬的比較深的坑位，

我從本次實踐中理解了.NET資料庫連線池的定義方式、並配套掌握了DBProvider 對於.net連線數的查詢定位方式。

對祖傳程式碼的改造，.NET資料獲取元件SDK 確實提高了原資料庫的吞吐量。

希望本文設計考量、理論+論證的行文思路對於讀者有所幫助，再次感謝有心讀者取關、再關注。

你認為的.NET資料庫連線池，真的是全部嗎？