Azure 事件中心 - 如何在 .Net Core WebAPI 中实现消费者？

Question

因此，我需要在 WebAPI (.Net core 3.1) 应用程序中实现消费者，阅读 Microsoft 文档并观看有关它的几个视频，我得到了这个解决方案。

这是 IServiceCollection 的扩展方法，我从 Startup.cs 调用它来实例化我的 Consumer（连接字符串和容器名称仅用于测试）：

    private static async Task AddPropostaEventHub(this IServiceCollection services)
    {
        const string eventHubName = "EVENT HUB NAME";
        const string ehubNamespaceConnectionString = "EVENT HUB CONNECTION STRING";
        const string blobContainerName = "BLOB CONTAINER NAME";
        const string blobStorageConnectionString = "BLOB CONNECTION STRING";

        string consumerGroup = EventHubConsumerClient.DefaultConsumerGroupName;
        BlobContainerClient storageClient = new BlobContainerClient(blobStorageConnectionString, blobContainerName);
        EventProcessorClient processor = new EventProcessorClient(storageClient, consumerGroup, ehubNamespaceConnectionString, eventHubName);

        processor.ProcessEventAsync += ProcessEvent.ProcessEventHandler;
        processor.ProcessErrorAsync += ProcessEvent.ProcessErrorHandler;

        await processor.StartProcessingAsync();
    }

ProcessorEventHandler 类：

public static class ProcessEvent
{
    public static async Task ProcessEventHandler(ProcessEventArgs eventArgs)
    {
        var result = Encoding.UTF8.GetString(eventArgs.Data.Body.ToArray());

        //DO STUFF
        await eventArgs.UpdateCheckpointAsync(eventArgs.CancellationToken);
    }

    public static Task ProcessErrorHandler(ProcessErrorEventArgs eventArgs)
    {
        //DO STUFF
        return Task.CompletedTask;
    }
}

这段代码可以运行，但我的问题是：这样实现它可以吗？如果消费者从不停止，会有问题吗？它可以阻止我的代码中的其他任务（或请求）吗？

有没有更好的方法在 .Net Core 中使用 Dependecy Injection 来实现它？

我找不到任何人在 WebApi 中实现的示例，这是有原因的吗？

Answer 1

正如 Jesse Squire 所提到的，WebAPI 不一定是正确的实施方法，但这主要取决于您的目标是什么。

如果您要创建的 API 还包括事件中心侦听器，则应在 IHostedService interface 下实现它。您现有的 AddPropostaEventHub() 方法位于接口的 StartAsync(CancellationToken cancellationToken) 中，这是 .NET Core 用来启动后台任务的方法。然后，在 Startup.cs 中，将处理程序注册为 services.AddHostedService<EventHubService>();。这可确保正确处理长时间运行的侦听器，而不会阻塞传入的 HTTP 请求。

如果您还没有涉及 API 或能够完全拆分流程，那么您应该考虑将其创建为控制台应用程序而不是托管服务，这进一步分离了 API 和事件侦听器的角色。

你没有提到你在哪里部署它，但如果你碰巧部署到 Azure 应用服务，你确实有一些选项可以将接收器从你的 API 中分离出来，在这种情况下，我肯定会建议你这样做所以。在 App Services 内部，有一个名为 WebJobs 的功能专门用于处理此类事情，而不会将其作为 API 的一部分。一个不错的选择是Functions。在这种情况下，您根本不必担心为 Event Hub 设置 DI，主机进程会为您处理。