Erste Schritte mit Azure Service Bus-Themen und -Abonnements (.NET)

Artikel
12/07/2023

In diesem Schnellstart erfahren Sie, wie mithilfe der .NET-Bibliothek Azure.Messaging.ServiceBus Nachrichten an ein Service Bus-Thema gesendet und von einem Abonnement dieses Themas empfangen werden.

Diese Schnellstartanleitung umfasst folgende Schritte:

Erstellen eines Service Bus-Namespace mithilfe des Azure-Portals
Erstellen eines Service Bus-Themas mithilfe des Azure-Portals
Erstellen eines Service Bus-Abonnements für dieses Thema mit dem Azure-Portal
Schreiben einer .NET-Konsolenanwendung, die eine Gruppe von Nachrichten an das Thema sendet.
Schreiben einer .NET-Konsolenanwendung, die diese Nachrichten aus dem Abonnement empfängt.

Hinweis

In dieser Schnellstartanleitung wird Schritt für Schritt die Implementierung eines einfachen Szenarios erläutert, bei dem Sie einen Batch von Nachrichten an ein Service Bus-Thema senden und diese Nachrichten von einem Abonnement des Themas empfangen werden. Weitere Beispiele zu anderen und erweiterten Szenarien finden Sie unter Service Bus-.NET-Beispiele auf GitHub.

In diesem Schnellstart werden zwei Möglichkeiten zum Herstellen einer Verbindung mit Azure Service Bus gezeigt: Verbindungszeichenfolge und kennwortlos. Die erste Option zeigt, wie Sie eine Verbindungszeichenfolge verwenden, um eine Verbindung mit einem Service Bus-Namespace herzustellen. Die zweite Option zeigt, wie Sie über Ihren Sicherheitsprinzipal in Microsoft Entra ID und die rollenbasierte Zugriffssteuerung (Role-Based Access Control, RBAC) eine Verbindung mit einem Service Bus-Namespace herstellen. Sie müssen sich keine Gedanken darüber machen, dass hartcodierte Verbindungszeichenfolgen in Ihrem Code oder in einer Konfigurationsdatei oder in einem sicheren Speicher wie Azure Key Vault vorhanden sind. Wenn Sie noch nicht mit Azure vertraut sind, ist die Option mit der Verbindungszeichenfolge möglicherweise einfacher. In realen Anwendungen und Produktionsumgebungen wird die kennwortlose Option empfohlen. Weitere Informationen finden Sie unter Authentifizierung und Autorisierung.

Voraussetzungen

Wenn Sie mit dem Dienst noch keine Erfahrung haben, informieren Sie sich über den Abschnitt Was ist Azure Service Bus?, bevor Sie die Schritte in dieser Schnellstartanleitung durchführen.

Azure-Abonnement. Für die Verwendung von Azure-Diensten benötigen Sie ein Abonnement. Das gilt auch für Azure Service Bus. Wenn Sie nicht über ein Azure-Konto verfügen, können Sie sich für eine kostenlose Testversion registrieren.
Visual Studio 2022 Die Beispielanwendung nutzt neue Features, die in C# 10 eingeführt wurden. Die Service Bus-Clientbibliothek kann zwar auch mit älteren Versionen von C# verwendet werden, die Syntax unterscheidet sich dann jedoch möglicherweise. Um die neueste Syntax verwenden zu können, empfiehlt es sich, mindestens .NET 6.0 zu installieren und die Sprachversion auf latest festzulegen. Bei Verwendung von Visual Studio sind Versionen vor Visual Studio 2022 nicht mit den Tools kompatibel, die zum Erstellen von C# 10-Projekten erforderlich sind.

Erstellen eines Namespace im Azure-Portal

Um mit der Verwendung von Service Bus-Nachrichtenentitäten in Azure beginnen zu können, müssen Sie zuerst einen Namespace mit einem in Azure eindeutigen Namen erstellen. Ein Namespace ist ein Bereichscontainer für Service Bus-Ressourcen (Warteschlangen, Themen usw.) innerhalb Ihrer Anwendung.

So erstellen Sie einen Namespace

Melden Sie sich beim Azure-Portal an.
Navigieren Sie zur Seite Alle Dienste.
Wählen Sie im linken Navigationsbereich in der Kategorienliste Integration aus, zeigen Sie mit dem Mauszeiger auf Service Bus, und wählen Sie auf der Service Bus-Kachel die Schaltfläche + aus.
Führen Sie auf der Seite Namespace erstellen auf der Registerkarte Grundlagen die folgenden Schritte aus:
1. Wählen Sie unter Abonnement ein Azure-Abonnement aus, in dem der Namespace erstellt werden soll.
2. Wählen Sie für die Ressourcengruppe eine vorhandene Ressourcengruppe aus, oder erstellen Sie eine neue.
3. Geben Sie einen Namen für den Namespace ein. Der Namespacename sollte den folgenden Namenskonventionen entsprechen:
  - Der Name muss innerhalb von Azure eindeutig sein. Das System überprüft sofort, ob dieser Name verfügbar ist.
  - Die Länge des Namens beträgt mindestens 6 und maximal 50 Zeichen.
  - Der Name darf nur Buchstaben, Zahlen, Bindestriche - enthalten.
  - Der Name muss mit einem Buchstaben beginnen und mit einem Buchstaben oder einer Ziffer enden.
  - Der Name endet nicht mit -sb oder -mgmt.
4. Wählen Sie unter Standort die Region aus, in der Ihr Namespace gehostet werden soll.
5. Wählen Sie unter Tarif den Tarif (Basic, Standard oder Premium) für den Namespace aus. Wählen Sie für diesen Schnellstart die Option Standard aus.
6. Wenn Sie Premium -Stufe auswählen, wählen Sie aus, ob Sie Georeplikation für den Namespace aktivieren können. Das Georeplikationsfeature stellt sicher, dass die Metadaten und Daten eines Namespaces kontinuierlich aus einer primären Region in eine oder mehrere sekundäre Regionen repliziert werden.
  
  Wichtig
  
  Wenn Sie Themen und Abonnements nutzen möchten, wählen Sie entweder Standard oder Premium aus. Themen/Abonnements werden für den Basic-Tarif nicht unterstützt.
  
  Wenn Sie den Tarif Premium auswählen, geben Sie die Anzahl von Messagingeinheiten an. Der Premium-Tarif bietet Ressourcenisolierung auf CPU- und Arbeitsspeicherebene, sodass die einzelnen Workloads voneinander isoliert ausgeführt werden. Dieser Ressourcencontainer wird als Messagingeinheit bezeichnet. Ein Premium-Namespace verfügt über mindestens eine Messagingeinheit. Sie können 1, 2, 4, 8 oder 16 Messagingeinheiten für jeden Service Bus Premium-Namespace auswählen. Weitere Informationen finden Sie unter Service Bus Premium- und Standard-Preisstufe für Messaging.
7. Wählen Sie am unteren Rand der Seite die Option Bewerten + erstellen aus.
8. Überprüfen Sie die Einstellungen auf der Seite Überprüfen und erstellen, und wählen Sie Erstellen aus.
Wählen Sie nach der erfolgreichen Bereitstellung der Ressource auf der Bereitstellungsseite Zur Ressource wechseln aus.
Die Startseite für Ihren Service Bus-Namespace wird angezeigt.

Erstellen eines Themas mit dem Azure-Portal

Erweitern Sie auf der Seite Service Bus Namespace Entitäten im Navigationsmenü links, und wählen Sie Themen im linken Menü aus.
Wählen Sie auf der Symbolleiste die Option + Thema aus.
Geben Sie unter Name einen Namen für das Thema ein. Behalten Sie bei den anderen Optionen die Standardwerte bei.
Klicken Sie auf Erstellen.

Erstellen eines Abonnements für das Thema

Wählen Sie das Thema aus, das Sie im vorherigen Abschnitt erstellt haben.
Wählen Sie auf der Seite Service Bus-Thema auf der Symbolleiste die Option + Abonnement aus.
Führen Sie auf der Seite Abonnement erstellen die folgenden Schritte aus:
1. Geben Sie S1 für Name des Abonnements ein.
2. Geben Sie 3 für Maximale Lieferungsanzahl ein.
3. Wählen Sie dann Erstellen, um das Abonnement zu erstellen.

Authentifizieren der App bei Azure

In dieser Schnellstartanleitung werden zwei Möglichkeiten zum Herstellen einer Verbindung mit Azure Service Bus gezeigt: kennwortlos und Verbindungszeichenfolge.

Die erste Option zeigt, wie Sie über Ihren Sicherheitsprinzipal in Microsoft Entra ID und die rollenbasierte Zugriffssteuerung (Role-Based Access Control, RBAC) eine Verbindung mit einem Service Bus-Namespace herstellen. Sie müssen sich keine Gedanken darüber machen, dass hartcodierte Verbindungszeichenfolgen in Ihrem Code oder in einer Konfigurationsdatei oder in einem sicheren Speicher wie Azure Key Vault vorhanden sind.

Die zweite Option zeigt, wie Sie mithilfe einer Verbindungszeichenfolge eine Verbindung mit einem Service Bus-Namespace herstellen. Wenn Sie noch nicht mit Azure vertraut sind, ist die Option mit der Verbindungszeichenfolge möglicherweise einfacher. In realen Anwendungen und Produktionsumgebungen wird die kennwortlose Option empfohlen. Weitere Informationen finden Sie unter Authentifizierung und Autorisierung. Weitere Informationen zur kennwortlosen Authentifizierung finden Sie auch auf der Übersichtsseite.

Kennwortlos (empfohlen)
Verbindungszeichenfolge

Zuweisen von Rollen zu Ihrem Microsoft Entra-Benutzer

Achten Sie bei der lokalen Entwicklung darauf, dass das Benutzerkonto, das die Verbindung mit Azure Service Bus herstellt, über die korrekten Berechtigungen verfügt. Zum Senden und Empfangen von Nachrichten ist die Rolle Azure Service Bus-Datenbesitzer erforderlich. Um sich selbst diese Rolle zuweisen zu können, benötigen Sie die Rolle „Benutzerzugriffsadministrator“ oder eine andere Rolle, die die Aktion Microsoft.Authorization/roleAssignments/write umfasst. Sie können einem Benutzer Azure RBAC-Rollen über das Azure-Portal, die Azure CLI oder mit Azure PowerShell zuweisen. Weitere Informationen zu den verfügbaren Bereichen für Rollenzuweisungen finden Sie auf der Seite Grundlegendes zum Bereich von Azure RBAC.

Im folgenden Beispiel wird Ihrem Benutzerkonto die Rolle Azure Service Bus Data Owner zugewiesen. Diese Rolle bietet Vollzugriff auf Azure Service Bus-Ressourcen. Halten Sie sich in einem echten Szenario an das Prinzip der geringsten Rechte, um Benutzern nur die benötigten Mindestberechtigungen zu erteilen und so die Produktionsumgebung besser zu schützen.

Integrierte Azure-Rollen für Azure Service Bus

Bei Azure Service Bus ist die Verwaltung der Namespaces und aller zugehörigen Ressourcen über das Azure-Portal und die Azure-Ressourcenverwaltungs-API bereits durch das Azure RBAC-Modell geschützt. Azure stellt die folgenden integrierten Azure-Rollen zum Autorisieren des Zugriffs auf einen Service Bus-Namespace bereit:

Azure Service Bus-Datenbesitzer: ermöglicht den Datenzugriff auf einen Service Bus-Namespace und seine Entitäten (Warteschlangen, Themen, Abonnements und Filter). Ein Mitglied dieser Rolle kann Nachrichten an Warteschlangen oder Themen/Abonnements senden bzw. aus diesen empfangen.
Azure Service Bus-Datensender: Verwenden Sie diese Rolle, um dem Service Bus-Namespace und seinen Entitäten Sendezugriff zu erteilen.
Azure Service Bus-Datenempfänger: Verwenden Sie diese Rolle, um Zugriff auf den Service Bus-Namespace und seine Entitäten zu erhalten.

Informationen zum Erstellen einer benutzerdefinierten Rolle finden Sie unter Erforderliche Rechte für Service Bus-Vorgänge.

Hinzufügen eines Microsoft Entra-Benutzers zur Azure Service Bus-Besitzerrolle

Fügen Sie auf Service Bus-Namespace-Ebene Ihren Microsoft Entra-Benutzernamen der Rolle Azure Service Bus-Datenbesitzer hinzu. Dies ermöglicht einer App, die im Kontext Ihres Benutzerkontos ausgeführt wird, Nachrichten an eine Warteschlange oder ein Thema zu senden und Nachrichten aus einer Warteschlange oder einem Abonnement eines Themas zu empfangen.

Wichtig

In der Regel dauert die Verteilung der Rollenzuweisung in Azure ein bis zwei Minuten. In seltenen Fällen kann sie aber bis zu acht Minuten dauern. Wenn bei der ersten Ausführung Ihres Codes Authentifizierungsfehler auftreten, warten Sie einige Momente, und versuchen Sie es dann erneut.

Wenn die Seite „Service Bus-Namespace“ im Azure-Portal nicht geöffnet ist, ermitteln Sie Ihren Service Bus-Namespace über die Hauptsuchleiste oder den linken Navigationsbereich.
Wählen Sie auf der Übersichtsseite im linken Menü die Option Zugriffssteuerung (IAM) aus.
Wählen Sie auf der Seite Zugriffssteuerung (IAM) die Registerkarte Rollenzuweisungen aus.
Wählen Sie im oberen Menü + Hinzufügen und aus dem dann angezeigten Dropdownmenü die Option Rollenzuweisung hinzufügen aus.
Über das Suchfeld können Sie die Ergebnisse für die gewünschte Rolle filtern. Suchen Sie in diesem Beispiel nach Azure Service Bus Data Owner, und wählen Sie das entsprechende Ergebnis aus. Klicken Sie dann auf Weiter.
Wählen Sie unter Zugriff zuweisen zu die Option Benutzer, Gruppe oder Dienstprinzipal und dann die Option + Mitglieder auswählen aus.
Suchen Sie im Dialogfeld nach Ihrem Microsoft Entra-Benutzernamen (normalerweise Ihre E-Mail-Adresse benutzer@domäne), und wählen Sie unten im Dialogfeld Auswählen aus.
Wählen Sie Überprüfen und zuweisen aus, um zur letzten Seite zu gelangen, und wählen Sie erneut Überprüfen und zuweisen aus, um den Vorgang abzuschließen.

Der Zugriff auf den Service Bus-Namespace kann mithilfe der folgenden Schritte autorisiert werden:

Starten Sie Visual Studio. Wenn das Fenster Erste Schritte angezeigt wird, wählen Sie im rechten Bereich den Link Ohne Code fortfahren aus.
Wählen Sie oben rechts in Visual Studio die Schaltfläche Anmelden aus.
Melden Sie sich mit dem Microsoft Entra-Konto an, dem Sie zuvor eine Rolle zugewiesen haben.

Senden von Nachrichten an das Thema

In diesem Abschnitt erfahren Sie, wie Sie eine .NET-Konsolenanwendung zum Senden von Nachrichten an ein Service Bus-Thema erstellen.

Hinweis

Erstellen einer Konsolenanwendung

Wählen Sie in Visual Studio Datei ->Neu ->Projekt aus.
Führen Sie im Dialogfeld Neues Projekt erstellen die folgenden Schritte aus: Sollte dieses Dialogfeld nicht angezeigt werden, wählen Sie im Menü die Option Datei und anschließend Neu > Projekt aus.
1. Wählen Sie die Programmiersprache C# aus.
2. Wählen Sie den Anwendungstyp Konsole aus.
3. Wählen Sie in der Ergebnisliste Konsolen-App aus.
4. Klicken Sie anschließend auf Weiter.
Geben Sie als Projektnamen TopicSender und als Projektmappennamen ServiceBusTopicQuickStart ein, und wählen Sie dann Weiter aus.
Wählen Sie auf der Seite Zusätzliche Informationen die Option Erstellen aus, um Projektmappe und Projekt zu erstellen.

Wählen Sie im Menü Extras>NuGet-Paket-Manager>Paket-Manager-Konsole aus.
Führen Sie den folgenden Befehl aus, um das NuGet-Paket Azure.Messaging.ServiceBus zu installieren.
```
Install-Package Azure.Messaging.ServiceBus
```
Führen Sie den folgenden Befehl aus, um das NuGet-Paket Azure.Identity zu installieren.
```
Install-Package Azure.Identity
```

Wählen Sie im Menü Extras>NuGet-Paket-Manager>Paket-Manager-Konsole aus.
Führen Sie den folgenden Befehl aus, um das NuGet-Paket Azure.Messaging.ServiceBus zu installieren:
```
Install-Package Azure.Messaging.ServiceBus
```

Hinzufügen von Code zum Senden von Nachrichten an das Thema

Ersetzen Sie den Inhalt von "Program.cs" durch den folgenden Code. Die wichtigen Schritte sind in diesem Abschnitt aufgeführt und werden durch zusätzliche Informationen in den Codekommentaren ergänzt.

Kennwortlos
Verbindungszeichenfolge

Erstellt ein Objekt vom Typ ServiceBusClient unter Verwendung des Objekts DefaultAzureCredential. DefaultAzureCredential erkennt automatisch die Anmeldeinformationen Ihrer Visual Studio-Anmeldung für die Authentifizierung bei Azure Service Bus.
Aufrufen der CreateSender-Methode für das ServiceBusClient-Objekt, um ein ServiceBusSender-Objekt für das angegebene Service Bus-Thema zu erstellen
Erstellen eines ServiceBusMessageBatch-Objekts mithilfe von ServiceBusSender.CreateMessageBatchAsync
Hinzufügen von Nachrichten zum Batch mithilfe von ServiceBusMessageBatch.TryAddMessage.
Senden des Nachrichtenbatches an das Service Bus-Thema mithilfe der Methode ServiceBusSender.SendMessagesAsync

Wichtig

Aktualisieren Sie Platzhalterwerte (<NAMESPACE-NAME> und <TOPIC-NAME>) im Codeschnipsel mit den Namen Ihres Service Bus-Namespaces und -Themas.

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 sender used to publish messages to the topic
ServiceBusSender sender;

// number of messages to be sent to the topic
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.

//TODO: Replace the "<NAMESPACE-NAME>" and "<TOPIC-NAME>" placeholders.
client = new ServiceBusClient(
    "<NAMESPACE-NAME>.servicebus.windows.net",
    new DefaultAzureCredential());
sender = client.CreateSender("<TOPIC-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 topic
    await sender.SendMessagesAsync(messageBatch);
    Console.WriteLine($"A batch of {numOfMessages} messages has been published to the topic.");
}
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();

Wichtig

Ersetzen Sie Platzhalterwerte (<NAMESPACE-CONNECTION-STRING> und <TOPIC-NAME>) im Codeschnipsel durch die tatsächlichen Werte, die Sie zuvor notiert haben.

Erstellen eines ServiceBusClient-Objekts unter Verwendung der Verbindungszeichenfolge für den Namespace
Aufrufen der CreateSender-Methode für das ServiceBusClient-Objekt, um ein ServiceBusSender-Objekt für das angegebene Service Bus-Thema zu erstellen
Erstellen eines ServiceBusMessageBatch-Objekts mithilfe von ServiceBusSender.CreateMessageBatchAsync
Hinzufügen von Nachrichten zum Batch mithilfe von ServiceBusMessageBatch.TryAddMessage.
Senden des Nachrichtenbatches an das Service Bus-Thema mithilfe der Methode ServiceBusSender.SendMessagesAsync

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 sender used to publish messages to the topic
ServiceBusSender sender;

// number of messages to be sent to the topic
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.
//TODO: Replace the "<NAMESPACE-CONNECTION-STRING>" and "<TOPIC-NAME>" placeholders.
client = new ServiceBusClient("<NAMESPACE-CONNECTION-STRING>");
sender = client.CreateSender("<TOPIC-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 topic
    await sender.SendMessagesAsync(messageBatch);
    Console.WriteLine($"A batch of {numOfMessages} messages has been published to the topic.");
}
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();

Erstellen Sie das Projekt, und vergewissern Sie sich, dass keine Fehler vorhanden sind.
Führen Sie das Programm aus, und warten Sie auf die Bestätigungsmeldung.
```
A batch of 3 messages has been published to the topic
```
Wichtig

In der Regel dauert die Verteilung der Rollenzuweisung in Azure ein bis zwei Minuten. In seltenen Fällen kann es aber bis zu acht Minuten dauern. Wenn bei der ersten Ausführung Ihres Codes Authentifizierungsfehler auftreten, warten Sie einige Momente, und versuchen Sie es dann erneut.
Gehen Sie im Azure-Portal wie folgt vor:
1. Navigieren Sie zu Ihrem Service Bus-Namespace.
2. Wechseln Sie auf der Seite Übersicht unten im mittleren Bereich zur Registerkarte Themen, und wählen Sie das Service Bus-Thema aus. Im folgenden Beispiel ist dies mytopic.
3. Auf der Seite Service Bus-Thema unten im Abschnitt Metriken können Sie im Diagramm Nachrichten sehen, dass für das Thema drei eingehende Nachrichten vorhanden sind. Wenn der Wert nicht angezeigt wird, sollten Sie einige Minuten warten und die Seite dann aktualisieren, damit das aktualisierte Diagramm angezeigt wird.
4. Wählen Sie im unteren Bereich das Abonnement aus. Im folgenden Beispiel ist dies S1. Auf der Seite Service Bus-Abonnement wird für Anzahl aktiver Nachrichten der Wert 3 angezeigt. Das Abonnement hat die drei Nachrichten empfangen, die Sie an das Thema gesendet haben, aber sie wurden noch nicht von einem Empfänger abgerufen.

Empfangen von Nachrichten aus einem Abonnement

In diesem Abschnitt erstellen Sie eine .NET-Konsolenanwendung für den Empfang von Nachrichten aus dem Abonnement an das Service Bus-Thema.

Hinweis

Erstellen eines Projekts für den Empfänger

Klicken Sie im Projektmappen-Explorer mit der rechten Maustaste auf die Projektmappe ServiceBusTopicQuickStart, zeigen Sie auf Hinzufügen, und wählen Sie anschließend Neues Projekt aus.
Wählen Sie zuerst Konsolenanwendung, dann Weiter aus.
Geben Sie SubscriptionReceiver als Projektnamen ein, und wählen Sie Weiter aus.
Wählen Sie auf der Seite Zusätzliche Informationen die Option Erstellen aus.
Klicken Sie im Fenster Projektmappen-Explorer mit der rechten Maustaste auf SubscriptionReceiver, und wählen Sie Als Startprojekt festlegen aus.

Hinzufügen der NuGet-Pakete zum Projekt

Kennwortlos
Verbindungszeichenfolge

Wählen Sie im Menü Extras>NuGet-Paket-Manager>Paket-Manager-Konsole aus.
Wählen Sie SubscriptionReceiver als Standardprojekt in der Dropdownliste aus.
Führen Sie den folgenden Befehl aus, um das NuGet-Paket Azure.Messaging.ServiceBus zu installieren.
```
Install-Package Azure.Messaging.ServiceBus
```
Führen Sie den folgenden Befehl aus, um das NuGet-Paket Azure.Identity zu installieren.
```
Install-Package Azure.Identity
```

Wählen Sie im Menü Extras>NuGet-Paket-Manager>Paket-Manager-Konsole aus.
Führen Sie den folgenden Befehl aus, um das NuGet-Paket Azure.Messaging.ServiceBus zu installieren:
```
Install-Package Azure.Messaging.ServiceBus
```

Hinzufügen von Code für das Empfangen von Nachrichten aus dem Abonnement

In diesem Abschnitt fügen Sie Code hinzu, mit dem Nachrichten vom Abonnement abgerufen werden.

Ersetzen Sie den vorhandenen Inhalt von Program.cs durch die folgenden Eigenschaften und Methoden:

Kennwortlos
Verbindungszeichenfolge

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 subscription
ServiceBusProcessor processor;    

// handle received messages
async Task MessageHandler(ProcessMessageEventArgs args)
{
    string body = args.Message.Body.ToString();
    Console.WriteLine($"Received: {body} from subscription.");

    // complete the message. messages is deleted from the subscription. 
    await args.CompleteMessageAsync(args.Message);
}

// handle any errors when receiving messages
Task ErrorHandler(ProcessErrorEventArgs args)
{
    Console.WriteLine(args.Exception.ToString());
    return Task.CompletedTask;
}

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 subscription
ServiceBusProcessor processor;    

// handle received messages
async Task MessageHandler(ProcessMessageEventArgs args)
{
    // TODO: Replace the <TOPIC-SUBSCRIPTION-NAME> placeholder
    string body = args.Message.Body.ToString();
    Console.WriteLine($"Received: {body} from subscription: <TOPIC-SUBSCRIPTION-NAME>");

    // complete the message. messages is deleted from the subscription. 
    await args.CompleteMessageAsync(args.Message);
}

// handle any errors when receiving messages
Task ErrorHandler(ProcessErrorEventArgs args)
{
    Console.WriteLine(args.Exception.ToString());
    return Task.CompletedTask;
}

Fügen Sie am Ende von Program.cs den folgenden Code hinzu.

Kennwortlos
Verbindungszeichenfolge

Erstellt ein Objekt vom Typ ServiceBusClient unter Verwendung des Objekts DefaultAzureCredential. DefaultAzureCredential erkennt automatisch die Anmeldeinformationen Ihrer Visual Studio-Anmeldung für die Authentifizierung bei Azure Service Bus.
Aufrufen der CreateProcessor-Methode für das ServiceBusClient-Objekt zum Erstellen eines ServiceBusProcessor-Objekts für das angegebene Service Bus-Thema.
Angeben von Handlern für die Ereignisse ProcessMessageAsync und ProcessErrorAsync des ServiceBusProcessor-Objekts
Starten der Verarbeitung von Nachrichten durch Aufrufen von StartProcessingAsync für das ServiceBusProcessor-Objekt
Aufrufen von StopProcessingAsync für das ServiceBusProcessor-Objekt, wenn der Benutzer eine Taste zum Beenden der Verarbeitung drückt

Wichtig

Aktualisieren Sie Platzhalterwerte (<NAMESPACE-NAME>, <TOPIC-NAME>, <SUBSCRIPTION-NAME>) im Codeschnipsel mit den Namen Ihres Service Bus-Namespaces, -Themas und -Abonnements.

Weitere Informationen finden Sie in den Codekommentaren.

// 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.
//
// Create the clients that we'll use for sending and processing messages.
// TODO: Replace the <NAMESPACE-NAME> placeholder
client = new ServiceBusClient(
    "<NAMESPACE-NAME>.servicebus.windows.net",
    new DefaultAzureCredential());

// create a processor that we can use to process the messages
// TODO: Replace the <TOPIC-NAME> and <SUBSCRIPTION-NAME> placeholders
processor = client.CreateProcessor("<TOPIC-NAME>", "<SUBSCRIPTION-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();
}

Wichtig

Aktualisieren Sie Platzhalterwerte (<NAMESPACE-CONNECTION-STRING>, <TOPIC-NAME>, <SUBSCRIPTION-NAME>) im Codeschnipsel mit den tatsächlichen Werten, die Sie sich zuvor notiert haben.

Erstellen eines ServiceBusClient-Objekts unter Verwendung der Verbindungszeichenfolge für den Namespace
Aufrufen der CreateProcessor-Methode für das ServiceBusClient-Objekt zum Erstellen eines ServiceBusProcessor-Objekts für das angegebene Service Bus-Thema.
Angeben von Handlern für die Ereignisse ProcessMessageAsync und ProcessErrorAsync des ServiceBusProcessor-Objekts
Starten der Verarbeitung von Nachrichten durch Aufrufen von StartProcessingAsync für das ServiceBusProcessor-Objekt
Aufrufen von StopProcessingAsync für das ServiceBusProcessor-Objekt, wenn der Benutzer eine Taste zum Beenden der Verarbeitung drückt

Weitere Informationen finden Sie in den Codekommentaren.

// 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.
//
// Create the clients that we'll use for sending and processing messages.
// TODO: Replace the <NAMESPACE-CONNECTION-STRING> placeholder
client = new ServiceBusClient("<NAMESPACE-CONNECTION-STRING>");

// create a processor that we can use to process the messages
// TODO: Replace the <TOPIC-NAME> and <SUBSCRIPTION-NAME> placeholders
processor = client.CreateProcessor("<TOPIC-NAME>", "<SUBSCRIPTION-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();
}

Program.cs sollte wie folgt aussehen:

Kennwortlos
Verbindungszeichenfolge

using System;
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 subscription
ServiceBusProcessor processor;

// handle received messages
async Task MessageHandler(ProcessMessageEventArgs args)
{
    string body = args.Message.Body.ToString();
    Console.WriteLine($"Received: {body} from subscription.");

    // complete the message. messages is deleted from the subscription. 
    await args.CompleteMessageAsync(args.Message);
}

// handle any errors when receiving messages
Task ErrorHandler(ProcessErrorEventArgs args)
{
    Console.WriteLine(args.Exception.ToString());
    return Task.CompletedTask;
}

// 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.
//
// Create the clients that we'll use for sending and processing messages.
// TODO: Replace the <NAMESPACE-NAME> placeholder
client = new ServiceBusClient(
    "<NAMESPACE-NAME>.servicebus.windows.net",
    new DefaultAzureCredential());

// create a processor that we can use to process the messages
// TODO: Replace the <TOPIC-NAME> and <SUBSCRIPTION-NAME> placeholders
processor = client.CreateProcessor("<TOPIC-NAME>", "<SUBSCRIPTION-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();
}

using System;
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 subscription
ServiceBusProcessor processor;

// handle received messages
async Task MessageHandler(ProcessMessageEventArgs args)
{
    string body = args.Message.Body.ToString();
    Console.WriteLine($"Received: {body} from subscription.");

    // complete the message. messages is deleted from the subscription. 
    await args.CompleteMessageAsync(args.Message);
}

// handle any errors when receiving messages
Task ErrorHandler(ProcessErrorEventArgs args)
{
    Console.WriteLine(args.Exception.ToString());
    return Task.CompletedTask;
}

// 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.
//
// Create the clients that we'll use for sending and processing messages.
// TODO: Replace the <NAMESPACE-CONNECTION-STRING> placeholder
client = new ServiceBusClient("<NAMESPACE-CONNECTION-STRING>");

// create a processor that we can use to process the messages
// TODO: Replace the <TOPIC-NAME> and <SUBSCRIPTION-NAME> placeholders
processor = client.CreateProcessor("<TOPIC-NAME>", "<SUBSCRIPTION-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();
}

Erstellen Sie das Projekt, und vergewissern Sie sich, dass keine Fehler vorhanden sind.

Führen Sie die Empfängeranwendung aus. Nun sollten die empfangenen Nachrichten angezeigt werden. Drücken Sie eine beliebige Taste, um Empfänger und Anwendung zu beenden.

Wait for a minute and then press any key to end the processing
Received: Message 1 from subscription: S1
Received: Message 2 from subscription: S1
Received: Message 3 from subscription: S1

Stopping the receiver...
Stopped receiving messages

Sehen Sie sich erneut die Informationen im Portal an.
- Auf der Seite Service Bus-Thema werden im Diagramm Nachrichten drei ein- und drei ausgehende Nachrichten angezeigt. Falls diese Zahlen nicht angezeigt werden, sollten Sie einige Minuten warten und die Seite dann aktualisieren, damit der aktuelle Stand im Diagramm angezeigt wird.
- Auf der Seite Service Bus-Abonnement wird für Anzahl aktiver Nachrichten der Wert „0“ angezeigt. Dies liegt daran, dass ein Empfänger Nachrichten von diesem Abonnement empfangen und den Vorgang für die Nachrichten abgeschlossen hat.

Nächste Schritte

Weitere Informationen finden Sie in der folgenden Dokumentation bzw. unter den folgenden Beispielen:

Freigeben über

Erste Schritte mit Azure Service Bus-Themen und -Abonnements (.NET)

Voraussetzungen

Erstellen eines Namespace im Azure-Portal

Erstellen eines Themas mit dem Azure-Portal

Erstellen eines Abonnements für das Thema

Authentifizieren der App bei Azure

Zuweisen von Rollen zu Ihrem Microsoft Entra-Benutzer

Integrierte Azure-Rollen für Azure Service Bus

Hinzufügen eines Microsoft Entra-Benutzers zur Azure Service Bus-Besitzerrolle

Abrufen der Verbindungszeichenfolge

Senden von Nachrichten an das Thema

Erstellen einer Konsolenanwendung

Hinzufügen der NuGet-Pakete zum Projekt

Hinzufügen von Code zum Senden von Nachrichten an das Thema

Empfangen von Nachrichten aus einem Abonnement

Erstellen eines Projekts für den Empfänger

Hinzufügen der NuGet-Pakete zum Projekt

Hinzufügen von Code für das Empfangen von Nachrichten aus dem Abonnement

Nächste Schritte

Feedback

Zusätzliche Ressourcen

Freigeben über

Erste Schritte mit Azure Service Bus-Themen und -Abonnements (.NET)

Voraussetzungen

Erstellen eines Namespace im Azure-Portal

Erstellen eines Themas mit dem Azure-Portal

Erstellen eines Abonnements für das Thema

Authentifizieren der App bei Azure

Zuweisen von Rollen zu Ihrem Microsoft Entra-Benutzer

Integrierte Azure-Rollen für Azure Service Bus

Hinzufügen eines Microsoft Entra-Benutzers zur Azure Service Bus-Besitzerrolle

Starten von Visual Studio und Anmelden bei Azure

Senden von Nachrichten an das Thema

Erstellen einer Konsolenanwendung

Hinzufügen der NuGet-Pakete zum Projekt

Hinzufügen von Code zum Senden von Nachrichten an das Thema

Empfangen von Nachrichten aus einem Abonnement

Erstellen eines Projekts für den Empfänger

Hinzufügen der NuGet-Pakete zum Projekt

Hinzufügen von Code für das Empfangen von Nachrichten aus dem Abonnement

Nächste Schritte

Feedback

Zusätzliche Ressourcen