SQL Server 清空 Service Broker 队列的两种方法

清空传输队列（Transmission Queue）

当 Service Broker 尝试发送消息但无法到达目标端时，消息会暂存在系统视图 sys.transmission_queue 中。如果这些消息不再需要或处于“死锁”状态，可以使用以下脚本进行批量清理。

执行此操作前请注意：这通常会删除尚未成功投递的消息，若数据有重要价值请确保已备份或确认消息内容可丢弃。

USE TestDB;
GO

DECLARE @conversation UNIQUEIDENTIFIER;

-- 当传输队列中存在记录时循环处理
WHILE EXISTS (SELECT 1 FROM sys.transmission_queue)
BEGIN
    -- 获取当前传输队列中的一条会话句柄
    SET @conversation = (
        SELECT TOP 1 conversation_handle 
        FROM sys.transmission_queue
    );

    -- 结束该对话并标记为清理（丢弃消息）
    END CONVERSATION @conversation WITH CLEANUP;
END
GO

操作说明：

• 入口：系统表 sys.transmission_queue。
• 关键参数：WITH CLEANUP 关键字告诉 Service Broker 放弃该对话上的所有未决消息。
• 完成判断：脚本执行完毕后再次查询 sys.transmission_queue 应无剩余记录。

清空客户端/目标队列中的未读消息

有时消息已成功到达目标队列（如 dbo.Test_TargetQueue），但应用程序未及时消费，导致队列中积攒大量“未读邮件”。要清空这类队列，最直接的方法是编写代码读取它们。一旦使用 RECEIVE 取出消息，该消息即从队列中移除。

以下脚本演示了一个典型的接收循环，读取后结束对话，从而实现队列清空的效果：

USE TestDB;
GO

DECLARE @RecvReplyMsg NVARCHAR(100);
DECLARE @RecvReplyDlgHandle UNIQUEIDENTIFIER;

BEGIN TRANSACTION;

-- 无限循环直到队列空或超时报错
WHILE (1 = 1)
BEGIN
    WAITFOR (
        RECEIVE TOP(1)
            @RecvReplyDlgHandle = conversation_handle,
            @RecvReplyMsg = message_body
        FROM dbo.Test_TargetQueue
    ), TIMEOUT 1000; -- 等待1秒后超时退出循环

    -- 检查是否收到消息，如果没有则跳出循环
    IF @@ROWCOUNT = 0 BREAK;

    -- 结束对话
    END CONVERSATION @RecvReplyDlgHandle;

    -- 可选：打印收到的消息内容以便调试
    SELECT @RecvReplyMsg AS ReceivedReplyMsg;
END

COMMIT TRANSACTION;
GO

注意事项：

1. 事务包裹：建议在显式事务中执行，以保证读取与结束对话的一致性。
2. TIMEOUT 设置：脚本中设置了 TIMEOUT 1000，防止在无消息时永久挂起。实际应用中可根据需求调整或改为非阻塞模式。
3. 副作用：执行此脚本后，队列中的消息将彻底消失。如果后续程序依赖这些消息，请先将它们存储到日志表中再做清空处理。

以上就是清空 SQL Server Service Broker 队列的详细内容，更多关于 Service Broker 队列管理和故障排查的资料请关注本站其它相关文章！