Azure Service Bus konularını ve aboneliklerini kullanmaya başlama (.NET)

Bu hızlı başlangıçta, Azure.Messaging.ServiceBus .NET kitaplığını kullanarak Service Bus konusuna ileti gönderme ve abonelikten bu konuya ileti alma işlemleri gösterilmektedir.

Bu hızlı başlangıçta aşağıdaki adımları uygulayacaksınız:

1. Azure portalı ile Service Bus ad alanı oluşturma.
2. Azure portalı ile Service Bus konusu oluşturma.
3. Azure portalı ile bu konu için bir Service Bus aboneliği oluşturma.
4. Konuya bir dizi ileti göndermek için bir .NET konsol uygulaması yazın.
5. Abonelikten bu iletileri almak için bir .NET konsol uygulaması yazın.

Önkoşullar

Hizmette yeniyseniz, bu hızlı başlangıcı gerçekleştirmeden önce bkz . Service Bus'a genel bakış .

• Azure aboneliği. Azure Service Bus dahil olmak üzere Azure hizmetlerini kullanmak için bir aboneliğe ihtiyacınız vardır. Mevcut bir Azure hesabınız yoksa ücretsiz deneme sürümüne kaydolabilirsiniz.
• Visual Studio 2022. Örnek uygulama, C# 10'da tanıtılan yeni özellikleri kullanır. Service Bus istemci kitaplığını önceki C# dil sürümleriyle kullanmaya devam edebilirsiniz, ancak söz dizimi farklılık gösterebilir. En son söz dizimini kullanmak için .NET 6.0 veya üzerini yüklemenizi ve dil sürümünü olarak latestayarlamanızı öneririz. Visual Studio kullanıyorsanız, Visual Studio 2022 öncesi sürümler C# 10 projeleri oluşturmak için gereken araçlarla uyumlu değildir.

Azure portalında bir ad alanı oluşturma

Azure'da Service Bus mesajlaşma varlıklarını kullanmaya başlamak için öncelikle Azure'da benzersiz olan bir ad alanı oluşturmanız gerekir. Ad alanı, uygulamanızdaki Service Bus kaynakları (kuyruklar, konular vb.) için bir kapsam kapsayıcısı sağlar.

Ad alanı oluşturmak için:

1. Azure Portal’ında oturum açın.

2. Tüm hizmetler sayfasına gidin.

3. Sol gezinti çubuğunda, kategoriler listesinden Tümleştirme'yi seçin, fareyi Service Bus'ın üzerine getirin ve ardından Service Bus kutucuğundaki düğmeyi seçin+.

   

4. Ad alanı oluştur sayfasının Temel bilgiler etiketinde şu adımları izleyin:

   1. Abonelik için ad alanının oluşturulacağı bir Azure aboneliği seçin.

   2. Kaynak grubu için, ad alanının yaşayacağı mevcut bir kaynak grubunu seçin veya yeni bir tane oluşturun.

   3. Ad alanı için bir ad girin. Ad alanı adı aşağıdaki adlandırma kurallarına uymalıdır:

      • Adın Azure genelinde benzersiz olması gerekir. Adın kullanılabilirliği sistem tarafından hemen denetlenir.
      • Ad uzunluğu en az 6 ve en fazla 50 karakterdir.
      • Ad yalnızca harf, sayı, kısa çizgi "-" içerebilir.
      • Ad bir harfle başlamalı ve bir harf veya numarayla bitmelidir.
      • Ad "-sb" veya "-mgmt" ile bitmiyor.

   4. Konum için ad alanınızın barındırılacağı bölgeyi seçin.

   5. Fiyatlandırma katmanı için ad alanı için fiyatlandırma katmanını (Temel, Standart veya Premium) seçin. Bu hızlı başlangıç için Standart'ı seçin.

      Önemli

      Konuları ve abonelikleri kullanmak istiyorsanız Standart veya Premium'u seçin. Konular/abonelikler Temel fiyatlandırma katmanında desteklenmez.

      Premium fiyatlandırma katmanını seçtiyseniz, mesajlaşma birimi sayısını belirtin. Premium katman, her iş yükünün yalıtılmış olarak çalışması için CPU ve bellek düzeyinde kaynak yalıtımı sağlar. Bu kaynak kapsayıcısı mesajlaşma birimi olarak adlandırılır. Premium ad alanında en az bir mesajlaşma birimi vardır. Her Service Bus Premium ad alanı için 1, 2, 4, 8 veya 16 mesajlaşma birimleri seçebilirsiniz. Daha fazla bilgi için bkz . Service Bus Premium Mesajlaşma.

   6. Sayfanın alt kısmındaki Gözden geçir ve oluştur'u seçin.

      

   7. Gözden geçir ve oluştur sayfasında ayarları gözden geçirin ve Oluştur'u seçin.

5. Kaynağın dağıtımı başarılı olduktan sonra dağıtım sayfasında Kaynağa git'i seçin.

   

6. Service Bus ad alanınızın giriş sayfasını görürsünüz.

   

Azure portalını kullanarak konu oluşturma

1. Service Bus Ad Alanı sayfasında, soldaki menüden Konular'ı seçin.

2. Araç çubuğunda + Konu'ya tıklayın.

3. Konu için bir ad girin. Diğer seçenekleri varsayılan değerlerinde bırakın.

4. Oluştur'u belirleyin.

   

Konuya abonelik oluşturma

1. Önceki bölümde oluşturduğunuz konuyu seçin.

   

2. Service Bus Konusu sayfasında araç çubuğunda + Abonelik'i seçin.

   

3. Abonelik oluştur sayfasında şu adımları izleyin:

   1. Aboneliğin adı olarak S1 girin.

   2. En fazla teslimat sayısı için 3 girin.

   3. Ardından, aboneliği oluşturmak için Oluştur'u seçin.

      

Azure'da uygulamanın kimliğini doğrulama

Bu hızlı başlangıçta Azure Service Bus'a bağlanmanın iki yolu gösterilir: parolasız ve bağlantı dizesi.

İlk seçenek, Service Bus ad alanına bağlanmak için Microsoft Entra Id ve rol tabanlı erişim denetiminde (RBAC) güvenlik sorumlunuzu nasıl kullanacağınızı gösterir. Kodunuzda, yapılandırma dosyasında veya Azure Key Vault gibi güvenli bir depolama alanında sabit kodlanmış bağlantı dizesi olması konusunda endişelenmeniz gerekmez.

İkinci seçenek, Service Bus ad alanına bağlanmak için bir bağlantı dizesi nasıl kullanacağınızı gösterir. Azure'da yeniyseniz bağlantı dizesi seçeneğini daha kolay takip edebilirsiniz. Gerçek dünyadaki uygulamalarda ve üretim ortamlarında parolasız seçeneği kullanmanızı öneririz. Daha fazla bilgi için bkz . Kimlik doğrulaması ve yetkilendirme. Ayrıca, genel bakış sayfasında parolasız kimlik doğrulaması hakkında daha fazla bilgi edinebilirsiniz.

Visual Studio'yu başlatma ve Azure'da oturum açma

Aşağıdaki adımları kullanarak service bus ad alanına erişim yetkisi vekleyebilirsiniz:

1. Visual Studio’yu başlatın. Başlarken penceresini görüyorsanız, sağ bölmedeki Kod olmadan devam et bağlantısını seçin.

2. Visual Studio'nun sağ üst kısmındaki Oturum aç düğmesini seçin.

   

3. Daha önce bir rol atadığınız Microsoft Entra hesabını kullanarak oturum açın.

   

Konuya ileti gönderme

Bu bölümde, Service Bus konusuna ileti göndermek için bir .NET konsol uygulamasının nasıl oluşturulacağı gösterilmektedir.

Konsol uygulaması oluşturma

1. Visual Studio'da Dosya -Yeni ->>Proje menüsü'ne tıklayın.
2. Yeni proje oluştur iletişim kutusunda aşağıdaki adımları uygulayın: Bu iletişim kutusunu görmüyorsanız, menüden Dosya'yı seçin, Yeni'yi ve ardından Proje'yi seçin.

   1. Programlama dili için C# öğesini seçin.

   2. Uygulamanın türü için Konsol'a tıklayın.

   3. Sonuçlar listesinden Konsol Uygulaması'nı seçin.

   4. Ardından İleri'yi seçin.

      

3. Proje adı olarak TopicSender, çözüm adı için ServiceBusTopicQuickStart girin ve İleri'yi seçin.
4. Ek bilgiler sayfasında Oluştur'u seçerek çözümü ve projeyi oluşturun.

NuGet paketlerini projeye ekleme

Konuya ileti göndermek için kod ekleme

1. Program.cs içeriğini aşağıdaki kodla değiştirin. Önemli adımlar, kod açıklamalarında ek bilgilerle birlikte bu bölümde özetlenmiştir.

   • Parolasız
   • Bağlantı Dizesi

   1. nesnesini kullanarak DefaultAzureCredential bir ServiceBusClient nesnesi oluşturur. DefaultAzureCredential Azure Service Bus'ta kimlik doğrulaması yapmak için Visual Studio oturum açma bilgilerinizi otomatik olarak bulur ve kullanır.
   2. Belirli Service Bus konusu için bir ServiceBusSender nesnesi oluşturmak üzere nesne üzerinde ServiceBusClient CreateSender yöntemini çağırır.
   3. ServiceBusSender.CreateMessageBatchAsync kullanarak bir ServiceBusMessageBatch nesnesi oluşturur.
   4. ServiceBusMessageBatch.TryAddMessage kullanarak toplu işleme ileti ekleyin.
   5. ServiceBusSender.SendMessagesAsync yöntemini kullanarak toplu iletileri Service Bus konusuna gönderir.

   Önemli

   Kod parçacığındaki yer tutucu değerlerini (<NAMESPACE-NAME> ve <TOPIC-NAME>) Service Bus ad alanınızın ve konu başlığınızın adlarıyla güncelleştirin.

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

2. Projeyi derleyin ve hata olmadığından emin olun.

3. Programı çalıştırın ve onay iletisini bekleyin.

   A batch of 3 messages has been published to the topic
   

   Önemli

   Çoğu durumda rol atamasının Azure'a yayılması bir veya iki dakika sürer. Nadir durumlarda, sekiz dakikaya kadar sürebilir. Kodunuzu ilk kez çalıştırdığınızda kimlik doğrulama hataları alıyorsanız, birkaç dakika bekleyin ve yeniden deneyin.

4. Azure portalında şu adımları izleyin:

   1. Service Bus ad alanınıza gidin.

   2. Genel Bakış sayfasındaki orta alt bölmede Konular sekmesine geçin ve Service Bus konusunu seçin. Aşağıdaki örnekte, şeklindedir mytopic.

      

   3. Service Bus Konusu sayfasında, alttaki Ölçümler bölümündeki İletiler grafiğinde, konu için üç gelen ileti olduğunu görebilirsiniz. Değeri görmüyorsanız, birkaç dakika bekleyin ve güncelleştirilmiş grafiği görmek için sayfayı yenileyin.

      

   4. Alt bölmede aboneliği seçin. Aşağıdaki örnekte S1'tir. Service Bus Aboneliği sayfasında Etkin ileti sayısını 3 olarak görürsünüz. Abonelik, konuya gönderdiğiniz üç iletiyi aldı, ancak henüz alıcı seçmedi.

      

Abonelikten ileti alma

Bu bölümde, abonelikten Service Bus konusuna ileti alan bir .NET konsol uygulaması oluşturacaksınız.

Alıcı için proje oluşturma

1. Çözüm Gezgini penceresinde ServiceBusTopicQuickStart çözümüne sağ tıklayın, Ekle'nin üzerine gelin ve Yeni Proje'yi seçin.
2. Konsol uygulaması'yı ve ardından İleri'yi seçin.
3. Proje adı için SubscriptionReceiver girin ve İleri'yi seçin.
4. Ek bilgiler sayfasında Oluştur'u seçin.
5. Çözüm Gezgini penceresinde SubscriptionReceiver'a sağ tıklayın ve Başlangıç Projesi Olarak Ayarla'yı seçin.

NuGet paketlerini projeye ekleme

Abonelikten ileti almak için kod ekleme

Bu bölümde, abonelikten iletileri almak için kod ekleyebilirsiniz.

1. öğesinin mevcut içeriğini Program.cs aşağıdaki özellikler ve yöntemlerle değiştirin:

   • Parolasız
   • Bağlantı Dizesi

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

2. Aşağıdaki kodu sonuna Program.csekleyin.

   • Parolasız
   • Bağlantı Dizesi

   • nesnesini kullanarak DefaultAzureCredential bir ServiceBusClient nesnesi oluşturur. DefaultAzureCredential Azure Service Bus'ta kimlik doğrulaması yapmak için Visual Studio oturum açma bilgilerinizi otomatik olarak bulur ve kullanır.
   • Belirtilen Service Bus konusu için bir ServiceBusProcessor nesnesi oluşturmak üzere nesnede CreateProcessor yöntemini ServiceBusClient çağırır.
   • Nesnenin ProcessMessageAsync ve ProcessErrorAsync olayları için işleyicileri ServiceBusProcessor belirtir.
   • nesnesinde StartProcessingAsync'i çağırarak iletileri işlemeye ServiceBusProcessor başlar.
   • Kullanıcı işlemi sonlandırmak için bir tuşa bastığında nesnesinde StopProcessingAsync'iServiceBusProcessor çağırır.

   Önemli

   Kod parçacığındaki yer tutucu değerlerini (<NAMESPACE-NAME>, <TOPIC-NAME>, <SUBSCRIPTION-NAME>) Service Bus ad alanınızın, konu başlığınızın ve aboneliğinizin adlarıyla güncelleştirin.

   Daha fazla bilgi için bkz. kod açıklamaları.

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

3. Aşağıdaki Program.cs gibi görünmelidir:

   • Parolasız
   • Bağlantı Dizesi

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

4. Projeyi derleyin ve hata olmadığından emin olun.

5. Alıcı uygulamasını çalıştırın. Alınan iletileri görmeniz gerekir. Alıcıyı ve uygulamayı durdurmak için herhangi bir tuşa basın.

   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
   

6. Portalı yeniden denetleyin.

   • Service Bus Konusu sayfasındaki İletiler grafiğinde üç gelen ileti ve üç giden ileti görürsünüz. Bu sayıları görmüyorsanız, birkaç dakika bekleyin ve güncelleştirilmiş grafiği görmek için sayfayı yenileyin.

     

   • Service Bus Aboneliği sayfasında Etkin ileti sayısını sıfır olarak görürsünüz. Bunun nedeni, bir alıcının bu abonelikten iletiler alıp iletileri tamamlamasıdır.

     

Sonraki adımlar

Aşağıdaki belgelere ve örneklere bakın:

• .NET için Azure Service Bus istemci kitaplığı - Benioku
• GitHub'da Azure Service Bus için .NET örnekleri
• .NET API başvurusu