SQL Server 2014 Service Broker消息延迟：如何配置即时发送？

我来帮你理清这个问题——SQL Server Service Broker的消息延迟发送其实是它的默认优化行为，但确实有办法调整，让消息更及时地送达目标队列。

为什么会有延迟？ #

Service Broker默认采用异步批量发送策略：后台的发送线程会每隔一段时间（默认约1秒）扫描待发送的消息，攒成一批再发送。这种设计是为了减少网络交互次数，提升整体系统性能，但在需要实时性的场景下就会显得有延迟。

让消息立即发送的几种方法 #

1. 针对单个会话设置即时发送

如果你只需要特定会话的消息立即发送，可以在创建会话后，用ALTER CONVERSATION将该会话的SEND_DELAY设为0。这样这个会话的消息会被后台线程优先处理，几乎无延迟发送。

示例代码：

-- 假设@conversation_handle是你的会话句柄
ALTER CONVERSATION @conversation_handle
SET SEND_DELAY = 0;

这个方法适合需要实时交互的特定会话，不会影响其他会话的批量发送策略。

2. 用队列激活触发立即发送

如果你的发起方队列是用来存放待发送的消息（比如通过业务逻辑把消息写入队列，再由程序发送），可以配置队列激活，让消息一进入队列就触发存储过程立即处理发送。

步骤如下：
首先创建一个处理发送逻辑的存储过程：

CREATE PROCEDURE dbo.SendHadoopMessages
AS
BEGIN
    SET NOCOUNT ON;
    DECLARE @conversation_handle UNIQUEIDENTIFIER;
    DECLARE @message_body VARBINARY(MAX);

    WHILE (1=1)
    BEGIN
        BEGIN TRANSACTION;

        -- 从发起方队列接收待发送的消息
        WAITFOR (
            RECEIVE TOP(1)
                @conversation_handle = conversation_handle,
                @message_body = message_body
            FROM dbo.HadoopInitiatorAuditQueue
        ), TIMEOUT 1000;

        -- 没有消息就退出循环
        IF @@ROWCOUNT = 0
        BEGIN
            ROLLBACK TRANSACTION;
            BREAK;
        END

        -- 发送消息到目标服务
        SEND ON CONVERSATION @conversation_handle
            MESSAGE TYPE [//Photo/Message] (@message_body);

        COMMIT TRANSACTION;
    END
END
GO

然后修改队列启用激活：

ALTER QUEUE dbo.HadoopInitiatorAuditQueue
WITH ACTIVATION (
    STATUS = ON, -- 启用激活
    PROCEDURE_NAME = dbo.SendHadoopMessages, -- 触发的存储过程
    MAX_QUEUE_READERS = 1, -- 最大并发处理的线程数
    EXECUTE AS OWNER -- 执行存储过程的身份
);

这样只要有消息进入发起方队列，存储过程就会立即被触发，把消息发送出去。

3. 纠正一个可能的误解

这里要提醒下：发起方队列的主要作用是接收目标服务的响应消息或错误消息，而不是存放待发送的消息。当你执行SEND语句时，消息会直接被标记为待发送，由后台线程处理，不会进入发起方队列。如果你的发起方队列里有消息，建议用RECEIVE语句查看消息类型，确认是不是响应或错误消息。

我之前在处理实时数据同步的场景时，用会话级的SEND_DELAY设置，几乎实现了无延迟发送，效果很理想。如果是批量消息场景，队列激活的方式也能保证消息的即时处理。

内容的提问来源于stack exchange，提问作者oula alshiekh