伙计们,我想在Java API和NodeJS API之间建立一个消息队列.在阅读了几个使用示例之后aws-sdk,我不确定如何使服务观察队列.
例如,本文使用SQS与节点:接收消息示例代码告诉我使用sqs.receiveMessage()接收和sqs.deleteMessage()删除消息.
我不清楚的是,如何将其包装到一个连续运行的服务中,该服务不断地将消息从sqs队列中取出,将它们传递给模型,将它们存储在mongo中等等.
希望我的问题不完全模糊.我对Node的经验主要在于Express.js.
答案就像使用sqs-poller之类的东西一样简单吗？我如何在已经运行的NodeJS Express应用程序中实现相同的功能？很可能我应该调查SNS在消息传输方面没有任何延迟.
谢谢!