如果收到消息，AWS SQS Long poll是否会提前返回？

如何解决如果收到消息，AWS SQS Long poll是否会提前返回？

如果我使用SQS长轮询并将“ WaitTimeSeconds”设置为10秒，将“ MaxNumberOfMessages”设置为1，并且在0.1秒后将单个消息传递到队列，则对sqs.receiveMessage（）的调用将返回紧接在那一点，还是应该等到“ WaitTimeSeconds”的10秒过去才返回？

在我的测试中，直到经过“ WaitTimeSeconds”的整个持续时间之后，才返回对sqs.receiveMessage（）的调用。

代码如下：

// Load the AWS SDK for Node.js
var AWS = require("aws-sdk");

const fmReqQ = "https://sqs.ap-southeast-2.amazonaws.com/myactid/fmReqQ";
const fmRspQ = "https://sqs.ap-southeast-2.amazonaws.com/myactid/fmRspQ";

const SydneyRegion = "ap-southeast-2";

var credentials = new AWS.SharedIniFileCredentials({ profile: "myprofile" });
AWS.config.credentials = credentials;

// Set the region
AWS.config.update({ region: SydneyRegion });

// Create an SQS service object
var sqs = new AWS.SQS({ apiVersion: "2012-11-05" });

async function sendRequest() {
  var sendParams = {
    MessageBody: "Information of 12/11/2016.",QueueUrl: fmReqQ,};

  try {
    data = await sqs.sendMessage(sendParams).promise();
    console.log("Success,request MessageId: ",data.MessageId);
  } catch (err) {
    console.log("Error",err);
  }
}

async function doModelling() {
  console.time("modelling");
  await sendRequest();
  await receiveResponse();
  console.timeEnd("modelling");
}

async function receiveResponse() {
  var receiveParams = {
    AttributeNames: ["SentTimestamp"],MaxNumberOfMessages: 1,MessageAttributeNames: ["All"],QueueUrl: fmRspQ,WaitTimeSeconds: 1,};

  let data = null;
  try {
    data = await sqs.receiveMessage(receiveParams).promise();
    console.log("Success,response MessageId: ",data);
  } catch (err) {
    console.log("Error",err);
  }
}

doModelling();

当我设置“ WaitTimeSeconds：3”时，我得到输出：

Success,request MessageId:  e5079c2a-050f-4681-aa8c-77b05ac7da7f
Success,response MessageId:  {
  ResponseMetadata: { RequestId: '1b4d6a6b-eaa2-59ea-a2c3-3d9b6fadbb3f' }
}
modelling: 3.268s

当我设置“ WaitTimeSeconds：10”时，我得到输出：

Success,request MessageId:  bbf0a429-b2f7-46f2-b9dd-38833b0c462a
Success,response MessageId:  {
  ResponseMetadata: { RequestId: '64bded2d-5398-5ca2-86f8-baddd6d4300a' }
}
modelling: 10.324s

注意经过的持续时间如何与WaitTimeSeconds相匹配。

它从reading about AWS SQS long polling开始说，它长期轮询“尽快返回可用消息”。

我似乎并没有在消息“可用后立即看到”，而是注意到sqs.receiveMessage（）调用总是采用WaitTimeSeconds中设置的持续时间。

如您在示例代码中所见，我已将MaxNumberOfMessage设置为1。

解决方法

将ReceiveMessage()与长轮询一起使用将在队列中至少有一条消息时返回。

我不是Node用户，但是这是我测试的方式：

• 创建了Amazon SQS队列
• 在一个窗口中，我跑了：

aws sqs receive-message --queue-url https://sqs.ap-southeast-2.amazonaws.com/123/foo --visibility-timeout 1 --wait-time-seconds 10

• 然后，在另一个窗口中，我跑了：

aws sqs send-message --queue-url https://sqs.ap-southeast-2.amazonaws.com/123/foo --message-body bar

在我使用receive-message命令之后，send-message命令很快返回。

您的测试可能会受到“接收到”但标记为“不可见”的消息的影响，并且对于以后的测试而言，它们仍然不可见，因为您的代码未调用DeleteMessage()。为了避免这种情况，我特别声明了--visibility-timeout 1，它使消息立即重新出现在队列中以进行下一次测试。

请求的消息数（--max-number-of-messages）不会影响此结果。至少有一条消息可用时，它将返回。

,

我将“ WaitTimeSeconds”设置为0，似乎得到了现在的行为：

Success,request MessageId:  9f286e22-1a08-4532-88ba-06c88be3dbc3
Success,response MessageId:  {
  ResponseMetadata: { RequestId: '5c264e27-0788-5772-a990-19d78c8b2565' }
}
modelling: 307.884ms

,

我为“ WaitTimeSeconds”指定的值确定了sqs.receiveMessage（）调用的持续时间，因为队列中没有消息，因此sqs.receiveMessage（）调用将等待“ WaitTimeSeconds”指定的持续时间。