ado.net链接池

时间 2020-05-30

标签 ado.net ado 链接繁體版

原文原文链接

ado.NET 中提供了链接池的功能，多数开发人员不多设置它，由于它是默认的。

界面设置以下图：

关闭链接池也很简单，在链接字符串以下：

Data Source=(local);Initial Catalog=AdventureWorks;Integrated Security=SSPI;Pooling=False ;

但链接池的本质是什么样的呢？

用Reflector ，打开System.Data.SqlClient.SqlConnection 的ConnectionString 属性的设置值的方法，以下：

private void ConnectionString_Set(string value)

{

DbConnectionOptions userConnectionOptions = null;

DbConnectionPoolGroup group = this.ConnectionFactory.GetConnectionPoolGroup(value, null, ref userConnectionOptions);

DbConnectionInternal innerConnection = this.InnerConnection;

bool allowSetConnectionString = innerConnection.AllowSetConnectionString;

if (allowSetConnectionString)

{

allowSetConnectionString= this.SetInnerConnectionFrom(DbConnectionClosedBusy.SingletonInstance, innerConnection);

if (allowSetConnectionString)

{

this._userConnectionOptions = userConnectionOptions;

this._poolGroup = group;

this._innerConnection = DbConnectionClosedNeverOpened.SingletonInstance;

}

if (!allowSetConnectionString)

{

throw ADP.OpenConnectionPropertySet("ConnectionString", innerConnection.State);

}

if (Bid.TraceOn)

{

string str = (userConnectionOptions != null) ? userConnectionOptions.UsersConnectionStringForTrace() : "";

Bid.Trace("<prov.DbConnectionHelper.ConnectionString_Set|API> %d#, '%ls'\n", this.ObjectID, str);

}

再链接到红色的GetConnectionPoolGroup 方法，以下代码

internal DbConnectionPoolGroup GetConnectionPoolGroup(string connectionString, DbConnectionPoolGroupOptions poolOptions, ref DbConnectionOptions userConnectionOptions)

{

DbConnectionPoolGroup group;

if (ADP.IsEmpty(connectionString))

{

return null;

}

if (!this._connectionPoolGroups.TryGetValue(connectionString, out group) || (group.IsDisabled && (group.PoolGroupOptions != null)))

{

DbConnectionOptions options = this.CreateConnectionOptions(connectionString, userConnectionOptions);

if (options == null)

{

throw ADP.InternalConnectionError(ADP.ConnectionError.ConnectionOptionsMissing);

}

string str = connectionString;

if (userConnectionOptions == null)

{

userConnectionOptions = options;

str = options.Expand();

if (str != connectionString)

{

return this.GetConnectionPoolGroup(str, null, ref userConnectionOptions);

}

if ((poolOptions == null) && ADP.IsWindowsNT)

{

if (group != null)

{

poolOptions = group.PoolGroupOptions;

}

else

{

poolOptions = this.CreateConnectionPoolGroupOptions(options);

}

DbConnectionPoolGroup group2 = new DbConnectionPoolGroup(options, poolOptions) {

ProviderInfo = this.CreateConnectionPoolGroupProviderInfo(options)

};

lock (this)

{

Dictionary<string, DbConnectionPoolGroup> dictionary = this._connectionPoolGroups;

if (!dictionary.TryGetValue(str, out group))

{

Dictionary<string, DbConnectionPoolGroup> dictionary2 = new Dictionary<string, DbConnectionPoolGroup>(1 + dictionary.Count);

foreach (KeyValuePair<string, DbConnectionPoolGroup> pair in dictionary)

{

dictionary2.Add(pair.Key, pair.Value);

}

dictionary2.Add(str, group2);

this.PerformanceCounters.NumberOfActiveConnectionPoolGroups.Increment();

group = group2;

this._connectionPoolGroups = dictionary2;

}

return group;

}

if (userConnectionOptions == null)

{

userConnectionOptions = group.ConnectionOptions;

}

return group;

}

TryGetValue 是判断是否存在链接字符串为connectionString 的链接，存在返回到group ，不存在就调用CreateConnectionOptions 建立一个DbConnectionOptions ，最后用

lock (this)

{

Dictionary<string, DbConnectionPoolGroup> dictionary = this._connectionPoolGroups;

if (!dictionary.TryGetValue(str, out group))

{

Dictionary<string, DbConnectionPoolGroup> dictionary2 = new Dictionary<string, DbConnectionPoolGroup>(1 + dictionary.Count);

foreach (KeyValuePair<string, DbConnectionPoolGroup> pair in dictionary)

{

dictionary2.Add(pair.Key, pair.Value);

}

dictionary2.Add(str, group2);

this.PerformanceCounters.NumberOfActiveConnectionPoolGroups.Increment();

group = group2;

this._connectionPoolGroups = dictionary2;

}

return group;

}

这段代码放到链接池中，在这里，可能显示的看到，ado.NET 的链接池实质上是一个Dictionary<string, DbConnectionPoolGroup> 泛型集合。

所谓的链接池，就是一个与链接对象Connection 相关的集合，这不仅是简单的集合，而是有必定的机制在内部。咱们作开发时，可能创建Connection 链接对象，关闭链接对象，有时候还调用Dispose 来释放链接。下次再用时，便从新实例化一个链接。但在池中的链接不随链接对象的Close 或Dispose 而释放。若是下次从新创建链接，链接字符串与前一次彻底如出一辙，则链接池就会把上次可用的链接对象赋给链接去用。若是两个链接字符串有一点不同，即便在某一个地方多一个空格，链接池也不会觉得是相同的链接，这点微软可能在内部只直接去比较两个字符串了，而不是比较链接数据库字符串的键值互相匹配。

链接池的好处就是保留链接对象，防止下次重头再来实例化一个链接对象。

（说明：可能找到结果后以为很是简单，但怎么找到结果的，倒是费了很大劲，几乎是5 个小时，因此相把找到结果的过程简单说一下：

一开始用Reflector 发现SqlConnection 中有一个PoolGroup 的属性，因而就想在运行时候比较两个SqlConnection 对象的这个属性，但因为这个属性是的访问修饰符是internal 的，不能直接访问，只有用反射，代码（是通过优化的）以下：

string constr1 = "Data Source=(local);Initial Catalog=AdventureWorks;Integrated Security=SSPI;";

string constr2 = "Data Source=(local);Initial Catalog=Pubs;Integrated Security=SSPI;";

string AssMark = "System.Data,Version=2.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089";

Assembly ass = Assembly.Load(AssMark);

Type SqlConType = null;

foreach (Type conType in ass.GetExportedTypes())

{

Console.WriteLine(conType .ToString ());

if ("System.Data.SqlClient.SqlConnection" == conType.ToString())

{

SqlConType = conType;

}

if (SqlConType != null)

{

Type[] types1 = new Type[0];

ConstructorInfo constructorInfoObj1 = SqlConType.GetConstructor(

BindingFlags.Instance | BindingFlags.Public, null,

CallingConventions.HasThis, types1, null);

SqlConnection con1 = (SqlConnection)constructorInfoObj1.Invoke(null);

con1.ConnectionString = constr1;

SqlConnection con2 = (SqlConnection)constructorInfoObj1.Invoke(null);

con2.ConnectionString = constr2;

PropertyInfo PI = SqlConType.GetProperty("PoolGroup", BindingFlags.Instance | BindingFlags.NonPublic);

object poolGroup1 = PI.GetValue(con1, null);

object poolGroup2 = PI.GetValue(con2, null);

}

而后在倒数第一行设置断点，为比较poolGroup1 和poolGroup2 的不一样，结果发现，当链接字符串同样时，这两个对象的_objectID 相同，字符串有一点不一样就会不一样，这点说明链接池中是用字符串自己比较的，而不是字符串中键值对进行比较。同还发现当con1 和con2 的ConnectionString 不赋值时这两个对象都是null ，由此说明关键是ConnectionString 赋值上，因此才开始用Reflector 查看这个属性的赋值方法，才有上面的代码。）

.net 职场链接池 .Net基础知识

0html

收藏微信

上一篇：.net中的TDD 下一篇：LINQ表间关联执行分析

桂素伟

199篇文章，105W+人气，42粉丝

关注