sqlserver清空service broker中的队列的语句分享

280 阅读 0 评论 185 点赞

我是靠谱客的博主妩媚冷风，这篇文章主要介绍sqlserver清空service broker中的队列的语句分享，现在分享给大家，希望可以做个参考。

复制代码代码如下:

 
USE TestDB 
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 

那么客户端接受到的消息如果没有处理，也会积攒在客户端队列中，其实就相当于许多未读邮件，我们可以使用以下脚本读取队列，读取后队列自动清空:

复制代码代码如下:

 
USE TestDB 
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 ; 
END CONVERSATION @RecvReplyDlgHandle ; 
SELECT @RecvReplyMsg AS ReceivedReplyMsg ; 
END 
COMMIT TRANSACTION ; 