Spring Boot整合阿里云OSS快速实现文件上传

• • 1.创建用户
  • 2.创建Bucket
  • 3.Spring Boot 整合 OSS

相比于fastdfs，使用阿里云的OSS对象存储对于学习阶段的同学来说十分友好，并且很快就能上手。所以我基于OSS快速入门文档快速搭建文件上传模块，便于以后需要该功能时参考。

tip：本人是在完成头像上传功能时使用OSS，所以不会介绍所有的代码

登录阿里云客户端，点击右上角的头像，点击AccessKey 管理：

提示说得也很清楚，一句话：为了安全，建议使用子用户，这样不会暴露自己的账号信息。

创建子用户，我专门创建了一个study用户，便于学习使用。

下面的AccessKey ID和AccessKey Secret务必记住，这个就相当于我们管理OSS的账号密码。

用户创建完后，为该用户添加权限

    com.aliyun.oss
    aliyun-sdk-oss
    3.10.2

application.yml存入用户账号和Bucket

编写服务层

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

实现OssService

@Service
public class OssServiceImpl implements OssService {

    @Value("${alioss.endpoint}")
    private String endpoint;
    @Value("${alioss.bucket}")
    private String bucket;
    @Value("${alioss.access-key}")
    private String accessKeyId;
    @Value("${alioss.secret-key}")
    private String accessKeySecret;


    
    @Override
    public String upload(MultipartFile file) {
        OSS ossClient = null;
        // 获取上传后文件浏览路径
        String url = null;
        try {
            // 创建OSSClient实例。
            ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
            // 用户上传文件时指定的前缀，这里我们使用日期作为文件前缀
            String format = new SimpleDateFormat("yyyy-MM-dd").format(new Date());
            String dir = format + "/";

            // 填写本地文件的完整路径。如果未指定本地路径，则默认从示例程序所属项目对应本地路径中上传文件流。
            InputStream fileInputStream = file.getInputStream();
            // 获取上传文件的全称
            String filename = file.getOriginalFilename();

            // 获取UUID
            String uuid = UUID.randomUUID().toString().replaceAll("-", "");

            // 获取上传文件的后缀名（文件类型）
            String fileType = filename.substring(filename.lastIndexOf("."));

            // 拼接文件名字
            String newFileName = dir + uuid + fileType;
            // 如果要实现文件的浏览效果，一定要设置权限
            // 1.设置文件的ACL权限：公共读 or 公共读写
            // 2.设置文本类型（jpg/png/html/txt/...）
            Objectmetadata objectmetadata = new Objectmetadata();
            // 设置公共读权限
            objectmetadata.setObjectAcl(CannedAccessControlList.PublicRead);
            // 设置文件类型ContentType
            objectmetadata.setContentType(getContentType(fileType));

            // 依次填写Bucket名称（例如examplebucket）和Object完整路径（例如exampledir/exampleobject.txt）。Object完整路径中不能包含Bucket名称。
            ossClient.putObject(bucket, newFileName, fileInputStream, objectmetadata);
            url = "https://" + bucket + "." + endpoint + "/" + newFileName;
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            ossClient.shutdown();
        }
        return url;
    }


    
    public static String getContentType(String FilenameExtension) {
        if (FilenameExtension.equalsIgnoreCase(".bmp")) {
            return "image/bmp";
        }
        if (FilenameExtension.equalsIgnoreCase(".gif")) {
            return "image/gif";
        }
        if (FilenameExtension.equalsIgnoreCase(".jpeg") ||
                FilenameExtension.equalsIgnoreCase(".jpg") ||
                FilenameExtension.equalsIgnoreCase(".png")) {
            return "image/jpg";
        }
        if (FilenameExtension.equalsIgnoreCase(".html")) {
            return "text/html";
        }
        if (FilenameExtension.equalsIgnoreCase(".txt")) {
            return "text/plain";
        }
        if (FilenameExtension.equalsIgnoreCase(".vsd")) {
            return "application/vnd.visio";
        }
        if (FilenameExtension.equalsIgnoreCase(".pptx") ||
                FilenameExtension.equalsIgnoreCase(".ppt")) {
            return "application/vnd.ms-powerpoint";
        }
        if (FilenameExtension.equalsIgnoreCase(".docx") ||
                FilenameExtension.equalsIgnoreCase(".doc")) {
            return "application/msword";
        }
        if (FilenameExtension.equalsIgnoreCase(".xml")) {
            return "text/xml";
        }
        return "image/jpg";
    }
}

控制层

@ApiOperation(value = "上传文件")
@PostMapping("/uploadOss")
public R uploadFile(MultipartFile file) {
    String url = ossService.upload(file);
    return R.ok().put("url", url);
}

使用Swagger2测试



由于我设置了文件的ACL权限：公共读，所以可以通过url直接在网页上浏览而不是下载文件。