invalid header: x-amz-content-sha256 > 请问如何关闭 checksum 校验？

[miozus]

我用 amazon-s3-v2 (rustfs 图床)，想要达到 checksumValidationEnabled(false) 的效果，这样能上传文件成功，否则总是报错 invalid header: x-amz-content-sha256

@Configuration
public class S3Config {

    @Bean
    public S3Client s3Client(@Value("${oss.uri}") String uri,
                             @Value("${oss.access-key-id}") String accessKeyId,
                             @Value("${oss.secret-key}") String secretKey) {
        log.info("开始自动配置 S3Client，来自yml配置");
        return S3Client.builder()
                .endpointOverride(URI.create(uri))
                .region(Region.US_EAST_1)
                .credentialsProvider(StaticCredentialsProvider.create(
                        AwsBasicCredentials.create(accessKeyId, secretKey)
                ))
                .forcePathStyle(true)
                .serviceConfiguration(builder -> builder
                        .checksumValidationEnabled(false)  // 关键：禁用 checksum 校验
                )
                .build();
    }
}

使用 x-file-storage 写的接口很简洁，

    @Operation(summary = "文件上传（配置类）")
    @PostMapping("/upload4")
    @ResponseBody
    public R uploadFileCustomConfig(@RequestPart("file") MultipartFile file,
                                     @RequestParam(value = "key", required = false) String customKey) {
        FileInfo fileInfo = fileStorageService.of(file).upload();
        return R.ok().setData(fileInfo.getUrl());
    }

但存在问题，上述 S3Config 配置类未能覆盖 x-file-storage 默认配置 （checksumValidationEnabled(true)）

---

pom.xml

...
        <awssdk-s3.version>2.31.78</awssdk-s3.version>
        <x-file-storage.version>2.3.0</x-file-storage.version>
...

            <!-- 调用图床 rustfs -->
            <dependency>
                <groupId>software.amazon.awssdk</groupId>
                <artifactId>s3</artifactId>
                <version>${awssdk-s3.version}</version>
            </dependency>
            <!--x-file-storage相关依赖-->
            <dependency>
                <groupId>org.dromara.x-file-storage</groupId>
                <artifactId>x-file-storage-spring</artifactId>
                <version>${x-file-storage.version}</version>
            </dependency>
...

[chendanlin]

我也遇到了这个问题，现在通过自定义工厂类和修改源码解决了，我写的自定义工厂类应该有点多余了，修改源码应该就够了

https://x-file-storage.xuyanwu.cn/#/%E5%AD%98%E5%82%A8%E5%B9%B3%E5%8F%B0?id=%e8%87%aa%e5%ae%9a%e4%b9%89%e5%ad%98%e5%82%a8%e5%b9%b3%e5%8f%b0-client-%e5%b7%a5%e5%8e%82

@EnableFileStorage
public class XFileStorageAutoConfiguration {

    /**
     *
     *
     * 修复 S3 V2 [The provided 'x-amz-content-sha256' header does not match what was computed]报错
     * 关键词：校验和，checknum
     * @param properties
     * @return
     */
    @Bean
    public List<FileStorageClientFactory<?>> awsS3V2FileStorageClientFactory(SpringFileStorageProperties properties) {
        return properties.getAmazonS3V2().stream()
                .filter(SpringFileStorageProperties.SpringAmazonS3V2Config::getEnableStorage)
                .map(config -> new AmazonS3V2FileStorageClientFactory(config))
                .collect(Collectors.toList());
    }
}

package org.dromara.x.file.storage.core.platform;

import cn.hutool.core.util.StrUtil;
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;
import org.dromara.x.file.storage.core.FileStorageProperties.AmazonS3V2Config;
import software.amazon.awssdk.auth.credentials.AwsBasicCredentials;
import software.amazon.awssdk.auth.credentials.StaticCredentialsProvider;
import software.amazon.awssdk.core.checksums.RequestChecksumCalculation;
import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.s3.S3Client;
import software.amazon.awssdk.services.s3.S3ClientBuilder;
import software.amazon.awssdk.services.s3.presigner.S3Presigner;

import java.net.URI;

/**
 * Amazon S3 存储平台的 Client 工厂<br/>
 * 适用于AWS SDK for Java 2.x，根据 Amazon 公告，AWS SDK for Java 1.x 自 2024 年 7 月 31 日起将进入维护模式，并于 2025 年 12 月 31 日终止支持<br/>
 * 公告链接地址：<a href="https://aws.amazon.com/blogs/developer/the-aws-sdk-for-java-1-x-is-in-maintenance-mode-effective-july-31-2024/">The AWS SDK for Java 1.x is in maintenance mode, effective July 31, 2024</a>
 * @author zhangxin
 * @date 2024-12-08
 */
@Getter
@Setter
@NoArgsConstructor
public class AmazonS3V2FileStorageClientFactory
        implements FileStorageClientFactory<AmazonS3V2FileStorageClientFactory.AmazonS3V2Client> {
    private String platform;
    private String accessKey;
    private String secretKey;
    private String region;
    private String endPoint;
    private volatile AmazonS3V2Client client;

    public AmazonS3V2FileStorageClientFactory(AmazonS3V2Config config) {
        platform = config.getPlatform();
        accessKey = config.getAccessKey();
        secretKey = config.getSecretKey();
        region = config.getRegion();
        endPoint = config.getEndPoint();
    }

    @Override
    public AmazonS3V2Client getClient() {
        if (client == null) {
            synchronized (this) {
                if (client == null) {
                    client = new AmazonS3V2Client(accessKey, secretKey, region, endPoint);
                }
            }
        }
        return client;
    }

    @Override
    public void close() {
        if (client != null) {
            client.close();
            client = null;
        }
    }

    @Getter
    @Setter
    public static class AmazonS3V2Client implements AutoCloseable {
        private String accessKey;
        private String secretKey;
        private String region;
        private String endPoint;
        private volatile S3Client client;
        private volatile S3Presigner presigner;

        public AmazonS3V2Client(String accessKey, String secretKey, String region, String endPoint) {
            this.accessKey = accessKey;
            this.secretKey = secretKey;
            this.region = region;
            this.endPoint = endPoint;
        }

        public S3Client getClient() {
            if (client == null) {
                synchronized (this) {
                    if (client == null) {
                        S3ClientBuilder builder = S3Client.builder()
                                .credentialsProvider(StaticCredentialsProvider.create(
                                        AwsBasicCredentials.create(accessKey, secretKey)))
                                .region(Region.of(region));
                        if (StrUtil.isNotBlank(endPoint)) {
                            builder.endpointOverride(URI.create(endPoint));
                        }

                        // 主要修改，修改校验和策略
                        builder.requestChecksumCalculation(RequestChecksumCalculation.WHEN_REQUIRED);

                        client = builder.build();
                    }
                }
            }
            return client;
        }

        public S3Presigner getPresigner() {
            if (presigner == null) {
                synchronized (this) {
                    if (presigner == null) {
                        S3Presigner.Builder builder = S3Presigner.builder()
                                .credentialsProvider(StaticCredentialsProvider.create(
                                        AwsBasicCredentials.create(accessKey, secretKey)))
                                .region(Region.of(region));
                        if (StrUtil.isNotBlank(endPoint)) {
                            builder.endpointOverride(URI.create(endPoint));
                        }
                        presigner = builder.build();
                    }
                }
            }
            return presigner;
        }

        @Override
        public void close() {
            if (client != null) {
                client.close();
                client = null;
            }
            if (presigner != null) {
                presigner.close();
                presigner = null;
            }
        }
    }
}