你当前正在访问 Microsoft Azure Global Edition 技术文档网站。如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站，请访问 https://docs.azure.cn。

快速入门：从 Azure 事件网格命名空间主题发送和接收消息 (.NET)

项目
03/06/2024

在本快速入门中，你将执行以下步骤：

使用 Azure 门户创建事件网格命名空间。
使用 Azure 门户创建事件网格命名空间主题。
使用 Azure 门户创建事件订阅。
编写 .NET 控制台应用程序，向主题发送一组消息
编写 .NET 控制台应用程序，从主题接收这些消息。

注意

此快速入门提供了分步说明来实现将一批消息发送到事件网格命名空间主题然后接收这些消息的简单方案。有关 .NET 客户端库的概述，请参阅适用于 .NET 的 Azure 事件网格客户端库。有关更多示例，请参阅GitHub 上的事件网格 .NET 示例。

先决条件

如果你是首次使用该服务，请在使用本快速入门之前先参阅事件网格概述。

Azure 订阅。要使用 Azure 服务（包括 Azure 事件网格），需要订阅。如果没有现成的 Azure 帐户，可以注册免费试用版。
Visual Studio 2022。示例应用程序利用 C# 10 中引入的新功能。要使用最新语法，建议安装 .NET 6.0 或更高版本，并将语言版本设置为latest。如果使用 Visual Studio，Visual Studio 2022 以前的版本与生成 C# 10 项目时所需的工具将不兼容。

在 Azure 门户中创建命名空间

Azure 事件网格中的命名空间是一个或多个主题、客户端、客户端组、主题空间和权限绑定的逻辑容器。它提供唯一的命名空间，让你可以在同一 Azure 区域中使用多个资源。使用 Azure 事件网格命名空间，现在可以将相关资源分组到一起，并将其作为 Azure 订阅中的单个单元进行管理。

请按照后续部分所述创建、查看和管理 Azure 事件网格命名空间。

创建命名空间：

登录到 Azure 门户。
在“搜索框”中，输入“事件网格命名空间”，然后在结果中选择“事件网格命名空间”。
在“事件网格命名空间”页上的工具栏中选择“+ 创建”。
在“基本信息”页上执行以下步骤。
1. 选择要在其中创建命名空间的 Azure 订阅。
2. 选择现有的资源组，或创建资源组。
3. 输入命名空间的名称。
4. 选择要在其中创建命名空间的区域或位置。
5. 在页面底部选择“查看 + 创建”。
在“查看 + 创建”选项卡上，查看设置并选择“创建”。
在“部署已成功”页面上选择“转到资源”，以导航到你的命名空间。

创建命名空间主题

如果没有在“事件网格命名空间”页面上，请按照创建、查看和管理命名空间步骤查看要用于创建主题的命名空间。
在“事件网格命名空间”页面上，选择左侧菜单中“事件”部分中的“主题”选项。
在“主题”页面上，选择命令栏上的“+ 主题”按钮。
在“创建主题”页面中，键入要创建的主题的名称，然后选择“创建”。

创建事件订阅

如果位于 Azure 门户中事件网格命名空间的“主题”页上，请从主题列表中选择主题。如果位于“主题”页上，请按照创建、查看和管理命名空间主题来确定要用于创建事件订阅的主题。
在“事件网格命名空间主题”页上，在左侧菜单中的“实体”部分选择“订阅”选项。
在“订阅”页上，选择命令栏上的“+ 订阅”按钮。
在“基本信息”选项卡中，键入要创建的主题的名称，然后在页面底部选择“下一步: 筛选器”。
在“筛选器”选项卡中，添加要在订阅中筛选的事件类型的名称，并添加要在订阅中使用的上下文属性筛选器。然后，在页面底部选择“下一步: 其他功能”。
在“其他功能”选项卡中，可以指定事件保留期、最大传递计数、锁定持续时间和死信设置。
选择“创建”以创建事件订阅。

向 Azure 验证应用

本快速入门介绍了连接到 Azure 事件中心的方法：连接字符串。

本文档展示了如何使用连接字符串连接到事件网格命名空间。如果不熟悉 Azure，你可能会感觉连接字符串选项更易于使用。

新建事件网格命名空间时，会自动生成初始的主密钥和辅助密钥，向每个密钥授予对命名空间或主题的所有资产的完全控制权限。

客户端可以使用连接字符串连接到事件网格命名空间。要复制命名空间主题的访问密钥，请执行以下步骤：

在“事件网格命名空间”页面，选择“主题”。
选择需要访问的主题。
在“访问密钥”页面，选择“密钥 1 或密钥 2”旁边的复制按钮，将访问密钥复制到剪贴板供以后使用。将此值粘贴到记事本或其他某个临时位置。

启动 Visual Studio

可以使用以下步骤授权对事件网格命名空间的访问：

启动 Visual Studio。如果看到“入门”窗口，请在右窗格中选择“在不使用代码的情况下继续”链接。

将消息发送到主题

本部分介绍了如何创建向事件网格主题发送消息的 .NET 控制台应用程序。

创建控制台应用程序

在 Visual Studio 中，选择“文件”->“新建”->“项目”菜单。
在“创建新项目”对话框中执行以下步骤：如果看不到此对话框，请在菜单中选择“文件”，然后依次选择“新建”、“项目”。
1. 选择“C#”作为编程语言。
2. 选择“控制台”作为应用程序类型。
3. 从结果列表中选择“控制台应用”。
4. 然后，选择“下一步” 。
输入EventSender作为项目名称、EventGridQuickStart作为解决方案名称，然后选择“下一步”。
在“其他信息”页面，选择“创建”来创建解决方案和项目。

向项目添加 NuGet 包

在菜单中选择“工具”>“NuGet 包管理器”>“包管理器控制台”。

运行以下命令安装Azure.Messaging.EventGrid NuGet 包：

Install-Package Azure.Messaging.EventGrid -version 4.22.0-beta.1

添加将事件发送到命名空间主题的代码

将 Program.cs 的内容替换为以下代码。概述了重要步骤，并在代码注释中提供了其他信息。

重要

使用主题终结点、主题名称、主题密钥和主题的订阅名称更新代码片段中的占位符值（<ENDPOINT>、<TOPIC-NAME>、<TOPIC-ACCESS-KEY>、<TOPIC-SUBSCRIPTION-NAME>）。

using Azure.Messaging;
using Azure;
using Azure.Messaging.EventGrid.Namespaces;    

// TODO: Replace the <ENDPOINT> , <TOPIC-KEY> and <TOPIC-NAME> placeholder

var topicEndpoint = "<TOPIC-ENDPOINT>"; // Should be in the form: https://namespace01.eastus-1.eventgrid.azure.net. 
var topicKey = "<TOPIC-ACCESS-KEY>";
var topicName = "<TOPIC-NAME>";
var subscription = "<TOPIC-SUBSCRIPTION-NAME>";

// Construct the client using an Endpoint for a namespace as well as the access key
var client = new EventGridClient(new Uri(topicEndpoint), new AzureKeyCredential(topicKey));

// Publish a single CloudEvent using a custom TestModel for the event data.
var @ev = new CloudEvent("employee_source", "type", new TestModel { Name = "Bob", Age = 18 });
await client.PublishCloudEventAsync(topicName, ev);

// Publish a batch of CloudEvents.

await client.PublishCloudEventsAsync(
topicName,
new[] {
    new CloudEvent("employee_source", "type", new TestModel { Name = "Tom", Age = 55 }),
    new CloudEvent("employee_source", "type", new TestModel { Name = "Alice", Age = 25 })});

Console.WriteLine("Three events have been published to the topic. Press any key to end the application.");
Console.ReadKey();

public class TestModel
{
    public string Name { get; set; }
    public int Age { get; set; }
}

生成项目并确保没有错误。
运行程序并等待出现确认消息。
```
Three events have been published to the topic. Press any key to end the application.
```
重要

在大多数情况下，角色分配在 Azure 中传播需要一两分钟。在极少数情况下，最多可能需要 8 分钟。如果在首次运行代码时收到身份验证错误，请稍等片刻再试。
在 Azure 门户中按照以下步骤操作：
1. 导航到事件网格命名空间。
2. 在概述页面上，可以看到图表中发布到命名空间的事件数。

从主题拉取消息

在本部分中，你会创建 .NET 控制台应用程序，用于接收来自主题的消息。

创建项目以接收发布的 CloudEvents

在“解决方案资源管理器”窗口中，右击EventGridQuickStart解决方案，指向“添加”，然后选择“新建项目”。
依次选择“控制台应用程序”、“下一步” 。
输入EventReceiver作为“项目名称”，然后选择“创建”。
在“解决方案资源管理器”窗口中，右击EventReceiver并选择“设为启动项目”。

向项目添加 NuGet 包

在菜单中选择“工具”>“NuGet 包管理器”>“包管理器控制台”。
运行以下命令来安装 NuGet 包 Azure.Messaging.EventGrid。如果尚未设置，请选择“EventReceiver”作为默认项目。
```
Install-Package Azure.Messaging.EventGrid -version 4.22.0-beta.1
```

添加代码以从主题接收事件

在本部分中，你将添加从队列检索消息的代码。

在 Program 类中，添加以下代码：

重要

using Azure;
using Azure.Messaging;
using Azure.Messaging.EventGrid.Namespaces;

var topicEndpoint = "<TOPIC-ENDPOINT>"; // Should be in the form: https://namespace01.eastus-1.eventgrid.azure.net. 
var topicKey = "<TOPIC-ACCESS-KEY>";
var topicName = "<TOPIC-NAME>";
var subscription = "<TOPIC-SUBSCRIPTION-NAME>";

// Construct the client using an Endpoint for a namespace as well as the access key
var client = new EventGridClient(new Uri(topicEndpoint), new AzureKeyCredential(topicKey));

// Receive the published CloudEvents
ReceiveResult result = await client.ReceiveCloudEventsAsync(topicName, subscription, 3);

Console.WriteLine("Received Response");
Console.WriteLine("-----------------");

将以下方法追加到 Program 类的末尾。

// handle received messages. Define these variables on the top.

var toRelease = new List<string>();
var toAcknowledge = new List<string>();
var toReject = new List<string>();

// Iterate through the results and collect the lock tokens for events we want to release/acknowledge/result

foreach (ReceiveDetails detail in result.Value)
{
    CloudEvent @event = detail.Event;
    BrokerProperties brokerProperties = detail.BrokerProperties;
    Console.WriteLine(@event.Data.ToString());

    // The lock token is used to acknowledge, reject or release the event
    Console.WriteLine(brokerProperties.LockToken);
    Console.WriteLine();

    // If the event is from the "employee_source" and the name is "Bob", we are not able to acknowledge it yet, so we release it
    if (@event.Source == "employee_source" && @event.Data.ToObjectFromJson<TestModel>().Name == "Bob")
    {
        toRelease.Add(brokerProperties.LockToken);
    }
    // acknowledge other employee_source events
    else if (@event.Source == "employee_source")
    {
        toAcknowledge.Add(brokerProperties.LockToken);
    }
    // reject all other events
    else
    {
        toReject.Add(brokerProperties.LockToken);
    }
}

// Release/acknowledge/reject the events

if (toRelease.Count > 0)
{
    ReleaseResult releaseResult = await client.ReleaseCloudEventsAsync(topicName, subscription, new ReleaseOptions(toRelease));

    // Inspect the Release result
    Console.WriteLine($"Failed count for Release: {releaseResult.FailedLockTokens.Count}");
    foreach (FailedLockToken failedLockToken in releaseResult.FailedLockTokens)
    {
        Console.WriteLine($"Lock Token: {failedLockToken.LockToken}");
        Console.WriteLine($"Error Code: {failedLockToken.Error}");
        Console.WriteLine($"Error Description: {failedLockToken.ToString}");
    }

    Console.WriteLine($"Success count for Release: {releaseResult.SucceededLockTokens.Count}");
    foreach (string lockToken in releaseResult.SucceededLockTokens)
    {
        Console.WriteLine($"Lock Token: {lockToken}");
    }
    Console.WriteLine();
}

if (toAcknowledge.Count > 0)
{
    AcknowledgeResult acknowledgeResult = await client.AcknowledgeCloudEventsAsync(topicName, subscription, new AcknowledgeOptions(toAcknowledge));

    // Inspect the Acknowledge result
    Console.WriteLine($"Failed count for Acknowledge: {acknowledgeResult.FailedLockTokens.Count}");
    foreach (FailedLockToken failedLockToken in acknowledgeResult.FailedLockTokens)
    {
        Console.WriteLine($"Lock Token: {failedLockToken.LockToken}");
        Console.WriteLine($"Error Code: {failedLockToken.Error}");
        Console.WriteLine($"Error Description: {failedLockToken.ToString}");
    }

    Console.WriteLine($"Success count for Acknowledge: {acknowledgeResult.SucceededLockTokens.Count}");
    foreach (string lockToken in acknowledgeResult.SucceededLockTokens)
    {
        Console.WriteLine($"Lock Token: {lockToken}");
    }
    Console.WriteLine();
}

if (toReject.Count > 0)
{
    RejectResult rejectResult = await client.RejectCloudEventsAsync(topicName, subscription, new RejectOptions(toReject));

    // Inspect the Reject result
    Console.WriteLine($"Failed count for Reject: {rejectResult.FailedLockTokens.Count}");
    foreach (FailedLockToken failedLockToken in rejectResult.FailedLockTokens)
    {
        Console.WriteLine($"Lock Token: {failedLockToken.LockToken}");
        Console.WriteLine($"Error Code: {failedLockToken.Error}");
        Console.WriteLine($"Error Description: {failedLockToken.ToString}");
    }

    Console.WriteLine($"Success count for Reject: {rejectResult.SucceededLockTokens.Count}");
    foreach (string lockToken in rejectResult.SucceededLockTokens)
    {
        Console.WriteLine($"Lock Token: {lockToken}");
    }
    Console.WriteLine();
}

public class TestModel
{
    public string Name { get; set; }
    public int Age { get; set; }
}

清理资源

导航到 Azure 门户中的事件网格命名空间，然后在 Azure 门户上选择“删除”以删除事件网格命名空间及其中的主题。

请查看 ASP.NET API 参考。

Share via

快速入门：从 Azure 事件网格命名空间主题发送和接收消息 (.NET)

先决条件

在 Azure 门户中创建命名空间

创建命名空间主题

创建事件订阅

向 Azure 验证应用

启动 Visual Studio

将消息发送到主题

创建控制台应用程序

向项目添加 NuGet 包

添加将事件发送到命名空间主题的代码

从主题拉取消息

创建项目以接收发布的 CloudEvents

向项目添加 NuGet 包

添加代码以从主题接收事件

清理资源

反馈

反馈

其他资源

Share via

快速入门：从 Azure 事件网格命名空间主题发送和接收消息 (.NET)

先决条件

在 Azure 门户中创建命名空间

创建命名空间主题

创建事件订阅

向 Azure 验证应用

启动 Visual Studio

将消息发送到主题

创建控制台应用程序

向项目添加 NuGet 包

添加将事件发送到命名空间主题的代码

从主题拉取消息

创建项目以接收发布的 CloudEvents

向项目添加 NuGet 包

添加代码以从主题接收事件

清理资源

相关主题

反馈

反馈

其他资源