2단원: 대화 시작 및 메시지 전송
새 설치: 2007년 9월 15일
이 단원에서는 대화를 시작하고 간단한 요청-응답 메시지 주기를 완료하고 대화를 종료하는 방법을 배웁니다.
절차
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
요청 수신 및 응답 전송
쿼리 편집기 창에 다음 코드를 복사하여 붙여 넣습니다. 그런 다음 이를 실행하여 TargetQueue2DB에서 응답 메시지를 받고 시작자로 응답 메시지를 전송합니다. RECEIVE 문은 요청 메시지를 검색합니다. 이어지는 SELECT 문은 텍스트를 표시하며 이를 통해 마지막 단계에서 전송한 메시지와 동일한 메시지인지를 확인할 수 있습니다. IF 문은 수신한 메시지가 요청 메시지 유형인지, 그리고 응답 메시지를 시작자에 전송하는 데 SEND 문이 사용되었는지 테스트합니다. END CONVERSATION 문은 대화의 대상 측을 종료하는 데 사용됩니다. 마지막 SELECT 문은 응답 메시지의 텍스트를 표시합니다.
DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER; DECLARE @RecvReqMsg NVARCHAR(100); DECLARE @RecvReqMsgName sysname; BEGIN TRANSACTION; RECEIVE TOP(1) @RecvReqDlgHandle = conversation_handle, @RecvReqMsg = message_body, @RecvReqMsgName = message_type_name FROM TargetQueue1DB; 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 문은 InitiatorQueue2DB에서 응답 메시지를 검색합니다. END CONVERSATION 문은 대화의 시작자 측을 종료합니다. 마지막 SELECT 문은 응답 메시지의 텍스트를 표시하며 이를 통해 이전 단계에서 전송한 메시지와 동일한 메시지인지 확인할 수 있습니다.
DECLARE @RecvReplyMsg NVARCHAR(100); DECLARE @RecvReplyDlgHandle UNIQUEIDENTIFIER; BEGIN TRANSACTION; RECEIVE TOP(1) @RecvReplyDlgHandle = conversation_handle, @RecvReplyMsg = message_body FROM InitiatorQueue1DB; END CONVERSATION @RecvReplyDlgHandle; SELECT @RecvReplyMsg AS ReceivedReplyMsg; COMMIT TRANSACTION; GO
다음 단계
이것으로 //AWDB/1DBSample/InitiatorService와 //AWDB/1DBSample/TargetService 간의 요청-응답 메시지 주기를 성공적으로 완료했습니다. 이 단원의 단계를 필요한 만큼 반복하여 요청-응답 메시지 쌍을 전송할 수 있습니다. SEND 및 REPLY 문을 모두 살펴본 다음에는 대화에 사용된 모든 개체를 삭제할 수 있습니다. 자세한 내용은 3단원: 대화 개체 삭제를 참조하십시오.
참고 항목
관련 자료
BEGIN DIALOG CONVERSATION(Transact-SQL)
SEND(Transact-SQL)
RECEIVE(Transact-SQL)
END CONVERSATION(Transact-SQL)
Service Broker Programming Basics