springboot使用阿里云oss实现文件上传

一、对象存储OSS

1、开通“对象存储OSS”服务

（1）申请阿里云账号

（2）实名认证

（3）开通“对象存储OSS”服务

（4）进入管理控制台

2、创建Bucket

3、创建AccessKey

阿里云帮助文档地址

https://help.aliyun.com/?spm=a2c4g.11186623.6.538.6cb923458Rfc7f

阿里云对象存储OSS地址

https://help.aliyun.com/document_detail/31883.html?spm=a2c4g.11186623.6.595.385114a0f8JyvT

阿里云javaSDK文件上传地址

https://help.aliyun.com/document_detail/32013.html?spm=a2c4g.11186623.6.934.5ce314a0xWEkf2

文件上传参照地址

https://help.aliyun.com/document_detail/84781.html?spm=a2c4g.11186623.6.935.59df14a0eK7bAr

使用SDK需要先安装，具体可以参照阿里云官方文档。

本例使用简单上传方式里的上传文件流方式。

pom文件依赖

<dependencies>
        <!-- 阿里云oss依赖 -->
        <dependency>
            <groupId>com.aliyun.oss</groupId>
            <artifactId>aliyun-sdk-oss</artifactId>
        </dependency>

        <!-- 日期工具栏依赖 -->
        <dependency>
            <groupId>joda-time</groupId>
            <artifactId>joda-time</artifactId>
        </dependency>
    </dependencies>

controller文件

package com.stu.oss.controller;

import com.stu.commonutils.ResultData;
import com.stu.oss.service.OssService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.CrossOrigin;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;

@RestController
@RequestMapping("/edu/fileoss")
@CrossOrigin
public class OssController {

    @Autowired
    private OssService ossService;
//上传头像的方法
    @PostMapping
    public ResultData uploadOssFile(MultipartFile file){

        //获取上传的文件

        String url = ossService.uploadFileAvatar(file);

        return ResultData.success().data("url",url);
    }
}

service接口

package com.stu.oss.service;

import org.springframework.web.multipart.MultipartFile;

public interface OssService {
    String uploadFileAvatar(MultipartFile file);
}

service实现类

endPoint,accessKeyId,accessKeySecret,bucketName的取值来源如下

 

package com.stu.oss.service.impl;

import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import com.stu.oss.service.OssService;
import com.stu.oss.utils.ConstantPropertiesUtil;
import org.joda.time.DateTime;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;

import java.io.IOException;
import java.io.InputStream;
import java.util.UUID;

@Service
public class OssServiceImpl implements OssService {
    @Override
    public String uploadFileAvatar(MultipartFile file) {
        //获取阿里云存储相关常量，以下值取自阿里云创建Bucket和AccessKey里的值

        String endPoint = ConstantPropertiesUtil.END_POINT;
        String accessKeyId = ConstantPropertiesUtil.KEY_ID;
        String accessKeySecret = ConstantPropertiesUtil.KEY_SECRET;
        String bucketName = ConstantPropertiesUtil.BUCKET_NAME;

        // 创建OSSClient实例。
        OSS ossClient = new OSSClientBuilder().build(endPoint, accessKeyId, accessKeySecret);

        // 填写本地文件的完整路径。如果未指定本地路径，则默认从示例程序所属项目对应本地路径中上传文件流。
        InputStream inputStream = null;
        try {
            //获取上传文件输入流
            inputStream = file.getInputStream();

            //调用oss的putObject方法实现上传
            //第一个参数 Bucket名称
            //第二个参数，上传到oss文件路径和文件名称   A/B/图片.jpg
            //第三个参数，上传文件输入流
//获取文件名称
            String fileName = file.getOriginalFilename();
            //1.文件名称添加一个唯一值
            String uuid = UUID.randomUUID().toString().replace("-","");
            fileName = uuid + fileName;
            //2.把文件安装日期进行分类
            //2021/05/20/图片.jpg
            //获取当前日期 joda-time
            String datePath = new DateTime().toString("yyyy/mm/dd");

            fileName = datePath+"/"+fileName;

            ossClient.putObject(bucketName, fileName, inputStream);

            // 关闭OSSClient。
            ossClient.shutdown();

            //上传之后把文件路径返回
            //https://edu8806.oss-cn-beijing.aliyuncs.com/12080849903156.jpg
            String url ="https://"+bucketName+"."+ endPoint +"/"+fileName;
            return url;


        } catch (Exception e) {
            e.printStackTrace();
            return null;
        }


    }
}