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.

Önkoşullar

• Azure aboneliği. Bu öğreticiyi tamamlamak için bir Azure hesabınızın olması gerekir. MSDN abone avantajınızı etkinleştirebilir ya da ücretsiz hesap için kaydolabilirsiniz.
• Java için Azure SDK'sını yükleyin. Eclipse kullanıyorsanız, Java için Azure SDK'yı içeren Eclipse için Azure Toolkit'i yükleyebilirsiniz. Daha sonra projenize Java için Microsoft Azure Kitaplıkları'nı ekleyebilirsiniz. IntelliJ kullanıyorsanız bkz . IntelliJ için Azure Toolkit'i yükleme.

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+.

   

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.

      

   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.

   

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

   

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.

   

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.

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.

    <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>

        <dependency>
            <groupId>com.azure</groupId>
            <artifactId>azure-messaging-servicebus</artifactId>
            <version>7.13.3</version>
        </dependency>

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

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

   • Parolasız (Önerilen)
   • Bağlantı Dizesi

   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.

   • Parolasız (Önerilen)
   • Bağlantı Dizesi

   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.

   • Parolasız (Önerilen)
   • Bağlantı Dizesi

   Ö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.

   • Parolasız (Önerilen)
   • Bağlantı Dizesi

   Ö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.

   • Parolasız (Önerilen)
   • Bağlantı Dizesi

   Ö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

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.

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.

Sonraki Adımlar

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

• Java için Azure Service Bus istemci kitaplığı - Benioku
• GitHub’daki örnekler
• Java API'si başvurusu