JAVA 整合 亚马逊AWS S3（文件上传，文件下载等）

JAVA 整合 亚马逊AWS S3（文件上传，文件下载）

1.添加依赖

因为aws需要发送请求上传、下载等api，所以需要加上httpclient相关的依赖

            software.amazon.awssdk            s3            1.12.198                            software.amazon.awssdk            s3-transfer-manager            2.20.26                            software.amazon.awssdk            kms                            software.amazon.awssdk            s3control        

2.配置AWS S3相关的信息

package com.ezfos.common.s3.config;import lombok.Data;import org.springframework.boot.context.properties.ConfigurationProperties;import org.springframework.context.annotation.Configuration;@Data@Configuration@ConfigurationProperties(prefix = "aws.s3")public class AwzS3Config {    // 访问密钥    private String accessKey;    // 秘密密钥    private String secretKey;    // 存储桶名称    private String bucket;    // 区域    private String region;    // 前缀    private String prefix;}

3.创建一个S3Client对象

S3Client是Amazon Web Services（AWS）的SDK中的一个类，用于与Amazon S3服务进行交互。该方法使用了@Bean注解，表示它是一个Spring框架中的Bean定义，可以被其他组件注入使用。在方法内部，

首先通过AwsBasicCredentials.create()方法创建了一个AwsBasicCredentials对象，该对象包含了访问AWS所需的凭证信息，包括访问密钥和秘密密钥。

然后，使用S3Client.builder()方法创建了一个S3Client对象的构建器，并设置了以下配置：

• region(Region.of(awzS3Config.getRegion()))：设置AWS的区域信息，从awzS3Config对象中获取区域值。
• credentialsProvider(StaticCredentialsProvider.create(awsCreds))：设置凭证提供者，使用前面创建的AwsBasicCredentials对象作为凭证。

最后，调用build()方法构建并返回一个S3Client对象。

请注意，代码中有一行被注释掉的代码：endpointOverride(URI.create("https://xxxxx(桶名).s3.cn-northwest-1.amazonaws.com"))。这行代码用于指定自定义的S3端点URL，如果需要使用自定义的S3端点，可以取消注释并修改为正确的URL。

package com.ezfos.common.s3.config;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.stereotype.Component;import software.amazon.awssdk.auth.credentials.AwsBasicCredentials;import software.amazon.awssdk.auth.credentials.StaticCredentialsProvider;import software.amazon.awssdk.regions.Region;import software.amazon.awssdk.services.s3.S3Client;import javax.annotation.Resource;@Component@Configurationpublic class S3Config {    @Resource    private AwzS3Config awzS3Config;    @Bean    public S3Client s3client() {        AwsBasicCredentials awsCreds = AwsBasicCredentials.create(awzS3Config.getAccessKey(), awzS3Config.getSecretKey());        S3Client s3Client = S3Client.builder().                region(Region.of(awzS3Config.getRegion())).                credentialsProvider(StaticCredentialsProvider.create(awsCreds)).build();//                endpointOverride(URI.create("https://xxxxx(桶名).s3.cn-northwest-1.amazonaws.com")).build();        return s3Client;    }}

4.实现上传文件

 /**     * 上传文件     *     * @param file     * @param uploadKey     * @return     */    public boolean uploadToS3(MultipartFile file, String uploadKey) {           try {               if (file == null) {                   return false;            }            //添加文件夹dev（文件夹其实就是一个前缀）            String prefix = awzS3Config.getPrefix();            String folderKey = prefix.concat(uploadKey);            PutObjectRequest putObjectRequest = PutObjectRequest.builder().bucket(awzS3Config.getBucket()).key(folderKey).contentType(file.getContentType()).build();            s3Client.putObject(putObjectRequest, RequestBody.fromBytes(file.getBytes()));            return true;        } catch (S3Exception | IOException e) {               e.printStackTrace();            return false;        }    }

5.实现下载文件

    /**     * 下载文件     *     * @param response     * @param downloadKey     * @return     * @throws IOException     */    public HttpServletResponse downloadFromS3(HttpServletResponse response, String downloadKey, String fileName) throws IOException {           // S3上存储的key        String keyName = awzS3Config.getPrefix().concat(downloadKey);        GetObjectRequest objectRequest = GetObjectRequest                .builder()                .key(keyName)                .bucket(awzS3Config.getBucket())                .build();        InputStream inputStream = null;        InputStream fis = null;        try {               ResponseBytes objectBytes = s3Client.getObjectAsBytes(objectRequest);            inputStream = objectBytes.asInputStream();            // 取得文件的后缀名。            // 以流的形式下载文件。            fis = new BufferedInputStream(inputStream);            byte[] buffer = new byte[fis.available()];            fis.read(buffer);            fis.close();            // 清空response            response.reset();            // 设置response的Header            response.setCharacterEncoding("UTF-8");            //Content-Disposition的作用：告知浏览器以何种方式显示响应返回的文件，用浏览器打开还是以附件的形式下载到本地保存            //attachment表示以附件方式下载 inline表示在线打开 "Content-Disposition: inline; filename=文件名.mp3"            // filename表示文件的默认名称，因为网络传输只支持URL编码的相关支付，因此需要将文件名URL编码后进行传输,前端收到后需要反编码才能获取到真正的名称            response.addHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(fileName, "UTF-8"