트랜잭션에서 메시지 일괄 처리
대기 중인 애플리케이션은 트랜잭션을 사용하여 정확하고 안정적인 메시지 배달을 수행합니다. 트랜잭션은 비용이 많이 드는 작업이나 메시지 처리량을 상당히 줄일 수 있습니다. 메시지 처리량을 향상시키기 위한 한가지 방법은 애플리케이션이 단일 트랜잭션 내에서 여러 메시지를 읽고 처리하는 것입니다. 성능이 좋아질수록 복구 작업도 늘어납니다. 즉, 일괄 처리하는 메시지 수가 증가하면 트랜잭션이 롤백 되는 경우 필요한 복구 작업의 크기도 증가합니다. 트랜잭션 및 세션에서 일괄 처리하는 메시지 사이에는 차이가 있습니다. 세션은 하나의 애플리케이션에 의해 처리되고 하나의 단위로 커밋되는 관련 메시지의 그룹입니다. 세션은 일반적으로 관련 메시지 그룹을 함께 처리해야 하는 경우 사용됩니다. 이러한 예로 온라인 쇼핑 웹 사이트를 들 수 있습니다. 일괄 처리는 메시지 처리량을 높이는 방식으로 관련 없는 여러 메시지를 처리하는 데 사용됩니다. 세션에 대한 자세한 내용은 세션에서 대기 중인 메시지 그룹화를 참조하세요. 또한 일괄 처리하는 메시지는 하나의 애플리케이션에 의해 처리되고 하나의 단위로 커밋되지만 일괄 처리하는 메시지 간에 관계가 없을 수 있습니다. 한 트랜잭션의 메시지를 일괄 처리하는 것이 애플리케이션이 실행되는 방법을 변경하지 않는 가장 적절한 방법입니다.
일괄 처리 모드 시작
ph x="1" /> 엔드포인트 동작은 일괄 처리를 제어합니다. 이 엔드포인트 동작을 서비스 엔드포인트에 추가하면 WCF(Windows Communication Foundation)에서 트랜잭션의 메시지를 일괄 처리하도록 지시합니다. 일부 메시지의 경우 트랜잭션이 필요하지 않기 때문에 트랜잭션이 필요한 메시지만 일괄 처리되고 TransactionScopeRequired = true 및 TransactionAutoComplete = true로 표시된 작업에서 보낸 메시지만 일괄 처리 대상으로 고려됩니다. 서비스 계약의 모든 작업이 TransactionScopeRequired = false 및 TransactionAutoComplete = false로 표시된 경우 일괄 처리 모드가 시작되지 않습니다.
트랜잭션 커밋
일괄 처리된 트랜잭션은 다음을 기준으로 커밋됩니다.
MaxBatchSize. TransactedBatchingBehavior 동작의 속성입니다. 이 속성은 일괄 처리로 배치되는 최대 메시지 수를 결정합니다. 이 값에 도달하면 일괄 처리가 커밋됩니다. 값은 엄격하게 제한하지 않으며 이 값의 메시지를 받기 전에 일괄 처리를 커밋할 수 있습니다.Transaction Timeout. 트랜잭션 시간 제한의 80%가 경과한 후, 일괄 처리가 커밋되고 새 일괄 처리가 만들어 집니다. 이는 완료할 트랜잭션의 지정된 시간이 20% 이하로 남은 경우, 일괄 처리가 커밋된다는 의미입니다.TransactionScopeRequired. 일괄 처리 메시지를 처리할 때 WCF가TransactionScopeRequired=false로 설정된 메시지를 발견한 경우, 일괄 처리를 커밋하고TransactionScopeRequired=true및TransactionAutoComplete=true상태의 첫 번째 메시지 수신 시 새 일괄 처리를 다시 엽니다.메시지가 더 이상 큐에 없는 경우
MaxBatchSize에 도달하지 않았거나 트랜잭션 시간 제한의 80%가 경과하지 않았더라도 현재 일괄 처리가 커밋됩니다.
일괄 처리 모드 종료
일괄 처리 메시지로 인해 트랜잭션이 중단되는 경우 다음 단계가 수행됩니다.
전체 일괄 처리 메시지가 롤백됩니다.
읽는 메시지 수가 최대 일괄 처리 크기의 두 배를 초과할 때까지 메시지를 한 번에 하나씩 읽습니다.
일괄 처리 모드가 다시 시작됩니다.
일괄 처리 크기 선택
일괄 처리 크기는 애플리케이션에 따라 달라집니다. 애플리케이션의 최적 일괄 처리 크기를 결정하는 데 가장 적절한 방법은 직접 경험하는 것입니다. 일괄 처리 크기 선택 시 애플리케이션의 실제 배포 모델에 따라 크기를 선택해야 합니다. 예를 들어, 애플리케이션을 배포할 때 원격 시스템에서 SQL Server가 필요하고 큐 및 SQL Server가 포함된 트랜잭션이 필요한 경우 이 구성을 실제로 실행하여 일괄 처리 크기를 결정하는 것이 가장 바람직합니다.
동시성 및 일괄 처리
처리량을 증가시키기 위해 여러 일괄 처리를 동시에 실행할 수도 있습니다. ConcurrencyMode.Multiple에서 ServiceBehaviorAttribute을 설정하여 동시 일괄 처리를 수행할 수 있습니다.
서비스 제한은 서비스에서 수행할 수 있는 최대 동시 호출 수를 나타내는 데 사용되는 서비스 동작입니다. 일괄 처리에서 사용하는 경우 이 동작은 동시에 실행할 수 있는 일괄 처리 수로 해석됩니다. 서비스 제한이 설정되지 않은 경우 WCF는 최대 동시 호출 수를 기본적으로 16으로 설정합니다. 따라서 기본적으로 일괄 처리 동작이 추가된 경우, 동시에 최대 16개의 일괄 처리를 수행할 수 있습니다. 사용자 성능을 기준으로 서비스 스로틀 및 일괄 처리를 조정하는 것이 가장 바람직합니다. 예를 들어, 큐에 100개의 메시지가 있고 20개를 일괄 처리하려는 경우 처리량에 따라 일괄 처리를 조정하지 않은 것처럼 16개의 트랜잭션을 수행할 수 있기 때문에, 최대 동시 호출을 16으로 설정하는 것이 유용하지 않을 수 있습니다. 따라서 성능을 세부적으로 조정하는 경우 동시 일괄 처리를 설정하지 않거나 올바른 서비스 스로틀 크기로 동시 일괄 처리를 설정합니다.
일괄 처리 및 여러 엔드포인트
엔드포인트는 주소 및 계약으로 구성됩니다. 동일한 바인딩을 공유하는 여러 엔드포인트가 있을 수 있습니다. 두 개의 엔드포인트가 동일한 바인딩을 공유하고 URI(Uniform Resource Identifier) 또는 큐 주소를 수신 대기할 수 있습니다. 두 개의 엔드포인트를 동일한 큐에서 읽는 경우, 트랜잭션된 일괄 처리 동작이 양쪽 엔드포인트에 추가되고 지정된 일괄 처리 크기 간에 충돌될 수 있습니다. 이러한 동작은 두 개의 트랜잭션된 일괄 처리 동작 간에 지정된 최소 일괄 처리 크기로 일괄 처리를 구현하여 확인합니다. 이 시나리오에서 엔드포인트 중 하나가 트랜잭션된 일괄 처리를 지정하지 않은 경우, 양쪽 엔드포인트 모두 일괄 처리를 사용하지 않습니다.
예시
다음 예제에서는 구성 파일에서 TransactedBatchingBehavior를 지정하는 방법을 보여 줍니다.
<behaviors>
<endpointBehaviors>
<behavior name="TransactedBatchingBehavior"
maxBatchSize="100" />
</endpointBehaviors>
</behaviors>
다음 예제에서는 코드에서 TransactedBatchingBehavior를 지정하는 방법을 보여 줍니다.
using (ServiceHost serviceHost = new ServiceHost(typeof(OrderProcessorService)))
{
ServiceEndpoint sep = ServiceHost.AddServiceEndpoint(typeof(IOrderProcessor), new NetMsmqBinding(), "net.msmq://localhost/private/ServiceModelSamplesTransacted");
sep.Behaviors.Add(new TransactedBatchingBehavior(100));
// Open the ServiceHost to create listeners and start listening for messages.
serviceHost.Open();
// The service can now be accessed.
Console.WriteLine("The service is ready.");
Console.WriteLine("Press <ENTER> to terminate service.");
Console.WriteLine();
Console.ReadLine();
// Close the ServiceHostB to shut down the service.
serviceHost.Close();
}