Aracılığıyla paylaş


Azure Service Bus kuyruklarına ileti gönderme ve bu kuyruklardan ileti alma (Java)

Bu hızlı başlangıçta, Azure Service Bus kuyruğuna ileti göndermek ve bu kuyruktan ileti almak için bir Java uygulaması oluşturacaksınız.

Not

Bu hızlı başlangıç, Service Bus kuyruğuna ileti gönderme ve alma ile ilgili basit bir senaryo için adım adım yönergeler sağlar. Azure Service Bus için önceden oluşturulmuş Java örneklerini GitHub'daki Java için Azure SDK deposunda bulabilirsiniz.

İpucu

Spring uygulamasında Azure Service Bus kaynaklarıyla çalışıyorsanız Spring Cloud Azure'ı alternatif olarak değerlendirmenizi öneririz. Spring Cloud Azure, Azure hizmetleriyle sorunsuz Spring tümleştirmesi sağlayan açık kaynak bir projedir. Spring Cloud Azure hakkında daha fazla bilgi edinmek ve Service Bus kullanarak bir örnek görmek için bkz . Azure Service Bus ile Spring Cloud Stream.

Önkoşullar

Azure portalında bir ad alanı oluşturma

Azure'da Service Bus mesajlaşma varlıklarını kullanmaya başlamak için öncelikle Azure'da benzersiz olan bir ad alanı oluşturmanız gerekir. Ad alanı, uygulamanızdaki Service Bus kaynakları (kuyruklar, konular vb.) için bir kapsam kapsayıcısı sağlar.

Ad alanı oluşturmak için:

  1. Azure Portal’ında oturum açın.

  2. Tüm hizmetler sayfasına gidin.

  3. Sol gezinti çubuğunda, kategoriler listesinden Tümleştirme'yi seçin, fareyi Service Bus'ın üzerine getirin ve ardından Service Bus kutucuğundaki düğmeyi seçin+.

    Menüde Kaynak oluştur, Tümleştirme ve ardından Service Bus seçimini gösteren görüntü.

  4. Ad alanı oluştur sayfasının Temel bilgiler etiketinde şu adımları izleyin:

    1. Abonelik için ad alanının oluşturulacağı bir Azure aboneliği seçin.

    2. Kaynak grubu için, ad alanının yaşayacağı mevcut bir kaynak grubunu seçin veya yeni bir tane oluşturun.

    3. Ad alanı için bir ad girin. Ad alanı adı aşağıdaki adlandırma kurallarına uymalıdır:

      • Adın Azure genelinde benzersiz olması gerekir. Adın kullanılabilirliği sistem tarafından hemen denetlenir.
      • Ad uzunluğu en az 6 ve en fazla 50 karakterdir.
      • Ad yalnızca harf, sayı, kısa çizgi "-" içerebilir.
      • Ad bir harfle başlamalı ve bir harf veya numarayla bitmelidir.
      • Ad "-sb" veya "-mgmt" ile bitmiyor.
    4. Konum için ad alanınızın barındırılacağı bölgeyi seçin.

    5. Fiyatlandırma katmanı için ad alanı için fiyatlandırma katmanını (Temel, Standart veya Premium) seçin. Bu hızlı başlangıç için Standart'ı seçin.

      Önemli

      Konuları ve abonelikleri kullanmak istiyorsanız Standart veya Premium'u seçin. Konular/abonelikler Temel fiyatlandırma katmanında desteklenmez.

      Premium fiyatlandırma katmanını seçtiyseniz, mesajlaşma birimi sayısını belirtin. Premium katman, her iş yükünün yalıtılmış olarak çalışması için CPU ve bellek düzeyinde kaynak yalıtımı sağlar. Bu kaynak kapsayıcısı mesajlaşma birimi olarak adlandırılır. Premium ad alanında en az bir mesajlaşma birimi vardır. Her Service Bus Premium ad alanı için 1, 2, 4, 8 veya 16 mesajlaşma birimleri seçebilirsiniz. Daha fazla bilgi için bkz . Service Bus Premium Mesajlaşma.

    6. Sayfanın alt kısmındaki Gözden geçir ve oluştur'u seçin.

      Ad alanı oluştur sayfasını gösteren resim

    7. Gözden geçir ve oluştur sayfasında ayarları gözden geçirin ve Oluştur'u seçin.

  5. Kaynağın dağıtımı başarılı olduktan sonra dağıtım sayfasında Kaynağa git'i seçin.

    Kaynağa git bağlantısını içeren dağıtım başarılı sayfasını gösteren görüntü.

  6. Service Bus ad alanınızın giriş sayfasını görürsünüz.

    Oluşturulan Service Bus ad alanının giriş sayfasını gösteren resim.

Azure portalında kuyruk oluşturma

  1. Service Bus Ad Alanı sayfasında, sol gezinti menüsünden Kuyruklar'ı seçin.

  2. Kuyruklar sayfasında araç çubuğunda + Kuyruk'a tıklayın.

  3. Kuyruk için bir ad girin ve diğer değerleri varsayılan değerleriyle bırakın.

  4. Şimdi Oluştur'u seçin.

    Portalda kuyruk oluşturmayı gösteren resim

Azure'da uygulamanın kimliğini doğrulama

Bu hızlı başlangıçta Azure Service Bus'a bağlanmanın iki yolu gösterilir: parolasız ve bağlantı dizesi.

İlk seçenek, Service Bus ad alanına bağlanmak için Microsoft Entra Id ve rol tabanlı erişim denetiminde (RBAC) güvenlik sorumlunuzu nasıl kullanacağınızı gösterir. Kodunuzda, yapılandırma dosyasında veya Azure Key Vault gibi güvenli bir depolama alanında sabit kodlanmış bağlantı dizesi olması konusunda endişelenmeniz gerekmez.

İkinci seçenek, Service Bus ad alanına bağlanmak için bir bağlantı dizesi nasıl kullanacağınızı gösterir. Azure'da yeniyseniz bağlantı dizesi seçeneğini daha kolay takip edebilirsiniz. Gerçek dünyadaki uygulamalarda ve üretim ortamlarında parolasız seçeneği kullanmanızı öneririz. Daha fazla bilgi için bkz . Kimlik doğrulaması ve yetkilendirme. Ayrıca, genel bakış sayfasında parolasız kimlik doğrulaması hakkında daha fazla bilgi edinebilirsiniz.

Microsoft Entra kullanıcınıza rol atama

Yerel olarak geliştirme yaparken, Azure Service Bus'a bağlanan kullanıcı hesabının doğru izinlere sahip olduğundan emin olun. İleti gönderip almak için Azure Service Bus Veri Sahibi rolüne sahip olmanız gerekir. Kendinize bu rolü atamak için Kullanıcı Erişimi Yöneticisi rolüne veya eylemi içeren Microsoft.Authorization/roleAssignments/write başka bir role ihtiyacınız vardır. Azure portalı, Azure CLI veya Azure PowerShell'i kullanarak kullanıcıya Azure RBAC rolleri atayabilirsiniz. Kapsam genel bakış sayfasında rol atamaları için kullanılabilir kapsamlar hakkında daha fazla bilgi edinin.

Aşağıdaki örnekte rol, Azure Service Bus kaynaklarına tam erişim sağlayan kullanıcı hesabınıza atanır Azure Service Bus Data Owner . Gerçek bir senaryoda, kullanıcılara yalnızca daha güvenli bir üretim ortamı için gereken minimum izinleri vermek için En Az Ayrıcalık İlkesi'ni izleyin.

Azure Service Bus için Azure yerleşik rolleri

Azure Service Bus için, Azure portalı ve Azure kaynak yönetimi API'sini kullanarak ad alanlarının ve tüm ilgili kaynakların yönetimi Azure RBAC modeli kullanılarak zaten korunur. Azure, Service Bus ad alanına erişim yetkisi vermek için aşağıdaki Azure yerleşik rollerini sağlar:

  • Azure Service Bus Veri Sahibi: Service Bus ad alanına ve varlıklarına (kuyruklar, konular, abonelikler ve filtreler) veri erişimini etkinleştirir. Bu rolün bir üyesi kuyruklardan veya konu başlıklarından/aboneliklerden ileti gönderip alabilir.
  • Azure Service Bus Veri Göndereni: Service Bus ad alanına ve varlıklarına gönderme erişimi vermek için bu rolü kullanın.
  • Azure Service Bus Veri Alıcısı: Service Bus ad alanına ve varlıklarına alma erişimi vermek için bu rolü kullanın.

Özel bir rol oluşturmak istiyorsanız bkz . Service Bus işlemleri için gereken haklar.

Microsoft Entra kullanıcısını Azure Service Bus Sahibi rolüne ekleme

Microsoft Entra kullanıcı adınızı Service Bus ad alanı düzeyinde Azure Service Bus Veri Sahibi rolüne ekleyin. Kullanıcı hesabınız bağlamında çalışan bir uygulamanın kuyruğa veya konuya ileti göndermesine ve kuyruktan veya konunun aboneliğinden ileti almasına olanak tanır.

Önemli

Çoğu durumda rol atamasının Azure'a yayılması bir veya iki dakika sürer. Nadir durumlarda, sekiz dakikaya kadar sürebilir. Kodunuzu ilk kez çalıştırdığınızda kimlik doğrulama hataları alıyorsanız, birkaç dakika bekleyin ve yeniden deneyin.

  1. Azure portalında Service Bus Ad Alanı sayfanız açık değilse ana arama çubuğunu veya sol gezintiyi kullanarak Service Bus ad alanınızı bulun.

  2. Genel bakış sayfasında, sol taraftaki menüden Erişim denetimi (IAM) öğesini seçin.

  3. Erişim denetimi (IAM) sayfasında Rol atamaları sekmesini seçin.

  4. Üst menüden + Ekle'yi seçin ve ardından açılan menüden Rol ataması ekle'yi seçin.

    Rol atamayı gösteren ekran görüntüsü.

  5. Sonuçları istenen role göre filtrelemek için arama kutusunu kullanın. Bu örnek için eşleşen sonucu arayın Azure Service Bus Data Owner ve seçin. Ardından İleri'yi seçin.

  6. Erişim ata'nın altında Kullanıcı, grup veya hizmet sorumlusu'na tıklayın ve ardından + Üye seç'e tıklayın.

  7. İletişim kutusunda Microsoft Entra kullanıcı adınızı (genellikle user@domain e-posta adresiniz) arayın ve iletişim kutusunun alt kısmındaki Seç'i seçin.

  8. Son sayfaya gitmek için Gözden geçir + ata'yı seçin ve ardından işlemi tamamlamak için Gözden geçir + yeniden ata'yı seçin.

Kuyruğa ileti gönderme

Bu bölümde bir Java konsol projesi oluşturacak ve daha önce oluşturduğunuz kuyruğa ileti göndermek için kod ekleyeceksiniz.

Java konsol projesi oluşturma

Eclipse'i veya seçtiğiniz bir aracı kullanarak bir Java projesi oluşturun.

Uygulamanızı Service Bus kullanacak şekilde yapılandırma

Azure Core ve Azure Service Bus kitaplıklarına başvurular ekleyin.

Eclipse kullanıyor ve bir Java konsol uygulaması oluşturduysanız Java projenizi Maven'a dönüştürün: Paket Gezgini penceresinde projeye sağ tıklayın, Yapılandır ->Maven projesine dönüştür'ü seçin. Ardından, aşağıdaki örnekte gösterildiği gibi bu iki kitaplıkta bağımlılıkları ekleyin.

pom.xml Azure Service Bus ve Azure Identity paketlerine bağımlılık eklemek için dosyayı güncelleştirin.

    <dependencies>
        <dependency>
            <groupId>com.azure</groupId>
            <artifactId>azure-messaging-servicebus</artifactId>
            <version>7.13.3</version>
        </dependency>
        <dependency>
            <groupId>com.azure</groupId>
            <artifactId>azure-identity</artifactId>
            <version>1.8.0</version>
            <scope>compile</scope>
        </dependency>
    </dependencies>

Kuyruğa ileti göndermek için kod ekleme

  1. Java dosyasının konusuna aşağıdaki import deyimleri ekleyin.

    import com.azure.messaging.servicebus.*;
    import com.azure.identity.*;
    
    import java.util.concurrent.TimeUnit;
    import java.util.Arrays;
    import java.util.List;
    
  2. sınıfında, bağlantı dizesi ve kuyruk adını tutacak değişkenleri tanımlayın.

    static String queueName = "<QUEUE NAME>";
    

    Önemli

    yerine <QUEUE NAME> kuyruğun adını yazın.

  3. Kuyruğa bir ileti göndermek için sınıfında adlı sendMessage bir yöntem ekleyin.

    Önemli

    NAMESPACENAME yerine Service Bus ad alanınızın adını yazdığınızdan emin olun.

    static void sendMessage()
    {
        // create a token using the default Azure credential
        DefaultAzureCredential credential = new DefaultAzureCredentialBuilder()
                .build();
    
        ServiceBusSenderClient senderClient = new ServiceBusClientBuilder()
                .fullyQualifiedNamespace("NAMESPACENAME.servicebus.windows.net")
                .credential(credential)
                .sender()
                .queueName(queueName)
                .buildClient();
    
        // send one message to the queue
        senderClient.sendMessage(new ServiceBusMessage("Hello, World!"));
        System.out.println("Sent a single message to the queue: " + queueName);
    }
    
    
  4. İleti listesi oluşturmak için sınıfına adlı createMessages bir yöntem ekleyin. Genellikle bu iletileri uygulamanızın farklı bölümlerinden alırsınız. Burada örnek iletilerin listesini oluşturacağız.

    static List<ServiceBusMessage> createMessages()
    {
        // create a list of messages and return it to the caller
        ServiceBusMessage[] messages = {
                new ServiceBusMessage("First message"),
                new ServiceBusMessage("Second message"),
                new ServiceBusMessage("Third message")
        };
        return Arrays.asList(messages);
    }
    
  5. Oluşturduğunuz kuyruğa ileti göndermek için method adlı sendMessageBatch bir yöntem ekleyin. Bu yöntem kuyruk için bir ServiceBusSenderClient oluşturur, ileti listesini almak için yöntemini çağırır createMessages , bir veya daha fazla toplu iş hazırlar ve toplu işleri kuyruğa gönderir.

    Önemli

    NAMESPACENAME yerine Service Bus ad alanınızın adını yazdığınızdan emin olun.

    static void sendMessageBatch()
    {
        // create a token using the default Azure credential
        DefaultAzureCredential credential = new DefaultAzureCredentialBuilder()
                .build();
    
        ServiceBusSenderClient senderClient = new ServiceBusClientBuilder()
                .fullyQualifiedNamespace("NAMESPACENAME.servicebus.windows.net")
                .credential(credential)
                .sender()
                .queueName(queueName)
                .buildClient();
    
        // Creates an ServiceBusMessageBatch where the ServiceBus.
        ServiceBusMessageBatch messageBatch = senderClient.createMessageBatch();
    
        // create a list of messages
        List<ServiceBusMessage> listOfMessages = createMessages();
    
        // We try to add as many messages as a batch can fit based on the maximum size and send to Service Bus when
        // the batch can hold no more messages. Create a new batch for next set of messages and repeat until all
        // messages are sent.
        for (ServiceBusMessage message : listOfMessages) {
            if (messageBatch.tryAddMessage(message)) {
                continue;
            }
    
            // The batch is full, so we create a new batch and send the batch.
            senderClient.sendMessages(messageBatch);
            System.out.println("Sent a batch of messages to the queue: " + queueName);
    
            // create a new batch
            messageBatch = senderClient.createMessageBatch();
    
            // Add that message that we couldn't before.
            if (!messageBatch.tryAddMessage(message)) {
                System.err.printf("Message is too large for an empty batch. Skipping. Max size: %s.", messageBatch.getMaxSizeInBytes());
            }
        }
    
        if (messageBatch.getCount() > 0) {
            senderClient.sendMessages(messageBatch);
            System.out.println("Sent a batch of messages to the queue: " + queueName);
        }
    
        //close the client
        senderClient.close();
    }
    

Kuyruktan ileti alma

Bu bölümde, kuyruktan iletileri almak için kod ekleyebilirsiniz.

  1. Kuyruktan ileti almak için adlı receiveMessages bir yöntem ekleyin. Bu yöntem, iletileri işlemek için bir işleyici ve hataları işlemek için başka bir işleyici belirterek kuyruk için bir ServiceBusProcessorClient oluşturur. Ardından işlemciyi başlatır, birkaç saniye bekler, alınan iletileri yazdırır ve ardından işlemciyi durdurup kapatır.

    Önemli

    • NAMESPACENAME yerine Service Bus ad alanınızın adını yazdığınızdan emin olun.
    • kodunda öğesini QueueTest::processMessage sınıfınızın adıyla değiştirinQueueTest.
    // handles received messages
    static void receiveMessages() throws InterruptedException
    {
        DefaultAzureCredential credential = new DefaultAzureCredentialBuilder()
                .build();
    
        ServiceBusProcessorClient processorClient = new ServiceBusClientBuilder()
                .fullyQualifiedNamespace("NAMESPACENAME.servicebus.windows.net")
                .credential(credential)
                .processor()
                .queueName(queueName)
                .processMessage(context -> processMessage(context))
                .processError(context -> processError(context))
                .buildProcessorClient();
    
        System.out.println("Starting the processor");
        processorClient.start();
    
        TimeUnit.SECONDS.sleep(10);
        System.out.println("Stopping and closing the processor");
        processorClient.close();
    }
    
  2. processMessage Service Bus aboneliğinden alınan bir iletiyi işlemek için yöntemini ekleyin.

    private static void processMessage(ServiceBusReceivedMessageContext context) {
        ServiceBusReceivedMessage message = context.getMessage();
        System.out.printf("Processing message. Session: %s, Sequence #: %s. Contents: %s%n", message.getMessageId(),
            message.getSequenceNumber(), message.getBody());
    }
    
  3. processError Hata iletilerini işlemek için yöntemini ekleyin.

    private static void processError(ServiceBusErrorContext context) {
        System.out.printf("Error when receiving messages from namespace: '%s'. Entity: '%s'%n",
            context.getFullyQualifiedNamespace(), context.getEntityPath());
    
        if (!(context.getException() instanceof ServiceBusException)) {
            System.out.printf("Non-ServiceBusException occurred: %s%n", context.getException());
            return;
        }
    
        ServiceBusException exception = (ServiceBusException) context.getException();
        ServiceBusFailureReason reason = exception.getReason();
    
        if (reason == ServiceBusFailureReason.MESSAGING_ENTITY_DISABLED
            || reason == ServiceBusFailureReason.MESSAGING_ENTITY_NOT_FOUND
            || reason == ServiceBusFailureReason.UNAUTHORIZED) {
            System.out.printf("An unrecoverable error occurred. Stopping processing with reason %s: %s%n",
                reason, exception.getMessage());
        } else if (reason == ServiceBusFailureReason.MESSAGE_LOCK_LOST) {
            System.out.printf("Message lock lost for message: %s%n", context.getException());
        } else if (reason == ServiceBusFailureReason.SERVICE_BUSY) {
            try {
                // Choosing an arbitrary amount of time to wait until trying again.
                TimeUnit.SECONDS.sleep(1);
            } catch (InterruptedException e) {
                System.err.println("Unable to sleep for period of time");
            }
        } else {
            System.out.printf("Error source %s, reason %s, message: %s%n", context.getErrorSource(),
                reason, context.getException());
        }
    }
    
  4. main, ve sendMessageBatchyöntemlerini çağırmak sendMessageve receiveMessages atmak InterruptedExceptioniçin yöntemini güncelleştirin.

    public static void main(String[] args) throws InterruptedException {
        sendMessage();
        sendMessageBatch();
        receiveMessages();
    }
    

Uygulamayı çalıştırma

  1. Eclipse kullanıyorsanız projeye sağ tıklayın, Dışarı Aktar'ı seçin, Java'yı genişletin, Çalıştırılabilir JAR dosyası'nı seçin ve çalıştırılabilir jar dosyası oluşturmak için adımları izleyin.

  2. Makinede Azure Service Bus Veri Sahibi rolüne eklenen kullanıcı hesabından farklı bir kullanıcı hesabı kullanarak oturum açtıysanız şu adımları izleyin. Aksi takdirde, bu adımı atlayın ve sonraki adımda Jar dosyasını çalıştırmak için devam edin.

    1. Makinenize Azure CLI yükleyin.

    2. Azure'da oturum açmak için aşağıdaki CLI komutunu çalıştırın. Azure Service Bus Veri Sahibi rolüne eklediğiniz kullanıcı hesabını kullanın.

      az login
      
  3. Aşağıdaki komutu kullanarak Jar dosyasını çalıştırın.

    java -jar <JAR FILE NAME>
    
  4. Konsol penceresinde aşağıdaki çıkışı görürsünüz.

    Sent a single message to the queue: myqueue
    Sent a batch of messages to the queue: myqueue
    Starting the processor
    Processing message. Session: 88d961dd801f449e9c3e0f8a5393a527, Sequence #: 1. Contents: Hello, World!
    Processing message. Session: e90c8d9039ce403bbe1d0ec7038033a0, Sequence #: 2. Contents: First message
    Processing message. Session: 311a216a560c47d184f9831984e6ac1d, Sequence #: 3. Contents: Second message
    Processing message. Session: f9a871be07414baf9505f2c3d466c4ab, Sequence #: 4. Contents: Third message
    Stopping and closing the processor
    

Azure portalındaki Service Bus ad alanının Genel Bakış sayfasında, gelen ve giden ileti sayısını görebilirsiniz. Bir dakika kadar bekleyin ve en son değerleri görmek için sayfayı yenileyin.

Gelen ve giden ileti sayısı

Service Bus Kuyruğu sayfasına gitmek için bu Genel Bakış sayfasındaki kuyruğu seçin. Bu sayfada gelen ve giden ileti sayısını da görürsünüz. Ayrıca kuyruğun geçerli boyutu, en büyük boyut, etkin ileti sayısı vb. gibi diğer bilgileri de görürsünüz.

Kuyruk ayrıntıları

Sonraki Adımlar

Aşağıdaki belgelere ve örneklere bakın: