포이즌 메시지 처리

예: 포이즌 메시지 감지

이 Transact-SQL 예에서는 포이즌 메시지를 처리하기 위한 논리를 포함하는 간단한 상태 비저장 서비스를 보여 줍니다. 저장 프로시저는 메시지를 받기 전에 트랜잭션을 저장했다가 메시지를 처리할 수 없을 때 해당 트랜잭션을 저장 지점으로 롤백합니다. 부분 롤백은 메시지의 대화 그룹에 대한 잠금을 계속 유지하면서 메시지를 큐로 돌려 보냅니다. 해당 프로그램에서는 대화 그룹 잠금을 계속 유지하므로 실패한 메시지 목록이 저장된 테이블을 업데이트할 수 있으며, 다른 큐 판독기에서 해당 메시지를 처리할 위험은 없습니다.

다음 예에서는 응용 프로그램의 활성화 저장 프로시저를 정의합니다.

CREATE PROCEDURE ProcessExpenseReport
AS
BEGIN
  WHILE (1 = 1)
    BEGIN
      BEGIN TRANSACTION ;
      DECLARE @conversationHandle UNIQUEIDENTIFIER ;
      DECLARE @messageBody VARBINARY(MAX) ;
      DECLARE @messageTypeName NVARCHAR(256) ;

      SAVE TRANSACTION UndoReceive ;

        WAITFOR ( 
                  RECEIVE TOP(1)
                    @messageTypeName = message_type_name,
                    @messageBody = message_body,
                    @conversationHandle = conversation_handle
                    FROM ExpenseQueue
                 ), TIMEOUT 500 ;

        IF @@ROWCOUNT = 0
        BEGIN
          ROLLBACK TRANSACTION ;
          BREAK ;
        END ;

        -- Typical message processing loop: dispatch to a stored
        -- procedure based on the message type name.  End conversation
        -- with an error for unknown message types.

        -- Process expense report messages. If processing fails,
        -- roll back to the save point and track the failed message.

        IF (@messageTypeName =
              '//Adventure-Works.com/AccountsPayable/ExpenseReport')
          BEGIN
            DECLARE @expenseReport NVARCHAR(MAX) ;
            SET @expenseReport = CAST(@messageBody AS NVARCHAR(MAX)) ;
            EXEC AdventureWorks2008R2.dbo.AddExpenseReport
              @report = @expenseReport ;
            IF @@ERROR <> 0
             BEGIN
               ROLLBACK TRANSACTION UndoReceive ;
               EXEC TrackMessage @conversationHandle ;
             END ;
            ELSE
             BEGIN
               EXEC AdventureWorks2008R2.dbo.ClearMessageTracking
                 @conversationHandle ;
             END ;
           END ;
        ELSE

        -- For error messages and end dialog messages, end the
        -- conversation.

        IF (@messageTypeName =
              'https://schemas.microsoft.com/SQL/ServiceBroker/Error' OR
             @messageTypeName =
              'https://schemas.microsoft.com/SQL/ServiceBroker/EndDialog')
          BEGIN
            END CONVERSATION @conversationHandle ;
            EXEC dbo.ClearMessageTracking @conversationHandle ;
          END ;


         COMMIT TRANSACTION ;
    END ;
END ;

저장 프로시저 TrackMessage는 메시지가 실패한 횟수를 추적합니다. 이전에 메시지가 실패한 적이 없으면 이 프로시저는 메시지에 대한 새 카운터를 ExpenseServiceFailedMessages 테이블에 삽입합니다. 또는 카운터를 통해 메시지가 실패한 횟수를 확인합니다. 이 프로시저는 카운터가 미리 정의된 횟수보다 작을 경우 카운터를 늘리고, 카운터가 미리 정의된 횟수보다 클 경우에는 오류가 발생한 대화를 종료하고 테이블에서 해당 대화의 카운터를 제거합니다.

CREATE PROCEDURE TrackMessage
@conversationHandle uniqueidentifier
AS
BEGIN
  IF @conversationHandle IS NULL
    RETURN ;

  DECLARE @count INT ;
  SET @count = NULL ;
  SET @count = (SELECT count FROM dbo.ExpenseServiceFailedMessages
                  WHERE conversation_handle = @conversationHandle) ;

  IF @count IS NULL
    BEGIN
      INSERT INTO dbo.ExpenseServiceFailedMessages
        (count, conversation_handle)
        VALUES (1, @conversationHandle) ;
    END ;
  IF @count > 3
    BEGIN
      EXEC dbo.ClearMessageTracking @conversationHandle ;
      END CONVERSATION @conversationHandle
        WITH ERROR = 500
        DESCRIPTION = 'Unable to process message.' ;
    END ;
  ELSE
    BEGIN
      UPDATE dbo.ExpenseServiceFailedMessages
        SET count=count+1
        WHERE conversation_handle = @conversationHandle ;
    END ;
END ;
GO

ExpenseServiceFailedMessages 테이블의 정의에는 다음 예에 표시된 것과 같이 conversation_handle 열과 count 열만 포함되어 있습니다.

CREATE TABLE ExpenseServiceFailedMessages (
  conversation_handle uniqueidentifier PRIMARY KEY,
  count smallint
) ;

다음 예제에 표시된 것과 같이 ClearMessageTracking 프로시저는 ExpenseServiceFailedMessages 테이블에서 대화의 카운터를 삭제합니다.

CREATE PROCEDURE ClearMessageTracking
  @conversationHandle uniqueidentifier
AS
BEGIN
   DELETE FROM dbo.ExpenseServiceFailedMessages
     WHERE conversation_handle = @conversationHandle ;
END ;
GO

여기에서 보여 주는 전략은 매우 간단합니다. 요구 사항에 맞는 응용 프로그램을 작성하려면 이 항목에 설명된 내용을 기초로 삼아야 합니다. 예를 들어 응용 프로그램에서 상태를 저장하는 경우에는 실패한 메시지에 대한 추적 정보를 응용 프로그램의 상태 테이블에 포함하는 것이 더 효율적일 수 있습니다.

위의 저장 프로시저는 트랜잭션 실패의 원인이 될 수 있는 오류는 처리하지 않습니다. 이 서비스가 전체 트랜잭션 실패의 원인이 될 수 있는 메시지를 받으면 해당 트랜잭션은 롤백됩니다. 롤백이 5번 발생하면 포이즌 메시지 자동 감지 기능은 해당 큐 상태를 OFF로 설정합니다. 이 경우 다른 응용 프로그램이나 관리자가 포이즌 메시지를 제거해야 합니다.

메시지에 대해 수행하는 처리 작업으로 인해 트랜잭션이 실패하는 것으로 생각되는 경우에는 TRY 및 CATCH 문을 사용하여 오류를 처리할 수 있습니다. 오류 처리에 대한 자세한 내용은 데이터베이스 엔진 오류 처리를 참조하십시오.

참고 항목

참조

개념

관련 자료