Azure Event Hub 技术研究系列2-发送事件到Event Hub

发布时间：2020-12-16 08:50:58 所属栏目：asp.Net 来源：网络整理

导读：上篇博文中，我们介绍了Azure Event Hub的一些基本概念和架构： Azure Event Hub 技术研究系列1-Event Hub入门篇本篇文章中，我们继续深入研究，了解Azure Event Hub的创建、编程SDK，实现将事件发送到云端的Azure Event Hub。一、Azure Portal中创建Event

上篇博文中，我们介绍了Azure Event Hub的一些基本概念和架构：

Azure Event Hub 技术研究系列1-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;
 System.Text;
using System.Threading.Tasks;

添加常量作为事件中心连接字符串和实体路径（单个事件中心名称）

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

新加MainAsync函数

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

            eventHubClient = EventHubClient.CreateFromConnectionString(connectionStringBuilder.ToString());

            await SendEvents(100);

            await eventHubClient.CloseAsync();

            Console.WriteLine(Press ENTER to exit.");
            Console.ReadLine();
        }

将100个事件消息发送到EventHub方法：SendEvents

        /// <summary>
        /// 创建100个消息事件，异步发送到EventHub
        </summary>
        <param name="count">个数</param>
        <returns></returns>
        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( 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这个是我们在代码中指定的。

MyEventHubMyEventHub

这个是否需要在Azure Portal中提前创建好？

再次Run：

这次可以了。

周国庆

2017/5/17

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!