Berichten verzenden naar en berichten ontvangen van Azure Service Bus-wachtrijen (Java)

Deze quickstart bevat stapsgewijze instructies voor een eenvoudig scenario voor het verzenden van berichten naar een Service Bus-wachtrij en het ontvangen ervan. U maakt een Java-app om berichten te verzenden naar en te ontvangen van een Azure Service Bus-wachtrij. U vindt vooraf gemaakte Java-voorbeelden voor Azure Service Bus in de Azure SDK voor Java-opslagplaats op GitHub.

Vereisten

• Een Azure-abonnement. U hebt een Azure-account nodig om deze quickstart te voltooien. U kunt uw maandelijkse Azure-tegoed activeren voor Visual Studio-abonnees of u aanmelden voor een gratis account.

• Installeer de Azure-SDK voor Java.

  • Als u Eclipse gebruikt, kunt u de Azure-toolkit voor Eclipse installeren die de Azure-SDK voor Java bevat. U kunt vervolgens de Microsoft Azure-bibliotheken voor Java toevoegen aan uw project.
  • Als u IntelliJ gebruikt, raadpleegt u De Azure-toolkit voor IntelliJ installeren.

Een naamruimte in de Azure-portal maken

Als u Service Bus-berichtenentiteiten in Azure wilt gaan gebruiken, maakt u een naamruimte met een naam die uniek is in Azure. Een naamruimte biedt een bereikcontainer voor Service Bus-resources, zoals wachtrijen en onderwerpen, in uw toepassing.

Ga als volgt te werk om een naamruimte te maken:

1. Meld u aan bij het Azure-portaal.

2. Selecteer het flyoutmenu linksboven en navigeer naar de pagina Alle services.

3. Selecteer Integratie in de linkernavigatiebalk.

4. Scroll naar beneden naar Berichtendiensten>Service Bus en selecteer Maken.

   

5. Voer op het tabblad Basis van de pagina Naamruimte maken de volgende stappen uit:

   1. Kies voor Abonnement een Azure-abonnement waarin u de naamruimte maakt.

   2. Kies voor resourcegroep een bestaande resourcegroep of maak een nieuwe.

   3. Voer een naamruimtenaam in die voldoet aan de volgende naamconventies:

      • De naam moet uniek zijn in Azure. In het systeem wordt onmiddellijk gecontroleerd of de naam beschikbaar is.
      • De naamlengte is ten minste 6 en maximaal 50 tekens.
      • De naam mag alleen letters, cijfers, afbreekstreepjes -bevatten.
      • De naam moet beginnen met een letter en eindigen op een letter of cijfer.
      • De naam eindigt niet op -sb of -mgmt.

   4. Kies voor Locatie de regio voor het hosten van uw naamruimte.

   5. Selecteer voor de prijscategorie de prijscategorie (Basic, Standard of Premium) voor de naamruimte. Voor deze quickstart selecteert u Standard.

      Als u de Premium-laag selecteert, kunt u geo-replicatie inschakelen voor de naamruimte. De functie voor geo-replicatie zorgt ervoor dat de metagegevens en gegevens van een naamruimte continu worden gerepliceerd van een primaire regio naar een of meer secundaire regio's.

      Belangrijk

      Kies Standard of Premium indien u gebruik wilt maken van onderwerpen en abonnementen. Onderwerpen en abonnementen worden niet ondersteund in de prijscategorie Basic.

      Als u de Prijscategorie Premium hebt geselecteerd, geeft u het aantal berichteneenheden op. De Premium-prijscategorie biedt isolatie van resources op het niveau van de CPU en het geheugen, zodat elke workload geïsoleerd wordt uitgevoerd. Deze resourcecontainer wordt een Messaging-eenheid genoemd. Een Premium-naamruimte heeft ten minste één Messaging-eenheid. U kunt 1, 2, 4, 8 of 16 berichteneenheden selecteren voor elke Service Bus Premium-naamruimte. Zie de Service Bus Premium Messaging-laag voor meer informatie.

   6. Selecteer Beoordelen en maken onderaan de pagina.

      

   7. Controleer de instellingen op de pagina Beoordelen en maken en selecteer Maken.

6. Nadat de implementatie van de resource is geslaagd, selecteert u Ga naar de resource op de implementatiepagina.

   

7. U ziet de startpagina voor uw Service Bus-Naamruimte.

   

Een wachtrij maken in de Microsoft Azure-portal

1. Vouw op de pagina Service Bus-naamruimte in het navigatiemenu aan de linkerkant Entiteiten uit, en selecteer Wachtrijen.

2. Op de Wachtrijen pagina, selecteer + Wachtrij op de werkbalk.

3. Voer een naam in voor de wachtrij. Laat de andere waarden ongewijzigd met de standaardwaarden.

4. Klik op Creëren.

   

De app verifiëren bij Azure

In dit artikel ziet u twee manieren om verbinding te maken met Azure Service Bus: zonder wachtwoord en verbindingsreeks.

De eerste optie laat zien hoe u uw beveiligingsprincipaal gebruikt in Microsoft Entra ID en op rollen gebaseerd toegangsbeheer (RBAC) om verbinding te maken met een Service Bus-naamruimte. U hoeft zich geen zorgen te maken over een in code vastgelegde verbindingsreeks in uw code, in een configuratiebestand of in een beveiligde opslag, zoals Azure Key Vault.

De tweede optie laat zien hoe u een verbindingsreeks gebruikt om verbinding te maken met een Service Bus-naamruimte. Als u nog niet eerder met Azure werkt, kunt u de verbindingsreeks optie gemakkelijker volgen. We raden u aan de optie zonder wachtwoord te gebruiken in echte toepassingen en productieomgevingen. Zie Service Bus-verificatie en -autorisatie voor meer informatie. Zie .NET-apps verifiëren voor meer informatie over verificatie zonder wachtwoord.

Berichten verzenden naar een wachtrij

In deze sectie maakt u een Java-consoleproject en voegt u code toe om berichten te verzenden naar de wachtrij die u eerder hebt gemaakt.

Een Java-consoleproject maken

Maak een Java-project met Eclipse of een hulpprogramma van uw keuze.

Uw toepassing configureren voor het gebruik van Service Bus

Voeg verwijzingen toe naar Azure Core- en Azure Service Bus-bibliotheken.

Als u Eclipse gebruikt en een Java-consoletoepassing hebt gemaakt, converteert u uw Java-project naar een Maven: klik met de rechtermuisknop op het project in het venster Package Explorer . Selecteer Configureren>Omzetten naar Maven-project. Voeg vervolgens afhankelijkheden toe aan deze twee bibliotheken, zoals wordt weergegeven in het volgende voorbeeld.

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

Code toevoegen om berichten naar de wachtrij te verzenden

1. Voeg de volgende import-instructies toe aan het onderwerp van het Java-bestand.

   • Wachtwoordloos (aanbevolen)
   • Verbindingsreeks

   import com.azure.messaging.servicebus.*;
   import com.azure.identity.*;
   
   import java.util.concurrent.TimeUnit;
   import java.util.Arrays;
   import java.util.List;
   

2. Definieer in de klasse variabelen voor het opslaan van de verbindingsreeks en de naam van de wachtrij.

   • Wachtwoordloos (aanbevolen)
   • Verbindingsreeks

   static String queueName = "<QUEUE NAME>";
   

   Belangrijk

   Vervang <QUEUE NAME> door de naam van de wachtrij.

3. Voeg in de klasse een methode toe met de naam sendMessage om een bericht naar de wachtrij te verzenden.

   • Wachtwoordloos (aanbevolen)
   • Verbindingsreeks

   Belangrijk

   Vervang NAMESPACENAME door de naam van de Service Bus-naamruimte.

   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. Voeg in de klasse een methode toe met de naam createMessages om een lijst met berichten te maken. Normaal gesproken ontvangt u deze berichten van verschillende onderdelen van uw toepassing. In dit voorbeeld gebruikt u een lijst met voorbeeldberichten.

   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. Voeg een methode toe met de naam sendMessageBatch om berichten te verzenden naar de wachtrij die u hebt gemaakt. Met deze methode maakt u een ServiceBusSenderClient voor de wachtrij, roept u de methode createMessages aan om de lijst met berichten op te halen, bereidt u een of meer batches voor en verzendt u de batches naar de wachtrij.

   • Wachtwoordloos (aanbevolen)
   • Verbindingsreeks

   Belangrijk

   Vervang NAMESPACENAME door de naam van de Service Bus-naamruimte.

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

Berichten van een wachtrij ontvangen

In deze sectie voegt u code toe om berichten uit de wachtrij op te halen.

1. Voeg een methode toe met de naam receiveMessages om berichten van de wachtrij te ontvangen. Met deze methode maakt u een ServiceBusProcessorClient voor de wachtrij door een handler op te geven voor de verwerking van berichten en een andere voor het afhandelen van fouten. Vervolgens wordt de verwerker gestart, wordt er een paar seconden gewacht, worden de ontvangen berichten getoond en wordt de verwerker gestopt en gesloten.

   • Wachtwoordloos (aanbevolen)
   • Verbindingsreeks

   Belangrijk

   • Vervang NAMESPACENAME door de naam van de Service Bus-naamruimte.

   // 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. Voeg de processMessage methode toe om een bericht te verwerken dat is ontvangen van het Service Bus-abonnement.

   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. Voeg de processError methode toe om foutberichten te verwerken.

   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. Werk de methode main bij om de methoden sendMessage, sendMessageBatchen receiveMessages aan te roepen en InterruptedException te genereren.

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

De app uitvoeren

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

Op de pagina Overzicht voor de Service Bus-naamruimte in Azure Portal ziet u het aantal inkomende en uitgaande berichten. Wacht een minuut of zo en vernieuw de pagina om de meest recente waarden te zien.

Selecteer de wachtrij op de pagina Overzicht om naar de pagina Service Bus-wachtrij te gaan. U ziet ook de inkomende en uitgaande berichten op deze pagina. U ziet ook andere informatie, zoals de huidige grootte van de wachtrij en de maximale grootte, het aantal actieve berichten.

Verwante inhoud

Raadpleeg de volgende documentatie en voorbeelden:

• Azure Service Bus-clientbibliotheek voor Java - Leesmij
• Voorbeelden op GitHub
• Java API-referentie