架构师_程序员

查看: 425|回复: 2

[.NET Core] ADO.NET 通过 ObjectPool 创建 SqlConnection 连接池

[复制链接]
发表于 2020-4-19 18:51:31 | 显示全部楼层
ObjectPool 是微软新出的一个功能,微软帮我们维护一些对象,这些对象都可以进行复用。

简单来说,和共享单车类似,你用的时候去扫码开锁,这个车辆就代表被占用了,当你用完的时候,你锁车的时候,车辆会释放解除占用。这些占用和解除都是平台帮我们去维护。

有些对象不是线程安全的,但是,我们每次去实例化这个对象的时候,需要消耗一些资源。

.NET Core 中 Object Pool 详解
https://www.itsvse.com/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|手机版|小黑屋|架构师 ( 鲁ICP备14021824号-2 )|网站地图

GMT+8, 2020-9-30 03:38

Powered by Discuz! X3.4

Copyright © 2001-2020, Tencent Cloud.

快速回复 返回顶部 返回列表