用于 .NET 的 Azure 事件中心库

概述

Azure 事件中心是高度可缩放的数据流式处理平台和事件引入服务。

若要详细了解 Azure 事件中心,请阅读什么是事件中心?一文。 若要开始使用,请查看事件中心编程指南

客户端库

使用事件中心客户端可与事件中心来回发送和接收消息。

直接从 Visual Studio 包管理器控制台或使用 .NET Core CLI 安装 NuGet 包

Visual Studio 包管理器

Install-Package Microsoft.Azure.EventHubs
dotnet add package Microsoft.Azure.EventHubs

代码示例

以下代码创建事件中心客户端并将消息发送到中心。

EventHubsConnectionStringBuilder connectionStringBuilder = new EventHubsConnectionStringBuilder(eventHubConnectionString)
{
    EntityPath = eventHubEntityPath
};

EventHubClient eventHubClient = EventHubClient.CreateFromConnectionString(connectionStringBuilder.ToString());
string message = $"Message {i}";
Console.WriteLine($"Sending message: {message}");
await eventHubClient.SendAsync(new EventData(Encoding.UTF8.GetBytes(message)));

管理库

使用事件中心管理库可创建、更新和删除中心与使用者组。

直接从 Visual Studio 包管理器控制台或使用 .NET Core CLI 安装 NuGet 包

Visual Studio 包管理器

Install-Package Microsoft.Azure.Management.EventHub
dotnet add package Microsoft.Azure.Management.EventHub

代码示例

以下代码创建新的事件中心。

TokenCredentials creds = new TokenCredentials(token);
EventHubManagementClient ehClient = new EventHubManagementClient(creds)
{
    SubscriptionId = subscriptionId
};

EventHubCreateOrUpdateParameters ehParams = new EventHubCreateOrUpdateParameters()
{
    Location = location
};

Console.WriteLine("Creating Event Hub...");
await ehClient.EventHubs.CreateOrUpdateAsync(resourceGroupName, namespaceName, EventHubName, ehParams);
Console.WriteLine("Created Event Hub successfully.");

教程

示例

详细了解可在应用中使用的示例 .NET 代码