如何在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。