Skicka meddelanden till och ta emot meddelanden från Azure Service Bus-köer (Java)

Den här snabbstarten innehåller stegvisa instruktioner för ett enkelt scenario med att skicka meddelanden till en Service Bus-kö och ta emot dem. Du skapar en Java-app för att skicka meddelanden till och ta emot meddelanden från en Azure Service Bus-kö. Du hittar fördefinierade Java-exempel för Azure Service Bus i Azure SDK för Java-lagringsplatsen på GitHub.

Förutsättningar

• Ett Azure-abonnemang. För att slutföra den här snabbstarten behöver du ett Azure-konto. Du kan aktivera dina månatliga Azure-krediter för Visual Studio-prenumeranter eller registrera dig för ett kostnadsfritt konto.

• Installera Azure SDK för Java.

  • Om du använder Eclipse kan du installera Azure Toolkit for Eclipse som innehåller Azure SDK för Java. Du kan sedan lägga till Microsoft Azure Libraries for Java i projektet.
  • Om du använder IntelliJ läser du Installera Azure Toolkit for IntelliJ.

Skapa ett namnområde i Azure Portal

Om du vill börja använda Service Bus-meddelandeentiteter i Azure skapar du ett namnområde med ett namn som är unikt i Hela Azure. Ett namnområde tillhandahåller en omfångscontainer för Service Bus-resurser, till exempel köer och ämnen, i ditt program.

Så här skapar du ett namnområde:

1. Logga in på Azure-portalen.

2. Välj den utfällbara menyn längst upp till vänster och gå till sidan Alla tjänster.

3. I det vänstra navigeringsfältet väljer du Integrering.

4. Rulla ned till Messaging Services>Service Bus och välj Skapa.

   

5. Följ dessa steg på fliken Grundläggande på sidan Skapa namnområde :

   1. För Prenumeration väljer du en Azure-prenumeration där du ska skapa namnrymden.

   2. För Resursgrupp väljer du en befintlig resursgrupp eller skapar en ny.

   3. Ange ett namnområdesnamn som uppfyller följande namngivningskonventioner:

      • Namnet måste vara unikt i Hela Azure. Systemet kontrollerar omedelbart om namnet är tillgängligt.
      • Namnlängden är minst 6 och högst 50 tecken.
      • Namnet får endast innehålla bokstäver, siffror, bindestreck -.
      • Namnet måste börja med en bokstav och sluta med en bokstav eller siffra.
      • Namnet slutar inte med -sb eller -mgmt.

   4. För Plats väljer du den region som ska vara värd för ditt namnområde.

   5. För Prisnivå väljer du prisnivån (Basic, Standard eller Premium) för namnområdet. För den här snabbstarten väljer du Standard.

      Om du väljer Premium-nivå kan du aktivera geo-replikering för namnområdet. Geo-replikeringsfunktionen säkerställer att metadata och data i ett namnområde kontinuerligt replikeras från en primär region till en eller flera sekundära regioner.

      Viktigt!

      Om du vill använda ämnen och prenumerationer väljer du antingen Standard eller Premium. Ämnen och prenumerationer stöds inte på prisnivån Basic.

      Om du har valt prisnivån Premium anger du antalet meddelandeenheter. Premium-nivån ger resursisolering på processor- och minnesnivå så att varje arbetsbelastning körs självständigt. Den här resurscontainern kallas för en meddelandefunktionsenhet. Ett premiumnamnområde har minst en meddelandeenhet. Du kan välja 1, 2, 4, 8 eller 16 meddelandeenheter för varje Service Bus Premium-namnområde. Mer information finns i Service Bus Premium-meddelandenivån.

   6. Välj Granska och skapa längst ned på sidan.

      

   7. På sidan Granska + skapa granskar du inställningarna och väljer Skapa.

6. När distributionen av resursen har slutförts väljer du Gå till resurs på distributionssidan.

   

7. Startsidan för din Service Bus-namnrymd visas.

   

Skapa en kö i Azure-portalen

1. På sidan Service Bus-namnområde expanderar du Entiteter på navigeringsmenyn till vänster och väljer Köer.

2. På sidan Köer, i verktygsfältet väljer du + Kö.

3. Ange ett namn för kön. Lämna de andra värdena med sina standardvärden.

4. Välj Skapa.

   

Autentisera appen till Azure

Den här artikeln visar två sätt att ansluta till Azure Service Bus: lösenordslös och anslutningssträng.

Det första alternativet visar hur du använder ditt säkerhetsobjekt i Microsoft Entra-ID och rollbaserad åtkomstkontroll (RBAC) för att ansluta till ett Service Bus-namnområde. Du behöver inte bekymra dig om att ha en hårdkodad anslutningssträng i koden, i en konfigurationsfil eller i en säker lagring som Azure Key Vault.

Det andra alternativet visar hur du använder en anslutningssträng för att ansluta till ett Service Bus-namnområde. Om du inte har använt Azure tidigare kan det vara enklare att följa anslutningssträng alternativet. Vi rekommenderar att du använder det lösenordslösa alternativet i verkliga program och produktionsmiljöer. Mer information finns i Service Bus-autentisering och auktorisering. Mer information om lösenordslös autentisering finns i Autentisera .NET-appar.

Skicka meddelanden till en kö

I det här avsnittet skapar du ett Java-konsolprojekt och lägger till kod för att skicka meddelanden till kön som du skapade tidigare.

Skapa ett Java-konsolprojekt

Skapa ett Java-projekt med Eclipse eller ett valfritt verktyg.

Konfigurera ditt program så att det använder Service Bus

Lägg till referenser till Azure Core- och Azure Service Bus-bibliotek.

Om du använder Eclipse och har skapat ett Java-konsolprogram konverterar du Java-projektet till en Maven: högerklicka på projektet i fönstret Paketutforskaren . Välj Konfigurera>Konvertera till Maven-projekt. Lägg sedan till beroenden i dessa två bibliotek enligt följande exempel.

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

Lägg till kod för att skicka meddelanden till kön

1. Lägg till följande import instruktioner i början av Java-filen.

   • lösenordsfri (rekommenderas)
   • Anslutningssträng

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

2. I klassen definiera variabler för att innehålla anslutningssträngen och kö namnet.

   • lösenordsfri (rekommenderas)
   • Anslutningssträng

   static String queueName = "<QUEUE NAME>";
   

   Viktigt!

   Ersätt <QUEUE NAME> med namnet på kön.

3. Lägg till en metod med namnet sendMessage i klassen för att skicka ett meddelande till kön.

   • lösenordsfri (rekommenderas)
   • Anslutningssträng

   Viktigt!

   Ersätt NAMESPACENAME med namnet på Service Bus-namnområdet.

   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. Lägg till en metod med namnet createMessages i klassen för att skapa en lista med meddelanden. Vanligtvis får du dessa meddelanden från olika delar av programmet. I det här exemplet använder du en lista med exempelmeddelanden.

   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. Lägg till en metod med namnet sendMessageBatch metod för att skicka meddelanden till kön som du skapade. Den här metoden skapar en ServiceBusSenderClient för kön, anropar createMessages metoden för att hämta listan över meddelanden, förbereder en eller flera batchar och skickar batcharna till kön.

   • lösenordsfri (rekommenderas)
   • Anslutningssträng

   Viktigt!

   Ersätt NAMESPACENAME med namnet på Service Bus-namnområdet.

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

Ta emot meddelanden från en kö

I det här avsnittet lägger du till kod för att hämta meddelanden från kön.

1. Lägg till en metod med namnet receiveMessages för att ta emot meddelanden från kön. Den här metoden skapar en ServiceBusProcessorClient för kön genom att ange en hanterare för bearbetning av meddelanden och en annan för hantering av fel. Sedan startar processorn, väntar i några sekunder, skriver ut de meddelanden som tas emot och stoppar och stänger sedan processorn.

   • lösenordsfri (rekommenderas)
   • Anslutningssträng

   Viktigt!

   • Ersätt NAMESPACENAME med namnet på Service Bus-namnområdet.

   // 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 Lägg till metoden för att bearbeta ett meddelande som tas emot från Service Bus-prenumerationen.

   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 Lägg till metoden för att hantera felmeddelanden.

   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 Uppdatera metoden för att anropa sendMessage, sendMessageBatchoch receiveMessages metoder och för att utlösa InterruptedException.

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

Kör appen

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

På sidan Översikt för Service Bus-namnområdet i Azure-portalen kan du se antal inkommande och utgående meddelanden. Vänta i en minut eller så och uppdatera sedan sidan för att se de senaste värdena.

Välj kön på den här översiktssidan för att gå till sidan Service Bus-kö . Du ser också antalet inkommande och utgående meddelanden på den här sidan. Du ser också annan information såsom aktuella storlek på kön, maximal storlek och antal aktiva meddelanden.

Relaterat innehåll

Se följande dokumentation och exempel:

• Azure Service Bus-klientbibliotek för Java – Readme
• Exempel på GitHub
• Java API-referens