架構師_程序員

 找回密碼
 注冊[Register]

QQ登錄

只需一步,快速開始

查看: 133|回復: 2

[.NET Core] ADO.NET 通過 ObjectPool 創建 SqlConnection 連接池

[復制鏈接]
發表于 2020-4-19 18:51:31 | 顯示全部樓層
ObjectPool 是微軟新出的一個功能,微軟幫我們維護一些對象,這些對象都可以進行復用。

簡單來說,和共享單車類似,你用的時候去掃碼開鎖,這個車輛就代表被占用了,當你用完的時候,你鎖車的時候,車輛會釋放解除占用。這些占用和解除都是平臺幫我們去維護。

有些對象不是線程安全的,但是,我們每次去實例化這個對象的時候,需要消耗一些資源。

.NET Core 中 Object Pool 詳解
http://www.729432.buzz/thread-9152-1-1.html
(出處: 架構師_程序員)
首先,我們新建一個SqlConnectionPooledObjectPolicy類,繼承IPooledObjectPolicy<T>接口,需要實現其兩個方法。

  1. public class SqlConnectionPooledObjectPolicy : IPooledObjectPolicy<SqlConnection>
  2.     {
  3.         public SqlConnection Create()
  4.         {
  5.             Console.WriteLine("create new sqlConnection");
  6.             var conn = new SqlConnection(Program.SqlConn);
  7.             conn.Open();
  8.             return conn;
  9.         }

  10.         public bool Return(SqlConnection obj)
  11.         {
  12.             if (obj != null && obj.State == ConnectionState.Open) return true;
  13.             else return false;
  14.         }
  15.     }
復制代碼
Create 方法是如何去實例化這個對象,Return表示,這個對象是否還能復用,當返回false的時候,這個對象會在對象池里面刪除。

測試源代碼如下:

  1. using ConsoleTables;
  2. using Microsoft.Extensions.ObjectPool;
  3. using System;
  4. using System.Collections.Generic;
  5. using System.Data;
  6. using System.Data.SqlClient;
  7. using System.Diagnostics;
  8. using System.Threading.Tasks;

  9. namespace obj_pool_demo
  10. {
  11.     class Program
  12.     {
  13.         public const string SqlConn = "Data Source=.;Initial Catalog=test;user id=sa;password=123456";
  14.         private static ObjectPool<SqlConnection> pool;
  15.         private const string sql = "SELECT TOP 1 * FROM [Account]";
  16.         private static List<int> vs = new List<int>() { 10, 100, 1000, 10000, 100000 };
  17.         static void Main(string[] args)
  18.         {
  19.             var table = new ConsoleTable("次數", "對象池", "ADO.NET");
  20.             //get defalut pool size
  21.             Console.WriteLine(Environment.ProcessorCount * 2);
  22.             var defaultProvider = new DefaultObjectPoolProvider();
  23.             var policy = new SqlConnectionPooledObjectPolicy();
  24.             pool = defaultProvider.Create(policy);
  25.             foreach (var item in vs)
  26.             {
  27.                 Stopwatch stopwatch = new Stopwatch();
  28.                 stopwatch.Start();
  29.                 for (int i = 0; i < item; i++)
  30.                 {
  31.                     var conn = pool.Get();
  32.                     TestCommand(sql, conn);
  33.                     pool.Return(conn);
  34.                 }
  35.                 stopwatch.Stop();
  36.                 var t1 = stopwatch.ElapsedMilliseconds;

  37.                 stopwatch.Restart();
  38.                 for (int i = 0; i < item; i++)
  39.                 {
  40.                     TestCommand(sql);
  41.                 }
  42.                 stopwatch.Stop();
  43.                 var t2 = stopwatch.ElapsedMilliseconds;

  44.                 table.AddRow(item,t1, t2);
  45.                 Console.WriteLine("測試次數:" + item);
  46.             }
  47.             table.Write();
  48.             Console.WriteLine("ok by:itsvse.com");
  49.             Console.ReadKey();
  50.         }

  51.         static void TestCommand(string sql)
  52.         {
  53.             using (var conn = new SqlConnection(SqlConn))
  54.             {
  55.                 conn.Open();
  56.                 TestCommand(sql, conn);
  57.                 conn.Close();
  58.             }
  59.         }

  60.         static void TestCommand(string sql, SqlConnection conn)
  61.         {
  62.             SqlCommand command = new SqlCommand(sql, conn);
  63.             command.ExecuteNonQuery();
  64.         }
  65.     }

  66.     public class SqlConnectionPooledObjectPolicy : IPooledObjectPolicy<SqlConnection>
  67.     {
  68.         public SqlConnection Create()
  69.         {
  70.             Console.WriteLine("create new sqlConnection by:itsvse.com");
  71.             var conn = new SqlConnection(Program.SqlConn);
  72.             conn.Open();
  73.             return conn;
  74.         }

  75.         public bool Return(SqlConnection obj)
  76.         {
  77.             if (obj != null && obj.State == ConnectionState.Open) return true;
  78.             else return false;
  79.         }
  80.     }
  81. }
復制代碼
測試結果如下:

QQ截圖20200419184607.jpg

可以看出,在第一次進行10次查詢的時候,連接池慢了一些,之后,都比每次實例化SqlConnection要快。

附上源碼

游客,如果您要查看本帖隱藏內容請回復






上一篇:C# 程序運行耗時測試類
下一篇:MSSQL Trusted_Connection 配置
碼農網,只發表在實踐過程中,遇到的技術難題,不誤導他人。
發表于 2020-4-19 21:58:46 | 顯示全部樓層
這是新東西
碼農網,只發表在實踐過程中,遇到的技術難題,不誤導他人。
發表于 2020-4-30 13:05:18 | 顯示全部樓層
來看看,支持,沙發
碼農網,只發表在實踐過程中,遇到的技術難題,不誤導他人。
您需要登錄后才可以回帖 登錄 | 注冊[Register]

本版積分規則

免責聲明:
碼農網所發布的一切軟件、編程資料或者文章僅限用于學習和研究目的;不得將上述內容用于商業或者非法用途,否則,一切后果請用戶自負。本站信息來自網絡,版權爭議與本站無關。您必須在下載后的24個小時之內,從您的電腦中徹底刪除上述內容。如果您喜歡該程序,請支持正版軟件,購買注冊,得到更好的正版服務。如有侵權請郵件與我們聯系處理。

Mail To:help@itsvse.com

QQ|Archiver|手機版|小黑屋|架構師 ( 魯ICP備14021824號-2 )|網站地圖

GMT+8, 2020-5-18 04:36

Powered by Discuz! X3.4

Copyright © 2001-2020, Tencent Cloud.

快速回復 返回頂部 返回列表
捕鸟达人老版