使用C++调用SQS ReceiveMessage()无法获取后续消息的原因咨询

问题现象 #

首次调用ReceiveMessage()能成功获取一批消息，但后续调用仅返回空消息；只有在每次调用后删除已接收的消息，才能正常获取下一批。

原因解析 #

你对SQS消息in-flight状态的理解是对的，但问题核心在于队列中没有新的未被锁定的消息：

• SQS的ReceiveMessage()默认仅返回未被接收过或in-flight状态已过期的消息
• 首次获取消息后，这批消息会进入in-flight状态（默认可见性超时30秒），在超时时间内，所有请求都无法再次获取到它们
• 你的代码未对接收的消息做任何处理（删除或延长可见性），在超时结束前，队列里没有可被新请求获取的消息，所以后续调用返回空结果
• 而删除消息后，队列中未被处理的下一批消息就会被正常返回

代码调整方案 #

根据业务需求，你可以选择两种处理方式：

方式1：处理完成后删除消息（常规业务场景） #

添加消息删除逻辑，确保处理完成的消息从队列中移除，后续请求能获取新消息：

// 新增删除消息的函数
void delete_message(const Aws::String& receipt_handle) const
{
    Aws::SQS::Model::DeleteMessageRequest dm_req;
    dm_req.SetQueueUrl(queue_url_);
    dm_req.SetReceiptHandle(receipt_handle);
    
    auto dm_out = sqs_client_->DeleteMessage(dm_req);
    if (!dm_out.IsSuccess()) {
        // 可添加删除失败的日志或重试逻辑
    }
}

// 修改main函数中的处理逻辑
int main()
{
    AmazonSQSReceiver sqs_receiver(Global::queue_name);

    while (true)
    {
        Aws::Vector<Aws::SQS::Model::Message> messages = sqs_receiver.receive_message();
        
        for (const auto &message : messages)
        {
            const Aws::String &message_body = message.GetBody();
            std::cout << message_body << std::endl;
            // 处理完成后删除消息
            sqs_receiver.delete_message(message.GetReceiptHandle());
        }
    }
    
    return 0;
}

方式2：延长消息可见性超时（需重复处理场景） #

如果需要长时间处理消息，可延长in-flight状态的超时时间，避免消息在处理过程中被重新分发：

// 在receive_message中添加自定义可见性超时
Aws::Vector<Aws::SQS::Model::Message> receive_message() const
{
    Aws::SQS::Model::ReceiveMessageRequest rm_req;
    rm_req.SetQueueUrl(queue_url_);
    rm_req.SetMaxNumberOfMessages(10);
    rm_req.SetWaitTimeSeconds(20);
    // 设置可见性超时为5分钟（根据实际处理时长调整）
    rm_req.SetVisibilityTimeout(300);

    const Aws::SQS::Model::ReceiveMessageOutcome rm_out = sqs_client_->ReceiveMessage(rm_req);

    if (false == rm_out.IsSuccess())
    {
        throw;
    }

    Aws::Vector<Aws::SQS::Model::Message> messages = rm_out.GetResult().GetMessages();
    return messages;
}

补充说明 #

• 若未删除消息，in-flight状态的消息会在超时后自动回到队列，此时再次调用ReceiveMessage()就能重新获取到它们
• 队列默认可见性超时为30秒，可在队列配置中修改全局默认值，也可通过ReceiveMessageRequest的SetVisibilityTimeout()单次覆盖

内容的提问来源于stack exchange，提问作者Hayk Poghosyan