如何在ASP.NET Core应用程序中持续收听Pub/Sub消息？

Question

我想实现一个ASP.NET核心API，它不响应HTTP请求，但在启动时开始监听Google Cloud Pub/Sub消息，并且在其整个生命周期中一直保持无限期地监听。

使用官方Pub/Sub SDK实现此功能的首选方式是什么？

我能想到的方法有两种：

方法1：只需使用一个SimpleSubscriber，并在Startup.Configure开始听消息：

public void Configure(IApplicationBuilder app) 
{ 
    var simpleSubscriber = await SimpleSubscriber.CreateAsync(subscriptionName); 
    var receivedMessages = new List<PubsubMessage>(); 

    simpleSubscriber.StartAsync((msg, cancellationToken) => 
    { 
     // Process the message here. 

     return Task.FromResult(SimpleSubscriber.Reply.Ack); 
    }); 

    ... 
} 

方法2：专门使用一个库创建用于定期运行作业，例如Quartz，Hangfire或FluentScheduler，并且每次触发作业时，都会使用SubscriberClient来提取新消息。

哪一个是首选方法？第一个似乎更简单，但我不确定它是否真的可靠。

Answer 1

第一种方法肯定是如何打算使用它。

但是，看到该文档为StartAsync：

开始接收邮件。当 StopAsync(CancellationToken)被调用时返回的Task完成，或者发生不可恢复的 故障。此方法不能被称为不止一次每 SimpleSubscriber实例。

所以你确实需要处理意外StartAsync关闭不可恢复的错误。最简单的做法是使用外部循环，但考虑到这些错误被认为是不可恢复的，这可能与调用需要在成功之前进行更改有关。

的代码可能是这样的：

while (true) 
{ 
    // Each SimpleSubscriber instance must only be used once. 
    var simpleSubscriber = await SimpleSubscriber.CreateAsync(subscriptionName); 
    try 
    { 
     await simpleSubscriber.StartAsync((msg, cancellationToken) => 
     { 
      // Process the message here. 
      return Task.FromResult(SimpleSubscriber.Reply.Ack); 
     }); 
    } 
    catch (Exception e) 
    { 
     // Handle the unrecoverable error somehow... 
    } 
} 

如果如预期这不起作用，请let us know。