复制代码 代码如下: 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 @co
复制代码 代码如下: 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 ;
