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: 8080

spring:
  datasource:
    driver-class-name: com.mysql.jdbc.Driver
    url: jdbc:mysql:///qiniuyun-cloud-file-upload?characterEncoding=utf-8&useSSL=false
    username: root
    password: 123456
# mybatis-plus相关配置
mybatis-plus:
  type-aliases-package: com.cxs.model
  mapper-locations: classpath:mapper/*.xml
  configuration:
    map-underscore-to-camel-case: true
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl

qiniuyun:
  upload:
    # 七牛云访问ak
    accessKey: 1REeC45m0AiPmF3ElxPE5qKRrYsBO_xZZcwet-ar
    # 七牛云访问sk
    secretKey: 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 {

    @Autowired
    private 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;
    }
    // 创建七牛云Auth
    Auth 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;
        // 解析出文件的key
        Response 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();
    }
}

三、成果展示

结语

1、完结撒花，制作不易，点赞、分享、在看再走吧，您的支持永远是我最大的动力！

2、完整代码案例获取：点击获取完整案例源码>>