Azure Service Bus 및 Spring Boot를 사용한 FIFO 메시징

소개

Azure Service Bus는 분산 애플리케이션 간의 안정적인 통신을 용이하게 하는 완전 관리형 메시지 브로커입니다. FIFO(선입선출) 순서 보장과 같이 특정 순서로 메시지를 처리해야 하는 애플리케이션의 경우 Azure Service Bus의 세션은 메시지 처리를 위한 효과적인 메커니즘을 제공합니다.

Spring Boot 애플리케이션의 컨텍스트에서 Azure Service Bus 주제의 세션을 활용하면 동일한 세션 ID를 가진 메시지가 한 번에 단일 소비자에 의해 올바른 순서로 처리됩니다. 이 솔루션은 메시지 순서를 유지하면서 처리량이 많은 메시징 시나리오를 처리할 때 특히 유용합니다.

이 가이드에서는 Azure Service Bus의 메시지를 FIFO 순서로 사용하도록 Spring Boot 애플리케이션을 구성하여 복잡한 인프라 없이도 세션을 사용하여 안정성과 확장성을 보장하는 방법을 간략하게 설명합니다.

실제로

여러 인스턴스에 배포된 Spring Boot 애플리케이션이 Azure Service Bus 주제의 메시지를 FIFO 순서로 사용하려면 해당 주제에 대한 세션을 사용하고 기관 간에 조정된 세션을 관리하도록 애플리케이션을 구성할 수 있습니다. 방법은 다음과 같습니다.

1. Azure Service Bus 주제에 대한 세션 활성화

• Azure Service Bus 주제 및 구독이 세션을 사용하도록 구성되어 있는지 확인하세요.
• 메시지를 보낼 때 각 메시지에 세션 ID를 설정하여 동일한 세션 ID를 가진 모든 메시지가 한 번에 한 명의 소비자만 도착 순서대로 처리되도록 합니다. .

2. Azure SDK를 사용하여 Spring Boot에서 세션 관리

Azure는 세션에서 메시지를 순서대로 사용할 수 있는 Java용 라이브러리를 제공합니다. 다음은 한 가지 접근 방식입니다.

Azure Service Bus 종속성 추가

Spring Boot 프로젝트(Maven의 경우 pom.xml)에서 Azure Service Bus에 대한 종속성을 추가합니다.

<dependency>
    <groupId>com.azure</groupId>
    <artifactId>azure-messaging-servicebus</artifactId>
    <version>7.5.0</version> <!-- check for the last version -->
</dependency>

애플리케이션에서 Service Bus 구성

Azure Service Bus 주제에 연결하도록 애플리케이션을 구성합니다. 기본 구성은 다음과 같습니다.

import com.azure.messaging.servicebus.*;

@Service
public class AzureServiceBusConsumer {

    private final String connectionString = "Endpoint=sb://<your-service-bus>.servicebus.windows.net/;SharedAccessKeyName=<key-name>;SharedAccessKey=<key>";
    private final String topicName = "<your-topic>";
    private final String subscriptionName = "<your-subscription>";

    public void startSessionProcessor() {
        ServiceBusClientBuilder clientBuilder = new ServiceBusClientBuilder()
                .connectionString(connectionString);

        ServiceBusProcessorClient processorClient = clientBuilder
                .sessionProcessor() // Using session mode
                .topicName(topicName)
                .subscriptionName(subscriptionName)
                .processMessage(this::processMessage)
                .processError(this::processError)
                .buildProcessorClient();

        // Start session processing in asynchronous mode
        processorClient.start();
    }

    private void processMessage(ServiceBusReceivedMessageContext context) {
        ServiceBusReceivedMessage message = context.getMessage();
        System.out.printf("Processing message from session: %s. Contents: %s%n",
                message.getSessionId(), message.getBody());

        // Process the message here, respecting the order of arrival in the session
        context.complete(); // Mark the message as processed
    }

    private void processError(ServiceBusErrorContext context) {
        System.err.printf("Error occurred while processing: %s%n", context.getException().getMessage());
    }
}

세션당 고유한 소비 보장

sessionProcessor()를 사용하면 각 세션이 한 번에 하나의 인스턴스에서만 소비되고 세션의 메시지는 인스턴스 수에 관계없이 항상 FIFO 순서로 처리됩니다.

3. EC2 인스턴스 간 동시성 관리

애플리케이션의 여러 EC2 인스턴스가 주제에 연결된 경우:

• Azure Service Bus는 사용 가능한 소비자에게 세션을 동적으로 할당합니다.
• 각 Spring Boot 인스턴스는 한 번에 한 세션씩 메시지를 수신하며, Azure Service Bus는 활성 세션이 여러 소비자에게 동시에 할당되지 않도록 합니다.
• 이를 통해 각 인스턴스가 서로 다른 세션을 동시에 지원하는 자동 확장이 가능해집니다.

4. 배포 및 복원력

동일한 Service Bus 구성으로 EC2 인스턴스에 Spring Boot 애플리케이션을 배포하면 동적으로 세션을 관리할 수 있습니다. 인스턴스가 다운되면 Azure Service Bus는 대기 세션을 연결된 다른 EC2 인스턴스에 자동으로 다시 할당합니다.

5. Spring Boot의 실행 예

Spring Boot 애플리케이션이 시작될 때 @PostConstruct를 사용하여 세션 내 소비를 시작하여 소비자를 시작합니다.

<dependency>
    <groupId>com.azure</groupId>
    <artifactId>azure-messaging-servicebus</artifactId>
    <version>7.5.0</version> <!-- check for the last version -->
</dependency>

결론

결론적으로, FIFO 메시지 처리를 위해 Azure Service Bus를 Spring Boot 애플리케이션과 통합하는 것은 세션을 활용하여 효과적으로 달성할 수 있습니다. Azure Service Bus 주제에 대한 세션을 활성화하고 메시지를 특정 세션 ID와 연결하면 메시지가 각 세션 내에서 도착하는 순서대로 정확히 처리되도록 할 수 있습니다.

Java용 Azure SDK를 사용하면 세션 기반 방식으로 메시지를 사용하도록 Spring Boot 애플리케이션을 구성하여 각 세션이 한 번에 단일 소비자에 의해 처리되도록 보장할 수 있습니다. 이를 통해 다중 스레드 환경에서도 메시지 재정렬의 위험을 제거하여 안정적이고 질서 있는 처리를 보장합니다.

이 접근 방식은 확장 가능하고 복원력이 뛰어난 솔루션을 제공하여 애플리케이션이 엄격한 FIFO 순서로 메시지를 처리하는 동시에 분산된 워크로드를 관리할 때 효율성과 유연성을 유지하도록 보장합니다.

위 내용은 Azure Service Bus 및 Spring Boot를 사용한 FIFO 메시징의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!