移动云存储上传文件

阿超

发布于 2022-08-16 11:09:27

7.7K00

代码可运行

文章被收录于专栏：快乐阿超快乐阿超

运行总次数：0

代码可运行

生命很快就过去了，一个时机从不会出现两次。必须当机立断，不然就永远别要。——罗曼·罗兰

首先打开官方文档

下载下方的开发包

期间我们可以去注册并配置，注意需要配置实名认证。。。

下面的步骤可以看快速入门

然后根据这篇博客把jar包引入maven项目

最后是代码

package com.ruben.utils;

import com.amazonaws.ClientConfiguration;
import com.amazonaws.auth.AWSCredentials;
import com.amazonaws.auth.BasicAWSCredentials;
import com.amazonaws.services.s3.AmazonS3Client;
import com.amazonaws.services.s3.model.CannedAccessControlList;
import com.amazonaws.services.s3.model.GeneratePresignedUrlRequest;
import com.amazonaws.services.s3.model.ObjectMetadata;
import org.springframework.web.multipart.MultipartFile;

import java.io.IOException;
import java.io.InputStream;
import java.net.URL;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.Random;
import java.util.UUID;

/**
 * @author <achao1441470436@gmail.com>
 * @className MoveyunUtils
 * @date 2021/3/2 0002 15:26
 * @description 移动云工具类
 */
public class MoveyunUtils {

    /**
     * 移动云上传文件
     *
     * @param fileName
     * @return filePath
     * @methodName upload
     * @date 2021/3/2 0002 16:07
     * @author <achao1441470436@gmail.com>
     */
    public static String upload(MultipartFile file, String fileName) throws IOException {
        InputStream inputStream = file.getInputStream();
        String filePath = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd")) + "/" + UUID.randomUUID() + "/" + fileName;
        ClientConfiguration opts = new ClientConfiguration();
        opts.setSignerOverride("S3SignerType");
        AWSCredentials credentials = new BasicAWSCredentials("<accessKey>", "<secretKey>");
        AmazonS3Client client = new AmazonS3Client(credentials, opts);
        client.setEndpoint("<hostName>");
        //设置为公共读
        client.setBucketAcl("<bucketName>", CannedAccessControlList.PublicRead);
        ObjectMetadata meta = new ObjectMetadata();
        meta.setContentLength(file.getSize());
        client.putObject("<bucketName>", filePath, inputStream, meta);
        client.setObjectAcl("<bucketName>", filePath, CannedAccessControlList.PublicRead);
        GeneratePresignedUrlRequest request = new GeneratePresignedUrlRequest("<bucketName>", filePath);
        URL url = client.generatePresignedUrl(request);
        filePath = url.getHost() + url.getPath();
        return filePath;
    }

}