BEGIN DIALOG CONVERSATION(Transact-SQL)

아티클
05/30/2023

적용 대상: SQL Server Azure SQL Managed Instance

서비스 간 대화를 시작합니다. 대화는 두 서비스 간에 정확한 순서대로 한 번 메시징을 제공하는 대화 방법입니다.

구문

BEGIN DIALOG [ CONVERSATION ] @dialog_handle  
   FROM SERVICE initiator_service_name  
   TO SERVICE 'target_service_name'  
       [ , { 'service_broker_guid' | 'CURRENT DATABASE' }]   
   [ ON CONTRACT contract_name ]  
   [ WITH  
   [  { RELATED_CONVERSATION = related_conversation_handle   
      | RELATED_CONVERSATION_GROUP = related_conversation_group_id } ]   
   [ [ , ] LIFETIME = dialog_lifetime ]   
   [ [ , ] ENCRYPTION = { ON | OFF }  ] ]  
[ ; ]

인수

@dialog_handle
BEGIN DIALOG CONVERSATION 문에서 반환하는 새 대화에 대한 시스템 생성 대화 핸들을 저장하는 데 사용되는 변수입니다. 변수는 uniqueidentifier 형식이어야 합니다.

FROM SERVICE initiator_service_name
대화를 시작하는 서비스를 지정합니다. 지정된 이름은 현재 데이터베이스에 있는 서비스의 이름이어야 합니다. 시작자 서비스에 지정된 큐는 대상 서비스에서 반환하는 메시지와 이 대화에 대해 Service Broker에서 생성하는 메시지를 받습니다.

TO SERVICE 'target_service_name'
대화를 시작하는 데 사용할 대상 서비스를 지정합니다. target_service_name은 nvarchar(256) 형식입니다. Service Broker는 바이트 단위로 비교하여 일치하는 target_service_name 문자열을 찾습니다. 즉, 비교 시 대/소문자가 구분되고 현재 데이터 정렬은 고려되지 않습니다.

service_broker_guid
대상 서비스를 호스팅하는 데이터베이스를 지정합니다. 둘 이상의 데이터베이스에서 대상 서비스 인스턴스를 호스팅하는 경우 service_broker_guid를 제공하여 특정 데이터베이스와 통신할 수 있습니다.

service_broker_guid는 nvarchar(128) 형식입니다. 데이터베이스에 대한 service_broker_guid를 찾으려면 데이터베이스에서 다음 쿼리를 실행합니다.

SELECT service_broker_guid  
FROM sys.databases  
WHERE database_id = DB_ID() ;

참고

포함된 데이터베이스에서는 이 옵션을 사용할 수 없습니다.

'CURRENT DATABASE'
대화에서 현재 데이터베이스에 대한 service_broker_guid를 사용하도록 지정합니다.

ON CONTRACT contract_name
이 대화가 따르는 계약을 지정합니다. 계약은 현재 데이터베이스에 있어야 합니다. 대상 서비스가 지정된 계약에서 새 대화를 수락하지 않으면 Service Broker는 대화에 대한 오류 메시지를 반환합니다. 이 절이 생략되면 대화는 DEFAULT라는 계약을 따릅니다.

RELATED_CONVERSATION =related_conversation_handle
기존 대화 그룹에서 새 대화를 추가할 그룹을 지정합니다. 이 절이 있으면 새 대화는 related_conversation_handle로 지정한 대화와 같은 대화 그룹에 속합니다. related_conversation_handle은 uniqueidentifier 유형으로 암시적으로 변환할 수 있는 유형이어야 합니다. related_conversation_handle에서 기존 대화를 참조하지 않으면 이 명령문은 실패합니다.

RELATED_CONVERSATION_GROUP =related_conversation_group_id
기존 대화 그룹에서 새 대화를 추가할 그룹을 지정합니다. 이 절이 있으면 새 대화는 related_conversation_group_id로 지정한 대화 그룹에 추가됩니다. related_conversation_group_id는 uniqueidentifier 유형으로 암시적으로 변환할 수 있는 유형이어야 합니다. related_conversation_group_id가 기존 대화 그룹을 참조하지 않으면 Service Broker에서는 지정한 related_conversation_group_id로 새 대화 그룹을 만들어 새 대화를 해당 대화 그룹과 연결합니다.

LIFETIME =dialog_lifetime
대화가 열려 있는 최대 시간을 지정합니다. 대화를 완료하려면 수명이 만료되기 전에 두 엔드포인트에서 대화를 명시적으로 종료해야 합니다. dialog_lifetime 값은 초 단위로 표시해야 합니다. 수명은 int 형식입니다. LIFETIME 절을 지정하지 않으면 대화 수명은 int 데이터 형식의 최댓값입니다.

ENCRYPTION
이 대화에서 주고받은 메시지를 Microsoft SQL Server 인스턴스 외부로 보낼 때 암호화해야 하는지 여부를 지정합니다. 암호화해야 하는 대화는 보안 대화(secured dialog)입니다. ENCRYPTION = ON인 경우 암호화 지원에 필요한 인증서가 구성되어 있지 않으면 Service Broker는 대화에 대한 오류 메시지를 반환합니다. ENCRYPTION = OFF인 경우 target_service_name에 대해 원격 서비스 바인딩이 구성되어 있으면 암호화가 사용되고, 그렇지 않으면 메시지가 암호화되지 않은 상태로 전송됩니다. 이 절이 없으면 기본값은 ON입니다.

참고

같은 SQL Server 인스턴스에서 서비스와 주고받는 메시지는 암호화되지 않습니다. 그러나 대화에 대한 서비스가 다른 데이터베이스에 있는 경우 암호화를 사용하는 대화에는 암호화에 대한 데이터베이스 마스터 키와 인증서가 계속 필요합니다. 따라서 대화가 진행 중인 동안 데이터베이스 중 하나를 다른 인스턴스로 이동해도 대화를 계속할 수 있습니다.

설명

모든 메시지는 대화의 일부입니다. 따라서 시작 서비스는 대상 서비스로 메시지를 보내기 전에 대상 서비스와 대화를 시작해야 합니다. BEGIN DIALOG CONVERSATION 문에서 지정한 정보는 편지의 주소와 유사합니다. Service Broker는 이 정보를 사용하여 올바른 서비스로 메시지를 배달합니다. TO SERVICE 절에서 지정한 서비스는 메시지가 전달되는 주소이고, FROM SERVICE 절에서 지정한 서비스는 회신 메시지에 사용되는 반송 주소입니다.

대화의 대상이 BEGIN DIALOG CONVERSATION을 호출할 필요는 없습니다. Service Broker는 시작자로부터 대화의 첫 번째 메시지가 도착하면 대상 데이터베이스에 대화를 만듭니다.

대화를 시작하면 시작 서비스에 대해 데이터베이스에 대화 엔드포인트가 생성되지만 대상 서비스를 호스팅하는 인스턴스에 네트워크로 연결되지는 않습니다. Service Broker는 첫 번째 메시지를 보낼 때까지 대화의 대상과 통신을 설정하지 않습니다.

BEGIN DIALOG CONVERSATION 문에서 관련 대화 또는 관련 대화 그룹을 지정하지 않으면 Service Broker는 새 대화에 대해 새로운 대화 그룹을 만듭니다.

Service Broker에서는 대화를 임의로 그룹화할 수 없습니다. 대화 그룹의 모든 대화에는 대화의 시작자 또는 대상으로 FROM 절에 서비스가 지정되어 있어야 합니다.

BEGIN DIALOG CONVERSATION 명령은 반환된 dialog_handle을 포함하는 대화 그룹을 잠급니다. 명령에 RELATED_CONVERSATION_GROUP 절이 포함되는 경우 dialog_handle에 대한 대화 그룹은 related_conversation_group_id 매개 변수에서 지정한 대화 그룹입니다. 명령에 RELATED_CONVERSATION 절이 포함되는 경우 dialog_handle에 대한 대화 그룹은 지정한 related_conversation_handle과 연관된 대화 그룹입니다.

BEGIN DIALOG CONVERSATION은 사용자 정의 함수에 유효하지 않습니다.

사용 권한

대화를 시작하려면 현재 사용자는 명령의 FROM 절에서 지정한 서비스의 큐에 대한 RECEIVE 권한과 지정한 계약에 대한 REFERENCES 권한이 있어야 합니다.

예제

A. 대화 시작

다음 예에서는 대화를 시작하고 @dialog_handle.에 대화 식별자를 저장합니다. //Adventure-Works.com/ExpenseClient 서비스는 대화의 시작자이고 //Adventure-Works.com/Expenses 서비스는 대화의 대상입니다. 대화는 //Adventure-Works.com/Expenses/ExpenseSubmission 계약을 따릅니다.

DECLARE @dialog_handle UNIQUEIDENTIFIER ;  
  
BEGIN DIALOG CONVERSATION @dialog_handle  
   FROM SERVICE [//Adventure-Works.com/ExpenseClient]  
   TO SERVICE '//Adventure-Works.com/Expenses'  
   ON CONTRACT [//Adventure-Works.com/Expenses/ExpenseSubmission] ;

B. 명시적으로 수명을 지정하고 대화 시작

다음 예에서는 대화를 시작하고 @dialog_handle에 대화 식별자를 저장합니다. //Adventure-Works.com/ExpenseClient 서비스는 대화의 시작자이고 //Adventure-Works.com/Expenses 서비스는 대화의 대상입니다. 대화는 //Adventure-Works.com/Expenses/ExpenseSubmission 계약을 따릅니다. END CONVERSATION 명령으로 60초 내에 대화가 닫히지 않으면 Broker에서 오류가 발생하여 대화가 종료됩니다.

DECLARE @dialog_handle UNIQUEIDENTIFIER ;  
  
BEGIN DIALOG CONVERSATION @dialog_handle  
   FROM SERVICE [//Adventure-Works.com/ExpenseClient]  
   TO SERVICE '//Adventure-Works.com/Expenses'  
   ON CONTRACT [//Adventure-Works.com/Expenses/ExpenseSubmission]  
   WITH LIFETIME = 60 ;

C. 특정 Broker 인스턴스로 대화 시작

다음 예에서는 대화를 시작하고 @dialog_handle에 대화 식별자를 저장합니다. //Adventure-Works.com/ExpenseClient 서비스는 대화의 시작자이고 //Adventure-Works.com/Expenses 서비스는 대화의 대상입니다. 대화는 //Adventure-Works.com/Expenses/ExpenseSubmission 계약을 따릅니다. Broker는 a326e034-d4cf-4e8b-8d98-4d7e1926c904. GUID에 의해 식별되는 Broker로 이 대화의 메시지를 라우팅합니다.

DECLARE @dialog_handle UNIQUEIDENTIFIER ;  
  
BEGIN DIALOG CONVERSATION @dialog_handle  
   FROM SERVICE [//Adventure-Works.com/ExpenseClient]  
   TO SERVICE '//Adventure-Works.com/Expenses',   
              'a326e034-d4cf-4e8b-8d98-4d7e1926c904'  
   ON CONTRACT [//Adventure-Works.com/Expenses/ExpenseSubmission] ;

D. 대화를 시작하여 기존 대화 그룹에 연결

다음 예에서는 대화를 시작하고 @dialog_handle에 대화 식별자를 저장합니다. //Adventure-Works.com/ExpenseClient 서비스는 대화의 시작자이고 //Adventure-Works.com/Expenses 서비스는 대화의 대상입니다. 대화는 //Adventure-Works.com/Expenses/ExpenseSubmission 계약을 따릅니다. Broker는 새 대화 그룹을 만들지 않고 @conversation_group_id로 식별되는 대화 그룹에 대화를 연결합니다.

DECLARE @dialog_handle UNIQUEIDENTIFIER;
DECLARE @conversation_group_id UNIQUEIDENTIFIER;

SET @conversation_group_id = <retrieve conversation group ID from database>;

BEGIN DIALOG CONVERSATION @dialog_handle
    FROM SERVICE [//Adventure-Works.com/ExpenseClient]
    TO SERVICE '//Adventure-Works.com/Expenses'
    ON CONTRACT [//Adventure-Works.com/Expenses/ExpenseSubmission]
    WITH RELATED_CONVERSATION_GROUP = @conversation_group_id;

E. 명시적으로 수명을 지정하여 대화를 시작하고 기존 대화에 대화 연결

다음 예에서는 대화를 시작하고 @dialog_handle에 대화 식별자를 저장합니다. //Adventure-Works.com/ExpenseClient 서비스는 대화의 시작자이고 //Adventure-Works.com/Expenses 서비스는 대화의 대상입니다. 대화는 //Adventure-Works.com/Expenses/ExpenseSubmission 계약을 따릅니다. 새 대화는 @existing_conversation_handle이 속하는 대화 그룹에 똑같이 속합니다. END CONVERSATION 명령으로 600초 내에 대화가 닫히지 않으면 Service Broker에서 오류가 발생하여 대화가 종료됩니다.

DECLARE @dialog_handle UNIQUEIDENTIFIER;
DECLARE @existing_conversation_handle UNIQUEIDENTIFIER;

SET @existing_conversation_handle = <retrieve conversation handle from database>;

BEGIN DIALOG CONVERSATION @dialog_handle
   FROM SERVICE [//Adventure-Works.com/ExpenseClient]
   TO SERVICE '//Adventure-Works.com/Expenses'
   ON CONTRACT [//Adventure-Works.com/Expenses/ExpenseSubmission]
   WITH RELATED_CONVERSATION = @existing_conversation_handle
   LIFETIME = 600;

F. 선택적 암호화를 사용하여 대화 시작

다음 예에서는 대화를 시작하고 @dialog_handle에 대화 식별자를 저장합니다. //Adventure-Works.com/ExpenseClient 서비스는 대화의 시작자이고 //Adventure-Works.com/Expenses 서비스는 대화의 대상입니다. 대화는 //Adventure-Works.com/Expenses/ExpenseSubmission 계약을 따릅니다. 이 예의 대화에서는 암호화를 사용할 수 없는 경우 암호화를 사용하지 않고 네트워크를 통해 메시지를 전달할 수 있습니다.

DECLARE @dialog_handle UNIQUEIDENTIFIER  
  
BEGIN DIALOG CONVERSATION @dialog_handle  
   FROM SERVICE [//Adventure-Works.com/ExpenseClient]  
   TO SERVICE '//Adventure-Works.com/Expenses'  
   ON CONTRACT [//Adventure-Works.com/Expenses/ExpenseSubmission]  
   WITH ENCRYPTION = OFF ;

참고 항목

BEGIN CONVERSATION TIMER(Transact-SQL)
END CONVERSATION(Transact-SQL)
MOVE CONVERSATION(Transact-SQL)
sys.conversation_endpoints(Transact-SQL)

다음을 통해 공유