javascript - AWS SQS 1队列2订阅者

Question

我遇到了问题。我正在尝试将单个 SQS 队列与两个长轮询 nodeJS 实例一起使用。我面临的问题是，当我将新消息放入队列时，两个实例都会立即提取相同的消息。有没有办法阻止这种行为？我的目标是最终拥有一个 NodeJS 处理场，其中每个实例将从队列中提取唯一的消息并执行处理。

下面是我的 SQS 监听器的代码:

console.log("Checking SQS Queue");
    return new Promise((resolve,reject) => {
        let sqs = new aws.SQS();
        let params = {
            AttributeNames: [
                "SentTimeStamp"
            ],
            MaxNumberOfMessages: 1,
            MessageAttributeNames: [
                "All"
            ],
            QueueUrl: SQS_URL,
            WaitTimeSeconds: 20,
            VisibilityTimeout: 0
        };
        sqs.receiveMessage(params, (err, data) => {
            if(err){
                console.log("Error: ",err);
                reject(err);
            } else if (data.Messages) {
                resolve(data);
            }
            resolve(data);
        });
    });

Answer 1

您需要设置更高的 VisibilityTimeout ，至少是处理该消息所花费的时间，那么当一个实例从SQS读取该消息后，直到VisibilityTimeout值为止，该消息对其他实例不可见。

请检查您在创建队列时为队列设置的 VisibilityTimeout。