Azure Event Hub 技術研究系列2-發送事件到Event Hub

上篇博文中，我們介紹了Azure Event Hub的一些基本概念和架構：

本篇文章中，我們繼續深入研究，了解Azure Event Hub的創建、編程SDK，實現將事件發送到雲端的Azure Event Hub。

一、Azure Portal中創建Event Hub

創建一個新的Event Hub：

將連接字元串拷貝出來，備用。

二、通過Event Hub的SDK將事件發送到Event Hub

新建一個Console工程：EventHubSend

添加Nuget：

Microsoft.Azure.EventHubs

添加關鍵引用：

using Microsoft.Azure.EventHubs;
using System.Text;
using System.Threading.Tasks;

添加常量作為事件中心連接字元串和實體路徑（單個事件中心名稱）

private static EventHubClient eventHubClient;
private const string EhConnectionString = "{Event Hubs connection string}"; //第一步拷貝的連接字元串
private const string EhEntityPath = "{Event Hub path/name}"; //

MyEventHub

新加MainAsync函數

private static async Task MainAsync(string[] args)
{
var connectionStringBuilder = new EventHubsConnectionStringBuilder(EhConnectionString)
{
EntityPath = EhEntityPath
};

eventHubClient

= EventHubClient.CreateFromConnectionString(connectionStringBuilder.ToString);

await

SendEvents

將100個事件消息發送到EventHub方法：SendEvents

///

/// 個數 ///
private static async Task SendEvents(int count)
{
for (var i = 0; i < count; i++) { try { var eventEntity = $"Event {i}"; Console.WriteLine($"Sending Event: {eventEntity}"); await eventHubClient.SendAsync(new EventData(Encoding.UTF8.GetBytes(eventEntity))); } catch (Exception exception) { Console.WriteLine($"{DateTime.Now} > Exception: {exception.Message}");
}

await Task.Delay(10);
}

Console.WriteLine($"{count} messages sent.");
}

在Main函數中添加：

static void Main(string[] args)

{

MainAsync(args).GetAwaiter.GetResult;

}

Run：

發現錯誤了：The messaging entity "sb://myeventhubtest.servicebus.chinacloudapi.cn/MyEventHub" could not be found.

MyEventHub這個是我們在代碼中指定的。

private const string EhEntityPath = "MyEventHub"; //MyEventHub

這個是否需要在Azure Portal中提前創建好？

再次Run：

這次可以了。

周國慶

2017/5/17

喜歡這篇文章嗎？立刻分享出去讓更多人知道吧！