【发布时间】：2014-05-20 10:00:36
【问题描述】：
我在任何地方都找不到答案。
我将展示简单的代码片段，展示如何轻松破坏连接池。
连接池损坏意味着每次打开新连接的尝试都会失败。
要体验我们需要的问题：
- 在分布式事务中
- 嵌套sqlconnection及其sqltransaction在其他sqlconnection和sqltransaction中
- 回滚（显式或隐式 - 根本不提交）嵌套 sqltransaction
当连接池损坏时，每个 sqlConnection.Open() 都会引发以下情况之一：
- SqlException：不允许启动新请求，因为它应该带有有效的事务描述符。
- SqlException：分布式事务已完成。在新事务或 NULL 事务中登记此会话。
ADO.NET 内部存在某种线程竞争。如果我将Thread.Sleep(10) 放在代码中的某个位置，它可能会将收到的异常更改为第二个异常。有时它会在没有任何修改的情况下改变。
如何重现
- 启用分布式事务协调器 windows 服务（默认启用）。
- 创建空的控制台应用程序。
- 创建 2 个数据库（可以为空）或 1 个数据库并取消注释行：
Transaction.Current.EnlistDurable[...] - 复制粘贴以下代码：
var connectionStringA = String.Format(@"Data Source={0};Initial Catalog={1};Integrated Security=True;pooling=true;Max Pool Size=20;Enlist=true",
@".\YourServer", "DataBaseA");
var connectionStringB = String.Format(@"Data Source={0};Initial Catalog={1};Integrated Security=True;pooling=true;Max Pool Size=20;Enlist=true",
@".\YourServer", "DataBaseB");
try
{
using (var transactionScope = new TransactionScope())
{
//we need to force promotion to distributed transaction:
using (var sqlConnection = new SqlConnection(connectionStringA))
{
sqlConnection.Open();
}
// you can replace last 3 lines with: (the result will be the same)
// Transaction.Current.EnlistDurable(Guid.NewGuid(), new EmptyIEnlistmentNotificationImplementation(), EnlistmentOptions.EnlistDuringPrepareRequired);
bool errorOccured;
using (var sqlConnection2 = new SqlConnection(connectionStringB))
{
sqlConnection2.Open();
using (var sqlTransaction2 = sqlConnection2.BeginTransaction())
{
using (var sqlConnection3 = new SqlConnection(connectionStringB))
{
sqlConnection3.Open();
using (var sqlTransaction3 = sqlConnection3.BeginTransaction())
{
errorOccured = true;
sqlTransaction3.Rollback();
}
}
if (!errorOccured)
{
sqlTransaction2.Commit();
}
else
{
//do nothing, sqlTransaction3 is alread rolled back by sqlTransaction2
}
}
}
if (!errorOccured)
transactionScope.Complete();
}
}
catch (Exception e)
{
Console.WriteLine(e.Message);
}
那么：
for (var i = 0; i < 10; i++) //all tries will fail
{
try
{
using (var sqlConnection1 = new SqlConnection(connectionStringB))
{
// Following line will throw:
// 1. SqlException: New request is not allowed to start because it should come with valid transaction descriptor.
// or
// 2. SqlException: Distributed transaction completed. Either enlist this session in a new transaction or the NULL transaction.
sqlConnection1.Open();
Console.WriteLine("Connection successfully open.");
}
}
catch (Exception e)
{
Console.WriteLine(e.Message);
}
}
已知的不良解决方案以及可以观察到的有趣之处
糟糕的解决方案：
在嵌套 sqltransaction 中使用块 do:
sqlTransaction3.Rollback(); SqlConnection.ClearPool(sqlConnection3);将所有 SqlTransactions 替换为 TransactionScopes（
TransactionScope必须包装SqlConnection.Open()）在嵌套块中使用外部块的 sqlconnection
有趣的观察：
如果应用程序在连接池损坏后等待几分钟，则一切正常。 所以连接池损坏只会持续几分钟。
附加了调试器。当执行离开外部 sqltransaction 时使用块
SqlException: The ROLLBACK TRANSACTION request has no corresponding BEGIN TRANSACTION.被抛出。try ... catch ....无法捕获该异常。
如何解决？
这个问题使我的 Web 应用程序几乎死机（无法打开任何新的 sql 连接）。
呈现的代码片段是从整个管道中提取的，其中也包含对 3rd 方框架的调用。我不能简单地更改代码。
- 有人知道到底出了什么问题吗？
- 是不是 ADO.NET 错误？
- 也许我（和一些框架......）做错了什么？
我的环境（好像不是很重要）
- .NET Framework 4.5
- MS SQL Server 2012
【问题讨论】：
-
我会说你的“糟糕的解决方案”#2 是正确的方法。我不确定你为什么偏爱 SqlTransaction 到 TransactionScope。
标签： transactions ado.net transactionscope msdtc