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

如何解决Azure事件中心-如何在.Net Core WebAPI中实现使用者？

因此，我需要在WebAPI（.Net核心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中使用依赖注入来实现它？

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

解决方法

正如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，主机进程会为您处理。