SpringBoot整合七牛云实现图片的上传管理

唠嗑部分

各位小伙伴大家好，我是全栈小白，今天我们来分享一下SpringBoot如何整合七牛云存储实现图片的上传与存储

首先我们来说说图片存储，在项目中图片几乎是必不可少的，那么大家会选择怎样存储呢，当然有几种方案

1、将图片直接上传至服务器上，使用nginx搭建静态资源服务器进行访问。

2、单独搭建文件服务器。

3、使用开源的分布式文件存储系统

4、使用第三方的云存储，七牛云、阿里云、腾讯云等

优缺点分析：

第一、二种：使用方便、直接将文件放到目录中，成本低，缺点是文件安全性低、不易扩展，加载速度慢

第三种：高容错性，数量级GB、TB、PB都支持件规模适合存储百万规模的数据，缺点是需要自己搭建，成品高

第四种：相对来说较方便、一定容量内免费使用，直接通过api进行文件操作，缺点是超过一定量后会收费、扩展收费

只不过对于我们自己使用的话，第四种足够了

言归正传

一、七牛云账号注册

七牛云文件存储是免费的，只不过每个月都要重新绑定一次域名，域名会换，自己有域名的话可以绑定自己的域名

1、七牛云账号注册

官网：https://www.qiniu.com/

填写信息进行注册

暂不绑定，进入控制台

绑定邮箱、实名认证

绑定邮箱、实名认证成功后

回到主页，点击新建存储空间

名称随便填写，存储区域随便选，访问控制选择公开

创建成功后，有两个选项

如果你自己有域名，可以绑定自己的域名，就不用每个月都来重新绑域名了

如果你没有或者不想配置，就选择好的，我知道了，我没有，选择第二项

进入空间后

二、SpringBoot整合并使用

七牛云JavaSDK开发者文档地址：https://developer.qiniu.com/kodo/1239/java

基本的操作都有，咱们就不看了，直接开始干

1、创建SpringBoot项目，导入依赖

创建过程省略，部分依赖省略

<dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>5.1.47</version></dependency><!--        mybatis-plus依赖--><dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-boot-starter</artifactId><version>3.0.5</version></dependency><!--        模板依赖--><dependency><groupId>org.apache.velocity</groupId><artifactId>velocity-engine-core</artifactId><version>2.3</version></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></dependency><dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId><version>2.0.45</version></dependency><!--        七牛云javaSDK--><dependency><groupId>com.qiniu</groupId><artifactId>qiniu-java-sdk</artifactId><version>[7.13.0, 7.13.99]</version></dependency>
</dependencies>

2、配置文件application.yml

server:port: 8080spring:datasource:driver-class-name: com.mysql.jdbc.Driverurl: jdbc:mysql:///qiniuyun-cloud-file-upload?characterEncoding=utf-8&useSSL=falseusername: rootpassword: 123456
# mybatis-plus相关配置
mybatis-plus:type-aliases-package: com.cxs.modelmapper-locations: classpath:mapper/*.xmlconfiguration:map-underscore-to-camel-case: truelog-impl: org.apache.ibatis.logging.stdout.StdOutImplqiniuyun:upload:# 七牛云访问akaccessKey: 1REeC45m0AiPmF3ElxPE5qKRrYsBO_xZZcwet-ar# 七牛云访问sksecretKey: iihMNq4wrfJAlnH3P_H2jb7T_I4Wqez7roVCVz8u# 你自己创建的空间名bucket: xiaobai-images# 表示在空间下穿件什么目录存储上传的图片mkdir: images/# 七牛云分配给你空间的域名domain: http://sc2howc0o.hb-bkt.clouddn.com/

AKSK获取位置说明

点击头像,秘钥管理

复制AKSK到配置文件中

注意：用你自己的，我的不能用

3、主要接口

/** @Project:cloud-file-upload* @Author:cxs* @Motto:放下杂念,只为迎接明天更好的自己* */
@RestController
@RequestMapping("/images")
public class FileController {@Autowiredprivate ImagesService imagesService;/*** 文件上传* @param file* @return* @throws IOException*/@PostMapping("/upload")public BaseResult upload(MultipartFile file) throws IOException {BaseResult result = BaseResult.ok();imagesService.uploadImage(file, result);return result;}/*** 获取文件列表* @param dto* @param request* @return*/@PostMapping("/getImagesList")public BaseResult getImagesList(@RequestBody BaseRequest dto, HttpServletRequest request){BaseResult result = BaseResult.ok();imagesService.getImagesList(dto, request, result);return result;}/*** 删除文件* @param id* @param request* @return*/@DeleteMapping("/removeImages/{id}")public BaseResult removeImages(@PathVariable("id") Integer id, HttpServletRequest request){BaseResult result = BaseResult.ok();imagesService.removeImages(id, request, result);return result;}
}

4、文件上传的主要代码

public String imageUploadGetUrl(MultipartFile file, BaseResult result) {String url = null;// 获取文件的源文件名String originalFilename = file.getOriginalFilename();// 截取后缀String postFix = originalFilename.substring(originalFilename.lastIndexOf("."));// 生成新的文件名String fileNewName = UUID.randomUUID().toString().replace("-", "") + postFix;//  判断上传的文件后缀是否符合要求if (!Arrays.asList(arrImg).contains(postFix)) {result.setCode(-1).setMsg("上传失败,类型暂不支持");return null;}// 创建七牛云AuthAuth auth = Auth.create(accessKey, secretKey);// 创建上传对象，Region.region1()表示华北Configuration cfg = new Configuration(Region.region1());cfg.resumableUploadAPIVersion = Configuration.ResumableUploadAPIVersion.V2;// 指定分片上传版本cfg.useHttpsDomains = false;UploadManager uploadManager = new UploadManager(cfg);try {// 调用put方法上传String token = auth.uploadToken(bucket, null, 3600, new StringMap().put("insertOnly", 1));if(!StringUtils.hasLength(token)) {result.setCode(-1).setMsg("上传失败");return null;}String fullName = mkdir + fileNewName;// 解析出文件的keyResponse res = uploadManager.put(file.getBytes(), fullName, token);DefaultPutRet putRet = JSON.parseObject(res.bodyString(), DefaultPutRet.class);if (res.isOK()) {result.setData(putRet.key);// 拼接图片访问路径url = qiNiuDomain + fullName;} else {result.setCode(-1).setMsg("上传失败");}} catch (Exception e) {log.error("", e);result.setCode(-1).setMsg("上传失败");}return url;
}

关于Region的说明，我选择的是华北，根据你自己选择的修改

5、删除文件的主要代码

public void removeCloudImage(String key, BaseResult result) {try {Auth auth = Auth.create(accessKey, secretKey);// 创建上传对象Configuration cfg = new Configuration(Region.region1());BucketManager bucketManager = new BucketManager(auth, cfg);Response res = bucketManager.delete(bucket, key);if (!res.isOK()) {result.setCode(-1).setMsg("删除失败");}} catch (QiniuException e) {e.printStackTrace();}
}