如何清理过期的SqlDependency对象并防止SQL Server内存泄漏？

解决由过期的 SqlDependency 对象导致的 SQL Server 内存泄漏

问题：

使用 SqlDependency 对象时，SQL Server 的内存使用量会稳步增加。 这是因为，即使在调用 SqlDependency.Stop() 并释放 SqlCommand 和 SqlConnection 之后，数据库也会保留会话组和端点。 这种积累最终会导致内存耗尽，尤其是在 SQL Server Express 中。

解决方案：

以下 SQL 脚本清理这些过期的对话端点：

<code class="language-sql">DECLARE @ConvHandle uniqueidentifier
DECLARE Conv CURSOR FOR
SELECT CEP.conversation_handle FROM sys.conversation_endpoints CEP
WHERE CEP.state = 'DI' or CEP.state = 'CD'
OPEN Conv;
FETCH NEXT FROM Conv INTO @ConvHandle;
WHILE (@@FETCH_STATUS = 0) BEGIN
    END CONVERSATION @ConvHandle WITH CLEANUP;
    FETCH NEXT FROM Conv INTO @ConvHandle;
END
CLOSE Conv;
DEALLOCATE Conv;</code>

针对出现内存泄漏的数据库执行此脚本。

Sql依赖限制：

重要的是要了解SqlDependency并不完美。它可能会错过一些表更改，特别是在重新订阅过程中发生的更改。

更好的方法：SqlDependencyEx

要获得更强大、更可靠的解决方案，请考虑使用 SqlDependencyEx，一种开源替代方案。 它利用数据库触发器和 Service Broker 通知来更有效地处理更改事件。 这是一个例子：

<code class="language-csharp">int changesReceived = 0;
using (SqlDependencyEx sqlDependency = new SqlDependencyEx(
          TEST_CONNECTION_STRING, TEST_DATABASE_NAME, TEST_TABLE_NAME)) 
{
    sqlDependency.TableChanged += (o, e) => changesReceived++;
    sqlDependency.Start();

    // Make table changes.
    MakeTableInsertDeleteChanges(changesCount);

    // Wait a little bit to receive all changes.
    Thread.Sleep(1000);
}

Assert.AreEqual(changesCount, changesReceived);</code>

SqlDependencyEx 提供卓越的更改跟踪并消除与标准 SqlDependency 相关的内存问题。

以上是如何清理过期的SqlDependency对象并防止SQL Server内存泄漏？的详细内容。更多信息请关注PHP中文网其他相关文章！