SpringBoot完美配置阿里雲的文件上傳

新建一個config類

• AliyunOSS.java

@Configuration
@Data
public class AliyunOSS {
    private OSSClient ossClient;


    @Value("${images-roland.file.endpoint}")
    private String endpoint;

    @Value("${images-roland.file.keyid}")
    private String accessKeyId;

    @Value("${images-roland.file.keysecret}")
    private String secretAccessKey;

    @Value("${images-roland.file.filehost}")
    private String file_filehost;

    @Value("${images-roland.file.bucketname1}")
    private String bucketname1;

    @Bean("ossClients")
    public OSSClient ossClient(){
        return new OSSClient(endpoint,accessKeyId,secretAccessKey);
    }
}

然后在yml中配置你的阿里雲信息

images-roland:
  file:
    endpoint: oss-cn-shenzhen.aliyuncs.com
    keyid: ********
    keysecret: ********
    bucketname: roland
    filehost: images/
    show_image_host: https://***.oss-cn-shenzhen.aliyuncs.com/

然后你就可以在你的業務層使用AliyunOSS啦

@Autowired
AliyunOSS aliyunOSS;

個人使用的util類

import com.aliyun.oss.ClientException;
import com.aliyun.oss.OSSClient;
import com.aliyun.oss.OSSException;
import com.aliyun.oss.model.CannedAccessControlList;
import com.aliyun.oss.model.CreateBucketRequest;
import com.aliyun.oss.model.PutObjectRequest;
import com.aliyun.oss.model.PutObjectResult;
import org.manage.management.permission.config.ConstantProperties;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.io.File;
import java.io.FileInputStream;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.UUID;

/**
 * Created by lightClouds917
 * Date 2018/2/7
 * Description:aliyunOSSUtil
 */
@Slf4j
@Component
public class AliyunOSSUtil {


    private static OSSClient ossClients;

    @Autowired
    public AliyunOSSUtil(OSSClient ossClients) {
        AliyunOSSUtil.ossClients = ossClients;
    }

    public static String upload(File file){
        log.info("=========>OSS文件上傳開始："+file.getName());
//        System.out.println(ossClients);

        String bucketName=ConstantProperties.BUCKET_NAME1;
        String fileHost=ConstantProperties.FILE_HOST;

        SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");
        String dateStr = format.format(new Date());

        if(null == file){
            return "";
        }

        OSSClient ossClient = ossClients;
        System.out.println(ossClient);
        try {
            //容器不存在，就創建
            if(! ossClient.doesBucketExist(bucketName)){
                ossClient.createBucket(bucketName);
                CreateBucketRequest createBucketRequest = new CreateBucketRequest(bucketName);
                createBucketRequest.setCannedACL(CannedAccessControlList.PublicRead);
                ossClient.createBucket(createBucketRequest);
            }
            //創建文件路徑
            String fileUrl = fileHost+"/"+(dateStr + "/" + UUID.randomUUID().toString().replace("-","")+"-"+file.getName());
            //上傳文件
            PutObjectResult result = ossClient.putObject(new PutObjectRequest(bucketName, fileUrl, file));
            //設置權限 這里是公開讀
            ossClient.setBucketAcl(bucketName,CannedAccessControlList.PublicRead);
            if(null != result){
                log.info("==========>OSS文件上傳成功,OSS地址："+fileUrl);
                return fileUrl;
            }
        }catch (OSSException oe){
            log.error(oe.getMessage());

        }catch (ClientException ce){
            log.error(ce.getMessage());

        }finally {
            //關閉
//            ossClient.shutdown();
        }
        return null;
    }
    public static String uploads(File file){
        String bucketName=ConstantProperties.BUCKET_NAME1;
        String fileHost=ConstantProperties.FILE_HOST;

        SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");
        String dateStr = format.format(new Date());

        if(null == file){
            return null;
        }

//        OSSClient ossClient = ossClients;

        // 創建OSSClient實例。
        OSSClient ossClient = ossClients;
        String fileUrl = fileHost+"/"+(dateStr + "/" + UUID.randomUUID().toString().replace("-","")+"-"+file.getName());
        try {
            // 帶進度條的上傳。
            ossClient.putObject(new PutObjectRequest(bucketName, fileUrl, new FileInputStream(file)).
                    <PutObjectRequest>withProgressListener(new PutObjectProgressListener()));

        } catch (Exception e) {
            e.printStackTrace();
        }
        // 關閉OSSClient。
//        ossClient.shutdown();
        return null;
    }
}