← Modification précédente Modification suivante →

Version du 15 décembre 2021 à 17:39

Description

It is a message broker with message queues and publish-subscribe topics.

Configure the service bus on Azure

Azure portal → Service Bus → Add
Create namespace: the namespace will be the url use by the service bus
Once deployed, go to the newly create service bus namespace → add queue

Sender

Add Nuget package Azure.Messaging.ServiceBus

Program.cs

private const string ConnectionString = "get it from Azure Portal → Service Bus Namespace → Shared access policy → Primary Connection String";
private const string QueueName = "myqueue";
private const string TopicName = "topic1";

static async Task Main(string[] args)
{
    var client = new ServiceBusClient(ConnectionString);
    try  // use await using in C# 8 / .Net Core
    {
        var sender = client.CreateSender(QueueName);
        var sender = client.CreateSender(TopicName);

        var message = new ServiceBusMessage("Hello!");
        await sender.SendMessageAsync(message);
        Console.WriteLine($"Sent {message.Body}");
    }
    finally
    {
        await client.DisposeAsync();
    }
}

Receiver

Add Nuget package Azure.Messaging.ServiceBus

Program.cs

private const string ConnectionString = "get it from Azure Portal → Service Bus Namespace → Shared access policy → Primary Connection String";
private const string QueueName = "myqueue";
private const string TopicName = "topic1";

static async Task Main(string[] args)
{
    var client = new ServiceBusClient(ConnectionString);
    try  // use await using in C# 8 / .Net Core
    {
        var receiver = client.CreateReceiver(QueueName);

        var message = await receiver.ReceiveMessageAsync();
        Console.WriteLine($"Received {message.Body}");
    }
    finally
    {
        await client.DisposeAsync();
    }
}