项目
04/02/2012

第 2 课：启动会话并传输消息

在本课中，您将学习启动会话，完成简单的请求-答复消息循环，然后结束会话。

过程

切换到 AdventureWorks2008R2 数据库

复制以下代码并将其粘贴到查询编辑器窗口中。然后，运行代码以将上下文切换到 AdventureWorks2008R2 数据库。
```
USE AdventureWorks2008R2;
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 课：删除会话对象。