java springboot 七牛云文件上传，下载，删除

/** * Copyright (c) 2016-2019 人人开源 All rights reserved. * <p> * https://www.renren.io * <p> * 版权所有，侵权必究！ */ package com.hkphantom.oss.config; import com.hkphantom.oss.common.util.DateUtils; import com.qiniu.common.QiniuException; import com.qiniu.common.Zone; import com.qiniu.http.Response; import com.qiniu.storage.BucketManager; import com.qiniu.storage.Configuration; import com.qiniu.storage.UploadManager; import com.qiniu.storage.model.FileInfo; import com.qiniu.util.Auth; import lombok.extern.slf4j.Slf4j; import okhttp3.OkHttpClient; import okhttp3.Request; import okhttp3.ResponseBody; import org.apache.commons.io.IOUtils; import org.apache.commons.lang.StringUtils; import org.springframework.web.multipart.MultipartFile; import javax.servlet.http.HttpServletResponse; import java.io.*; import java.net.URLEncoder; import java.util.Date; import java.util.UUID; /** * 七牛云存储 * * @author Mark sunlightcs@gmail.com */ @Slf4j public class QiniuCloudStorageService extends CloudStorageService { private UploadManager uploadManager; private BucketManager bucketManager; private String token; private Auth auth; public QiniuCloudStorageService(CloudStorageConfig config) { this.config = config; //初始化 init(); } private void init() { uploadManager = new UploadManager(new Configuration(Zone.autoZone())); token = Auth.create(config.getAccessKey(), config.getSecretKey()). uploadToken(config.getBucketName()); auth = Auth.create(config.getAccessKey(), config.getSecretKey()); bucketManager = new BucketManager(auth, new Configuration(Zone.autoZone())); } /** * 获取下载文件路径，即：donwloadUrl * * @return */ public String getDownloadUrl(String targetUrl) { String downloadUrl = auth.privateDownloadUrl(targetUrl); log.info("downloadUrl=====" + downloadUrl); return downloadUrl; } /** * 文件下载 * * @param targetUrl */ @Override public void download(String targetUrl, HttpServletResponse response) throws IOException { //获取downloadUrl String downloadUrl = getDownloadUrl(targetUrl); log.info("downloadUrl=============" + downloadUrl); //根据url地址返回文件字节流 OkHttpClient client = new OkHttpClient(); Request req = new Request.Builder().url(downloadUrl).build(); okhttp3.Response resp = null; InputStream input = null; OutputStream out = null; try { resp = client.newCall(req).execute(); System.out.println(resp.isSuccessful()); if (resp.isSuccessful()) { ResponseBody body = resp.body(); input = body.byteStream(); String fileName = "1.jpg"; //1、设置response 响应头 // response.reset(); //设置页面不缓存,清空buffer response.setCharacterEncoding("UTF-8"); //字符编码 // response.setContentType("multipart/form-data"); //二进制传输数据 response.setContentType(body.contentType().toString()); //设置响应头 response.setHeader("Content-Disposition", "attachment;fileName=" + URLEncoder.encode(fileName, "UTF-8")); //3、 写出文件--输出流 out = response.getOutputStream(); byte[] buff = new byte[1024]; int index = 0; //4、执行 写出操作 while ((index = input.read(buff)) != -1) { out.write(buff, 0, index); out.flush(); } } } catch (IOException e) { e.printStackTrace(); System.out.println("Unexpected code " + resp); } finally { if (out != null) { out.close(); } if (input != null) { input.close(); } System.gc(); } //本地保存路径 //下载文件到本地 // String filePath = "E:\\hu\\"; // download(downloadUrl, filePath); } @Override public String uploadFile(MultipartFile file, String suffix) { return null; } /** * 通过发送http get 请求获取文件资源 * * @param url * @param filepath * @return */ private static void download(String url, String filepath) { OkHttpClient client = new OkHttpClient(); System.out.println(url); Request req = new Request.Builder().url(url).build(); okhttp3.Response resp = null; try { resp = client.newCall(req).execute(); System.out.println(resp.isSuccessful()); if (resp.isSuccessful()) { ResponseBody body = resp.body(); InputStream is = body.byteStream(); byte[] data = readInputStream(is); //判断文件夹是否存在，不存在则创建 File file = new File(filepath); if (!file.exists() && !file.isDirectory()) { System.out.println("===文件夹不存在===创建===="); file.mkdir(); } File imgFile = new File(filepath + "888.jpg"); FileOutputStream fops = new FileOutputStream(imgFile); fops.write(data); fops.close(); } } catch (IOException e) { e.printStackTrace(); System.out.println("Unexpected code " + resp); } } /** * 读取字节输入流内容 * * @param is * @return */ private static byte[] readInputStream(InputStream is) { ByteArrayOutputStream writer = new ByteArrayOutputStream(); byte[] buff = new byte[1024 * 2]; int len = 0; try { while ((len = is.read(buff)) != -1) { writer.write(buff, 0, len); } is.close(); } catch (IOException e) { e.printStackTrace(); } return writer.toByteArray(); } @Override public String upload(byte[] data, String path) { try { Response res = uploadManager.put(data, path, token); //获取文件信息 FileInfo fileInfo = bucketManager.stat(config.getBucketName(), path); System.out.println(fileInfo.hash); System.out.println(fileInfo.fsize); System.out.println(fileInfo.mimeType); System.out.println(fileInfo.putTime); if (!res.isOK()) { throw new RuntimeException("上传七牛出错：" + res.toString()); } } catch (Exception e) { throw new RuntimeException("上传文件失败，请核对七牛配置信息", e); } return config.getDomain() + "/" + path; } @Override public String upload(InputStream inputStream, String path) { try { byte[] data = IOUtils.toByteArray(inputStream); return this.upload(data, path); } catch (IOException e) { throw new RuntimeException("上传文件失败", e); } } @Override public String uploadSuffix(byte[] data, String suffix) { return upload(data, getPath(config.getPrefix(), suffix)); } @Override public String uploadSuffix(InputStream inputStream, String suffix) { String path = getPath(config.getPrefix(), suffix); log.info("文件上传的路径========" + path); return upload(input