Service Broker：使用 With Cleanup 时 Sys.Conversation_endpoints 会填充 CO/CONVERSING 消息

Question

我们最近发现我们的一个数据库存在问题，该问题是由于“火灾和火灾”导致的。忘记'设置（即：发送后立即关闭对话），我们的 sys.conversation_endpoints 表被 DI/DISCONNECTED_INBOUND 消息填满。这最终会溢出到 tempDB 中，导致它急剧增长并耗尽宝贵的磁盘空间。我们最终解决了这个问题，方法是在发送 SP 中注释掉行

END CONVERSATION @handle WITH CLEANUP

关闭接收 SP 中的对话

，并使用相同的代码END CONVERSATION @handle WITH CLEANUP< < /code>

然而，我们现在遇到了一个新问题。自从移动服务器（并从 SQL Server 2005 迁移到 SQL Server 2008）以来，我们最近发现 sys.conversation_endpoints 现在充满了 CO/CONVERSING 消息，表明对话尚未关闭。接收 SP 正在关闭它们，或者至少正在运行命令来这样做，所以我不明白这些消息来自哪里。

我尝试返回到发送时结束对话，但没有效果。使用 WITH CLEANUP 在接收端结束对话是否错误？或者还有其他问题吗？

此techtarget 上的帖子 似乎表明它是一个错误，运行作业来清理剩余物是唯一的解决方案......

更新： 帕维尔在下面指出，我应该避免火灾和火灾。忘记模式，我已将激活的 SP 添加到发起者队列中以结束任何对话。然而，sys.conversation_endpoints 仍然填满，这次是 CD/CLOSED 消息。这是我的队列 Send_SP 的结构

：

DECLARE @h UNIQUEIDENTIFIER 
BEGIN DIALOG CONVERSATION @h 
FROM SERVICE 'InitiatorQueue' TO SERVICE 'TargetQueue' 
ON CONTRACT 'MyContract' WITH ENCRYPTION = OFF; 
SEND ON CONVERSATION @h MESSAGE TYPE 'MyMessage' (@msg)

Receive_SP（TargetQueue 上激活的 SP）

DECLARE @type SYSNAME, @h UNIQUEIDENTIFIER, @msg XML;
DECLARE @target TABLE (
    [message_type_name] SYSNAME,
    [message_body] VARBINARY(MAX),
    [conversation_handle] UNIQUEIDENTIFIER
)
WHILE(1=1)
BEGIN TRANSACTION
    WAITFOR(RECEIVE TOP (1000) 
        [message_type_name],[message_body],[conversation_handle] 
        FROM TargetQueue INTO @target), TIMEOUT 2000            
    IF(@@rowcount!=0)
    BEGIN
        WHILE((SELECT count(*) FROM @target) > 0) 
        BEGIN
        SELECT TOP (1) @type = [message_type_name],
            @msg = [message_body],
            @h = [conversation_handle]  FROM @target;
        // Handle Message Here
        END CONVERSATION @h; 
        DELETE TOP (1) FROM @target;
    END
END
COMMIT TRANSACTION;

End_SP（InitiatorQueue 上激活的 SP）

DECLARE @type SYSNAME, @h UNIQUEIDENTIFIER, @msg XML;
DECLARE @init TABLE (
    [message_type_name] SYSNAME,
    [message_body] VARBINARY(MAX),
    [conversation_handle] UNIQUEIDENTIFIER
)
WHILE(1=1)
BEGIN TRANSACTION
    WAITFOR(RECEIVE TOP (1000) 
        [message_type_name],[message_body],[conversation_handle] 
        FROM InitiatorQueue INTO @init), TIMEOUT 2000           
    IF(@@rowcount!=0)
    BEGIN
        WHILE((SELECT count(*) FROM @init) > 0) 
        BEGIN
        SELECT TOP (1) @type = [message_type_name],
            @msg = [message_body],
            @h = [conversation_handle]  FROM @init;
        END CONVERSATION @h; 
        DELETE TOP (1) FROM @init;
    END
END
COMMIT TRANSACTION;

Answer 1

使用“即发即忘”模式将不可避免地导致此类问题和其他类型的问题。此外，它将使任何假设的错误都不会被注意到。是否有任何原因无法更改消息交换模式，以便目标在收到消息后发出 END CONVERSATION （无需清理！），然后发起者仅在收到结束对话消息时调用 END CONVERSATION （再次，无需清理）从目标？