Amazon SQS-轮询多线程上的多个队列

Question

我正在使用他们的SQS队列服务为Amazon SES设置反弹、投诉和送货通知。

文档建议在轮询多个SQS队列时，在多个线程上进行轮询。使用长轮询时尤其如此，因为长轮询一个线程上的多个队列可能会导致轮询队列延迟来自不同队列的新消息。

因此，如果我想在我的ASP.NET MVC应用程序中轮询3个SQS队列，我是否应该像下面这样生成裸体线程：

 Thread bouncesThread = new Thread(() => 
 {
      IAmazonSQS sqsClient = AWSClientFactory.CreateAmazonSQSClient(RegionEndpoint.USWest2);
      while(true) 
      {
          //this will long-poll
          ReceiveMessageResponse receiveMessageResponse = sqsClient.ReceiveMessage(bouncesQueueRequest);

          ProcessQueuedBounce(receiveMessageResponse);
      }
 });

 bouncesThread.SetApartmentState(ApartmentState.STA);
 bouncesThread.Start();

或者是否有更好的方法来实现这一点，因为这是一个长时间运行的进程，并且应该在应用程序的长度内运行？是否应该使用iRegisteredObject？

推荐的方法是什么？

Answer 1

这样做的“推荐”方法将根据您的用例和处理消息的瓶颈而有所不同。根据队列拆分为线程是防止SQS_QueueA被空SQS_QUEUEB阻塞的一个很好的开始。

您可能还希望：

1. 为特定队列添加更多线程。例如，如果您有一个特别忙的sqs队列，您可能有多个线程从它接收消息。如果您对SQS有较高的延迟，这将是非常有益的。
2. 将接收消息与处理消息分开-拥有一个单独的threadsafe队列用于保存ReceiveMessageResponse对象，然后拥有一个线程（或一组线程）专门负责处理该队列的结果。

结合以上内容，您可以根据哪一个是瓶颈分别扩展SQS轮询和结果处理。

如果您的线程正在做非常相似的事情（在本例中，轮询SQS队列并处理消息），那么您可能可以在这些线程之间共享部分或全部代码，将差异作为要传入的参数。