第 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 課:卸除交談物件>。