Pemesejan FIFO dengan Bas Perkhidmatan Azure dan Spring Boot

pengenalan

Azure Service Bus ialah broker mesej terurus sepenuhnya yang memudahkan komunikasi yang boleh dipercayai antara aplikasi yang diedarkan. Untuk aplikasi yang memerlukan mesej diproses dalam susunan tertentu, seperti memastikan urutan First-In-First-Out (FIFO), sesi dalam Azure Service Bus menyediakan mekanisme yang berkesan untuk pemprosesan mesej.

Dalam konteks aplikasi Spring Boot, memanfaatkan sesi pada topik Bas Perkhidmatan Azure memastikan bahawa mesej dengan ID Sesi yang sama dikendalikan dalam susunan yang betul oleh pengguna tunggal pada satu masa. Penyelesaian ini amat berguna apabila mengendalikan senario pemesejan berkemampuan tinggi sambil mengekalkan susunan mesej.

Panduan ini menggariskan cara mengkonfigurasi aplikasi Spring Boot untuk menggunakan mesej daripada Azure Service Bus dalam susunan FIFO, memastikan kebolehpercayaan dan kebolehskalaan dengan menggunakan sesi tanpa memerlukan infrastruktur yang kompleks.

Dalam amalan

Untuk aplikasi Spring Boot yang digunakan pada berbilang kejadian untuk menggunakan mesej daripada topik Bas Perkhidmatan Azure dalam susunan FIFO, anda boleh menggunakan sesi mengenai topik tersebut dan mengkonfigurasi aplikasi untuk mengurus sesi dalam penyelarasan antara pihak berkuasa. Begini caranya:

1. Dayakan Sesi pada Topik Bas Perkhidmatan Azure

• Pastikan Bas Perkhidmatan Azure topik dan langganan dikonfigurasikan untuk menggunakan sesi.
• Apabila menghantar mesej, tetapkan ID Sesi pada setiap mesej untuk memastikan semua mesej dengan ID Sesi yang sama akan diproses mengikut urutan ketibaan oleh hanya seorang pengguna pada satu masa .

2. Gunakan SDK Azure untuk Mengurus Sesi dalam But Spring

Azure menyediakan perpustakaan untuk Java yang membolehkan mesej digunakan dengan sesi secara teratur. Berikut ialah satu pendekatan:

Tambah Ketergantungan Bas Perkhidmatan Azure

Tambahkan pergantungan untuk Azure Service Bus dalam projek Spring Boot anda (dalam pom.xml untuk Maven):

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

Konfigurasi Bas Perkhidmatan dalam Aplikasi

Konfigurasikan aplikasi untuk menyambung ke topik Bas Perkhidmatan Azure. Berikut ialah konfigurasi asas:

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());
    }
}

Pastikan Penggunaan Unik setiap Sesi

Menggunakan sessionProcessor() memastikan bahawa setiap sesi digunakan oleh hanya satu tika pada satu masa dan mesej dalam satu sesi sentiasa diproses dalam susunan FIFO, tanpa mengira bilangan kejadian.

3. Pengurusan Concurrency antara Instans EC2

Apabila berbilang kejadian EC2 aplikasi disambungkan ke topik:

• Azure Service Bus secara dinamik menetapkan sesi kepada pengguna yang tersedia.
• Setiap kejadian Spring Boot menerima mesej satu sesi pada satu masa dan Azure Service Bus memastikan sesi aktif tidak akan diberikan kepada berbilang pengguna secara serentak.
• Ini membolehkan penskalaan automatik, dengan setiap kejadian menyokong sesi berbeza secara selari.

4. Deployment dan Resilience

Gunakan aplikasi Spring Boot pada kejadian EC2 anda dengan konfigurasi Bas Perkhidmatan yang sama, supaya mereka boleh mengurus sesi secara dinamik. Jika kejadian terputus, Bas Perkhidmatan Azure akan menetapkan semula sesi menunggu secara automatik kepada tika EC2 yang disambungkan yang lain.

5. Lancarkan Contoh dalam Spring Boot

Lancarkan pengguna apabila aplikasi Spring Boot anda bermula, menggunakan @PostConstruct untuk memulakan penggunaan dalam sesi:

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

Kesimpulan

Kesimpulannya, menyepadukan Azure Service Bus dengan aplikasi Spring Boot untuk pemprosesan mesej FIFO boleh dicapai dengan berkesan dengan menggunakan sesi. Dengan mendayakan sesi mengenai topik Bas Perkhidmatan Azure dan mengaitkan mesej dengan ID Sesi tertentu, anda memastikan bahawa mesej diproses dalam susunan tepat ia tiba, dalam setiap sesi.

Menggunakan Azure SDK untuk Java, aplikasi Spring Boot boleh dikonfigurasikan untuk menggunakan mesej dalam cara berasaskan sesi, menjamin bahawa setiap sesi diproses oleh pengguna tunggal pada satu masa. Ini menghapuskan risiko penyusunan semula mesej, walaupun dalam persekitaran berbilang benang, memastikan pemprosesan yang boleh dipercayai dan teratur.

Pendekatan ini menawarkan penyelesaian berskala dan berdaya tahan, memastikan aplikasi memproses mesej dalam susunan FIFO yang ketat sambil mengekalkan kecekapan dan fleksibiliti dalam mengurus beban kerja teragih.

Atas ialah kandungan terperinci Pemesejan FIFO dengan Bas Perkhidmatan Azure dan Spring Boot. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!