amazon-web-services - 订阅 AWS SQS 消息

Question

我在 AWS SQS 队列中有大量消息。这些消息将被其他来源不断推送给它。这些消息被推送到队列的频率没有适当的动态。目前，我每秒都在轮询 SQS 并检查那里是否有可用的消息。有没有更好的方法来处理这个问题，比如从 SQS 或 SNS 接收一些消息可用的通知，以便我只在需要时请求 SQS 而不是不断轮询？

Answer 1

做你想做的事情的方法是使用长轮询——而不是每秒不断地轮询，你打开一个保持打开状态的请求，直到它超时或消息进入队列。查看 ReceiveMessageRequest 的文档

ReceiveMessageRequest req = new ReceiveMessageRequest()
    .withWaitTimeSeconds(Integer.valueOf(20));    // set long poll timeout to 20 sec
// set other properties on the request as well

ReceiveMessageResult result = amazonSQS.receiveMessage(req);

一个常见的使用模式是让后台线程运行长轮询并将结果推送到内部队列(例如 LinkedBlockingQueue 或 ExecutorService )以供工作线程读取。

PS。不要忘记调用 deleteMessage 一旦你处理完结果，你就不会再次收到它。