【SQL Server】Service Broker——在单个数据库建完成对话

一般来说，在SQL Server中调用存储过程，是同步的。如果一个操作比较长，那么我们我们希望执行异步操作。

消息队列概念 。消息队列在SQL Server李，是一种存储消息的结构。消息生产者将消息发送到队列中，而消息消费者则从队列中读取并处理消息。这种机制实现了应用程序组件之间的异步通信，提高了系统的可扩展性和响应能力。

消息队列位置

 接下来，我们会在同一个数据库间完成对话。

步骤

1. 启用Server Broker;请确保数据库支持Server Broker （SQL Server 2008r2及其以上，请参考官网）。https://learn.microsoft.com/zh-cn/sql/database-engine/service-broker/lesson-1-creating-the-conversation-objects?view=sql-server-ver16

 ALTER DATABASE AdventureWorks2008R2SET ENABLE_BROKER;

 2. 创建消息类型。复制以下代码并将其粘贴到查询编辑器窗口中。 然后，运行代码为会话创建消息类型。 由于通常在数据库引擎的多个实例间引用 Service Broker 对象，因而大多数 Service Broker 对象的名称都是以 URI 格式指定的。 这有助于确保它们在多台计算机上是唯一的。 这两种消息类型都指定 Service Broker 将只验证消息是否是格式正确的 XML 文档，并且指定 Service Broker 将不按照特定架构验证 XM

CREATE MESSAGE TYPE
           [//AWDB/1DBSample/RequestMessage]
           VALIDATION = WELL_FORMED_XML;
    CREATE MESSAGE TYPE
           [//AWDB/1DBSample/ReplyMessage]
           VALIDATION = WELL_FORMED_XML;
    GO

 3.创建协定。复制以下代码并将其粘贴到查询编辑器窗口中。 然后，运行代码为会话创建约定。 约定指定了使用此约定的会话必须将类型为 /AWDB/1DBSample/RequestMessage 的消息从发起方发送到目标以及将类型为 //AWDB/1DBSample/ReplyMessage 的消息从目标发送到发起方。

CREATE CONTRACT [//AWDB/1DBSample/SampleContract]
          ([//AWDB/1DBSample/RequestMessage]
           SENT BY INITIATOR,
           [//AWDB/1DBSample/ReplyMessage]
           SENT BY TARGET
          );
    GO

 4.创建目标队列和服务。复制以下代码并将其粘贴到查询编辑器窗口中。 然后，运行代码以创建要用于目标的队列和服务。 由于队列是从相同的数据库以类似于表和视图的方式引用的，因而队列名称的格式也类似于表名称或视图名称。 CREATE SERVICE 语句将服务与 TargetQueue1DB 相关联。 因此，所有发送给此服务的消息将接收到 TargetQueue1DB 中。 CREATE SERVICE 还指定只有使用先前创建的 //AWDB/1DBSample/SampleContract 的会话才能将该服务用作目标服务。

CREATE QUEUE TargetQueue1DB;

    CREATE SERVICE
           [//AWDB/1DBSample/TargetService]
           ON QUEUE TargetQueue1DB
           ([//AWDB/1DBSample/SampleContract]);
    GO

 5.创建发起方队列和服务。复制以下代码并将其粘贴到查询编辑器窗口中。 然后，运行代码以创建要用于发起方的队列和服务。 由于未指定约定名称，因而其他服务不可将此服务用作目标服务。

CREATE QUEUE InitiatorQueue1DB;

    CREATE SERVICE
           [//AWDB/1DBSample/InitiatorService]
           ON QUEUE InitiatorQueue1DB;
    GO

 6.启用会话并发动请求。复制以下代码并将其粘贴到查询编辑器窗口中。 然后，运行该代码以启动会话并向 //AWDB/1DBSample/TargetService 发送请求消息。 该代码必须在一个块中运行，因为是使用变量将对话句柄从 BEGIN DIALOG 语句传递到 SEND 语句。 批处理运行 BEGIN DIALOG 语句，以启动会话。 它会生成一个请求消息，然后使用 SEND 语句中的对话句柄发送该会话的请求消息。 最后一条 SELECT 语句显示已发送消息的文本。

DECLARE @InitDlgHandle UNIQUEIDENTIFIER;
    DECLARE @RequestMsg NVARCHAR(100);

    BEGIN TRANSACTION;

    BEGIN DIALOG @InitDlgHandle
         FROM SERVICE
          [//AWDB/1DBSample/InitiatorService]
         TO SERVICE
          N'//AWDB/1DBSample/TargetService'
         ON CONTRACT
          [//AWDB/1DBSample/SampleContract]
         WITH
             ENCRYPTION = OFF;

    SELECT @RequestMsg =
           N'<RequestMsg>Message for Target service.</RequestMsg>';

    SEND ON CONVERSATION @InitDlgHandle
         MESSAGE TYPE
         [//AWDB/1DBSample/RequestMessage]
         (@RequestMsg);

    SELECT @RequestMsg AS SentRequestMsg;

    COMMIT TRANSACTION;
    GO

 7. 接收请求并发送答复。复制以下代码并将其粘贴到查询编辑器窗口中。 然后，运行该代码以接收来自 TargetQueue1DB 的答复消息，并将答复消息发回给发起方。 RECEIVE 语句可检索该请求消息。 以下 SELECT 语句将显示文本，以便您可以验证它是否与上一步中发送的消息相同。 IF 语句测试所接收的消息是否是请求消息类型，并测试是否使用了 SEND 语句将答复消息发送回发起方。 END CONVERSATION 语句用于结束会话的目标端。 最后一条 SELECT 语句显示答复消息的文本。

DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER;
    DECLARE @RecvReqMsg NVARCHAR(100);
    DECLARE @RecvReqMsgName sysname;

    BEGIN TRANSACTION;

    WAITFOR
    ( RECEIVE TOP(1)
        @RecvReqDlgHandle = conversation_handle,
        @RecvReqMsg = message_body,
        @RecvReqMsgName = message_type_name
      FROM TargetQueue1DB
    ), TIMEOUT 1000;

    SELECT @RecvReqMsg AS ReceivedRequestMsg;

    IF @RecvReqMsgName =
       N'//AWDB/1DBSample/RequestMessage'
    BEGIN
         DECLARE @ReplyMsg NVARCHAR(100);
         SELECT @ReplyMsg =
         N'<ReplyMsg>Message for Initiator service.</ReplyMsg>';

         SEND ON CONVERSATION @RecvReqDlgHandle
              MESSAGE TYPE
              [//AWDB/1DBSample/ReplyMessage]
              (@ReplyMsg);

         END CONVERSATION @RecvReqDlgHandle;
    END

    SELECT @ReplyMsg AS SentReplyMsg;

    COMMIT TRANSACTION;
    GO

 8.接收答复并结束会话。

DECLARE @RecvReplyMsg NVARCHAR(100);
    DECLARE @RecvReplyDlgHandle UNIQUEIDENTIFIER;

    BEGIN TRANSACTION;

    WAITFOR
    ( RECEIVE TOP(1)
        @RecvReplyDlgHandle = conversation_handle,
        @RecvReplyMsg = message_body
      FROM InitiatorQueue1DB
    ), TIMEOUT 1000;

    END CONVERSATION @RecvReplyDlgHandle;

    SELECT @RecvReplyMsg AS ReceivedReplyMsg;

    COMMIT TRANSACTION;
    GO

 9.删除会话对象。复制以下代码并将其粘贴到查询编辑器窗口中。 然后，运行代码以删除用于支持该会话的对象

IF EXISTS (SELECT * FROM sys.services
               WHERE name =
               N'//AWDB/1DBSample/TargetService')
         DROP SERVICE
         [//AWDB/1DBSample/TargetService];

    IF EXISTS (SELECT * FROM sys.service_queues
               WHERE name = N'TargetQueue1DB')
         DROP QUEUE TargetQueue1DB;

    -- Drop the initiator queue and service if they already exist.
    IF EXISTS (SELECT * FROM sys.services
               WHERE name =
               N'//AWDB/1DBSample/InitiatorService')
         DROP SERVICE
         [//AWDB/1DBSample/InitiatorService];

    IF EXISTS (SELECT * FROM sys.service_queues
               WHERE name = N'InitiatorQueue1DB')
         DROP QUEUE InitiatorQueue1DB;

    IF EXISTS (SELECT * FROM sys.service_contracts
               WHERE name =
               N'//AWDB/1DBSample/SampleContract')
         DROP CONTRACT
         [//AWDB/1DBSample/SampleContract];

    IF EXISTS (SELECT * FROM sys.service_message_types
               WHERE name =
               N'//AWDB/1DBSample/RequestMessage')
         DROP MESSAGE TYPE
         [//AWDB/1DBSample/RequestMessage];

    IF EXISTS (SELECT * FROM sys.service_message_types
               WHERE name =
               N'//AWDB/1DBSample/ReplyMessage')
         DROP MESSAGE TYPE
         [//AWDB/1DBSample/ReplyMessage];
    GO