Azure Service Bus（二）在NET Core 控制台中如何操作 Service Bus Queue

一，引言

　　上一篇講到關於 Azure ServiceBus 的一些概念，講到 Azure Service Bus（服務總線），其實也叫 ”雲消息服務“，是微軟在Azure 上提供的一種 ”雲消息服務“，在應用和服務之間傳遞消息時，即使消息的接受着處於脫機狀態下，也不影響接收者在聯機后接收信息。消息采用二進制格式，可能包含 JSON、XML 或純文本。那么今天就帶着上一節內容來動手實踐一番，通過如何在 .NET Core 控制台應用程序和Azure Service Bus之間建立簡單的連接是如何將消息添加到 Service Bus Queue中的。

--------------------我是分割線--------------------

Azure ServiceBus 系列：

1，Azure Service Bus（一）入門簡介

2，Azure Service Bus（二）在NET Core 控制台中如何操作 Service Bus Queue

二，正文

1，Azure Portal 上創建 Service Bus Queue

登錄到Azure Portal 上后，點擊 “Create a resource”，搜索 “Service Bus”

點擊圖中的 “Create” 進行創建

輸入對應的參數列表

Resource group 選擇創建一個新的：“Web_Test_SB_RG”

Namespace name：“cnbateblogweb”

Loaction：“East Asia”

Pricing tier：“Basic”

點擊 “Review + create” 進行創建預校驗。校驗完成后，點擊 “Create” 進行創建

等待一會，等創建完成后，我們跳轉到剛剛創建好的 “cnbateblogweb” 的 Service Bus 中。

選擇 “Setting =》Shared access policies”，點擊選中的 “Policy” 查看 “Primary Connection String”

復制圖中的 “Primary Connection String”，並且保存到其他位置，稍后在實際操作Service Bus 的代碼中需要配置這個連接字符串。

最后一步，我們需要創建Service Bus Queue，選擇 “Entities =》Queues”，點擊 “+ Queue” 進行創建

需要輸入 Queue 的的相關參數

Name：“cnbateblogweb_queue”

Max queue size 選擇默認：“1GB”

Max delivery count （最大傳遞數）選擇默認：“10”

點擊 “Create” 進行創建

創建完成后，就可以看到當前列表的Queue的信息

 

 

2，NET Core 控制台應用添加對Service Bus Queue 的相應方法

2.1，創建 .NET Core 控制台應用，添加對 Azure.Message.ServiceBus 的引用 “Azure.Messaging.ServiceBus”

使用程序包管理控制台進行安裝

Install-Package Azure.Messaging.ServiceBus -Version 7.0.0

2.2，獲取 ServiceBus Client

由於ServiceBusClient 實現了 IAsyncDisposable，因此我們 await using 來創建 ServiceBusClient 對象

await using var queueClient = new ServiceBusClient(Appsettings.app("ServiceBus", "PrimaryConnectionString"));

發送信息到Queue

// create the sender
ServiceBusSender sender = queueClient.CreateSender(Appsettings.app("ServiceBus", "QueueName"));
string messageBody = JsonSerializer.Serialize(msg);
// create a message that we can send. UTF-8 encoding is used when providing a string.
ServiceBusMessage message = new ServiceBusMessage(messageBody);

// send the message
await sender.SendMessageAsync(message);
Console.WriteLine($"Sending message: {messageBody} success");

接收信息

// create a receiver that we can use to receive the message
ServiceBusReceiver receiver = queueClient.CreateReceiver(Appsettings.app("ServiceBus", "QueueName"));

// the received message is a different type as it contains some service set properties
ServiceBusReceivedMessage receivedMessage = await receiver.ReceiveMessageAsync();

// get the message body as a string
string body = receivedMessage.Body.ToString();
Console.WriteLine(body);

完成信息並且從當前 Queue 中刪除信息

// create a receiver that we can use to receive the message
ServiceBusReceiver receiver = queueClient.CreateReceiver(Appsettings.app("ServiceBus", "QueueName"));
ServiceBusReceivedMessage peekedMessage = await receiver.ReceiveMessageAsync();

await receiver.CompleteMessageAsync(peekedMessage);

 查看信息（PeekMessage）-----獲取下一個活動的ServiceBusReceivedMessage，而不更改接收者或消息源的狀態。

// create a receiver that we can use to receive the message
ServiceBusReceiver receiver = queueClient.CreateReceiver(Appsettings.app("ServiceBus", "QueueName"));
ServiceBusReceivedMessage peekedMessage = await receiver.PeekMessageAsync();

// get the message body as a string
string body = peekedMessage.Body.ToString();
Console.WriteLine(body);

配置文件 appseting.json

{
  "ServiceBus": {
    "PrimaryConnectionString": "Endpoint=sb://cnbateblogweb.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=ZEJqhFZ3XXXSSXv1Frr61Zad0M8a4dh9WFaWXTGzxSseIw=",
    "QueueName": "CNBATEBLOGWEB_QUEUE"
  }
}

完整代碼請查看文章底部的代碼庫地址

3，測試-----發送信息到Service Bus Queue，並且獲取 Queue 信息

F5運行，可以看到控制台打印出的日志數據，成功將數據寫入到Service Bus Queue 中

同時，我們登錄到Azure Portal中，查看Service Bus Queue 中有沒有寫入的數據

選擇 “Entities =》Queues”，點擊 “cnbateblogweb_queue” 進入Service Bus Queue 中

可以看到概述頁面顯示 “Message Count” 計數為 1，以及寫入了1條數據

點擊 “Setting = 》Service Bus Explorer（preview）” ，切換 “Peek” 頁，點擊 “Peek”進行查看具體的 message 信息

快速查看消息以查看 “cnbateblogweb_queue”的快照

提示成功查看信息，並且在頁面上顯示出 message 信息，點擊當前信息查看具體信息內容

可以看到消息體中正是我們剛剛發送的內容

ok，接下來關於接收信息，完成信息，查看信息我就不一一演示了，大家可以自行下載代碼進行測試。

bingo，*★,°*:.☆(￣▽￣)/$:*.°★* 。🐱‍🏍🐱‍🏍🐱‍🏍🐱‍🏍

三，結尾

　　OK，今天的分享到此結束，同時實踐操作在Azure Portal 上創建Service Bus Queue，並且通過代碼實現Service Bus Queue 的發送，接收等操作，本文所分享的內容也存在着很多我自己的一些理解，有理解不到位的，還包含，並且指出不足之處！！！！！*★,°*:.☆(￣▽￣)/$:*.°★* 。

參考資料：服務總線消息傳遞：https://docs.microsoft.com/zh-cn/azure/service-bus-messaging/

github：https://github.com/yunqian44/Azure.ServiceBus.git

作者：Allen 

版權：轉載請在文章明顯位置注明作者及出處。如發現錯誤，歡迎批評指正。