SQL Server Service Broker结束会话在发起方队列新增条目如何处理

首先明确核心逻辑：你遇到的是SQL Service Broker的标准会话生命周期规则，当目标方调用END CONVERSATION后，系统会自动向发起方队列发送EndDialog系统消息，必须在发起方也调用一次END CONVERSATION才能完全释放会话资源、清理队列中的消息，不存在绕过该逻辑的方案。

不处理堆积消息的副作用 #

• 发起方队列会持续堆积EndDialog和潜在的错误消息，占用数据库存储空间
• 会话资源无法释放，SQL Server每个实例的会话句柄有容量上限，长期堆积会导致新对话无法创建，业务消息发送失败
• 会拉低Service Broker的整体消息处理性能，增加队列扫描开销

推荐解决方案 #

方案1：SQL侧自动处理（无需修改C#服务，推荐） #

通过给发起方队列配置激活存储过程，由SQL Server自动处理系统消息，无需改动现有C#服务逻辑：

1. 创建消息处理存储过程：

CREATE PROCEDURE dbo.ProcessInitiatorQueueMessages
AS
BEGIN
    SET NOCOUNT ON;
    DECLARE @conversation_handle UNIQUEIDENTIFIER;
    DECLARE @message_type_name SYSNAME;

    WHILE 1 = 1
    BEGIN
        -- 从发起方队列接收顶部消息
        WAITFOR (
            RECEIVE TOP(1)
                @conversation_handle = conversation_handle,
                @message_type_name = message_type_name
            FROM dbo.MyEventInitiatorQueue
        ), TIMEOUT 1000;

        IF @@ROWCOUNT = 0 BREAK;

        -- 仅处理结束对话和错误消息，直接关闭会话
        IF @message_type_name IN (
            'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog',
            'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
        )
        BEGIN
            END CONVERSATION @conversation_handle;
        END
    END
END
GO

2. 绑定队列激活配置：

ALTER QUEUE dbo.MyEventInitiatorQueue
WITH ACTIVATION (
    STATUS = ON,
    PROCEDURE_NAME = dbo.ProcessInitiatorQueueMessages,
    MAX_QUEUE_READERS = 1,
    EXECUTE AS OWNER
);
GO

该方案会自动监听发起方队列，收到系统消息后自动关闭会话，完全无需人工运维。

方案2：扩展C#服务逻辑 #

在现有C#服务中增加轻量的发起方队列监听逻辑，仅处理两类系统消息：

• 收到http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog或错误消息时，调用END CONVERSATION关闭对应会话即可，无需额外处理业务逻辑。

单向消息场景优化（火并忘场景） #

如果你的业务场景本身是单向通知，不需要目标方回复、也不需要确认送达状态，可以直接修改发送消息的SQL逻辑，发送完成后直接关闭发起方会话，从根源上避免消息堆积：

SEND ON CONVERSATION @conversation_handle   
    MESSAGE TYPE @MessageType(@MessageBody);
-- 发送完成直接关闭发起方会话
END CONVERSATION @conversation_handle;

现有堆积消息批量清理 #

如果当前发起方队列已经有大量堆积的结束会话消息，可以执行以下SQL一次性清理：

DECLARE @conversation_handle UNIQUEIDENTIFIER;
DECLARE cur CURSOR FOR
SELECT conversation_handle
FROM dbo.MyEventInitiatorQueue
WHERE message_type_name IN (
    'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog',
    'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
);

OPEN cur;
FETCH NEXT FROM cur INTO @conversation_handle;
WHILE @@FETCH_STATUS = 0
BEGIN
    END CONVERSATION @conversation_handle;
    FETCH NEXT FROM cur INTO @conversation_handle;
END
CLOSE cur;
DEALLOCATE cur;

内容的提问来源于stack exchange，提问作者user729400