新增表行时，能否用触发器、队列及SQL Server Service Broker向本地非WS服务发数据？

嗨，咱们来逐个解决你关于SQL Server Service Broker（SSB）的两个问题——这些都是非常典型的使用场景，很高兴你在探索这块技术！

当然可以！SSB本身就是SQL Server原生的异步消息传递组件，天生就支持和各类服务交互，主要分两种场景：

• 数据库内部/跨实例服务通信：这是SSB的核心能力，同一SQL Server实例内的不同数据库服务，或者不同SQL Server实例之间的服务，都可以直接通过SSB的对话机制收发消息，完全不需要额外中间件。
• 与外部服务通信：如果要给数据库外的服务发数据，你需要一个"桥接"程序——可以是后台运行的外部应用（比如用C#、Python写的监听程序），它持续监听SSB的队列，一旦有新消息就取出并转发给目标服务；也可以用SSB的内部激活存储过程，但存储过程调用外部服务的灵活性有限，更推荐用外部程序来做这件事。

绝对可行！这是SSB结合触发器实现事件驱动业务流程的经典玩法，整体流程清晰明了：

步骤拆解： #

1. 搭建SSB基础环境：先给目标数据库启用SSB，然后创建消息类型（定义消息格式）、契约（规定消息交互规则）、队列（存储消息）和服务（负责收发消息）——这些是SSB工作的基础组件，缺一不可。
2. 编写INSERT触发器：在你要监控的表上创建AFTER INSERT触发器，当有新行插入时，触发器把新增数据打包成XML/JSON格式，通过SEND ON CONVERSATION语句将消息送入SSB队列。

   划重点：触发器里的逻辑一定要轻量化！只负责把消息丢进队列就行，复杂处理交给后续环节，不然会拖慢插入操作的速度。

3. 实现消息监听与转发：因为目标是非WS的本地服务，你需要写一个独立的后台程序（比如.NET控制台应用、Python脚本），它持续连接SQL Server，监听SSB队列的新消息。一旦收到消息，就解析内容，再通过对应协议（比如TCP、本地IPC、自定义协议）把数据发送给本地的非WS服务。

简单的触发器代码示例： #

-- 假设已提前创建好消息类型、契约、队列和服务
CREATE TRIGGER trg_AfterInsert_NewRecords
ON YourTargetTable
AFTER INSERT
AS
BEGIN
    SET NOCOUNT ON;

    DECLARE @convHandle UNIQUEIDENTIFIER;
    DECLARE @recordData XML;

    -- 从插入的行中提取数据，打包成XML格式
    SELECT @recordData = (SELECT * FROM INSERTED FOR XML AUTO, ROOT('NewRecord'))
    FROM INSERTED;

    -- 启动SSB对话并发送消息
    BEGIN DIALOG CONVERSATION @convHandle
        FROM SERVICE [YourLocalNotificationService]
        TO SERVICE 'TargetQueueService'
        ON CONTRACT [NewRecordNotificationContract]
        WITH ENCRYPTION = OFF;

    SEND ON CONVERSATION @convHandle
        MESSAGE TYPE [NewRecordMessage] (@recordData);

    END CONVERSATION @convHandle;
END;

几个关键注意事项： #

• 确保数据库已启用SSB：执行ALTER DATABASE YourDatabaseName SET ENABLE_BROKER;（注意需要单用户模式或确保无活跃连接）
• 消息格式优先选XML或JSON，方便后续解析和传递复杂数据结构
• 外部监听程序要做好异常处理：比如断开自动重连、消息重试机制，避免消息丢失
• 触发器里严禁执行耗时操作，保持快速完成，否则会影响表的插入性能

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