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

Question

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

c#sqlsql-server-2008sqldependency

14

如何清理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();

- JeremyK

你是如何创建 SqlDependency 对象的？请把你的代码贴出来。你是否正确地处理了它们的释放？ - Oded

明天上班时我会更新我的评论并附上代码。Sudo： SqlDependency dep = new SqlDependency(cmd); dep.OnChange += fun;SqlDependency没有实现IDisposable。 - JeremyK

我已经更新了代码。即使我只运行一个 SqlDepdency 实例并每次调用 Stop 和 Start，内存也会不断上升。我对发生的事情毫无头绪。 - JeremyK

1个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- dyatchenko · Accepted Answer

Microsoft SqlDependency类具有特定的行为。即使您调用了SqlDependency.Stop()方法并释放了SqlCommand和SqlConnection，它仍然会在数据库中保留对话组（sys.conversation_groups）和对话端点（sys.conversation_endpoints）。看起来SQL Server加载了每个对话端点并使用了所有允许的内存。这里是证明这一点的测试。因此，要清除所有未使用的对话端点并释放所有占用的内存，您需要针对数据库启动此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。它使用数据库触发器和本地服务代理通知来接收有关表格更改的事件。以下是使用示例：

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

希望这可以帮到您。