如何使用Spring AWS Messaging为FIFO SQS设置消息延迟？

报错原因 #

FIFO类型的SQS队列不支持在发送单个消息时使用DelaySeconds参数（对应你代码里的SQS_DELAY_HEADER），这个参数仅对标准队列有效，因此会触发参数无效的报错。

解决方案 #

根据AWS SQS官方文档，FIFO队列的延迟需求可以通过以下两种方式实现：

1. 队列级全局延迟 #

在创建FIFO队列时设置默认延迟秒数，之后所有发送到该队列的消息都会自动应用这个延迟，无需在发送消息时额外指定。

• 操作方式：可通过AWS控制台、CloudFormation模板或AWS SDK创建队列时配置DelaySeconds参数（取值范围0-900秒）；已创建的队列也可在AWS控制台中修改该属性。

2. 单消息定时投递（支持自定义延迟） #

如果需要为不同消息设置不同的延迟时间，可使用FIFO队列支持的定时投递功能：通过指定消息的计划投递时间戳，让消息在指定时间之后变为可见。

修改你的代码，将SQS_DELAY_HEADER替换为SQS_SCHEDULED_DELIVERY_TIMESTAMP_HEADER，传入延迟后的时间戳（单位：毫秒）即可：

sqsTemplate.convertAndSend(
    "myqueue.fifo",
    myObject,
    Map.of(
        SQS_GROUP_ID_HEADER, id,
        SQS_DEDUPLICATION_ID_HEADER, UUID.randomUUID().toString(),
        SQS_SCHEDULED_DELIVERY_TIMESTAMP_HEADER, System.currentTimeMillis() + 1000 // 延迟1秒
    )
);

注意：计划投递时间戳必须是当前时间之后的时间，且最大延迟不可超过15分钟（900秒）。

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