Java AWS SDK v1拦截SQS SendMessageRequest添加消息属性时MD5哈希异常的解决方案咨询

我之前也碰到过这个棘手的问题——AWS SDK v1会提前计算消息属性的MD5哈希并缓存，直接修改originalRequestObject会导致缓存的哈希和实际内容不一致，触发校验失败。下面给你几个更优的实现方式，按推荐优先级排序：

1. 直接在构造请求时添加自定义属性（最推荐） #

如果所有发送到SQS的消息都需要这个自定义属性，最直接的方式是封装一个请求创建工具，避免后续拦截修改带来的问题：

fun buildSqsSendRequest(queueUrl: String, messageBody: String): SendMessageRequest {
    val customAttribute = MessageAttributeValue()
        .withStringValue("123456789")
        .withDataType("String") // 注意：必须指定数据类型，否则SDK可能报错
    
    return SendMessageRequest(queueUrl, messageBody)
        .withMessageAttributes(mapOf("my-custom-attribute" to customAttribute))
}

使用时直接调用这个方法创建请求，无需任何拦截器，从根源上避免MD5冲突问题。

2. 克隆请求对象后修改（适合必须用拦截器的场景） #

如果必须通过拦截器统一处理（比如属性值需要动态获取，或者无法修改所有请求创建逻辑），不要直接修改原请求对象，而是克隆一个副本修改后替换掉原对象，这样SDK会重新计算MD5哈希：

class CustomMessagesAttributesRequestHandler : RequestHandler2() {
    override fun beforeRequest(request: Request<*>) {
        val originalRequest = request.originalRequestObject
        if (originalRequest is SendMessageRequest) {
            // 克隆原请求，避免修改原对象破坏已计算的MD5
            val updatedRequest = originalRequest.clone()
            
            val customAttribute = MessageAttributeValue()
                .withStringValue("123456789")
                .withDataType("String")
            updatedRequest.messageAttributes["my-custom-attribute"] = customAttribute
            
            // 替换request中的原始请求对象，让SDK重新处理
            request.setOriginalRequestObject(updatedRequest)
        }
    }
}

这个方法的核心是利用SendMessageRequest的clone()方法创建副本，修改副本后替换原对象，SDK会重新执行包括MD5计算在内的所有预处理流程，不会触发哈希不匹配的异常。

3. 手动触发MD5重新计算（不推荐，依赖内部实现） #

如果你坚持要修改原请求对象，可以手动调用SDK内部的MD5处理类重新计算哈希，但这个方法依赖SDK的内部实现，不同版本可能有变化，存在兼容性风险：

class CustomMessagesAttributesRequestHandler : RequestHandler2() {
    override fun beforeRequest(request: Request<*>) {
        val originalRequest = request.originalRequestObject
        if (originalRequest is SendMessageRequest) {
            val customAttribute = MessageAttributeValue()
                .withStringValue("123456789")
                .withDataType("String")
            originalRequest.messageAttributes["my-custom-attribute"] = customAttribute
            
            // 手动调用内部MD5校验处理器重新计算哈希
            val md5Handler = SqsMd5ChecksumHandler()
            try {
                md5Handler.beforeRequest(request)
            } catch (e: Exception) {
                // 处理可能的异常，比如类找不到、方法签名变化等
                e.printStackTrace()
            }
        }
    }
}

注意：SqsMd5ChecksumHandler是AWS SDK内部的包私有类，未来版本可能会被修改或移除，所以除非万不得已，不建议使用这个方案。

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