c# - SQL Server 断开连接导致连接池问题

Question

我有一个通过 RabbitMQ 接收消息的 Windows 服务，这会触发一个事件处理程序，它会执行一些工作，然后尝试将结果保存到数据库中。它的线程使用:

ThreadPool.QueueUserWorkItem(ProcessMessageOnThread, messageReceived);

其中 ProcessMessageOnThread 是一种在 messageReceived 上工作的方法，messageReceived 表示从 RabbitMQ 出队的消息。

在正常情况下，windows 服务按预期运行，即出队、处理和持久化。

我想确保我的所有消息都得到处理并给予公平的处理更改，所以如果我无法打开到 SQL Server 的连接，我只需重新排队消息以便再次处理它(希望那个时候SQL Server 会回来，否则这种情况会继续 - 我对此很好)。

当进程按预期运行了一段时间后，问题就来了，SQL Server 连接池已满，然后 SQL Server 断开连接，现在这是事情发生的时候有点不稳定。

可能会发生以下两种情况之一:

• 在 connection.Open() 上抛出了一个异常 - 但是我正在捕获它，所以并不担心它

• cmd.ExecuteNonQuery() 抛出异常 - 这是我执行存储过程的地方

这是我需要弄清楚如何处理的第二个选项。以前我假设这里的任何异常都意味着我传递给存储过程的数据有问题，因此应该将它移出队列并让其他东西分析它。

但是，现在我认为我需要一种新方法来处理异常与实际未建立的连接有关的情况。

我看过 SqlException class 并注意到一个名为 Class 的属性，它具有这样的描述 Gets the severity level of the error returned from SQL Server，现在关于这个的信息说:

Messages with a severity level of 10 or less are informational and indicate problems caused by mistakes in information that a user has entered. Severity levels from 11 through 16 are generated by the user, and can be corrected by the user. Severity levels from 17 through 25 indicate software or hardware errors. When a level 17, 18, or 19 error occurs, you can continue working, although you might not be able to execute a particular statement.

这是否意味着修复我的异常处理我可以检查 if (ex.Class > 16) 然后重新排队消息，因为问题出在连接上 else 抛出它离开，因为它很可能与发送到存储过程的格式错误的数据有关？

所以问题是，我应该如何进行异常处理，以及在调用 cmd.ExecuteNonQuery() 时如何检测抛出的异常是否是因为连接断开。

---

更新:

我之前遇到过连接未返回到池中的问题(这是由于线程问题)并且已经解决了这些问题，所以我相信问题与连接未返回到池中无关水池。此外，关于连接的用途的逻辑非常简单，我也确保它们始终关闭......所以我更感兴趣的是与 Sql Server 断开连接然后捕获行为的答案cmd.ExecuteNonQuery() 的

Answer 1

由于各种原因，连接池中的连接可能会进入一种奇怪的状态，所有这些都与糟糕的应用程序设计有关:

• 在其关联的数据读取器之前关闭连接
• 更改池不会重置的设置(如事务隔离级别)
• 启动异步查询 (BeginOpenReader)，然后在异步处理程序触发之前将连接返回到池中

您应该调查您的应用程序并确保连接已正确返回到池中。可以帮助调试的一件事是减少开发设置中应用程序池的大小。您更改连接字符串中池的大小:

...;Integrated Security=SSPI;Max Pool Size=2;Pooling=True;

这使得池化问题更容易重现。

如果您找不到原因，但仍需要部署修复程序，您可以使用 ClearPool 或 ClearAllPools 之一。当您在 Open() 或 ExecuteNonQuery() 之后检测到可疑异常之一时，这样做的好地方。两者都是 SqlConnection 类的静态方法:

SqlConnection.ClearPool(yourConnection);

或者更粗略的方法:

SqlConnection.ClearAllPools()

请注意，这基本上是 Pokémon Exception Handling .如果它有效，你将不知道为什么。 :)