java七牛云上传文件详解

第一步：添加依赖

        <dependency>
            <groupId>com.qiniu</groupId>
            <artifactId>qiniu-java-sdk</artifactId>
            <version>[7.2.0, 7.2.99]</version>
        </dependency>

第二步：从七牛云官网获得AK和SK
1.注册七牛云账号
2.登陆
3.点击头像
4.点击密钥管理
5.创建密钥和仓库名

image.png

第三步：编写工具类并且填入AK SK bucket

import com.alibaba.fastjson.JSONObject;
import com.google.common.collect.Maps;
import com.qiniu.common.QiniuException;
import com.qiniu.http.Response;
import com.qiniu.storage.BucketManager;
import com.qiniu.storage.Configuration;
import com.qiniu.storage.Region;
import com.qiniu.storage.UploadManager;
import com.qiniu.storage.model.BatchStatus;
import com.qiniu.util.Auth;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;

import java.io.IOException;
import java.util.*;

/**
 * @Author KasonZzz
 * @Description //TODO 七牛云工具类
 * @Date 9:46 2020/7/29
 */
@Service
public class QiNiuUtil {

    /** 七牛云AK */
    private final String accessKey = "xxxxxxxxxxxx";
   /** 七牛云密钥 */
    private final String secretKey = "xxxxxxxxxxxxxxxx";
    /** 仓库名 */
    private final String bucket = "xxxxxxxxx";
    /**
     * 七牛云的域名，如果自己没有域名
     * 这里可以存放临时域名（七牛自带的临时域名只有30天）
     * 这个变量可能会在其他地方用到（比如拼接字符串），所以设为public
     */
    public static final String QINIU_IMAGE_DOMAIN = "xxxxxxxxx";


    /** 通过AK和SK创建Auth */
    private Auth auth = Auth.create(accessKey, secretKey);
    /** 创建地区 */
    private Configuration cfg = new Configuration(Region.region0());
    /** 七牛封装的上传工厂 */
    private UploadManager uploadManager = new UploadManager(cfg);


    /** 可接收的后缀名 */
    private static String[] IMAGE_FILE_EXTD = new String[]{"png", "bmp", "jpg", "jpeg", "pdf"};
    /** 判断是否是允许的格式 */
    private static boolean isFileAllowed(String fileName) {
        for (String ext : IMAGE_FILE_EXTD) {
            if (ext.equals(fileName)) {
                return true;
            }
        }
        return false;
    }


    /**
     * 获取简单的上传凭证
     * @return 此处的token可以配合前端JS是哦那个
     */
    public String getUpToken() {
        return auth.uploadToken(bucket);
    }



    /**
     * 从前台接收文件保存到七牛云中
     * @param files 多个文件
     * @return hashmap存状态
     */
    public HashMap saveImage(MultipartFile[] files) throws IOException {
        HashMap<String, String> maps = Maps.newHashMap();
        if (files.length > 0) {
            for (MultipartFile file : files) {
                /** 获取文件格式 */
                int dotPos = file.getOriginalFilename().lastIndexOf(".");
                if (dotPos < 0) {
                    maps.put(file.getOriginalFilename(), "文件没有后缀名");
                } else {
                    String fileExt = file.getOriginalFilename().substring(dotPos + 1).toLowerCase();
                    /** 判断是否是合法的文件后缀 */
                    if (!isFileAllowed(fileExt)) {
                        maps.put(file.getOriginalFilename(), "文件后缀名不合法");
                    }
                    String fileName = UUID.randomUUID().toString().replaceAll("-", "") + "." + fileExt;
                    /** 调用put方法上传 */
                    Response res = uploadManager.put(file.getBytes(), fileName, getUpToken());
                    /** 打印返回的信息 */
                    if (res.isOK() && res.isJson()) {
                        maps.put(QINIU_IMAGE_DOMAIN + JSONObject.parseObject(res.bodyString()).get("key"),"success");
                    } else {
                        maps.put(file.getOriginalFilename(),"上传失败");
                    }
                }
            }
        }else {
            maps.put("fail","未上传文件");
        }

        return maps;
    }


    /**
     * 删除文件 单删
     * @param fileName  要删除的文件名
     * @return
     */
    public int deleteFileFromQiniu(String fileName){
        BucketManager bucketManager = new BucketManager(auth, cfg);
        try {
            Response delete = bucketManager.delete(bucket, fileName);
            return delete.statusCode;
        } catch (QiniuException ex) {
            ex.printStackTrace();
            System.err.println(ex.code());
            System.err.println(ex.response.toString());
        }
        return -1;
    }


    /**
     *  通过数组批量删除七牛云已上传的文件
     * @param fileNames 数组形式存放的文件名
     */
    public HashMap deleteFilesFromQiNiu(String[] fileNames) throws QiniuException{
        HashMap<String, String> maps = Maps.newHashMap();
        BucketManager bucketManager = new BucketManager(auth, cfg);
        BucketManager.BatchOperations batchOperations = new BucketManager.BatchOperations();
        batchOperations.addDeleteOp(bucket, fileNames);
        Response response = bucketManager.batch(batchOperations);
        BatchStatus[] batchStatusList = response.jsonToObject(BatchStatus[].class);
        for (int i = 0; i < fileNames.length; i++) {
            BatchStatus status = batchStatusList[i];
            String key = fileNames[i];
            System.out.print(key + "\t");
            maps.put(key, String.valueOf(status.code));
        }
        return maps;
    }


    /**
     * 通过List批量删除文件
     * @param fileNames list储存的文件名
     */
    public HashMap deleteFilesFromQiNiu(List<String> fileNames)throws QiniuException{
        String[] fileArr = fileNames.toArray(new String[fileNames.size()]);
        for (int i = 0; i < fileNames.size(); i++) {
            fileArr[i] = fileNames.get(i);
        }
       return deleteFilesFromQiNiu(fileArr);
    }
}

第四步：编写controller

import com.example.tadmin.util.BaseResult;
import com.example.tadmin.util.QiNiuUtil;
import com.qiniu.common.QiniuException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;

import java.io.IOException;
import java.util.HashMap;
import java.util.List;

/**
 * @Author KasonZzz
 * @Description //TODO
 * @Date 15:07 2020/7/29
 */
@RestController
@RequestMapping("qn")
public class QiNiuController {
    @Autowired
    private QiNiuUtil qiNiuUtil;

    /**
     * 获取token
     * @return 返回token字符串给前端
     */
    @GetMapping("findToken")
    public String findToken(){
        return qiNiuUtil.getUpToken();
    }


    /**
     * 批量增加文件格式
     * @param file 前台文件命名方式
     * @return BaseResult 公共返回类
     * @throws IOException
     */
    @PostMapping("upImgs")
    public BaseResult uploadImgs(@RequestBody MultipartFile[] file)throws IOException{
        HashMap hashMap = qiNiuUtil.saveImage(file);
        return new BaseResult(hashMap);
    }

    /**
     * 批量删除文件
     * @param list 因为我喜欢用list，工具类中有数组方法，推荐使用数组
     * @return BaseResult 公共返回类
     * @throws QiniuException 七牛云自带异常
     */
    @PostMapping("delImgs")
    public BaseResult delImgs(@RequestBody List<String> list) throws QiniuException {
        HashMap hashMap = qiNiuUtil.deleteFilesFromQiNiu(list);
        return new BaseResult(hashMap);
    }
}

***公共返回类BaseResult ***

import lombok.Data;
import lombok.ToString;

/**
 * @Author KasonZzz
 * @Description //TODO
 * @Date 10:21 2020/7/22
 */
@Data
@ToString
public class BaseResult<T> {
    /**
     * 响应中的数据
     */
    private T data;

    /**
     * 响应消息
     */
    private String msg;

    /**
     * 响应业务状态
     */
    private Integer code;

    public BaseResult() {
    }

    public BaseResult(T data) {
        this.data = data;
        msg = "success";
        code = 200;
    }

    public BaseResult(Integer code) {
        String msg;
        switch (code){
            case 200:
                msg = "success";
                break;
            case 400:
                msg="bad request";
                break;
            case 401:
                msg="401 Unauthorized";
                break;
            case 403:
                msg="403 Forbidden";
                break;
            case 404:
                msg = "404 Not Found";
                break;
            case 500:
                msg=" Internal Server Error ";
                break;
            default:
                msg = "fail";
                break;
        }
        this.msg = msg;
        this.code = code;
    }
}

第四步，POSTMAN上传测试

image.png

第五步，POSTMAN删除测试

image.png