5

即使我指定 Receive Top(25) 等,我一次也只能收到一条消息出列。不确定我在存储过程中做错了什么?可能是一些微不足道的事情,但我没有看到问题。

存储过程:

CREATE PROCEDURE dbo.SPP_DEQUEUE_MESSAGE

AS

BEGIN

DECLARE @receiveTable TABLE(
message_type        sysname,
message_body        xml,
message_dialog      uniqueidentifier);

    BEGIN TRANSACTION;

    WAITFOR
        ( RECEIVE TOP(25)
            message_type_name,
            message_body,
            conversation_handle  
          FROM TargetQueue1DB
            INTO @receiveTable
        ), TIMEOUT 3000;

    SELECT 
        *
    From @receiveTable;     

    Delete from @receiveTable;

COMMIT TRANSACTION;

END --End Sproc

知道我做错了什么吗?

谢谢,

4

2 回答 2

5

我的猜测是每条消息都属于不同的对话(因此默认情况下属于不同的对话组)。如果是这种情况,那么这是预期的行为。

联机书籍 - 接收 (Transact-SQL)

RECEIVE 语句返回的所有消息都属于同一个会话组

如果您想一次接收多条消息,请在单个会话中发送多条消息,或将多个会话分组到接收端的单个会话组中。

于 2010-12-16T09:51:15.063 回答
0

在运行过程之前,您知道该队列中有多少条消息吗?

如果您运行以下查询以获取所有队列中的计数

SELECT sq.name, p.rows FROM sys.service_queues sq Join sys.internal_tables it ON sq.object_id = it.parent_id AND it.parent_minor_id = 0 AND it.internal_type = 201 Join sys.indexes as i on i.object_id = it .object_id 和 i.index_id = 1 将 sys.partitions 作为 p 加入 p.object_id = i.object_id 和 p.index_id = i.index_id WHERE sq.object_id = it.parent_id AND it.parent_minor_id = 0 AND it.internal_type = 201

如果该队列中有超过 1 条消息,您应该收到超过 1 条消息。

于 2010-12-15T23:11:57.460 回答