Spring Boot 整合 AWS S3协议 OSS功能 支持 七牛、阿里、Minio等一切支持S3协议的云厂商_七牛云存储s3os协议头

参考项目: RuoYi-Vue-Plus

依赖引入

		<dependency>
		    <groupId>com.amazonaws</groupId>
		    <artifactId>aws-java-sdk-s3</artifactId>
		    <version>1.12.215</version>
		</dependency>
1
2
3
4
5

配置OSS客户端

配置文件

oss:
  # 对应云厂商的站点域名
  endpoint: XXX.XXX.XXX
  # 对应云厂商桶的绑定域名
  domain: XXX.XXX.XXX
  accessKey: XXXXXXX
  secretKey: XXXXXXX
  # 存储空间名/桶名
  bucketName: LionLi
  # 存储区域
  region: XXX
  # 是否https（Y=是,N=否）
  isHttps: N
1
2
3
4
5
6
7
8
9
10
11
12
13

配置文件映射类 OssProperties

/**
 * OSS对象存储 配置属性
 *
 * @author Lion Li
 */
@Data
@Component
@ConfigurationProperties(prefix = "oss")
public class OssProperties {

    /**
     * 访问站点
     */
    private String endpoint;

    /**
     * 自定义域名
     */
    private String domain;

    /**
     * ACCESS_KEY
     */
    private String accessKey;

    /**
     * SECRET_KEY
     */
    private String secretKey;

    /**
     * 存储空间名
     */
    private String bucketName;

    /**
     * 存储区域
     */
    private String region;

    /**
     * 是否https（Y=是,N=否）
     */
    private String isHttps;

}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46

客户端配置类 OssConfig

/**
 * S3 存储协议 所有兼容S3协议的云厂商均支持
 * 阿里云 腾讯云 七牛云 minio
 *
 * @author Lion Li
 */
@Configuration
public class OssConfig {

    @Bean
    public AmazonS3 createOssClient(OssProperties properties) {
        AwsClientBuilder.EndpointConfiguration endpointConfig =
            new AwsClientBuilder.EndpointConfiguration(properties.getEndpoint(), properties.getRegion());

        AWSCredentials credentials = new BasicAWSCredentials(properties.getAccessKey(), properties.getSecretKey());
        AWSCredentialsProvider credentialsProvider = new AWSStaticCredentialsProvider(credentials);
        ClientConfiguration clientConfig = new ClientConfiguration();
        if (OssConstant.IS_HTTPS.equals(properties.getIsHttps())) {
            clientConfig.setProtocol(Protocol.HTTPS);
        } else {
            clientConfig.setProtocol(Protocol.HTTP);
        }
        return AmazonS3Client.builder()
            .withEndpointConfiguration(endpointConfig)
            .withClientConfiguration(clientConfig)
            .withCredentials(credentialsProvider)
            .disableChunkedEncoding()
            .build();
    }
    
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

以下方法通用代码

    @Autowired
    private OssProperties properties;

    @Autowired
    private AmazonS3 client;
1
2
3
4
5

创建桶方法

String bucketName = properties.getBucketName();
if (client.doesBucketExistV2(bucketName)) {
    return;
}
CreateBucketRequest createBucketRequest = new CreateBucketRequest(bucketName);
createBucketRequest.setCannedAcl(CannedAccessControlList.PublicRead);
client.createBucket(createBucketRequest);
1
2
3
4
5
6
7

上传文件

try {
    ObjectMetadata metadata = new ObjectMetadata();
    metadata.setContentType(contentType);
    metadata.setContentLength(inputStream.available());
    client.putObject(new PutObjectRequest(properties.getBucketName(), "文件路径", inputStream, metadata));
} catch (Exception e) {
    e.printStackTrace();
}
1
2
3
4
5
6
7
8

删除文件

client.deleteObject(properties.getBucketName(), "文件路径");
1

更多使用越多协议文档

S3 协议文档