共用方式為


第 2 課:開始交談和傳輸訊息

在這一課,您將學會啟動交談、完成簡易要求回覆訊息循環,然後結束交談。

程序

切換至 AdventureWorks 資料庫

  • 將下列程式碼複製並貼入 [查詢編輯器] 視窗中。然後,執行此程式碼以便將內容切換至 AdventureWorks 資料庫。

    USE AdventureWorks;
    GO
    

開始交談並傳送要求訊息

  • 將下列程式碼複製並貼入 [查詢編輯器] 視窗中。然後,執行此程式碼以便啟動交談並將要求訊息傳送至 //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
    

接收要求並傳送回覆

  • 將下列程式碼複製並貼入 [查詢編輯器] 視窗中。然後,執行此程式碼以便從 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
    

接收回覆並結束交談

  • 將下列程式碼複製並貼入 [查詢編輯器] 視窗中。然後,執行此程式碼以便接收回覆訊息並結束交談。RECEIVE 陳述式會從 InitiatorQueue1DB 中擷取回覆訊息。END CONVERSATION 陳述式會結束交談的起始端。最後一個 SELECT 陳述式會顯示回覆訊息的文字,如此您就可以確認它是否與上一個步驟中傳送的訊息相同。

    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
    

後續的步驟

您已成功完成 //AWDB/1DBSample/InitiatorService//AWDB/1DBSample/TargetService 之間的要求回覆訊息循環。您可以依照需要多次重複本課程中的步驟來傳輸訊息的要求回覆組。當您已完成 SEND 和 REPLY 陳述式的調查時,就可以卸除交談使用的所有物件。如需詳細資訊,請參閱<第 3 課:卸除交談物件>。