Quickstart: Berichten verzenden en ontvangen van een Azure Service Bus-wachtrij (.NET)

In deze quickstart voert u de volgende stappen uit:

1. Een Service Bus-naamruimte maken met de Azure-portal.

2. Een Service Bus-wachtrij maken met de Azure-portal.

3. Schrijf een .NET-consoletoepassing om een set berichten naar de wachtrij te verzenden.

4. Schrijf een .NET-consoletoepassing om deze berichten uit de wachtrij te ontvangen.

   Notitie

   Deze quickstart bevat stapsgewijze instructies voor het implementeren van een eenvoudig scenario voor het verzenden van een batch berichten naar een Service Bus-wachtrij en deze vervolgens ontvangt. Zie de Azure Service Bus-clientbibliotheek voor .NET voor een overzicht van de .NET-clientbibliotheek. Zie Service Bus .NET-voorbeelden op GitHub voor meer voorbeelden.

Vereisten

Als u geen toegang hebt tot de service, raadpleegt u het Service Bus-overzicht voordat u deze quickstart uitvoert.

• Azure-abonnement. Als u Azure-services, waaronder Azure Service Bus, wilt gebruiken, hebt u een abonnement nodig. Als u geen bestaand Azure-account hebt, kunt u zich aanmelden voor een gratis proefversie.
• Visual Studio 2022. De voorbeeldtoepassing maakt gebruik van nieuwe functies die zijn geïntroduceerd in C# 10. U kunt de Service Bus-clientbibliotheek nog steeds gebruiken met eerdere C#-taalversies, maar de syntaxis kan variëren. Als u de nieuwste syntaxis wilt gebruiken, raden we u aan .NET 6.0 of hoger te installeren en de taalversie in te stellen op latest. Als u Visual Studio gebruikt, zijn versies vóór Visual Studio 2022 niet compatibel met de hulpprogramma's die nodig zijn om C# 10-projecten te bouwen.

Een naamruimte in de Azure-portal maken

Als u Service Bus-berichtenentiteiten wilt gebruiken in Azure, moet u eerst een naamruimte maken met een naam die uniek is binnen Azure. Een naamruimte biedt een bereikcontainer voor Service Bus-resources (wachtrijen, onderwerpen, enzovoort) in uw toepassing.

Ga als volgt te werk om een naamruimte te maken:

1. Meld u aan bij het Azure-portaal.

2. Navigeer naar de pagina Alle services.

3. Selecteer integratie in de linkernavigatiebalk in de lijst met categorieën, beweeg de muisaanwijzer over Service Bus en selecteer + vervolgens de knop op de Service Bus-tegel.

   

4. Voer in de tag Basisinformatie 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 naam in voor de naamruimte. De naamruimtenaam moet voldoen 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 waarin uw naamruimte moet worden gehost.

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

   6. Als u de Premium-laag selecteert, selecteert u of u geo-replicatie voor de naamruimte kunt inschakelen. De functie 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/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 Service Bus Premium Messaging voor meer informatie.

   7. Selecteer Controleren en maken onderaan de pagina.

      

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

5. Zodra de implementatie van de resource is geslaagd, selecteert u Ga naar de resource op de implementatiepagina.

   

6. 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 entiteiten uit in het navigatiemenu aan de linkerkant en selecteer Wachtrijen.

2. Selecteer op de pagina Wachtrijen de optie + Wachtrij op de werkbalk.

3. Voer een naam voor de wachtrij in en hanteer voor de andere waarden de standaardinstellingen.

4. Selecteer nu Maken.

   

Belangrijk

Als u nog niet eerder met Azure bent, is de optie Verbindingsreeks mogelijk gemakkelijker te volgen. Selecteer het tabblad Verbindingsreeks voor instructies voor het gebruik van een verbindingsreeks in deze quickstart. U wordt aangeraden de optie Wachtwoordloos te gebruiken in echte toepassingen en productieomgevingen.

De app verifiëren bij Azure

In deze quickstart 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 het in code vastgelegde verbindingsreeks in uw code of 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 Verificatie en autorisatie voor meer informatie. U kunt ook meer lezen over verificatie zonder wachtwoord op de overzichtspagina.

Wachtwoordloos

Rollen toewijzen aan uw Microsoft Entra-gebruiker

Zorg er bij het lokaal ontwikkelen voor dat het gebruikersaccount dat verbinding maakt met Azure Service Bus over de juiste machtigingen beschikt. U hebt de rol Azure Service Bus-gegevenseigenaar nodig om berichten te kunnen verzenden en ontvangen. Als u uzelf deze rol wilt toewijzen, hebt u de rol Gebruikerstoegangsbeheerder of een andere rol nodig die de Microsoft.Authorization/roleAssignments/write actie bevat. U kunt Azure RBAC-rollen toewijzen aan een gebruiker met behulp van Azure Portal, Azure CLI of Azure PowerShell. Meer informatie over de beschikbare bereiken voor roltoewijzingen op de overzichtspagina van het bereik.

In het volgende voorbeeld wordt de Azure Service Bus Data Owner rol toegewezen aan uw gebruikersaccount, dat volledige toegang biedt tot Azure Service Bus-resources. Volg in een echt scenario het principe van minimale bevoegdheden om gebruikers alleen de minimale machtigingen te geven die nodig zijn voor een veiligere productieomgeving.

Ingebouwde Azure-rollen voor Azure Service Bus

Voor Azure Service Bus is het beheer van naamruimten en alle gerelateerde resources via Azure Portal en de Azure Resource Management-API al beveiligd met behulp van het Azure RBAC-model. Azure biedt de onderstaande ingebouwde Azure-rollen voor het autoriseren van toegang tot een Service Bus-naamruimte:

• Azure Service Bus-gegevenseigenaar: hiermee schakelt u gegevenstoegang tot de Service Bus-naamruimte en de bijbehorende entiteiten (wachtrijen, onderwerpen, abonnementen en filters) in. Een lid van deze rol kan berichten verzenden en ontvangen van wachtrijen of onderwerpen/abonnementen.
• Azure Service Bus-gegevenszender: gebruik deze rol om de verzendtoegang tot de Service Bus-naamruimte en de bijbehorende entiteiten te geven.
• Azure Service Bus-gegevensontvanger: gebruik deze rol om de ontvangsttoegang te geven tot de Service Bus-naamruimte en de bijbehorende entiteiten.

Als u een aangepaste rol wilt maken, raadpleegt u Rechten die vereist zijn voor Service Bus-bewerkingen.

Microsoft Entra-gebruiker toevoegen aan de rol Azure Service Bus-eigenaar

Voeg uw Microsoft Entra-gebruikersnaam toe aan de rol Azure Service Bus-gegevenseigenaar op het niveau van de Service Bus-naamruimte. Hiermee kan een app die wordt uitgevoerd in de context van uw gebruikersaccount berichten verzenden naar een wachtrij of een onderwerp en berichten ontvangen van een wachtrij of het abonnement van een onderwerp.

Belangrijk

In de meeste gevallen duurt het een paar minuten voordat de roltoewijzing is doorgegeven in Azure. In zeldzame gevallen kan het maximaal acht minuten duren. Als u verificatiefouten ontvangt wanneer u de code voor het eerst uitvoert, wacht u even en probeert u het opnieuw.

1. Als u de pagina Service Bus-naamruimte niet hebt geopend in Azure Portal, zoekt u uw Service Bus-naamruimte met behulp van de hoofdzoekbalk of linkernavigatiebalk.

2. Selecteer op de overzichtspagina toegangsbeheer (IAM) in het linkermenu.

3. Selecteer op de pagina Toegangsbeheer (IAM) het tabblad Roltoewijzingen .

4. Selecteer + Toevoegen in het bovenste menu en voeg vervolgens roltoewijzing toe in de resulterende vervolgkeuzelijst.

   

5. Gebruik het zoekvak om de resultaten te filteren op de gewenste rol. In dit voorbeeld zoekt Azure Service Bus Data Owner en selecteert u het overeenkomende resultaat. Kies vervolgens Volgende.

6. Selecteer onder Toegang toewijzen de optie Gebruiker, groep of service-principal en kies vervolgens + Leden selecteren.

7. Zoek in het dialoogvenster naar uw Microsoft Entra-gebruikersnaam (meestal uw user@domain e-mailadres) en kies Vervolgens onderaan het dialoogvenster Selecteren .

8. Selecteer Beoordelen + toewijzen om naar de laatste pagina te gaan en vervolgens opnieuw beoordelen en toewijzen om het proces te voltooien.

Verbindingsreeks

De verbindingsreeks ophalen

Als u een nieuwe naamruimte maakt, wordt automatisch een eerste SAS-beleid (Shared Access Signature) gegenereerd met primaire en secundaire sleutels en primaire en secundaire verbindingsreeks s die elk volledige controle over alle aspecten van de naamruimte verlenen. Raadpleeg Service Bus-verificatie en -autorisatie voor meer informatie over het maken van regels met beperktere rechten voor reguliere afzenders en ontvangers.

Een client kan de verbindingsreeks gebruiken om verbinding te maken met de Service Bus-naamruimte. Voer de volgende stappen uit om de primaire verbindingsreeks voor uw naamruimte te kopiëren:

1. Selecteer op de pagina Service Bus-naamruimte gedeeld toegangsbeleid in het linkermenu.

2. Selecteer RootManageSharedAccessKey op de pagina Beleid voor gedeelde toegang.

3. Selecteer in het venster Beleid: RootManageSharedAccessKey de knop Kopiëren naast primaire verbindingsreeks om de verbindingsreeks naar het klembord te kopiëren voor later gebruik. Plak deze waarde in Kladblok of een andere tijdelijke locatie.

   

   U kunt deze pagina gebruiken om de primaire sleutel, secundaire sleutel, primaire verbindingsreeks en secundaire verbindingsreeks te kopiëren.

Visual Studio starten en u aanmelden bij Azure

U kunt toegang tot de Service Bus-naamruimte autoriseren met behulp van de volgende stappen:

1. Start Visual Studio. Als u het venster Aan de slag ziet, selecteert u de koppeling Doorgaan zonder code in het rechterdeelvenster.

2. Selecteer de knop Aanmelden in de rechterbovenhoek van Visual Studio.

   

3. Meld u aan met het Microsoft Entra-account waaraan u eerder een rol hebt toegewezen.

   

Berichten naar de wachtrij verzenden

In deze sectie wordt beschreven hoe u een .NET-consoletoepassing maakt voor het verzenden van berichten naar een Service Bus-wachtrij.

Notitie

Deze quickstart bevat stapsgewijze instructies voor het implementeren van een eenvoudig scenario voor het verzenden van een batch berichten naar een Service Bus-wachtrij en deze vervolgens ontvangt. Zie Service Bus .NET-voorbeelden op GitHub voor meer voorbeelden over andere en geavanceerde scenario's.

Een consoletoepassing maken

1. Selecteer in Visual Studio het menu File ->New ->Project .

2. Voer in het dialoogvenster Een nieuw project maken de volgende stappen uit: Als u dit dialoogvenster niet ziet, selecteert u Bestand in het menu, selecteert u Nieuw en selecteert u Vervolgens Project.

   1. Selecteer de programmeertaal C#.

   2. Selecteer Console als het type toepassing.

   3. Selecteer Console-app in de lijst met resultaten.

   4. Selecteer vervolgens Volgende.

      

3. Voer QueueSender in voor de projectnaam, ServiceBusQueueQuickStart voor de naam van de oplossing en selecteer vervolgens Volgende.

   

4. Selecteer Op de pagina Aanvullende informatie de optie Maken om de oplossing en het project te maken.

De NuGet-pakketten toevoegen aan het project

Wachtwoordloos

1. Selecteer Tools>NuGet-pakketbeheer>Package Manager Console in het menu.

2. Voer de volgende opdracht uit om het NuGet-pakket Azure.Messaging.ServiceBus te installeren.

   Install-Package Azure.Messaging.ServiceBus
   

3. Voer de volgende opdracht uit om het Azure.Identity NuGet-pakket te installeren.

   Install-Package Azure.Identity
   

Verbindingsreeks

1. Selecteer Tools>NuGet-pakketbeheer>Package Manager Console in het menu.

2. Voer de volgende opdracht uit om het NuGet-pakket Azure.Messaging.ServiceBus te installeren:

   Install-Package Azure.Messaging.ServiceBus
   

Code toevoegen om berichten naar de wachtrij te verzenden

1. Vervang de inhoud door Program.cs de volgende code. De belangrijke stappen worden beschreven in de volgende sectie, met aanvullende informatie in de codeopmerkingen.

   Wachtwoordloos

   • Hiermee maakt u een ServiceBusClient-object met behulp van het DefaultAzureCredential object. DefaultAzureCredential detecteert en gebruikt automatisch de referenties van uw Visual Studio-aanmelding om te verifiëren bij Azure Service Bus.
   • Roept de methode CreateSender op het ServiceBusClient-object aan om een ServiceBusSender-object te maken voor de specifieke Service Bus-wachtrij.
   • Hiermee maakt u een ServiceBusMessageBatch-object met behulp van de methode ServiceBusSender.CreateMessageBatchAsync .
   • Voeg berichten toe aan de batch met behulp van de ServiceBusMessageBatch.TryAddMessage.
   • Verzendt de batch berichten naar de Service Bus-wachtrij met behulp van de methode ServiceBusSender.SendMessagesAsync .

   Belangrijk

   Werk de waarden van tijdelijke aanduidingen (<NAMESPACE-NAME> en <QUEUE-NAME>) in het codefragment bij met de namen van uw Service Bus-naamruimte en -wachtrij.

   using Azure.Messaging.ServiceBus;
   using Azure.Identity;
   
   // name of your Service Bus queue
   // the client that owns the connection and can be used to create senders and receivers
   ServiceBusClient client;
   
   // the sender used to publish messages to the queue
   ServiceBusSender sender;
   
   // number of messages to be sent to the queue
   const int numOfMessages = 3;
   
   // The Service Bus client types are safe to cache and use as a singleton for the lifetime
   // of the application, which is best practice when messages are being published or read
   // regularly.
   //
   // Set the transport type to AmqpWebSockets so that the ServiceBusClient uses the port 443. 
   // If you use the default AmqpTcp, ensure that ports 5671 and 5672 are open.
   var clientOptions = new ServiceBusClientOptions
   { 
       TransportType = ServiceBusTransportType.AmqpWebSockets
   };
   //TODO: Replace the "<NAMESPACE-NAME>" and "<QUEUE-NAME>" placeholders.
   client = new ServiceBusClient(
       "<NAMESPACE-NAME>.servicebus.windows.net",
       new DefaultAzureCredential(),
       clientOptions);
   sender = client.CreateSender("<QUEUE-NAME>");
   
   // create a batch 
   using ServiceBusMessageBatch messageBatch = await sender.CreateMessageBatchAsync();
   
   for (int i = 1; i <= numOfMessages; i++)
   {
       // try adding a message to the batch
       if (!messageBatch.TryAddMessage(new ServiceBusMessage($"Message {i}")))
       {
           // if it is too large for the batch
           throw new Exception($"The message {i} is too large to fit in the batch.");
       }
   }
   
   try
   {
       // Use the producer client to send the batch of messages to the Service Bus queue
       await sender.SendMessagesAsync(messageBatch);
       Console.WriteLine($"A batch of {numOfMessages} messages has been published to the queue.");
   }
   finally
   {
       // Calling DisposeAsync on client types is required to ensure that network
       // resources and other unmanaged objects are properly cleaned up.
       await sender.DisposeAsync();
       await client.DisposeAsync();
   }
   
   Console.WriteLine("Press any key to end the application");
   Console.ReadKey();
   

   Verbindingsreeks

   • Hiermee maakt u een ServiceBusClient-object met behulp van de verbindingsreeks.
   • Roept de methode CreateSender op het ServiceBusClient-object aan om een ServiceBusSender-object te maken voor de specifieke Service Bus-wachtrij.
   • Hiermee maakt u een ServiceBusMessageBatch-object met behulp van de methode ServiceBusSender.CreateMessageBatchAsync .
   • Voeg berichten toe aan de batch met behulp van de ServiceBusMessageBatch.TryAddMessage.
   • Verzendt de batch berichten naar de Service Bus-wachtrij met behulp van de methode ServiceBusSender.SendMessagesAsync .

   Belangrijk

   Werk de waarden van tijdelijke aanduidingen (<NAMESPACE-CONNECTION-STRING> en <QUEUE-NAME>) in het codefragment bij met de namen van uw Service Bus-naamruimte en -wachtrij.

   using Azure.Messaging.ServiceBus;
   
   // the client that owns the connection and can be used to create senders and receivers
   ServiceBusClient client;
   
   // the sender used to publish messages to the queue
   ServiceBusSender sender;
   
   // number of messages to be sent to the queue
   const int numOfMessages = 3;
   
   // The Service Bus client types are safe to cache and use as a singleton for the lifetime
   // of the application, which is best practice when messages are being published or read
   // regularly.
   //
   // set the transport type to AmqpWebSockets so that the ServiceBusClient uses the port 443. 
   // If you use the default AmqpTcp, you will need to make sure that the ports 5671 and 5672 are open
   
   // TODO: Replace the <NAMESPACE-CONNECTION-STRING> and <QUEUE-NAME> placeholders
   var clientOptions = new ServiceBusClientOptions()
   { 
       TransportType = ServiceBusTransportType.AmqpWebSockets
   };
   client = new ServiceBusClient("<NAMESPACE-CONNECTION-STRING>", clientOptions);
   sender = client.CreateSender("<QUEUE-NAME>");
   
   // create a batch 
   using ServiceBusMessageBatch messageBatch = await sender.CreateMessageBatchAsync();
   
   for (int i = 1; i <= numOfMessages; i++)
   {
       // try adding a message to the batch
       if (!messageBatch.TryAddMessage(new ServiceBusMessage($"Message {i}")))
       {
           // if it is too large for the batch
           throw new Exception($"The message {i} is too large to fit in the batch.");
       }
   }
   
   try
   {
       // Use the producer client to send the batch of messages to the Service Bus queue
       await sender.SendMessagesAsync(messageBatch);
       Console.WriteLine($"A batch of {numOfMessages} messages has been published to the queue.");
   }
   finally
   {
       // Calling DisposeAsync on client types is required to ensure that network
       // resources and other unmanaged objects are properly cleaned up.
       await sender.DisposeAsync();
       await client.DisposeAsync();
   }
   
   Console.WriteLine("Press any key to end the application");
   Console.ReadKey();
   

2. Bouw het project en controleer of er geen fouten zijn.

3. Voer het programma uit en wacht op het bevestigingsbericht.

   A batch of 3 messages has been published to the queue
   

   Belangrijk

   In de meeste gevallen duurt het een paar minuten voordat de roltoewijzing is doorgegeven in Azure. In zeldzame gevallen kan het maximaal acht minuten duren. Als u verificatiefouten ontvangt wanneer u de code voor het eerst uitvoert, wacht u even en probeert u het opnieuw.

4. Volg deze stappen in Azure Portal:

   1. Navigeer naar uw Service Bus-naamruimte.

   2. Selecteer op de pagina Overzicht de wachtrij in het deelvenster in het midden onderaan.

      

   3. Let op de waarden in de sectie Essentials.

      

   Let op de volgende waarden:

   • De waarde voor het aantal actieve berichten voor de wachtrij is nu 3. Telkens wanneer u deze afzender-app uitvoert zonder de berichten op te halen, neemt deze waarde met 3 toe.
   • De huidige grootte van de wachtrij wordt steeds verhoogd wanneer de app berichten toevoegt aan de wachtrij.
   • In de grafiek Berichten in de onderste sectie Metrische gegevens ziet u dat er drie binnenkomende berichten voor de wachtrij zijn.

Berichten ontvangen uit de wachtrij

In deze sectie maakt u een .NET-consoletoepassing die berichten uit de wachtrij ontvangt.

Notitie

Deze quickstart bevat stapsgewijze instructies voor het implementeren van een scenario voor het verzenden van een batch berichten naar een Service Bus-wachtrij en het ontvangen ervan. Zie Service Bus .NET-voorbeelden op GitHub voor meer voorbeelden over andere en geavanceerde scenario's.

Een project maken voor de ontvanger

1. Klik in het venster Solution Explorer met de rechtermuisknop op de oplossing ServiceBusQueueQuickStart, wijs Toevoegen aan en selecteer Nieuw project.
2. Selecteer Consoletoepassing en selecteer Volgende.
3. Voer QueueReceiver in voor de projectnaam en selecteer Maken.
4. Klik in het venster Solution Explorer met de rechtermuisknop op QueueReceiver en selecteer Instellen als opstartproject.

De NuGet-pakketten toevoegen aan het project

Wachtwoordloos

1. Selecteer Tools>NuGet-pakketbeheer>Package Manager Console in het menu.

2. Selecteer QueueReceiver voor het standaardproject.

   

3. Voer de volgende opdracht uit om het NuGet-pakket Azure.Messaging.ServiceBus te installeren.

   Install-Package Azure.Messaging.ServiceBus
   

4. Voer de volgende opdracht uit om het Azure.Identity NuGet-pakket te installeren.

   Install-Package Azure.Identity
   

Verbindingsreeks

1. Selecteer Tools>NuGet-pakketbeheer>Package Manager Console in het menu.

2. Voer de volgende opdracht uit om het NuGet-pakket Azure.Messaging.ServiceBus te installeren:

   Install-Package Azure.Messaging.ServiceBus
   

   

De code toevoegen voor het ontvangen van berichten uit de wachtrij

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

1. Voeg in de Program klasse de volgende code toe:

   Wachtwoordloos

   using System.Threading.Tasks;
   using Azure.Identity;
   using Azure.Messaging.ServiceBus;
   
   // the client that owns the connection and can be used to create senders and receivers
   ServiceBusClient client;
   
   // the processor that reads and processes messages from the queue
   ServiceBusProcessor processor;
   

   Verbindingsreeks

   using System.Threading.Tasks;
   using Azure.Messaging.ServiceBus;
   
   // the client that owns the connection and can be used to create senders and receivers
   ServiceBusClient client;
   
   // the processor that reads and processes messages from the queue
   ServiceBusProcessor processor;
   

2. Voeg de volgende methoden toe aan het einde van de Program klasse.

   // handle received messages
   async Task MessageHandler(ProcessMessageEventArgs args)
   {
       string body = args.Message.Body.ToString();
       Console.WriteLine($"Received: {body}");
   
       // complete the message. message is deleted from the queue. 
       await args.CompleteMessageAsync(args.Message);
   }
   
   // handle any errors when receiving messages
   Task ErrorHandler(ProcessErrorEventArgs args)
   {
       Console.WriteLine(args.Exception.ToString());
       return Task.CompletedTask;
   }
   

3. Voeg de volgende code toe aan het einde van de Program klasse. De belangrijke stappen worden beschreven in de volgende sectie, met aanvullende informatie in de codeopmerkingen.

   Wachtwoordloos

   • Hiermee maakt u een ServiceBusClient-object met behulp van het DefaultAzureCredential object. DefaultAzureCredential detecteert en gebruikt automatisch de referenties van uw Visual Studio-aanmelding om te verifiëren bij Azure Service Bus.
   • Roept de methode CreateProcessor op het ServiceBusClient object aan om een ServiceBusProcessor-object te maken voor de opgegeven Service Bus-wachtrij.
   • Hiermee geeft u handlers op voor de gebeurtenissen ProcessMessageAsync en ProcessErrorAsync van het ServiceBusProcessor-object .
   • Begint met het verwerken van berichten door de StartProcessingAsync op het ServiceBusProcessor object aan te roepen.
   • Wanneer de gebruiker op een toets drukt om de verwerking te beëindigen, roept u de StopProcessingAsync op het ServiceBusProcessor object aan.

   Belangrijk

   Werk de waarden van tijdelijke aanduidingen (<NAMESPACE-NAME> en <QUEUE-NAME>) in het codefragment bij met de namen van uw Service Bus-naamruimte en -wachtrij.

   // The Service Bus client types are safe to cache and use as a singleton for the lifetime
   // of the application, which is best practice when messages are being published or read
   // regularly.
   //
   // Set the transport type to AmqpWebSockets so that the ServiceBusClient uses port 443. 
   // If you use the default AmqpTcp, make sure that ports 5671 and 5672 are open.
   
   // TODO: Replace the <NAMESPACE-NAME> placeholder
   var clientOptions = new ServiceBusClientOptions()
   {
       TransportType = ServiceBusTransportType.AmqpWebSockets
   };
   client = new ServiceBusClient(
       "<NAMESPACE-NAME>.servicebus.windows.net",
       new DefaultAzureCredential(),
       clientOptions);
   
   // create a processor that we can use to process the messages
   // TODO: Replace the <QUEUE-NAME> placeholder
   processor = client.CreateProcessor("<QUEUE-NAME>", new ServiceBusProcessorOptions());
   
   try
   {
       // add handler to process messages
       processor.ProcessMessageAsync += MessageHandler;
   
       // add handler to process any errors
       processor.ProcessErrorAsync += ErrorHandler;
   
       // start processing 
       await processor.StartProcessingAsync();
   
       Console.WriteLine("Wait for a minute and then press any key to end the processing");
       Console.ReadKey();
   
       // stop processing 
       Console.WriteLine("\nStopping the receiver...");
       await processor.StopProcessingAsync();
       Console.WriteLine("Stopped receiving messages");
   }
   finally
   {
       // Calling DisposeAsync on client types is required to ensure that network
       // resources and other unmanaged objects are properly cleaned up.
       await processor.DisposeAsync();
       await client.DisposeAsync();
   }
   

   Verbindingsreeks

   • Hiermee maakt u een ServiceBusClient-object met behulp van de verbindingsreeks.
   • Roept de methode CreateProcessor op het ServiceBusClient-object aan om een ServiceBusProcessor-object te maken voor de opgegeven Service Bus-wachtrij.
   • Hiermee geeft u handlers op voor de gebeurtenissen ProcessMessageAsync en ProcessErrorAsync van het ServiceBusProcessor-object .
   • Hiermee wordt gestart met het verwerken van berichten door de StartProcessingAsync aan te roepen op het ServiceBusProcessor-object .
   • Wanneer de gebruiker op een toets drukt om de verwerking te beëindigen, roept u de StopProcessingAsync aan op het ServiceBusProcessor-object .

   // The Service Bus client types are safe to cache and use as a singleton for the lifetime
   // of the application, which is best practice when messages are being published or read
   // regularly.
   //
   // Set the transport type to AmqpWebSockets so that the ServiceBusClient uses port 443. 
   // If you use the default AmqpTcp, make sure that ports 5671 and 5672 are open.
   
   // TODO: Replace the <NAMESPACE-CONNECTION-STRING> and <QUEUE-NAME> placeholders
   var clientOptions = new ServiceBusClientOptions()
   {
       TransportType = ServiceBusTransportType.AmqpWebSockets
   };
   client = new ServiceBusClient("<NAMESPACE-CONNECTION-STRING>", clientOptions);
   
   // create a processor that we can use to process the messages
   // TODO: Replace the <QUEUE-NAME> placeholder
   processor = client.CreateProcessor("<QUEUE-NAME>", new ServiceBusProcessorOptions());
   
   try
   {
       // add handler to process messages
       processor.ProcessMessageAsync += MessageHandler;
   
       // add handler to process any errors
       processor.ProcessErrorAsync += ErrorHandler;
   
       // start processing 
       await processor.StartProcessingAsync();
   
       Console.WriteLine("Wait for a minute and then press any key to end the processing");
       Console.ReadKey();
   
       // stop processing 
       Console.WriteLine("\nStopping the receiver...");
       await processor.StopProcessingAsync();
       Console.WriteLine("Stopped receiving messages");
   }
   finally
   {
       // Calling DisposeAsync on client types is required to ensure that network
       // resources and other unmanaged objects are properly cleaned up.
       await processor.DisposeAsync();
       await client.DisposeAsync();
   }
   

4. De voltooide Program klasse moet overeenkomen met de volgende code:

   Wachtwoordloos

   using System.Threading.Tasks;
   using Azure.Messaging.ServiceBus;
   using Azure.Identity;
   
   // the client that owns the connection and can be used to create senders and receivers
   ServiceBusClient client;
   
   // the processor that reads and processes messages from the queue
   ServiceBusProcessor processor;
   
   // The Service Bus client types are safe to cache and use as a singleton for the lifetime
   // of the application, which is best practice when messages are being published or read
   // regularly.
   //
   // Set the transport type to AmqpWebSockets so that the ServiceBusClient uses port 443.
   // If you use the default AmqpTcp, make sure that ports 5671 and 5672 are open.
   
   // TODO: Replace the <NAMESPACE-NAME> and <QUEUE-NAME> placeholders
   var clientOptions = new ServiceBusClientOptions() 
   {
       TransportType = ServiceBusTransportType.AmqpWebSockets
   };
   client = new ServiceBusClient("<NAMESPACE-NAME>.servicebus.windows.net", 
       new DefaultAzureCredential(), clientOptions);
   
   // create a processor that we can use to process the messages
   // TODO: Replace the <QUEUE-NAME> placeholder
   processor = client.CreateProcessor("<QUEUE-NAME>", new ServiceBusProcessorOptions());
   
   try
   {
       // add handler to process messages
       processor.ProcessMessageAsync += MessageHandler;
   
       // add handler to process any errors
       processor.ProcessErrorAsync += ErrorHandler;
   
       // start processing 
       await processor.StartProcessingAsync();
   
       Console.WriteLine("Wait for a minute and then press any key to end the processing");
       Console.ReadKey();
   
       // stop processing 
       Console.WriteLine("\nStopping the receiver...");
       await processor.StopProcessingAsync();
       Console.WriteLine("Stopped receiving messages");
   }
   finally
   {
       // Calling DisposeAsync on client types is required to ensure that network
       // resources and other unmanaged objects are properly cleaned up.
       await processor.DisposeAsync();
       await client.DisposeAsync();
   }
   
   // handle received messages
   async Task MessageHandler(ProcessMessageEventArgs args)
   {
       string body = args.Message.Body.ToString();
       Console.WriteLine($"Received: {body}");
   
       // complete the message. message is deleted from the queue. 
       await args.CompleteMessageAsync(args.Message);
   }
   
   // handle any errors when receiving messages
   Task ErrorHandler(ProcessErrorEventArgs args)
   {
       Console.WriteLine(args.Exception.ToString());
       return Task.CompletedTask;
   }
   

   Verbindingsreeks

   using Azure.Messaging.ServiceBus;
   using System;
   using System.Threading.Tasks;
   
   // the client that owns the connection and can be used to create senders and receivers
   ServiceBusClient client;
   
   // the processor that reads and processes messages from the queue
   ServiceBusProcessor processor;
   
   // The Service Bus client types are safe to cache and use as a singleton for the lifetime
   // of the application, which is best practice when messages are being published or read
   // regularly.
   //
   // Set the transport type to AmqpWebSockets so that the ServiceBusClient uses port 443. 
   // If you use the default AmqpTcp, make sure that ports 5671 and 5672 are open.
   
   // TODO: Replace the <NAMESPACE-CONNECTION-STRING> and <QUEUE-NAME> placeholders
   var clientOptions = new ServiceBusClientOptions()
   {
       TransportType = ServiceBusTransportType.AmqpWebSockets
   };
   client = new ServiceBusClient("<NAMESPACE-CONNECTION-STRING>", clientOptions);
   
   // create a processor that we can use to process the messages
   // TODO: Replace the <QUEUE-NAME> placeholder
   processor = client.CreateProcessor("<QUEUE-NAME>", new ServiceBusProcessorOptions());
   
   try
   {
       // add handler to process messages
       processor.ProcessMessageAsync += MessageHandler;
   
       // add handler to process any errors
       processor.ProcessErrorAsync += ErrorHandler;
   
       // start processing 
       await processor.StartProcessingAsync();
   
       Console.WriteLine("Wait for a minute and then press any key to end the processing");
       Console.ReadKey();
   
       // stop processing 
       Console.WriteLine("\nStopping the receiver...");
       await processor.StopProcessingAsync();
       Console.WriteLine("Stopped receiving messages");
   }
   finally
   {
       // Calling DisposeAsync on client types is required to ensure that network
       // resources and other unmanaged objects are properly cleaned up.
       await processor.DisposeAsync();
       await client.DisposeAsync();
   }
   
   // handle received messages
   async Task MessageHandler(ProcessMessageEventArgs args)
   {
       string body = args.Message.Body.ToString();
       Console.WriteLine($"Received: {body}");
   
       // complete the message. message is deleted from the queue. 
       await args.CompleteMessageAsync(args.Message);
   }
   
   // handle any errors when receiving messages
   Task ErrorHandler(ProcessErrorEventArgs args)
   {
       Console.WriteLine(args.Exception.ToString());
       return Task.CompletedTask;
   }
   

5. Bouw het project en controleer of er geen fouten zijn.

6. Voer de ontvangende toepassing uit. U ziet nu de ontvangen berichten. Druk op een willekeurige toets om de ontvanger en de toepassing te stoppen.

   Wait for a minute and then press any key to end the processing
   Received: Message 1
   Received: Message 2
   Received: Message 3
   
   Stopping the receiver...
   Stopped receiving messages
   

7. Controleer de portal opnieuw. Wacht enkele minuten en vernieuw de pagina als u geen actieve berichten ziet.0

   • Het aantal actieve berichten en de waarden voor huidige grootte zijn nu 0.

   • In de grafiek Berichten in de onderste sectie Metrische gegevens ziet u dat er drie binnenkomende berichten en drie uitgaande berichten voor de wachtrij zijn.

     

Resources opschonen

Navigeer naar uw Service Bus-naamruimte in Azure Portal en selecteer Verwijderen in Azure Portal om de naamruimte en de wachtrij erin te verwijderen.

Zie ook

Raadpleeg de volgende documentatie en voorbeelden:

• Azure Service Bus-clientbibliotheek voor .NET - Leesmij
• Voorbeelden op GitHub
• .NET-API-referentie
• Problemen met infrastructuur op een hoger niveau abstraheren, zoals NServiceBus

Volgende stappen

Aan de slag met Azure Service Bus-onderwerpen en -abonnementen (.NET)