RECEIVE(Transact-SQL)

  • 아티클

큐에서 하나 이상의 메시지를 검색합니다. 큐의 보존 기간 설정에 따라 큐에서 메시지를 제거하거나 큐에 있는 메시지의 상태를 업데이트합니다.

구문

[ WAITFOR ( ]
    RECEIVE [ TOP ( n ) ] 
        <column_specifier> [ ,...n ]
        FROM <queue>
        [ INTO table_variable ]
        [ WHERE {  conversation_handle = conversation_handle
                 | conversation_group_id = conversation_group_id } ]
[ ) ] [ , TIMEOUT timeout ]
[ ; ]

<column_specifier> ::=
{    * 
  |  { column_name | [ ] expression } [ [ AS ] column_alias ]
  |  column_alias = expression 
}     [ ,...n ] 

<queue> ::=
{
    [ database_name . [ schema_name ] . | schema_name . ]
        queue_name
}

인수

  • WAITFOR
    현재 메시지가 없으면 메시지가 큐에 도착할 때까지 RECEIVE 문이 대기하도록 지정합니다.
  • TOP( n )
    반환할 메시지의 최대 개수를 지정합니다. 이 절을 지정하지 않으면 문 조건을 만족하는 모든 메시지가 반환됩니다.
  • *
    결과 집합이 큐에 있는 모든 열을 포함하도록 지정합니다.
  • column_name
    결과 집합에 포함할 열의 이름입니다.
  • expression
    열 이름, 상수, 함수이거나 열 이름, 상수, 연산자로 연결된 함수의 모든 조합입니다.
  • column_alias
    결과 집합에서 열 이름을 대신하는 또 다른 이름입니다.
  • FROM
    검색할 메시지가 포함된 큐를 지정합니다.
  • database_name
    메시지를 보낼 큐가 포함된 데이터베이스의 이름입니다. database_name을 제공하지 않으면 기본값은 현재 데이터베이스입니다.
  • schema_name
    메시지를 보낼 큐를 소유하는 스키마의 이름입니다. schema_name을 제공하지 않으면 기본값은 현재 사용자의 기본 스키마입니다.
  • queue_name
    메시지를 보낼 큐의 이름입니다.
  • INTO table_variable
    받은 메시지에서 열로 선택할 테이블을 지정합니다.
  • WHERE
    받은 메시지에 대한 대화 또는 대화 그룹을 지정합니다. 생략하면 사용 가능한 다음 대화 그룹에서 메시지를 반환합니다.
  • conversation_handle = conversation_handle
    받은 메시지에 대한 대화를 지정합니다. 제공한 conversation_handle은 uniqueidentifer이거나 uniqueidentifier로 변환할 수 있는 유형이어야 합니다.
  • conversation_group_id = conversation_group_id
    받은 메시지에 대한 대화 그룹을 지정합니다. 제공한 conversation_group_id는 uniqueidentifier이거나 uniqueidentifier로 변환할 수 있는 유형이어야 합니다.
  • TIMEOUT timeout
    문이 메시지를 대기하는 시간(밀리초)을 지정합니다. 이 절은 WAITFOR 절에서만 사용할 수 있습니다. 이 절을 지정하지 않거나 제한 시간이 -1이면 대기 시간에 제한이 없습니다. 제한 시간이 만료되면 RECEIVE는 빈 결과 집합을 반환합니다.

주의

ms186963.note(ko-kr,SQL.90).gif중요:
RECEIVE 문이 일괄 처리 또는 저장 프로시저에서 첫 번째 문이 아닌 경우 이전 문은 Transact-SQL 문 종결자인 세미콜론(;)으로 종료되어야 합니다.

RECEIVE 문은 큐에서 메시지를 읽고 결과 집합을 반환합니다. 반환된 결과 집합은 없거나 1개 이상의 행으로 구성되며 각 행에는 메시지 하나가 들어 있습니다. INTO 절을 사용하지 않고 column_specifier에서 로컬 변수에 값을 할당하지 않으면 문은 호출 프로그램에 결과 집합을 반환합니다.

큐에서 메시지 보존 기간을 지정하지 않으면 RECEIVE 문은 받은 메시지를 큐에서 제거합니다. 큐의 RETENTION 설정이 ON이면 RECEIVE 문은 status 열을 1로 업데이트하고 메시지를 큐에 그대로 남겨둡니다. RECEIVE 문을 포함하는 트랜잭션이 롤백되면 트랜잭션 내에 있는 큐의 모든 변경 내용도 롤백되어 메시지를 큐로 반환합니다.

RECEIVE 문에 의해 반환된 모든 메시지는 동일한 대화 그룹에 속합니다. RECEIVE 문은 문을 포함하는 트랜잭션이 완료될 때까지 반환된 메시지에 대한 대화 그룹을 잠급니다. RECEIVE 문에 의해 반환된 결과 집합은 암시적으로 정렬되어 있습니다. 특정 대화에 대해 RECEIVE 문은 status가 1인 메시지를 message_sequence_number의 오름차순으로 반환합니다.

RECEIVE 문의 WHERE 절에는 conversation_handle 또는 conversation_group_id를 사용하는 검색 조건만 포함될 수 있습니다. 검색 조건에는 큐에 있는 다른 모든 열이 포함되지 않습니다. conversation_handle 또는 conversation_group_id는 식이 될 수 없습니다. WHERE 절을 지정하지 않으면 RECEIVE 문은 현재 연결이 다른 대화 그룹에 설정한 잠금에 관계없이 사용 가능한 다음 대화 그룹에서 메시지를 반환합니다. WHERE 절이 conversation_handle을 지정하지 않으면 RECEIVE 문은 각 메시지가 속하는 대화에 관계없이 대화 그룹에서 메시지를 반환합니다. WHERE 절에 지정된 대화 핸들 또는 대화 그룹 식별자가 없거나 지정된 큐에 연결되어 있지 않으면 RECEIVE 문은 오류를 반환합니다.

RECEIVE 문에 지정된 큐의 상태가 OFF로 설정되어 있으면 문에서 Transact-SQL 오류가 발생하고 실패합니다.

WAITFOR 절을 지정하면 문은 지정된 제한 시간 동안 대기하거나 결과 집합을 사용할 수 있을 때까지 대기합니다. 문이 대기하는 동안 큐가 삭제되거나 큐의 상태가 OFF로 설정되면 문은 즉시 오류를 반환합니다. RECEIVE 문에서 대화 그룹 또는 대화 핸들을 지정하고 해당 대화에 대한 서비스가 삭제되거나 또 다른 큐로 옮겨지면 RECEIVE 문은 Transact-SQL 오류를 보고합니다.

RECEIVE는 사용자 정의 함수에 유효하지 않습니다.

다음 표에서는 큐의 열을 나열합니다.

열 이름 데이터 형식 설명

status

tinyint

메시지의 상태입니다. RECEIVE 명령에 의해 반환되는 메시지는 상태가 항상 0입니다. 큐의 메시지는 다음 값 중 하나를 포함할 수 있습니다.

0=준비1=받은 메시지2=아직 완료되지 않음3=보낸 메시지 보유

priority

tinyint

0. 정보 제공용으로만 식별됩니다. 지원되지 않습니다. 향후 호환성은 보장되지 않습니다..

queuing_order

bigint

큐 내의 메시지 정렬 번호입니다.

conversation_group_id

uniqueidentifier

이 메시지가 속하는 대화 그룹의 식별자입니다.

conversation_handle

uniqueidentifier

이 메시지가 속하는 대화의 핸들입니다.

message_sequence_number

bigint

대화 내의 메시지 시퀀스 번호입니다.

service_name

nvarchar(512)

대화와 연관된 서비스의 이름입니다.

service_id

int

대화와 연관된 서비스의 SQL Server 개체 식별자입니다.

service_contract_name

nvarchar(256)

대화에서 준수하는 계약의 이름입니다.

service_contract_id

int

대화에서 준수하는 계약의 SQL Server 개체 식별자입니다.

message_type_name

nvarchar(256)

메시지를 설명하는 메시지 유형의 이름입니다.

message_type_id

int

메시지를 설명하는 메시지 유형의 SQL Server 개체 식별자입니다.

유효성 검사

nchar(2)

메시지에 사용된 유효성 검사입니다.

E=비어 있음N=없음X=XML

message_body

varbinary(MAX)

메시지 내용입니다.

사용 권한

메시지를 받으려면 현재 사용자는 큐에서 RECEIVE 권한이 있어야 합니다.

예

1. 대화 그룹의 모든 메시지에 대한 모든 열 받기

다음 예에서는 ExpenseQueue 큐에서 사용 가능한 다음 대화 그룹에 대한 모든 수신 가능한 메시지를 받습니다. 문은 결과 집합으로 메시지를 반환합니다.

RECEIVE * FROM ExpenseQueue ;

2. 대화 그룹의 모든 메시지에 대해 지정된 열 받기

다음 예에서는 ExpenseQueue 큐에서 사용 가능한 다음 대화 그룹에 대한 모든 수신 가능한 메시지를 받습니다. 문은 conversation_handle, message_type_name 및 message_body 열을 포함하는 결과 집합으로 메시지를 반환합니다.

RECEIVE conversation_handle, message_type_name, message_body
FROM ExpenseQueue ;

3. 큐에서 수신 가능한 첫 번째 메시지 받기

다음 예에서는 ExpenseQueue 큐에서 수신 가능한 첫 번째 메시지를 결과 집합으로 받습니다.

RECEIVE TOP (1) * FROM ExpenseQueue ;

4. 지정된 대화에 대한 모든 메시지 받기

다음 예에서는 ExpenseQueue 큐에서 지정된 대화에 대해 수신 가능한 모든 메시지를 결과 집합으로 받습니다.

DECLARE @conversation_handle UNIQUEIDENTIFIER ;

SET @conversation_handle = <retrieve conversation from database> ;

RECEIVE *
FROM ExpenseQueue
WHERE conversation_handle = @conversation_handle ;

5. 지정된 대화 그룹에 대한 메시지 받기

다음 예에서는 ExpenseQueue 큐에서 지정된 대화 그룹에 대해 수신 가능한 모든 메시지를 결과 집합으로 받습니다.

DECLARE @conversation_group_id UNIQUEIDENTIFIER ;

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

RECEIVE *
FROM ExpenseQueue
WHERE conversation_group_id = @conversation_group_id ;

6. 테이블 변수로 받기

다음 예에서는 ExpenseQueue 큐에서 지정된 대화 그룹에 대해 수신 가능한 모든 메시지를 테이블 변수로 받습니다.

DECLARE @conversation_group_id UNIQUEIDENTIFIER ;

DECLARE @procTable TABLE(
     service_instance_id UNIQUEIDENTIFIER,
     handle UNIQUEIDENTIFIER,
     message_sequence_number BIGINT,
     service_name NVARCHAR(512),
     service_contract_name NVARCHAR(256),
     message_type_name NVARCHAR(256),
     validation NCHAR,
     message_body VARBINARY(MAX)) ;

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

RECEIVE TOP (1)
    conversation_group_id,
    conversation_handle,
    message_sequence_number,
    service_name,
    service_contract_name,
    message_type_name,
    validation,
    message_body
FROM ExpenseQueue
INTO @procTable
WHERE conversation_group_id = @conversation_group_id ;

7. 메시지 받기 및 무기한 대기

다음 예에서는 ExpenseQueue 큐에서 사용 가능한 다음 대화 그룹에 대한 모든 수신 가능한 메시지를 받습니다. 문은 적어도 하나 이상의 메시지를 사용할 수 있을 때까지 대기한 다음 모든 메시지 열을 포함하는 결과 집합을 반환합니다.

WAITFOR (
    RECEIVE *
    FROM ExpenseQueue) ;

8. 메시지 받기 및 지정된 기간 동안 대기

다음 예에서는 ExpenseQueue 큐에서 사용 가능한 다음 대화 그룹에 대한 모든 수신 가능한 메시지를 받습니다. 문은 어떤 경우가 먼저 발생하는지에 관계없이 60초 동안 대기하거나 적어도 하나 이상의 메시지를 사용할 수 있을 때까지 대기합니다. 적어도 하나 이상의 메시지를 사용할 수 있으면 문은 모든 메시지 열을 포함하는 결과 집합을 반환하고, 그렇지 않으면 빈 결과 집합을 반환합니다.

WAITFOR (
    RECEIVE *
    FROM ExpenseQueue ),
TIMEOUT 60000 ;

9. 메시지 받기, 열의 유형 수정

다음 예에서는 ExpenseQueue 큐에서 사용 가능한 다음 대화 그룹에 대한 모든 수신 가능한 메시지를 받습니다. 메시지 유형이 메시지에 XML 문서가 포함되어 있음을 나타내면 문은 메시지 본문을 XML로 변환합니다.

WAITFOR (
    RECEIVE message_type_name,
        CASE
            WHEN validation = 'X' THEN CAST(message_body as XML)
            ELSE NULL
         END AS message_body 
         FROM ExpenseQueue ),
TIMEOUT 60000 ;

10. 메시지 받기, 메시지 본문에서 데이터 추출, 대화 상태 검색

다음 예에서는 ExpenseQueue 큐에서 사용 가능한 다음 대화 그룹에 대해 수신 가능한 다음 메시지를 받습니다. 메시지가 //Adventure-Works.com/Expenses/SubmitExpense 유형이면 문은 메시지 본문에서 직원 ID와 항목 목록을 추출합니다. 또한 문은 ConversationState 테이블에서 대화의 상태를 검색합니다.

WAITFOR(
    RECEIVE 
    TOP(1)
      message_type_name,
      COALESCE(
           (SELECT TOP(1) ConversationState
            FROM CurrentConversations AS cc
            WHERE cc.ConversationHandle = conversation_handle),
           'NEW')
      AS ConversationState,
      COALESCE(
          (SELECT TOP(1) ErrorCount
           FROM CurrentConversations AS cc
           WHERE cc.ConversationHandle = conversation_handle), 
           0)
      AS ConversationErrors,
      CASE WHEN message_type_name = N'//Adventure-Works.com/Expenses/SubmitExpense'
          THEN CAST(message_body AS XML).value(
                'declare namespace rpt = "http://Adventure-Works.com/schemas/expenseReport"
                   (/rpt:ExpenseReport/rpt:EmployeeID)[1]', 'nvarchar(20)')
         ELSE NULL
      END AS EmployeeID,
      CASE WHEN message_type_name = N'//Adventure-Works.com/Expenses/SubmitExpense'
          THEN CAST(message_body AS XML).query(
                'declare namespace rpt = "http://Adventure-Works.com/schemas/expenseReport" 
                     /rpt:ExpenseReport/rpt:ItemDetail')
          ELSE NULL
      END AS ItemList
    FROM ExpenseQueue 
), TIMEOUT 60000 ;

참고 항목

참조

BEGIN DIALOG CONVERSATION(Transact-SQL)
BEGIN CONVERSATION TIMER(Transact-SQL)
END CONVERSATION(Transact-SQL)
SEND(Transact-SQL)
CREATE QUEUE(Transact-SQL)
ALTER QUEUE(Transact-SQL)
DROP QUEUE(Transact-SQL)

관련 자료

Service Broker 자습서
Conversation Group Locks
대화(Conversation) 아키텍처

도움말 및 정보

SQL Server 2005 지원 받기