다음을 통해 공유

Service Bus 트랜잭션 처리의 개요

  • 아티클

이 문서에서는 Microsoft Azure Service Bus의 트랜잭션 기능을 설명합니다. 대부분의 토론은 트랜잭션 샘플에서 설명합니다. 이 문서는 트래잭션 처리에 대한 개요와 Service Bus의 send via 기능으로 제한되며 원자적 트랜잭선 샘플의 범위는 훨씬 광범위하고 더 복잡합니다.

참고 항목

  • Service Bus의 기본 계층에서는 트랜잭션을 지원하지 않습니다. 표준 및 프리미엄 계층은 트랜잭션을 지원합니다. 이러한 계층 간의 차이점은 Service Bus 가격 책정을 참조하세요.
  • 트랜잭션에서 관리 및 메시징 작업을 혼합하는 것은 지원되지 않습니다.
  • JavaScript SDK는 트랜잭션을 지원하지 않습니다.

Service Bus의 트랜잭션

트랜잭션은 두 개 이상의 작업을 실행 범위로 그룹화합니다. 기본적으로 이러한 트랜잭션은 지정된 작업 그룹에 속한 모든 작업이 성공 또는 실패해야 합니다. 이러한 점에서 트랜잭션은 하나의 단위(또는 원자성이라고 함)로 작용합니다.

Service Bus는 트랜잭션 메시지 broker이며 메시지 저장소에 대한 모든 내부 작업의 트랜잭션 무결성을 보장합니다. 엔터티 간 메시지의 원자성 전달 또는 배달 못한 편지 큐로 메시지 이동과 같이 Service Bus에 메시지의 모든 전송은 트랜잭션입니다. 따라서 Service Bus에서 메시지를 수락할 경우 이미 저장되어 시퀀스 번호가 레이블로 지정되었습니다. 이후로 Service Bus 내 메시지 전송은 엔터티 전반에서 조정된 작업으로 손실(원본 성공 및 대상 실패) 또는 메시지의 중복(원본 실패 및 대상 성공)이 발생하지 않습니다.

Service Bus는 트랜잭션 범위 내에서 단일 메시징 엔터티(큐, 토픽, 구독)에 대한 그룹화 작업을 지원합니다. 예를 들어 트랜잭션 범위 내에서 하나의 큐에 여러 메시지를 보낼 수 있으며, 트랜잭션이 성공적으로 완료되면 메시지가 큐의 로그에만 커밋됩니다.

트랜잭션 범위 내 작업

트랜잭션 범위 내에서 수행할 수 있는 작업은 다음과 같습니다.

  • 보내기
  • 완료
  • 중단
  • 데드레터
  • 지연
  • 잠금 갱신

애플리케이션이 일부 수신 루프 내에서 또는 콜백과 함께 보기 잠금 모드를 사용하여 메시지를 획득한다고 가정하므로 수신 작업은 포함되지 않으며, 메시지 처리에 대한 트랜잭션 범위만 열립니다.

메시지 처리(완료, 중단, 배달 못 한 편지, 지연)가 범위 내에서 그리고 전반적인 트랜잭션 결과에 다라 발생합니다.

Important

Azure Service Bus는 작업이 트랜잭션 범위에 있을 때 예외가 발생하는 경우 작업을 다시 시도하지 않습니다.

트랜잭션 범위에 등록하지 않는 작업

데이터베이스 및 Cosmos DB와 같은 다른 서비스를 호출하는 메시지 처리 코드는 해당 다운스트림 리소스를 동일한 트랜잭션 범위로 자동으로 등록하지 않습니다. 이러한 시나리오를 처리하는 방법에 대한 자세한 내용은 idempotent 메시지 처리에 대한 지침을 참조하세요.

전송 및 "send via"

큐 또는 토픽에서 프로세서로, 그런 다음, 다른 큐 또는 토픽으로 데이터의 트랜잭션을 인도하기 위해 Service Bus는 전송을 지원합니다. 전송 작업에서 발신자는 전송 큐 또는 토픽으로 메시지를 전송하며 전송 큐 또는 토픽은 자동 전달 기능이 적용된 것과 같은 강력한 전송 구현을 사용하여 의도된 대상 큐 또는 토픽으로 메시지를 즉시 이동합니다. 이 메시지는 전송 큐 또는 토픽의 소비자에게 표시되는 방식으로 전송 큐 또는 토픽의 로그에 커밋되지 않습니다.

이 트랜잭션 기능 자체는 전송 큐 또는 토픽이 발신자의 입력 메시지 원본인 경우에 분명해집니다. 즉, Service Bus는 하나의 통합된 원자성 작업으로 입력 메시지에 대한 완료(또는 지연, 또는 배달 못 한 편지) 작업을 수행하면서 메시지를 전송 큐 또는 토픽을 "통해" 대상 큐 또는 토픽으로 메시지를 전송할 수 있습니다.

토픽 구독에서 받은 다음, 동일한 트랜잭션의 큐 또는 토픽으로 보내야 하는 경우 전송 엔터티는 토픽이어야 합니다. 이 시나리오에서는 토픽에 대해 트랜잭션 범위를 시작하고, 트랜잭션 범위에 있는 구독에서 수신하고, 전송 토픽을 통해 큐 또는 토픽 대상으로 보냅니다.

참고 항목

  • 트랜잭션 TransactionPartitionKey 범위에서 전송 큐를 통해 메시지를 보내는 경우 PartitionKey와 기능적으로 동일합니다. 메시지를 전송할 때 순서대로 함께 유지되도록 합니다.
  • 대상 큐나 항목이 삭제되면 404 예외가 발생합니다.

실제 코드 엿보기

이러한 전송을 설정하기 위해 전송 큐를 통해 대상 큐를 목표로 하는 메시지 보낸 사람을 생성합니다. 또한 같은 큐에서 메시지를 풀링하는 수신기가 있을 수도 있습니다. 예시:

다음 예와 같이 간단한 트랜잭션이 이러한 요소를 사용합니다. 전체 예제를 참조하려면 GitHub의 소스 코드를 참조하세요.

var options = new ServiceBusClientOptions { EnableCrossEntityTransactions = true };
await using var client = new ServiceBusClient(connectionString, options);

ServiceBusReceiver receiverA = client.CreateReceiver("queueA");
ServiceBusSender senderB = client.CreateSender("queueB");

ServiceBusReceivedMessage receivedMessage = await receiverA.ReceiveMessageAsync();

using (var ts = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled))
{
    await receiverA.CompleteMessageAsync(receivedMessage);
    await senderB.SendMessageAsync(new ServiceBusMessage());
    ts.Complete();
}

EnableCrossEntityTransactions 속성에 대한 자세한 내용은 다음 참조 ServiceBusClientBuilder.enableCrossEntityTransactions 메서드를 참조하세요.

시간 제한

트랜잭션은 2분 후에 시간 초과됩니다. 트랜잭션 타이머는 트랜잭션의 첫 번째 작업이 시작될 때 시작됩니다.

다음 단계

Service Bus 큐에 대한 자세한 내용은 다음 문서를 참조하세요.