当前位置：文江博客话题详情

如何让nodejs服务器监听AWS SQS？

发布于 2024-10-15 08:54:56 字数 249 浏览 1 评论 0原文

在详细解释这个问题之前，我先告诉大家我目前的做法。

我有一个运行 setInterval() 的 js 脚本。在每个时间间隔，我都会调用 SQS 从队列中获取消息。如果有消息，我会处理它。
它无限运行，直到我终止该进程。

我之前也构建过一个节点服务器（使用nodejs.org上的示例）。

所以，我想知道的是，有没有一种方法可以检测 SQS 中是否有新消息，然后触发一个事件并处理该消息，而不是让 setInterval 无限运行？

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

挽袖吟 2024-10-22 08:54:56

这个问题已经有两年多了..但是有一个比改变轮询间隔更好的方法。而是将队列的接收消息等待时间设置为最大值 20 秒。然后你可以进行连续轮询，但在队列为空时每分钟只会发出 3 个请求。当队列中有数据时，将立即响应。

回复收藏 0 原文

吃不饱 2024-10-22 08:54:56

不可以。您必须向 SQS 请求消息。

如果您确实需要推送通知，请查看 SNS。如果您希望在将消息添加到队列后向服务器提示轮询 SQS，则 SNS 效果很好。

回复收藏 0 原文

櫻之舞 2024-10-22 08:54:56

您可以使用 SQS 长轮询来实现此目的。长轮询允许 Amazon SQS 等到队列中有可用消息后再发送响应，从而减少空响应的数量。这也将显着降低 SQS 的成本。

为了让这一切变得简单，有一个名为 sqs-consumer 的优秀库。它允许您定义一个接收 SQS 消息的函数，并在处理消息时调用回调：

const Consumer = require('sqs-consumer');

const app = Consumer.create({
  queueUrl: 'https://sqs.eu-west-1.amazonaws.com/account-id/queue-name',
  handleMessage: (message, done) => {
    // do some work with `message`
    done();
  }
});

app.on('error', (err) => {
  console.log(err.message);
});

app.start();

在幕后，它已经利用了上述的长轮询技术。

You can use SQS Long Polling to achieve this. Long polling reduces the number of empty responses by allowing Amazon SQS to wait until a message is available in the queue before sending a response. This will also significantly reduce the costs for SQS.

To make this easy there is an excellent library called sqs-consumer. It allows you to just define a function that receives an SQS message and call a callback when the message has been processed:

const Consumer = require('sqs-consumer');

const app = Consumer.create({
  queueUrl: 'https://sqs.eu-west-1.amazonaws.com/account-id/queue-name',
  handleMessage: (message, done) => {
    // do some work with `message`
    done();
  }
});

app.on('error', (err) => {
  console.log(err.message);
});

app.start();

Under the hood it already makes use of the long polling technique described above.

回复收藏 0 原文