标签:ipo header common test yun htm public bytearray apache
工具类如下:
public class OssClientUtils { // 都是配置信息oss public static final String END_POINT = "oss-cn-beijing.aliyuncs.com"; private static final String ACCESS_KEY_ID = "sdfdsfsgg"; private static final String ACCESS_KEY_SECRET = "sdfsfsfdsg"; private static final OSSClient OSS_CLIENT; static { // 根据配置信息创建oss客户端对象 OSS_CLIENT = new OSSClient(END_POINT, ACCESS_KEY_ID, ACCESS_KEY_SECRET); } /** * 多文件自定义多级文件夹、文件名压缩下载 * @param zipName 压缩文件下载名,例如:压缩包名称.zip,需要带zip后缀 * @param bucketName 文件存储的位置 * @param list 自定义内容,name:自定义下载的文件名;filePath:文件在oss存储的全路径,第一个/需要去掉 * dir:压缩包中文件目录路径,可以是多级目录,以/结束,不以/开头 * @param response * @return void */ public static void zipDownload(String zipName, String bucketName, List<Map<String, Object>> list, HttpServletResponse response){ // 设置强制下载不打开 response.setContentType("application/force-download"); ZipOutputStream zos = null; BufferedInputStream bis = null; BufferedOutputStream out = null; byte[] buffer = new byte[100 * 1024]; ByteArrayOutputStream baos = new ByteArrayOutputStream(); try { String key = "/food_safety/2021-01-04/135/160974729398964.ppt*图片测试.ppt,/food_safety/2021-01-04/135/160974770957682.pngx*excel测试.png,"; if(!org.apache.commons.lang3.StringUtils.isEmpty(key)){ // 用于将数据压缩成Zip文件格式 zos = new ZipOutputStream(baos); for (int j = 0; j < list.size(); j++) { Map<String, Object> map = list.get(j); // 下载的自定义文件名(包含文件后缀) String name = (String) map.get("name"); /** * 文件oss的路径,去掉Bucket,不能以/开头; * 例如oss文件路径为:https://yigoutest.oss-cn-beijing.aliyuncs.com/food_safety/2021-01-04/1/cpu.jpg * 则map中为filePath:food_safety/2021-01-04/1/cpu.jpg */ String filePath = (String) map.get("filePath"); // 下载的自定义文件夹目录 String dir = (String) map.get("dir"); //bucketName需改为自己的bucketName OSSObject ossObject = OSS_CLIENT.getObject(bucketName, filePath); bis = new BufferedInputStream(ossObject.getObjectContent()); zos.putNextEntry(new ZipEntry(dir + name)); int i = bis.read(buffer); // 向压缩文件中输出数据 while(i != -1){ zos.write(buffer, 0, i); i = bis.read(buffer); } zos.closeEntry(); } // 设置文件名 response.addHeader("Content-Disposition", "attachment;fileName=" + URLEncoder.encode(zipName , "UTF-8")); out=new BufferedOutputStream(response.getOutputStream()); out.write(baos.toByteArray()); } } catch (Exception e) { e.printStackTrace(); } finally { //关闭流 if(zos != null){ try { zos.close(); } catch (IOException e) { e.printStackTrace(); } }if(bis != null){ try { bis.close(); } catch (IOException e) { e.printStackTrace(); } } if(out != null){ try { out.close(); } catch (IOException e) { e.printStackTrace(); } } } } }
调用工具类demo如下:
/** * 参考:阿里云(oss)官网api地址 * https://help.aliyun.com/product/31815.html */ @RequestMapping(value = "/zipDownload") public void zipDownload(HttpServletResponse response){ List<Map<String, Object>> list = new ArrayList<>(); Map<String, Object> map1 = new HashMap<>(); map1.put("dir", "test/"); map1.put("name","test.jpg"); map1.put("filePath", "food_safety/2021-01-04/1/cpu.jpg"); list.add(map1); Map<String, Object> map2 = new HashMap<>(); map2.put("dir", "test/哈哈/"); map2.put("name","哈哈.jpg"); map2.put("filePath", "food_safety/2021-01-04/1/cpu.jpg"); list.add(map2); Map<String, Object> map3 = new HashMap<>(); map3.put("dir", "啧啧/"); map3.put("name","啧啧.jpg"); map3.put("filePath", "food_safety/2021-01-04/1/cpu.jpg"); list.add(map3); Map<String, Object> map4 = new HashMap<>(); map4.put("dir", "啧啧/tt/ss/嗯嗯/"); map4.put("name","sfsd是搭嘎第三个.jpg"); map4.put("filePath", "food_safety/2021-01-04/1/cpu.jpg"); list.add(map4); // gunsProperties.getOssBucket() 得到的是文件存储位置的bucket OssClientUtils.zipDownload("压缩文件下载测试.zip", gunsProperties.getOssBucket(), list, response); }
标签:ipo header common test yun htm public bytearray apache
原文地址:https://www.cnblogs.com/cainiao-Shun666/p/14786072.html