使用Java SDK从SQS FIFO队列消息中无法获取MessageGroupId

问题核心：默认情况下，SQS的ReceiveMessage API不会返回MessageGroupId这类系统属性，必须在接收请求中显式声明要获取该属性，否则message.attributes()里不会包含对应值。

修正后的接收代码 #

修改ReceiveMessageRequest的构建逻辑，添加attributeNames指定要获取的系统属性：

private static final SqsClient sqsClient = SqsClient.builder()
            .region(Region.US_WEST_2)
            .credentialsProvider(DefaultCredentialsProvider.create())
            .build();
private static final String queueUrl = "fifo_url";

ReceiveMessageRequest receiveMessageRequest = ReceiveMessageRequest.builder()
                    .queueUrl(queueUrl)
                    .maxNumberOfMessages(10)
                    .waitTimeSeconds(20)
                    // 显式指定要获取MessageGroupId系统属性
                    .attributeNames(MessageSystemAttributeName.MESSAGE_GROUP_ID)
                    .build();

ReceiveMessageResponse response = sqsClient.receiveMessage(receiveMessageRequest);
List<Message> messages = response.messages();
for (Message message : messages) {
    Map<MessageSystemAttributeName, String> systemAttributes = message.attributes();
    // 现在可正常获取MessageGroupId
    String messageGroupId = systemAttributes.get(MessageSystemAttributeName.MESSAGE_GROUP_ID);
}

关键说明 #

1. 系统属性与自定义属性的区别：

   • message.attributes()：存储SQS内置的系统属性（如MessageGroupId、MessageDeduplicationId、SentTimestamp等），仅当请求中指定要获取的系统属性时，才会返回对应值。
   • message.messageAttributes()：存储发送消息时自定义的业务属性，MessageGroupId不属于此类，因此从这里获取必然失败。

2. 额外确认项：

   • 发送消息时需通过SendMessageRequest.builder().messageGroupId("xxx")设置合法的分组ID。
   • 确认队列URL后缀为.fifo，确保是FIFO队列。

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