AWS SQS如何仅针对特定自定义异常触发消息重试？

你的核心需求是让SQS消息仅在抛出MyCustomException时触发重试，其他运行时异常直接忽略（不重试）。当前代码的问题在于，任何未捕获的异常都会导致消息不被删除，进而触发重试。可以通过捕获并处理非目标异常的方式实现需求，修改后的代码如下：

@SqsListener(value = "/MyQueueURL", deletionPolicy = SqsMessageDeletionPolicy.ON_SUCCESS )
public void getMessageFromSqs(MyMessage message) {
    log.info("message: {}", message);

    try {
        // 业务逻辑放在try块内
        if(somecondition) {
            throw new MyCustomException("Retry it"); // 仅这个异常会触发重试
        }
        
        log.info("Success");
    } catch (MyCustomException e) {
        // 直接抛出自定义异常，让SQS感知到处理失败
        throw e;
    } catch (Exception e) {
        // 捕获所有其他异常，记录日志但不抛出
        log.warn("处理消息时遇到非重试异常，忽略: {}", e.getMessage(), e);
        // 这里不抛出异常，方法会正常结束，触发消息删除
    }
}

逻辑说明 #

• 用try-catch块包裹核心业务逻辑，精准控制异常流向
• 遇到MyCustomException时直接抛出，此时方法异常终止，SQS会保留消息（因为deletionPolicy = ON_SUCCESS），按照队列的重试规则（可见性超时、最大重试次数）进行重试
• 其他所有异常都被捕获并记录日志，方法正常执行完毕，SQS会自动删除消息，不会触发重试

额外注意事项 #

• 确保你的SQS队列配置了合理的可见性超时：避免消息在重试期间被其他消费者重复获取
• 建议配置死信队列（DLQ）：当消息重试达到最大次数后，自动转移到死信队列，避免无限循环占用资源

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