关于SPring Boot文件上传的两种方式#

传统方式--->本地上传#

概述场景#

文件上传，是程序开发中必须会使用到一个功能,比如:

添加商品,用户头像,文章封面等需求

富文本编辑（插件文件上传）

文件上传原理是什么？#

为什么要实现文件上传？ ---> 就是为了要共享资源，大家都可以在你的平台上看到上传的文件，一句话概括：就是把自己电脑上的文件通过程序上传到服务器的过程！

其实就是一句话:把用户的文件通过javaio流程复制到服务器的过程，称之为文件上传。

使用SpringBoot如何实现文件上传呢？#

使用spring boot完成的本地文件上传

1.1、实现步骤#

1.1.1、搭建一个spring boot工程#

1
<dependencies>
2
        <dependency>
3
            <groupId>org.springframework.boot</groupId>
4
            <artifactId>spring-boot-starter-web</artifactId>
5
        </dependency>
6
        <dependency>
7
            <groupId>org.springframework.boot</groupId>
8
            <artifactId>spring-boot-starter-freemarker</artifactId>
9
        </dependency>
10
    </dependencies>

1.1.2、准备一个文件上传的页面#

在resources/templates/upload.html

1
server:
2
  port: 3333
3

4
spring:
5
  freemarker:
6
    suffix: .html
7
    cache: false

1.1.3、实现后台的文件上传#

定义文件上传的server

1
package com.nacl.server;
2

3
import org.springframework.stereotype.Service;
4
import org.springframework.web.multipart.MultipartFile;
5

6
import java.io.File;
7
import java.io.IOException;
8

9
/**
10
 * @author HAOYANG
11
 * @create 2023-07-16 11:41
12
 */
13
@Service
14
public class UploadServe {
15

16
    /**
17
     * MultipartFile这个对象是springHvc提供的文件上传的接受的类。
18
     * 它的底层自动会去和HttpServletRequest request中的request.getInputstream()融合
19
     * 从而达到文件上传的效果。也就是告诉你一个道理:
20
     * 文件上传威层原理是:request.getinputstream()
21
     * @param multipartFile
22
     * @param dir
23
     * @return
24
     */
25
    public String uploadImg(MultipartFile multipartFile,String dir){
26
        //1. 指定文件上传的目录
27
        File targetFile = new File("D://usr//local//upload/"+dir);
28
        try {
29
            if (!targetFile.exists())targetFile.mkdirs();
30
            //2. 文件上传的文件名
31
            File targetFileName = new File(targetFile,"aaa.png");
32
            //2. 文件上传到指定的目录
33
            multipartFile.transferTo(targetFileName);
34
            return "ok";
35
        } catch (IOException e) {
36
            e.printStackTrace();
37
            return "fail";
38
        }
39
    }
40
}

定义文件上传的controller

1
package com.nacl.controller;
2

3
import com.nacl.server.UploadServe;
4
import org.springframework.beans.factory.annotation.Autowired;
5
import org.springframework.stereotype.Controller;
6
import org.springframework.web.bind.annotation.PostMapping;
7
import org.springframework.web.bind.annotation.RequestParam;
8
import org.springframework.web.bind.annotation.ResponseBody;
9
import org.springframework.web.multipart.MultipartFile;
10

11
import javax.servlet.http.HttpServletRequest;
12

13
/**
14
 * @author HAOYANG
15
 * @create 2023-07-16 11:40
16
 */
17
@Controller
18
public class UploadController {
19

20
    @Autowired
21
    UploadServe uploadServe;
22
    /**
23
     * 文件上传具体实现
24
     * @param multipartFile
25
     * @param request
26
     * @return
27
     */
28
    @PostMapping("/upload/file")
29
    @ResponseBody
30
    public String upload(@RequestParam("file")MultipartFile multipartFile, HttpServletRequest request){
31
        if (multipartFile.isEmpty()){
32
            return "文件有误";
33
        }
34
        //原文件大小
35
        long size = multipartFile.getSize();
36
        //原文件名
37
        String originalFilename = multipartFile.getOriginalFilename();
38
        //原文件类型
39
        String contentType = multipartFile.getContentType();
40
        //1:获取用户指定的文件夹。问这个文件夹为什么要从页面上传递过来呢?
41
        //原因是:傲隔离，不司业务，不同文件放在不同的目录中
42
        String dir = request.getParameter("dir");
43
        return uploadServe.uploadImg(multipartFile,dir);
44
    }
45
}

定义文件上传的html

1
<!DOCTYPE html>
2
<html lang="en">
3
<head>
4
    <meta charset="UTF-8">
5
    <title>文件上传</title>
6
</head>
7
<body>
8
<h1>文件上传</h1>
9
<form action="/upload/file" enctype="multipart/form-data" method="post">
10
    <input name="dir" value="bbs">
11
    <input name="file" type="file">
12
    <input type="submit" value="文件上传">
13
</form>
14
</body>
15
</html>

修改一下

1
<!DOCTYPE html>
2
<html lang="en">
3
<head>
4
    <meta charset="UTF-8">
5
    <title>文件上传</title>
6
</head>
7
<body>
8
<h1>文件上传</h1>
9
<form action="/upload/file" id="uploadform" enctype="multipart/form-data" method="post">
10
    <input name="dir" value="bbs">
11
    <input name="file" onchange="toupload()" type="file">
12

13
</form>
14

15
<script>
16
    function toupload() {
17
        document.getElementById("uploadform").submit();
18
    }
19
</script>
20
</body>
21
</html>

运行项目就可以看到如下效果：

springmvc中文件上传给提供了包装对象MultipartFile原理如下：

通过MultipartFile我吗很清楚的看到，文件上传已经被服务器接收。

但是会产生一个临时目录，这个目录是可以去配置

文件上传不会直接上传真是的目录，它一定要经过一个临时目录的中转以后，才会上传到真是目录。作用:

1、防止上传出现网络断开，或者用户上传直接刷新或者取消。因为如果用户的网络断开或者取消，就造成大量的垃圾文件

2、保证真实目录上传的文件一定是有效的。
文件上传的大小:也可以进行配置的

文件上传的类型:也是进行配置的

1
server:
2
  port: 3333
3

4
spring:
5
  freemarker:
6
    suffix: .html
7
    cache: false
8
  servlet:
9
    multipart:
10
      enabled: true
11
      # 单个文件上传大小  默认是1MB
12
      max-file-size: 10MB
13
      # 设置总上传的数据大小
14
      max-request-size: 100MB
15
      # 当文件达到多少大小时，进行磁盘写入
16
      file-size-threshold: 20MB
17
      # 设置临时目录
18
      location: D://usr//local//temp

1.1.4、指定文件上传的目录#

配置spring boot静态资源存储服务，将上传的文件放入指定的目录中

1
package com.nacl.server;
2

3
import org.springframework.stereotype.Service;
4
import org.springframework.web.multipart.MultipartFile;
5

6
import java.io.File;
7
import java.io.IOException;
8
import java.text.SimpleDateFormat;
9
import java.util.Date;
10
import java.util.UUID;
11

12
/**
13
 * @author HAOYANG
14
 * @create 2023-07-16 11:41
15
 */
16
@Service
17
public class UploadServe {
18

19
    /**
20
     * MultipartFile这个对象是springHvc提供的文件上传的接受的类。
21
     * 它的底层自动会去和HttpServletRequest request中的request.getInputstream()融合
22
     * 从而达到文件上传的效果。也就是告诉你一个道理:
23
     * 文件上传威层原理是:request.getinputstream()
24
     * @param multipartFile
25
     * @param dir
26
     * @return
27
     */
28
    public String uploadImg(MultipartFile multipartFile,String dir){
29
        try {
30
            //1.原文件名
31
            String oldFilename = multipartFile.getOriginalFilename(); // 上传的文件：aaa.png
32
            // 2. 截取文件名的后缀
33
            String imgSuffix = oldFilename.substring(oldFilename.lastIndexOf("."));//拿到 .png
34
            //3. 生成唯一的文件名  不能用中文名，统一用英文
35
            String newFileName = UUID.randomUUID().toString()+imgSuffix;//将aaa.png改写成Sdjksdj532XXX.png   Sdjksdj532XXX--->这个是随意的
36
            //4. 日期目录
37
            SimpleDateFormat dateFormat = new SimpleDateFormat("yyy/MM/dd");
38
            String datePath = dateFormat.format(new Date());//日期目录：2023/7/16
39
            //5. 原文件上传以后的目录
40
            File targetPath = new File("D://usr//local//upload/"+dir,datePath);//生成一个最终的目录：D:/usr/local/upload/2023/7/16
41
            if (!targetPath.exists())targetPath.mkdirs();//如果目录不存在：D:/usr/local/upload/2023/7/16   递归创建
42
            //6. 指定文件上传以后的服务器的完整的文件名
43
            File targetFileName = new File(targetPath,newFileName);// 文件上传以后在服务器上最终文件名和目录是://如果目录不存在：D:/usr/local/upload/2023/7/16/Sdjksdj532XXX.png
44
            //7. 文件上传到指定的目录
45
            multipartFile.transferTo(targetFileName);//将用户选择的aa.png上传到D:/usr/local/upload/2023/7/16/Sdjksdj532XXX.png
46
            return "ok";
47
        } catch (IOException e) {
48
            e.printStackTrace();
49
            return "fail";
50
        }
51
    }
52
}

效果图：

1.1.5、通过http请求访问资源#

springboot如果去指定任意目录作为的资源的访问目录?

springboot有一个目录： static这个目录其实就是静态资源目录，这个目录下面的文件是可以通过http直接问题的。但是程序话一般打成jar包，我们没办法去文件写入到这个static下，所以springboot提供静态资源目录的额外的映射机制，就是静态资源服务映射。它就类似于: nginx的静态资源映射

配置静态资源服务映射：

1
package com.nacl.config;
2

3
import org.springframework.context.annotation.Configuration;
4
import org.springframework.web.servlet.config.annotation.ResourceHandlerRegistry;
5
import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
6

7
/**
8
 * @author HAOYANG
9
 * @create 2023-07-16 13:06
10
 */
11
@Configuration
12
public class WebMvcConfiguration implements WebMvcConfigurer {
13

14
    //这个就是springboot/springMvc让程序开发者去配置文件上传的额外的静态资源服务的配置
15
    @Override
16
    public void addResourceHandlers(ResourceHandlerRegistry registry) {
17
        registry.addResourceHandler("/uploadimg").addResourceLocations("file:D://usr//local//upload");
18
    }
19
}

核心代码分析：

1
registry.addResourceHandler("访问路径").addResourceLocations("上传资源路径");
2
 registry.addResourceHandler("/uploadimg/**").addResourceLocations("file:D://usr//local//upload//");

这个时候自己把aaa.png文件上传到D://usr//local//upload下，就可以通过http://localhost:3333/uploadimg/aaa.png，进行访问了

完整代码：

定义文件映射的WebMvcConfiguration

1
package com.nacl.config;
2

3
import org.springframework.beans.factory.annotation.Value;
4
import org.springframework.context.annotation.Configuration;
5
import org.springframework.web.servlet.config.annotation.ResourceHandlerRegistry;
6
import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
7

8
/**
9
 * @author HAOYANG
10
 * @create 2023-07-16 13:06
11
 */
12
@Configuration
13
public class WebMvcConfiguration implements WebMvcConfigurer {
14

15
    @Value("${file.staticPatternPath}")
16
    private String staticPatternPath;
17
    @Value("${file.uploadFolder}")
18
    private String uploadFolder;
19
    //这个就是springboot/springMvc让程序开发者去配置文件上传的额外的静态资源服务的配置
20
    @Override
21
    public void addResourceHandlers(ResourceHandlerRegistry registry) {
22
        registry.addResourceHandler(staticPatternPath).addResourceLocations("file:"+uploadFolder);
23
    }
24
}

controller

1
package com.nacl.controller;
2

3
import com.nacl.server.UploadServe;
4
import org.springframework.beans.factory.annotation.Autowired;
5
import org.springframework.stereotype.Controller;
6
import org.springframework.web.bind.annotation.PostMapping;
7
import org.springframework.web.bind.annotation.RequestParam;
8
import org.springframework.web.bind.annotation.ResponseBody;
9
import org.springframework.web.multipart.MultipartFile;
10

11
import javax.servlet.http.HttpServletRequest;
12

13
/**
14
 * @author HAOYANG
15
 * @create 2023-07-16 11:40
16
 */
17
@Controller
18
public class UploadController {
19

20
    @Autowired
21
    UploadServe uploadServe;
22
    /**
23
     * 文件上传具体实现
24
     * @param multipartFile
25
     * @param request
26
     * @return
27
     */
28
    @PostMapping("/upload/file")
29
    @ResponseBody
30
    public String upload(@RequestParam("file")MultipartFile multipartFile, HttpServletRequest request){
31
        if (multipartFile.isEmpty()){
32
            return "文件有误";
33
        }
34
        //原文件大小
35
        long size = multipartFile.getSize();
36
        //原文件名
37
        String originalFilename = multipartFile.getOriginalFilename();
38
        //原文件类型
39
        String contentType = multipartFile.getContentType();
40
        //1:获取用户指定的文件夹。问这个文件夹为什么要从页面上传递过来呢?
41
        //原因是:傲隔离，不司业务，不同文件放在不同的目录中
42
        String dir = request.getParameter("dir");
43
        return uploadServe.uploadImg(multipartFile,dir);
44
    }
45
}

service

1
package com.nacl.server;
2

3
import org.springframework.beans.factory.annotation.Value;
4
import org.springframework.stereotype.Service;
5
import org.springframework.web.multipart.MultipartFile;
6

7
import java.io.File;
8
import java.io.IOException;
9
import java.text.SimpleDateFormat;
10
import java.util.Date;
11
import java.util.UUID;
12

13
/**
14
 * @author HAOYANG
15
 * @create 2023-07-16 11:41
16
 */
17
@Service
18
public class UploadServe {
19

20
    @Value("${file.uploadFolder}")
21
    private String uploadFolder;
22
    @Value("${file.staticpath}")
23
    private String staticpath;
24
    /**
25
     * MultipartFile这个对象是springHvc提供的文件上传的接受的类。
26
     * 它的底层自动会去和HttpServletRequest request中的request.getInputstream()融合
27
     * 从而达到文件上传的效果。也就是告诉你一个道理:
28
     * 文件上传威层原理是:request.getinputstream()
29
     * @param multipartFile
30
     * @param dir
31
     * @return
32
     */
33
    public String uploadImg(MultipartFile multipartFile,String dir){
34
        try {
35
            //1.原文件名
36
            String oldFilename = multipartFile.getOriginalFilename(); // 上传的文件：aaa.png
37
            // 2. 截取文件名的后缀
38
            String imgSuffix = oldFilename.substring(oldFilename.lastIndexOf("."));//拿到 .png
39
            //3. 生成唯一的文件名  不能用中文名，统一用英文
40
            String newFileName = UUID.randomUUID().toString()+imgSuffix;//将aaa.png改写成Sdjksdj532XXX.png   Sdjksdj532XXX--->这个是随意的
41
            //4. 日期目录
42
            SimpleDateFormat dateFormat = new SimpleDateFormat("yyy/MM/dd");
43
            String datePath = dateFormat.format(new Date());//日期目录：2023/7/16
44
            //5. 原文件上传以后的目录
45
            String servepath = uploadFolder;//D://usr//local//upload/
46
            File targetPath = new File(servepath+dir,datePath);//生成一个最终的目录：D:/usr/local/upload/2023/7/16
47
            if (!targetPath.exists())targetPath.mkdirs();//如果目录不存在：D:/usr/local/upload/2023/7/16   递归创建
48
            //6. 指定文件上传以后的服务器的完整的文件名
49
            File targetFileName = new File(targetPath,newFileName);// 文件上传以后在服务器上最终文件名和目录是://如果目录不存在：D:/usr/local/upload/2023/7/16/Sdjksdj532XXX.png
50
            //7. 文件上传到指定的目录
51
            multipartFile.transferTo(targetFileName);//将用户选择的aa.png上传到D:/usr/local/upload/2023/7/16/Sdjksdj532XXX.png
52
            // 可以访问的路径要返回页面
53
            //http://localhost:3333/uploadimg/bbs/2023/7/16/Sdjksdj532XXX.png
54
            String filename = dir+"/"+datePath+"/"+newFileName;
55
            return staticpath+"/uploadimg/"+filename;
56
        } catch (IOException e) {
57
            e.printStackTrace();
58
            return "fail";
59
        }
60
    }
61
}

application-dev.yml

1
# 本机配置
2
file:
3
  staticpath: http://localhost:3333
4
  staticPatternPath: /uploadimg/**
5
  uploadFolder: D:/usr/local/upload/

application.yml

1
server:
2
  port: 3333
3

4
spring:
5
  freemarker:
6
    suffix: .html
7
    cache: false
8
  profiles:
9
    active: dev
10
  servlet:
11
    multipart:
12
      enabled: true
13
      # 单个文件上传大小  默认是1MB
14
      max-file-size: 10MB
15
      # 设置总上传的数据大小
16
      max-request-size: 100MB
17
      # 当文件达到多少大小时，进行磁盘写入
18
      file-size-threshold: 20MB
19
      # 设置临时目录
20
      location: D://usr//local//temp

application-prod.yml

1
# 服务器配置
2
file:
3
  staticpath: https://www.xxxxx.com
4
  staticPatternPath: /uploadimg/**
5
  uploadFolder: /www/upload/

实现效果：

1.1.6、对文件上传的思考和优化与控制#

比如文件的格式
比如文件的大小

在application.yml可以配置
比如文件的重命名

简略使用UUID.randomUUID().toString()随机生成一个

比如文件的目录分类

前端没有传入目录名称，后端有一个天然的目录--->日期目录，用指定的文件目录+日期目录

1
SimpleDateFormat dateFormat = new SimpleDateFormat("yyy/MM/dd");
2
String datePath = dateFormat.format(new Date());//日期目录：2023/7/16
3
//5. 原文件上传以后的目录
4
String servepath = uploadFolder;//D://usr//local//upload/
5
File targetPath = new File(servepath+dir,datePath);//生成一个最终的目录：D:/usr/local/upload/2023/7/16
6
if (!targetPath.exists())targetPath.mkdirs();//如果目录不存在：  D:/usr/local/upload/2023/7/16  递归创建

对service进行封装

1
package com.nacl.server;
2

3
import org.springframework.beans.factory.annotation.Value;
4
import org.springframework.stereotype.Service;
5
import org.springframework.web.multipart.MultipartFile;
6

7
import java.io.File;
8
import java.io.IOException;
9
import java.text.SimpleDateFormat;
10
import java.util.Date;
11
import java.util.HashMap;
12
import java.util.Map;
13
import java.util.UUID;
14

15
/**
16
 * @author HAOYANG
17
 * @create 2023-07-16 11:41
18
 */
19
@Service
20
public class UploadServe {
21

22
    @Value("${file.uploadFolder}")
23
    private String uploadFolder;
24
    @Value("${file.staticpath}")
25
    private String staticpath;
26
    /**
27
     * MultipartFile这个对象是springHvc提供的文件上传的接受的类。
28
     * 它的底层自动会去和HttpServletRequest request中的request.getInputstream()融合
29
     * 从而达到文件上传的效果。也就是告诉你一个道理:
30
     * 文件上传威层原理是:request.getinputstream()
31
     * @param multipartFile
32
     * @param dir
33
     * @return
34
     */
35
    public Map<String,Object> uploadImg(MultipartFile multipartFile, String dir){
36
        try {
37
            //1.原文件名
38
            String oldFilename = multipartFile.getOriginalFilename(); // 上传的文件：aaa.png
39
            // 2. 截取文件名的后缀
40
            String imgSuffix = oldFilename.substring(oldFilename.lastIndexOf("."));//拿到 .png
41
            //3. 生成唯一的文件名  不能用中文名，统一用英文
42
            String newFileName = UUID.randomUUID().toString()+imgSuffix;//将aaa.png改写成Sdjksdj532XXX.png   Sdjksdj532XXX--->这个是随意的
43
            //4. 日期目录
44
            SimpleDateFormat dateFormat = new SimpleDateFormat("yyy/MM/dd");
45
            String datePath = dateFormat.format(new Date());//日期目录：2023/7/16
46
            //5. 原文件上传以后的目录
47
            String servepath = uploadFolder;//D://usr//local//upload/
48
            File targetPath = new File(servepath+dir,datePath);//生成一个最终的目录：D:/usr/local/upload/2023/7/16
49
            if (!targetPath.exists())targetPath.mkdirs();//如果目录不存在：D:/usr/local/upload/2023/7/16   递归创建
50
            //6. 指定文件上传以后的服务器的完整的文件名
51
            File targetFileName = new File(targetPath,newFileName);// 文件上传以后在服务器上最终文件名和目录是://如果目录不存在：D:/usr/local/upload/2023/7/16/Sdjksdj532XXX.png
52
            //7. 文件上传到指定的目录
53
            multipartFile.transferTo(targetFileName);//将用户选择的aa.png上传到D:/usr/local/upload/2023/7/16/Sdjksdj532XXX.png
54
            // 可以访问的路径要返回页面
55
            //http://localhost:3333/uploadimg/bbs/2023/7/16/Sdjksdj532XXX.png
56
            String filename = dir+"/"+datePath+"/"+newFileName;
57
            Map<String,Object> map = new HashMap<>();
58
            map.put("url",staticpath+"/uploadimg/"+filename);
59
            map.put("size",multipartFile.getSize());
60
            map.put("ext",imgSuffix);
61
            map.put("filename",oldFilename);
62
            map.put("rpath",datePath+"/"+newFileName);
63
            return map;
64
        } catch (IOException e) {
65
            e.printStackTrace();
66
            return null;
67
        }
68
    }
69
}

对controller进行封装

1
package com.nacl.controller;
2

3
import com.nacl.server.UploadServe;
4
import org.springframework.beans.factory.annotation.Autowired;
5
import org.springframework.stereotype.Controller;
6
import org.springframework.web.bind.annotation.PostMapping;
7
import org.springframework.web.bind.annotation.RequestParam;
8
import org.springframework.web.bind.annotation.ResponseBody;
9
import org.springframework.web.multipart.MultipartFile;
10

11
import javax.servlet.http.HttpServletRequest;
12
import java.util.Map;
13

14
/**
15
 * @author HAOYANG
16
 * @create 2023-07-16 11:40
17
 */
18
@Controller
19
public class UploadController {
20

21
    @Autowired
22
    UploadServe uploadServe;
23
    /**
24
     * 文件上传具体实现
25
     *
26
     * @param multipartFile
27
     * @param request
28
     * @return
29
     */
30
    @PostMapping("/upload/file")
31
    @ResponseBody
32
    public Map<String, Object> upload(@RequestParam("file")MultipartFile multipartFile, HttpServletRequest request){
33
        if (multipartFile.isEmpty()){
34
            return null;
35
        }
36
        //原文件大小
37
        long size = multipartFile.getSize();
38
        //原文件名
39
        String originalFilename = multipartFile.getOriginalFilename();
40
        //原文件类型
41
        String contentType = multipartFile.getContentType();
42
        //1:获取用户指定的文件夹。问这个文件夹为什么要从页面上传递过来呢?
43
        //原因是:傲隔离，不司业务，不同文件放在不同的目录中
44
        String dir = request.getParameter("dir");
45
        return uploadServe.uploadImg(multipartFile,dir);
46
    }
47
}

现在方式--->OSS对象存储#

1. 注册阿里云#

2. 购买OSS对象存储#

3.创建Bucket文件存储桶#

Bucket相当于本地存储的文件夹

1.创建Bucket列表

2.创建好后找到SDK下载

4.安装SDK#

导入依赖：#

5.导入oss的sdk依赖

定义OssUplaodService对接文件上传实现简单上传文件：

1
// Endpoint以华东1（杭州）为例，其它Region请按实际情况填写。
2
        String endpoint = "https://oss-cn-hangzhou.aliyuncs.com";
3
        // 阿里云账号AccessKey拥有所有API的访问权限，风险很高。强烈建议您创建并使用RAM用户进行API访问或日常运维，请登录RAM控制台创建RAM用户。
4
        String accessKeyId = "yourAccessKeyId";
5
        String accessKeySecret = "yourAccessKeySecret";
6
        // 填写Bucket名称，例如examplebucket。
7
        String bucketName = "examplebucket";
8
        // 填写Object完整路径，例如exampledir/exampleobject.txt。Object完整路径中不能包含Bucket名称。
9
        String objectName = "exampledir/exampleobject.txt";
10

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

14
        try {
15
            String content = "Hello OSS";
16
            ossClient.putObject(bucketName, objectName, new ByteArrayInputStream(content.getBytes()));
17
        } catch (OSSException oe) {
18
            System.out.println("Caught an OSSException, which means your request made it to OSS, "
19
                    + "but was rejected with an error response for some reason.");
20
            System.out.println("Error Message:" + oe.getErrorMessage());
21
            System.out.println("Error Code:" + oe.getErrorCode());
22
            System.out.println("Request ID:" + oe.getRequestId());
23
            System.out.println("Host ID:" + oe.getHostId());
24
        } catch (ClientException ce) {
25
            System.out.println("Caught an ClientException, which means the client encountered "
26
                    + "a serious internal problem while trying to communicate with OSS, "
27
                    + "such as not being able to access the network.");
28
            System.out.println("Error Message:" + ce.getMessage());
29
        } finally {
30
            if (ossClient != null) {
31
                ossClient.shutdown();
32
            }
33
        }

填写对应参数：

代码展示：#

本地文件上传测试

1
package com.tian.service;
2

3
import com.aliyun.oss.ClientException;
4
import com.aliyun.oss.OSS;
5
import com.aliyun.oss.OSSClientBuilder;
6
import com.aliyun.oss.OSSException;
7
import com.aliyun.oss.model.CannedAccessControlList;
8
import org.springframework.web.multipart.MultipartFile;
9

10
import java.io.ByteArrayInputStream;
11
import java.io.File;
12
import java.io.FileInputStream;
13
import java.io.InputStream;
14
import java.text.SimpleDateFormat;
15
import java.util.Date;
16
import java.util.UUID;
17

18
public class OSSservice {
19
    public static void main(String[] args) {
20
        String uploadfile = uploadfile(new File("e://1.txt"));
21
        System.out.println(uploadfile);
22

23
    }
24
    public static String uploadfile(File multipartFile){
25
        // Endpoint以华东1（杭州）为例，其它Region请按实际情况填写。
26
        String endpoint = "oss-cn-beijing.aliyuncs.com";
27
        // 阿里云账号AccessKey拥有所有API的访问权限，风险很高。强烈建议您创建并使用RAM用户进行API访问或日常运维，请登录RAM控制台创建RAM用户。
28
        String accessKeyId = "LTAI5tABrZYxNYybmLhQx5ng";
29
        String accessKeySecret = "zGzSWHp4asGWEUT048gt6MQQMbnUV2dvA";
30
        // 填写Bucket名称，例如examplebucket。
31
        String bucketName = "atian-123";
32
        // 创建OSSClient实例。
33
        OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
34
        try {
35
            //如果桶不存在，创建桶。
36
            if(!ossClient.doesBucketExist(bucketName)){
37
                //创建桶
38
                ossClient.createBucket(bucketName);
39
                //设置oss实例的访问权限：公共读
40
                ossClient.setBucketAcl(bucketName, CannedAccessControlList.PublicRead);
41
            }
42
            //2.获取文件上传的流
43
            InputStream inputStream = new FileInputStream(multipartFile);
44
            //3.构建日期目录
45
            SimpleDateFormat dateFormat = new SimpleDateFormat(  "yyyy/MM/dd");
46
            String datePath = dateFormat.format(new Date());
47
            //4.获取文件名
48
            String originalFilename = multipartFile.getName();
49
            String filename = UUID.randomUUID().toString();//生成文件名
50
            String substring = originalFilename.substring(originalFilename.lastIndexOf("."));//截取出后缀名
51
            String newName = filename + substring;//拼接
52
            String fileUrl = datePath+"/"+newName;//完整的目录
53
            //5.文件上传到阿里云服务器
54
            ossClient.putObject(bucketName,fileUrl,inputStream);
55
            //6.返回文件的访问路径
56
            return "https://"+bucketName+"."+endpoint +"/"+fileUrl;
57
            //https://atian-123.oss-cn-beijing.aliyuncs.com/2022/08/11/dfab1c62-8b2f-42e8-baa2-8ca18333a681.txt
58
            //成功返回
59
        } catch (OSSException oe) {
60
            System.out.println("Caught an OSSException, which means your request made it to OSS, "
61
                    + "but was rejected with an error response for some reason.");
62
            System.out.println("Error Message:" + oe.getErrorMessage());
63
            System.out.println("Error Code:" + oe.getErrorCode());
64
            System.out.println("Request ID:" + oe.getRequestId());
65
            System.out.println("Host ID:" + oe.getHostId());
66
            return "fail";
67
        } catch (ClientException ce) {
68
            System.out.println("Caught an ClientException, which means the client encountered "
69
                    + "a serious internal problem while trying to communicate with OSS, "
70
                    + "such as not being able to access the network.");
71
            System.out.println("Error Message:" + ce.getMessage());
72
            return "fail";
73
        } catch (Exception e) {
74
            System.out.println("获取文件流对象失败！！");
75
            return "fail";
76
        }finally {
77
            if (ossClient != null) {
78
                ossClient.shutdown();
79
            }
80
        }
81
    }
82
}

正常代码：

1
    //-------------------------------------------------------------------------------------------------------------------
2
package com.tian.service;
3

4
import com.aliyun.oss.ClientException;
5
import com.aliyun.oss.OSS;
6
import com.aliyun.oss.OSSClientBuilder;
7
import com.aliyun.oss.OSSException;
8
import com.aliyun.oss.model.CannedAccessControlList;
9
import org.springframework.web.multipart.MultipartFile;
10

11
import java.io.ByteArrayInputStream;
12
import java.io.File;
13
import java.io.FileInputStream;
14
import java.io.InputStream;
15
import java.text.SimpleDateFormat;
16
import java.util.Date;
17
import java.util.UUID;
18

19
public class OSSservice {
20
    public String uploadfile(MultipartFile multipartFile){
21
    // Endpoint以华东1（杭州）为例，其它Region请按实际情况填写。
22
    String endpoint = "oss-cn-beijing.aliyuncs.com";
23
    // 阿里云账号AccessKey拥有所有API的访问权限，风险很高。强烈建议您创建并使用RAM用户进行API访问或日常运维，请登录RAM控制台创建RAM用户。
24
    String accessKeyId = "LTAI5tABrZYxNYybmLhQx5ng";
25
    String accessKeySecret = "zGzSWHp4GWUT048gt6MQQMbnUV2dvA";
26
    // 填写Bucket名称，例如examplebucket。
27
    String bucketName = "atian-123";
28
    // 创建OSSClient实例。
29
    OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
30
        try {
31
            //如果桶不存在，创建桶。
32
            if(!ossClient.doesBucketExist(bucketName)){
33
                //创建桶
34
                ossClient.createBucket(bucketName);
35
                //设置oss实例的访问权限：公共读
36
                ossClient.setBucketAcl(bucketName, CannedAccessControlList.PublicRead);
37
            }
38
            //2.获取文件上传的流
39
            InputStream inputStream = multipartFile.getInputStream();
40
            //3.构建日期目录
41
            SimpleDateFormat dateFormat = new SimpleDateFormat(  "yyyy/MM/dd");
42
            String datePath = dateFormat.format(new Date());
43
            //4.获取文件名
44
            String originalFilename = multipartFile.getOriginalFilename();
45
            String filename = UUID.randomUUID().toString();//生成文件名
46
            String substring = originalFilename.substring(originalFilename.lastIndexOf("."));//截取出后缀名
47
            String newName = filename + substring;//拼接
48
            String fileUrl = datePath+"/"+newName;//完整的目录
49
            //5.文件上传到阿里云服务器
50
            ossClient.putObject(bucketName,fileUrl,inputStream);
51
            //6.返回文件的访问路径
52
            return "https://"+bucketName+"."+endpoint +"/"+fileUrl;
53
    } catch (OSSException oe) {
54
        System.out.println("Caught an OSSException, which means your request made it to OSS, "
55
                + "but was rejected with an error response for some reason.");
56
        System.out.println("Error Message:" + oe.getErrorMessage());
57
        System.out.println("Error Code:" + oe.getErrorCode());
58
        System.out.println("Request ID:" + oe.getRequestId());
59
        System.out.println("Host ID:" + oe.getHostId());
60
            return "fail";
61
    } catch (ClientException ce) {
62
        System.out.println("Caught an ClientException, which means the client encountered "
63
                + "a serious internal problem while trying to communicate with OSS, "
64
                + "such as not being able to access the network.");
65
        System.out.println("Error Message:" + ce.getMessage());
66
            return "fail";
67
    } catch (Exception e) {
68
            System.out.println("获取文件流对象失败！！");
69
            return "fail";
70
        }finally {
71
            if (ossClient != null) {
72
                ossClient.shutdown();
73
            }
74
        }
75
    }
76
}

公告