단원 4: 대화 시작 및 메시지 전송

  • 아티클

적용 대상:SQL ServerAzure SQL Managed Instance

이 단원에서는 같은 데이터베이스 엔진 인스턴스에 있는 두 데이터베이스를 연결하는 대화를 시작하는 방법을 배웁니다. 간단한 요청-회신 메시지 주기를 완료한 다음 대화를 종료하는 방법도 알아봅니다.

절차

InitiatorDB 데이터베이스로 전환

  • 다음 코드를 복사하여 쿼리 편집기 창에 붙여넣습니다. 그런 다음 코드를 실행하여 컨텍스트를 InitiatorDB 데이터베이스로 전환하고 여기에서 대화를 시작합니다.

        USE InitiatorDB;
    GO

대화를 시작하고 요청 메시지 보내기

  • 다음 코드를 복사하여 쿼리 편집기 창에 붙여넣습니다. 그런 다음 코드를 실행하여 대화를 시작하고 요청 메시지를 TargetDB의 //TgtDB/2DBSample/TargetService에 보냅니다. 변수가 BEGIN DIALOG의 대화 핸들을 SEND 문으로 전달하는 데 사용되므로 코드를 한 블록에서 실행해야 합니다. 일괄 처리는 BEGIN DIALOG 문을 실행하여 대화를 시작하고 요청 메시지를 작성합니다. 그런 다음 SEND 문의 대화 핸들을 사용하여 해당 대화에 요청 메시지를 보냅니다. 마지막 SELECT 문은 전송된 메시지의 텍스트를 표시합니다.

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

    BEGIN TRANSACTION;

    BEGIN DIALOG @InitDlgHandle
         FROM SERVICE [//InitDB/2DBSample/InitiatorService]
         TO SERVICE N'//TgtDB/2DBSample/TargetService'
         ON CONTRACT [//BothDB/2DBSample/SimpleContract]
         WITH
             ENCRYPTION = OFF;

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

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

    SELECT @RequestMsg AS SentRequestMsg;

    COMMIT TRANSACTION;
    GO

TargetDB 데이터베이스로 전환

  • 다음 코드를 복사하여 쿼리 편집기 창에 붙여넣습니다. 그런 다음 이 코드를 실행하여 컨텍스트를 TargetDB 데이터베이스로 전환합니다. 여기서 요청 메시지를 받고 InitiatorDB에 응답 메시지를 다시 보냅니다.

        USE TargetDB;
    GO

요청을 받고 회신을 보냅니다.

  • 다음 코드를 복사하여 쿼리 편집기 창에 붙여넣습니다. 그런 다음 코드를 실행하여 TargetQueue2DB의 응답 메시지를 받고 시작자에게 응답 메시지를 다시 보냅니다. 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 TargetQueue2DB
    ), TIMEOUT 1000;

    SELECT @RecvReqMsg AS ReceivedRequestMsg;

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

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

         END CONVERSATION @RecvReqDlgHandle;
    END

    SELECT @ReplyMsg AS SentReplyMsg;

    COMMIT TRANSACTION;
    GO

InitiatorDB 데이터베이스로 전환

  • 다음 코드를 복사하여 쿼리 편집기 창에 붙여넣습니다. 그런 다음 코드를 실행하여 컨텍스트를 InitiatorDB 데이터베이스로 되돌리고 여기에서 응답 메시지를 받고 대화를 종료합니다.

        USE InitiatorDB;
    GO

회신 메시지 수신 및 대화 종료

  • 다음 코드를 복사하여 쿼리 편집기 창에 붙여넣습니다. 그런 다음 코드를 실행하여 회신 메시지를 수신하고 대화를 종료합니다. RECEIVE 문은 InitiatorQueue2DB에서 응답 메시지를 검색합니다. END CONVERSATION 문은 초기자 쪽의 대화를 종료합니다. 마지막 SELECT 문은 이전 단계에서 보낸 것과 동일한지 확인할 수 있도록 회신 메시지의 텍스트를 표시합니다.

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

    BEGIN TRANSACTION;

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

    END CONVERSATION @RecvReplyDlgHandle;

    -- Display recieved request.
    SELECT @RecvReplyMsg AS ReceivedReplyMsg;

    COMMIT TRANSACTION;
    GO

다음 단계

이것으로 자습서를 마칩니다. 자습서는 간략한 소개만 제공합니다. 사용 가능한 모든 옵션을 설명하지는 않습니다. 자습서는 간소화된 논리 및 오류 처리를 사용하므로 프로덕션 환경에서는 사용하지 않아야 합니다. 효율적이고 안정적이며 강력한 대화를 만들려면 이 자습서의 예제보다 더 복잡한 코드가 필요합니다.

참고 항목