删除服务代理队列中的消息

Question

我想在 SQL Server Management Studio 中清除我的队列，但我不想删除整个队列，只删除队列中的内容（消息）。

Answer 1

为了清楚起见，只需结合前面的两个答案（Ben 和 Jānis）。这对我有用：

declare @c uniqueidentifier
while(1=1)
begin
    select top 1 @c = conversation_handle from dbo.queuename
    if (@@ROWCOUNT = 0)
    break
    end conversation @c with cleanup
end

Answer 2

这样的事情应该可以工作：

while(1=1)
begin
    waitfor (
        receive top(1)
        conversation_group_id
        from dbo.yourQueue
    ), timeout 1000;

    if (@@rowcount = 0)
        break;
end

Answer 3

我会使用end conversation（这也会从所有队列中删除所有相关消息）使用语句：

End Converstation @c With CleanUp

如果您只是收到消息，那么您将保持对话打开。 使用 CleanUp 结束对话仅适用于特定情况。

Answer 4

如果您使用的是 SQL Server（从 2008 年开始），您可以使用 RECEIVE

WHILE (0=0)
BEGIN
    RECEIVE * FROM dbo.YourQueue;
    IF (@@ROWCOUNT = 0) BREAK;
END

Answer 5

我遇到了与原始海报相同的问题，但我需要清除队列 数百万条消息（失败的消息队列，尤其是在多年未检查的非生产环境中）。

上述解决方案本来可行，但每分钟处理的消息不到 10 条。通过批量处理，我每分钟收到 30000 条消息。

代码中唯一值得注意的项目是where validation = 'N'。这将对话句柄限制为真实消息。 end conversation 删除了响应/错误的重复对话句柄。如果没有这个子句，脚本仍然可以工作，但会在输出中产生很多错误。

declare @conversationBatch table (convH uniqueidentifier)
declare @conversationHandle uniqueidentifier

declare convCursor cursor for
    select convH from @conversationBatch

insert into @conversationBatch
    select top 1000 conversation_handle  
      from dbo.queuename WITH (NOLOCK) 
     where validation = 'N'


while @@rowcount > 0
begin
    open convCursor
    fetch next from convCursor into @conversationHandle
    while @@FETCH_STATUS = 0 
    begin
        end conversation @conversationHandle with cleanup
        fetch next from convCursor into @conversationHandle
    end
    close convCursor

    delete from @conversationBatch
    insert into @conversationBatch
        select top 1000 conversation_handle  
          from dbo.queuename WITH (NOLOCK) 
         where validation = 'N'
    
 end

 deallocate convCursor

Answer 6

while(1=1)
begin
    waitfor (
        receive top(1)
        conversation_group_id
        from kartokumaqueue2), timeout 1000;

        if(@@ROWCOUNT = 0) break;
end