如何从 SQL Server 内存中清除 SqlDependency？

Posted 2023-02-19

【中文标题】如何从 SQL Server 内存中清除 SqlDependency？

【英文标题】：How do I clean SqlDependency from SQL Server memory?

【发布时间】：2012-01-20 15:50:18

【问题描述】：

如何清理 SQL Server 以清除过期的SqlDependency 对象？从SqlDepedency 对象接收到事件后，我需要创建一个新事件，然后才能获取新事件。但是，SQL Server 进程的内存使用会攀升，直到用完允许的内存 (SQL Server Express)。如何摆脱旧查询？

代码：

// Func: RegisterTableListener
using (SqlConnection cn = new SqlConnection(Properties.Settings.Default.DatabseEventConnectionString))

if (cmd == null)

    cmd = cn.CreateCommand();

    cmd.CommandType = CommandType.Text;
    cmd.CommandText = "SELECT HostName, LastStatus, LastDetails, xml FROM dbo.[SystemTable]";


lock (cmd)

    cmd.Connection = cn;
    cn.Open();
    cmd.Notification = null;

    //  creates a new dependency for the SqlCommand
    if (dep == null)
        dep = new SqlDependency(cmd);
    //  creates an event handler for the notification of data
    //      changes in the database.
    dep.OnChange += new OnChangeEventHandler(dependency_OnChange);


    using (SqlDataReader reader = cmd.ExecuteReader())
    
    // code here to read
    



// Func dependency_OnChange
//SqlDependency dep = sender as SqlDependency;
dep.OnChange -= dependency_OnChange;
RegisterTableListener();

【问题讨论】：

您是如何创建SqlDependency 对象的？请发布您的代码。你处理得当吗？

明天上班时我会用代码更新我的评论。须藤：SqlDependency dep = new SqlDependency(cmd); dep.OnChange += 有趣； SqlDependency 没有实现 IDisposable

我已经更新了代码。即使我只运行一个 SqlDepdency 实例并每次调用 Stop 和 Start，内存也会攀升。我对正在发生的事情一无所知。

【参考方案1】：

Microsoft SqlDependency 类有一个特定的行为。即使您调用 SqlDependency.Stop() 方法，释放 SqlCommand 和 SqlConnection - 它仍将会话组 (sys.conversation_groups) 和会话端点 (sys.conversation_endpoints) 保留在数据库中。看起来 SQL Server 会加载每个对话端点并使用所有允许的内存。 Here 测试证明了这一点。因此，要清除所有未使用的会话端点并释放所有占用的内存，您必须为您的数据库启动此 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;

此外，SqlDependency 不会让您有机会接收表的所有更改。因此，您不会在 SqlDependency 重新订阅期间收到有关更改的通知。

为了避免所有这些问题，我使用了 SqlDependency 类的另一个开源实现 - SqlDependencyEx。它使用数据库触发器和本机 Service Broker 通知来接收有关表更改的事件。这是一个用法示例：

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);

希望这会有所帮助。

【讨论】：

这一行是什么意思 WHERE CEP.state = 'DI' or CEP.state = 'CD'。你想做什么。请帮我理解。谢谢

@Mou DI 表示“DisconnectedInbound”，CD 表示“关闭”。带有此标记的对话端点没有由SqlDependency 设置的生命周期。这意味着它们将在数据库中，直到您强制清理它们。根据文章rusanu.com/2014/03/31/…（最后），这是清理旧对话端点的正确方法。

这是否意味着如果我使用这个 sql WHERE CEP.state = 'DI' or CEP.state = 'CD' 那么旧对话将被删除？

@Mou 这是内存泄漏的另一个证据和发明者关于它的cmets。最后，您可以找到类似的解决方案。 groups.google.com/forum/#!topic/… 这里是单元测试，显示SqlDependency 在数据库中保持未关闭或终生不存在的会话端点。 github.com/dyatchenko/ServiceBrokerListener/blob/master/…

@Mou 我上面提到的来自 Rusanu 的文章给出了一个仅清理具有 CD 状态的旧对话端点的示例。但根据我的经验，DI 端点也一直在数据库中。