• 从0到1 手把手搭建spring cloud alibaba 微服务大型应用框架（九）文件服务篇（2）：集成minio文件服务

    本文承接上篇《从0到1 手把手搭建spring cloud alibaba 微服务大型应用框架（九）文件服务篇（1）：minio 单机与集群搭建》 ，目的是搭建一个独立的操作文件的服务

    为什么要搭建独立的文件服务，而不是做一个共通某个业务端去引用，主要是有以下几点理由

    1.独立服务可以让前后台有唯一的路由访问，避免嵌入到某个业务端造成的路由混乱
2.可以独立集群部署，做独立得的文件集群服务
3.不需要将代码逻辑渗透到前后台，封装性，易用性更好
4.可以进行权限隔离，做到灵活控制哪些服务可以访问哪些不可以访问

    创建文件服务

    由于我们文件服务属于一种支撑服务，而且以后可能会有很多类似的支撑服务，所以我们首先创建一个support支撑服务父项目，添加创建支撑父工程以及文件服务工程目录结构如下：

     

    minio pom.xml依赖

    1.   
    2.         
    3.             com.squareup.okhttp3
    4.             okhttp
    5.             compile
    6.         
    7.         
    8.         
    9.             io.minio
    10.             minio
    11.         

    添加 files文件服务 nacos 端以及内容明细

     

    mini-cloud-files-biz-dev.yml

    1.  
    2. security:
    3.   oauth2:
    4.     resource:
    5.       token-info-uri: http://mini-cloud-authentication-center/oauth/check_token
    6.     client:
    7.       client-id: test-auth-client
    8.       client-secret: 123
    9.       scope: read
    引入minioclient 配置

     

    配置放在本地yml或者nacos中均可，我这里放在nacos便于维护 

    1. minio:
    2.     endpoint: http://192.168.1.5:9090
    3.     accessKey: pZKVfmfSQMDRHZ3I
    4.     secretKey: sswL7XLx5wAwUKY6OJhIp6an7ZIuYPFc
    5.     bucketName: test1

     如何设置accessKey 和secretKey

     首先登录到管理页面，点击如下菜单

     

     复制accessKey和secretKey后点击保存

     

    配置 spring boot 上传文件最大大小

    spring:

      servlet:

        multipart:

           max-request-size: 50MB

           max-file-size: 50MB

     

    代码明细

     这里主要贴关键代码

    MinioConfig.java
    1. @Configuration
    2. public class MinioConfig {
    3.  
    4.     @Value("${minio.endpoint}")
    5.     private String endpoint;
    6.  
    7.     @Value("${minio.accessKey}")
    8.     private String accessKey;
    9.  
    10.     @Value("${minio.secretKey}")
    11.     private String secretKey;
    12.  
    13.     @Bean
    14.     public MinioClient minioClient() {
    15.         return MinioClient.builder()
    16.                 .endpoint(endpoint)
    17.                 .credentials(accessKey, secretKey)
    18.                 .build();
    19.     }
    20.  
    21. }
    MinioUtil.java

    1. @Component
    2. public class MinioUtil {
    3.  
    4.     @Autowired
    5.     private MinioClient client;
    6.  
    7.  
    8.     @Value("${minio.bucketName}")
    9.     private String bucketName;
    10.  
    11.  
    12.  
    13.     private static final String SEPARATOR_DOT = ".";
    14.  
    15.     private static final String SEPARATOR_ACROSS = "-";
    16.  
    17.     private static final String SEPARATOR_STR = "";
    18.  
    19.     // 存储桶名称
    20.     private static final String chunkBucKet = "img";
    21.  
    22.     /**
    23.      * 不排序
    24.      */
    25.     public final static boolean NOT_SORT = false;
    26.  
    27.     /**
    28.      * 排序
    29.      */
    30.     public final static boolean SORT = true;
    31.  
    32.     /**
    33.      * 默认过期时间(分钟)
    34.      */
    35.     private final static Integer DEFAULT_EXPIRY = 60;
    36.  
    37.     /**
    38.      * 删除分片
    39.      */
    40.     public final static boolean DELETE_CHUNK_OBJECT = true;
    41.     /**
    42.      * 不删除分片
    43.      */
    44.     public final static boolean NOT_DELETE_CHUNK_OBJECT = false;
    45.  
    46.     /**
    47.      * @param bucketName
    48.      * @return boolean
    49.      * @Description 判断 bucket是否存在
    50.      * @author exe.wangtaotao
    51.      * @date 2020/10/21 16:33
    52.      */
    53.     public boolean bucketExists(String bucketName) {
    54.         try {
    55.             return client.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());
    56.         } catch (Exception e) {
    57.             e.printStackTrace();
    58.         }
    59.         return false;
    60.     }
    61.  
    62.  
    63.     /**
    64.      * 创建存储桶
    65.      * 创建 bucket
    66.      *
    67.      * @param bucketName
    68.      */
    69.     public void makeBucket(String bucketName) {
    70.         try {
    71.             boolean isExist = bucketExists(bucketName);
    72.             if (!isExist) {
    73.                 client.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());
    74.             }
    75.         } catch (Exception e) {
    76.             e.printStackTrace();
    77.         }
    78.     }
    79.  
    80.     /**
    81.      * @param
    82.      * @return java.util.List
    83.      * @Description 获取文件存储服务的所有存储桶名称
    84.      * @author exe.wangtaotao
    85.      * @date 2020/10/21 16:35
    86.      */
    87.     public List listBucketNames() {
    88.         List bucketList = listBuckets();
    89.         List bucketListName = new ArrayList<>();
    90.         for (Bucket bucket : bucketList) {
    91.             bucketListName.add(bucket.name());
    92.         }
    93.         return bucketListName;
    94.     }
    95.  
    96.     /**
    97.      * @return java.util.List
    98.      * @Description 列出所有存储桶
    99.      */
    100.     @SneakyThrows
    101.     private List listBuckets() {
    102.         return client.listBuckets();
    103.     }
    104.  
    105.  
    106.     /**
    107.      * 获取对象文件名称列表
    108.      *
    109.      * @param bucketName 存储桶名称
    110.      * @param prefix     对象名称前缀(文件夹 /xx/xx/xxx.jpg 中的 /xx/xx/)
    111.      * @return objectNames
    112.      */
    113.     public List listObjectNames(String bucketName, String prefix) {
    114.         return listObjectNames(bucketName, prefix, NOT_SORT);
    115.     }
    116.  
    117.  
    118.     /**
    119.      * 获取对象文件名称列表
    120.      *
    121.      * @param bucketName 存储桶名称
    122.      * @param prefix     对象名称前缀(文件夹 /xx/xx/xxx.jpg 中的 /xx/xx/)
    123.      * @param sort       是否排序(升序)
    124.      * @return objectNames
    125.      */
    126.     @SneakyThrows
    127.     public List listObjectNames(String bucketName, String prefix, Boolean sort) {
    128.  
    129.         boolean flag = bucketExists(bucketName);
    130.         if (flag) {
    131.  
    132.             ListObjectsArgs listObjectsArgs;
    133.             if (null == prefix) {
    134.                 listObjectsArgs = ListObjectsArgs.builder()
    135.                         .bucket(bucketName)
    136.                         .recursive(true)
    137.                         .build();
    138.             } else {
    139.                 listObjectsArgs = ListObjectsArgs.builder()
    140.                         .bucket(bucketName)
    141.                         .prefix(prefix)
    142.                         .recursive(true)
    143.                         .build();
    144.             }
    145.             Iterable> chunks = client.listObjects(listObjectsArgs);
    146.             List chunkPaths = new ArrayList<>();
    147.             for (Result item : chunks) {
    148.                 chunkPaths.add(item.get().objectName());
    149.             }
    150.             if (sort) {
    151.                 chunkPaths.sort(new Str2IntComparator(false));
    152.             }
    153.             return chunkPaths;
    154.         }
    155.         return new ArrayList<>();
    156.     }
    157.  
    158.     /**
    159.      * 在桶下创建文件夹,文件夹层级结构根据参数决定
    160.      *
    161.      * @param bucket 桶名称
    162.      * @param WotDir 格式为 xxx/xxx/xxx/
    163.      */
    164.     @SneakyThrows
    165.     public String createDirectory(String bucket, String WotDir) {
    166.         if (!this.bucketExists(bucket)) {
    167.             return null;
    168.         }
    169.         client.putObject(PutObjectArgs.builder().bucket(bucket).object(WotDir).stream(
    170.                 new ByteArrayInputStream(new byte[]{}), 0, -1)
    171.                 .build());
    172.         return WotDir;
    173.     }
    174.  
    175.  
    176.     /**
    177.      * 删除一个文件
    178.      *
    179.      * @param bucketName
    180.      * @param objectName
    181.      */
    182.     @SneakyThrows
    183.     public boolean removeObject(String bucketName, String objectName) {
    184.  
    185.         if (!bucketExists(bucketName)) {
    186.             return false;
    187.         }
    188.         client.removeObject(
    189.                 RemoveObjectArgs.builder()
    190.                         .bucket(bucketName)
    191.                         .object(objectName)
    192.                         .build());
    193.         return true;
    194.     }
    195.  
    196.     /**
    197.      * @param bucketName
    198.      * @param objectNames
    199.      * @return java.util.List
    200.      * @Description 删除指定桶的多个文件对象, 返回删除错误的对象列表，全部删除成功，返回空列表
    201.      * @author exe.wangtaotao
    202.      * @date 2020/10/21 16:43
    203.      */
    204.     @SneakyThrows
    205.     public List removeObjects(String bucketName, List objectNames) {
    206.         if (!bucketExists(bucketName)) {
    207.             return new ArrayList<>();
    208.         }
    209.         List deleteObjects = new ArrayList<>(objectNames.size());
    210.         for (String objectName : objectNames) {
    211.             deleteObjects.add(new DeleteObject(objectName));
    212.         }
    213.         List deleteErrorNames = new ArrayList<>();
    214.         Iterable> results = client.removeObjects(
    215.                 RemoveObjectsArgs.builder()
    216.                         .bucket(bucketName)
    217.                         .objects(deleteObjects)
    218.                         .build());
    219.         for (Result result : results) {
    220.             DeleteError error = result.get();
    221.             deleteErrorNames.add(error.objectName());
    222.         }
    223.         return deleteErrorNames;
    224.     }
    225.  
    226.  
    227.     /**
    228.      * 获取访问对象的外链地址
    229.      * 获取文件的下载url
    230.      *
    231.      * @param bucketName 存储桶名称
    232.      * @param objectName 对象名称
    233.      * @param expiry     过期时间(分钟) 最大为7天 超过7天则默认最大值
    234.      * @return viewUrl
    235.      */
    236.     @SneakyThrows
    237.     public String getObjectUrl(String bucketName, String objectName, Integer expiry) {
    238.         expiry = expiryHandle(expiry);
    239.         return client.getPresignedObjectUrl(
    240.                 GetPresignedObjectUrlArgs.builder()
    241.                         .method(Method.GET)
    242.                         .bucket(bucketName)
    243.                         .object(objectName)
    244.                         .expiry(expiry)
    245.                         .build()
    246.         );
    247.     }
    248.  
    249.  
    250.     /**
    251.      * 创建上传文件对象的外链
    252.      *
    253.      * @param bucketName 存储桶名称
    254.      * @param objectName 欲上传文件对象的名称
    255.      * @return uploadUrl
    256.      */
    257.     public String createUploadUrl(String bucketName, String objectName) {
    258.         return createUploadUrl(bucketName, objectName, DEFAULT_EXPIRY);
    259.     }
    260.  
    261.     /**
    262.      * 创建上传文件对象的外链
    263.      *
    264.      * @param bucketName 存储桶名称
    265.      * @param objectName 欲上传文件对象的名称
    266.      * @param expiry     过期时间(分钟) 最大为7天 超过7天则默认最大值
    267.      * @return uploadUrl
    268.      */
    269.     @SneakyThrows
    270.     public String createUploadUrl(String bucketName, String objectName, Integer expiry) {
    271.         expiry = expiryHandle(expiry);
    272.         return client.getPresignedObjectUrl(
    273.                 GetPresignedObjectUrlArgs.builder()
    274.                         .method(Method.PUT)
    275.                         .bucket(bucketName)
    276.                         .object(objectName)
    277.                         .expiry(expiry)
    278.                         .build()
    279.         );
    280.     }
    281.  
    282.     /**
    283.      * 文件下载
    284.      *
    285.      * @param fileName 文件名
    286.      * @return InputStream
    287.      */
    288.     public void downLoadFile(HttpServletResponse response,String fileName) {
    289.        /* InputStream inputStream = null;
    290.         try {
    291.             StatObjectResponse statObjectResponse = client.statObject(StatObjectArgs.builder().bucket(chunkBucKet).object(fileName).build());
    292.             if (statObjectResponse.size() > 0) {
    293.                 inputStream = client.getObject(GetObjectArgs.builder().bucket(chunkBucKet).object(fileName).build());
    294.             }
    295.         } catch (Exception e) {
    296.             e.printStackTrace();
    297.         }
    298.         return inputStream;*/
    299.         try(InputStream ism = new BufferedInputStream(client.getObject(GetObjectArgs.builder()
    300.                 .bucket(chunkBucKet)
    301.                 .object(fileName).build()))) {
    302.             // 调用statObject()来判断对象是否存在。
    303.             // 如果不存在, statObject()抛出异常,
    304.             // 否则则代表对象存在
    305.             client.statObject(StatObjectArgs.builder()
    306.                     .bucket(chunkBucKet)
    307.                     .object(fileName).build());
    308.             byte buf[] = new byte[1024];
    309.             int length = 0;
    310.             response.reset();
    311.             //Content-disposition 是 MIME 协议的扩展，MIME 协议指示 MIME 用户代理如何显示附加的文件。
    312.             // Content-disposition其实可以控制用户请求所得的内容存为一个文件的时候提供一个默认的文件名，
    313.             // 文件直接在浏览器上显示或者在访问时弹出文件下载对话框。
    314.             response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(fileName, "UTF-8"));
    315.             response.setContentType("application/x-msdownload");
    316.             response.setCharacterEncoding("utf-8");
    317.             OutputStream osm = new BufferedOutputStream(response.getOutputStream());
    318.             while ((length = ism.read(buf))>0) {
    319.                 osm.write(buf,0, length);
    320.             }
    321.             osm.close();
    322.         } catch (Exception ex) {
    323.             ex.printStackTrace();
    324.         }
    325.     }
    326.  
    327.  
    328.     /**
    329.      * 批量下载
    330.      *
    331.      * @param directory
    332.      * @return
    333.      */
    334.     @SneakyThrows
    335.     public List downLoadMore(String bucket, String directory) {
    336.         Iterable> objs = client.listObjects(ListObjectsArgs.builder().bucket(bucket).prefix(directory).useUrlEncodingType(false).build());
    337.         List list = new ArrayList<>();
    338.         for (Result result : objs) {
    339.             String objectName = null;
    340.             objectName = result.get().objectName();
    341.             StatObjectResponse statObject = client.statObject(StatObjectArgs.builder().bucket(bucket).object(objectName).build());
    342.             if (statObject != null && statObject.size() > 0) {
    343.                 String fileurl = client.getPresignedObjectUrl(GetPresignedObjectUrlArgs.builder().bucket(bucket).object(statObject.object()).method(Method.GET).build());
    344.                 list.add(fileurl);
    345.             }
    346.         }
    347.         return list;
    348.     }
    349.  
    350.  
    351.     /**
    352.      * @param multipartFile
    353.      * @param bucketName
    354.      * @param directory image/
    355.      * @return java.lang.String
    356.      * @Description 文件上传
    357.      * @author exe.wangtaotao
    358.      * @date 2020/10/21 13:45
    359.      */
    360.     public MinioResponseDTO upload(MultipartFile multipartFile, String bucketName, String directory) throws Exception {
    361.  
    362.         InputStream inputStream = multipartFile.getInputStream();
    363.         directory = Optional.ofNullable(directory).orElse("");
    364.         String originFilename = Base64.getEncoder().encodeToString(multipartFile.getOriginalFilename().getBytes());
    365.         String username = SecurityContextHolder.getContext().getAuthentication().getName();
    366.         String minFileName = directory + minFileName(multipartFile.getOriginalFilename());
    367.  
    368.         Map userMetadata = new HashMap<>();
    369.         userMetadata.put("originFilename", originFilename);
    370.         userMetadata.put("username", username);
    371.         userMetadata.put("size", inputStream.available()+"");
    372.  
    373.         //上传文件到指定目录
    374.         client.putObject(PutObjectArgs.builder()
    375.                 .bucket(bucketName)
    376.                 .object(minFileName)
    377.                 .contentType(multipartFile.getContentType())
    378.                 .stream(inputStream, inputStream.available(), -1)
    379.                 .userMetadata(userMetadata)
    380.                 .extraQueryParams(userMetadata)
    381.                 .build());
    382.         inputStream.close();
    383.  
    384.         String url =  getObjectUrl(bucketName, minFileName, DEFAULT_EXPIRY);
    385.         MinioResponseDTO minioResponseDTO =  new MinioResponseDTO(minFileName,originFilename,username,url);
    386.         return minioResponseDTO;
    387.     }
    388.  
    389.     /**
    390.      * @param response
    391.      * @return java.lang.String
    392.      * @Description 下载文件
    393.      * @author exe.wangtaotao
    394.      * @date 2020/10/21 15:18
    395.      */
    396.     public void download(HttpServletResponse response, String bucketName, String minFileName)  {
    397.         InputStream fileInputStream = null;
    398.         try {
    399.             fileInputStream = client.getObject(GetObjectArgs.builder()
    400.                     .bucket(bucketName)
    401.                     .object(minFileName).build());
    402.             response.setHeader("Content-Disposition", "attachment;filename=" + minFileName);
    403.             response.setContentType("application/force-download");
    404.             response.setCharacterEncoding("UTF-8");
    405.             IOUtils.copy(fileInputStream, response.getOutputStream());
    406.         } catch (ErrorResponseException e) {
    407.             e.printStackTrace();
    408.         } catch (InsufficientDataException e) {
    409.             e.printStackTrace();
    410.         } catch (InternalException e) {
    411.             e.printStackTrace();
    412.         } catch (InvalidKeyException e) {
    413.             e.printStackTrace();
    414.         } catch (InvalidResponseException e) {
    415.             e.printStackTrace();
    416.         } catch (IOException e) {
    417.             e.printStackTrace();
    418.         } catch (NoSuchAlgorithmException e) {
    419.             e.printStackTrace();
    420.         } catch (ServerException e) {
    421.             e.printStackTrace();
    422.         } catch (XmlParserException e) {
    423.             e.printStackTrace();
    424.         } finally {
    425.             //关闭流
    426.             try {
    427.                 fileInputStream.close();
    428.             } catch (IOException e) {
    429.                 e.printStackTrace();
    430.             }
    431.         }
    432.  
    433.     }
    434.  
    435.  
    436.     /**
    437.      * 批量创建分片上传外链
    438.      *
    439.      * @param bucketName 存储桶名称
    440.      * @param objectMD5  欲上传分片文件主文件的MD5
    441.      * @param chunkCount 分片数量
    442.      * @return uploadChunkUrls
    443.      */
    444.     public List createUploadChunkUrlList(String bucketName, String objectMD5, Integer chunkCount) {
    445.         if (null == bucketName) {
    446.             bucketName = chunkBucKet;
    447.         }
    448.         if (null == objectMD5) {
    449.             return null;
    450.         }
    451.         objectMD5 += "/";
    452.         if (null == chunkCount || 0 == chunkCount) {
    453.             return null;
    454.         }
    455.         List urlList = new ArrayList<>(chunkCount);
    456.         for (int i = 1; i <= chunkCount; i++) {
    457.             String objectName = objectMD5 + i + ".chunk";
    458.             urlList.add(createUploadUrl(bucketName, objectName, DEFAULT_EXPIRY));
    459.         }
    460.         return urlList;
    461.     }
    462.  
    463.     /**
    464.      * 创建指定序号的分片文件上传外链
    465.      *
    466.      * @param bucketName 存储桶名称
    467.      * @param objectMD5  欲上传分片文件主文件的MD5
    468.      * @param partNumber 分片序号
    469.      * @return uploadChunkUrl
    470.      */
    471.     public String createUploadChunkUrl(String bucketName, String objectMD5, Integer partNumber) {
    472.         if (null == bucketName) {
    473.             bucketName = chunkBucKet;
    474.         }
    475.         if (null == objectMD5) {
    476.             return null;
    477.         }
    478.         objectMD5 += "/" + partNumber + ".chunk";
    479.         return createUploadUrl(bucketName, objectMD5, DEFAULT_EXPIRY);
    480.     }
    481.  
    482.  
    483.     /**
    484.      * 获取分片文件名称列表
    485.      *
    486.      * @param bucketName 存储桶名称
    487.      * @param ObjectMd5  对象Md5
    488.      * @return objectChunkNames
    489.      */
    490.     public List listChunkObjectNames(String bucketName, String ObjectMd5) {
    491.         if (null == bucketName) {
    492.             bucketName = chunkBucKet;
    493.         }
    494.         if (null == ObjectMd5) {
    495.             return null;
    496.         }
    497.         return listObjectNames(bucketName, ObjectMd5, SORT);
    498.     }
    499.  
    500.     /**
    501.      * 获取分片名称地址HashMap key=分片序号 value=分片文件地址
    502.      *
    503.      * @param bucketName 存储桶名称
    504.      * @param ObjectMd5  对象Md5
    505.      * @return objectChunkNameMap
    506.      */
    507.     public Map mapChunkObjectNames(String bucketName, String ObjectMd5) {
    508.         if (null == bucketName) {
    509.             bucketName = chunkBucKet;
    510.         }
    511.         if (null == ObjectMd5) {
    512.             return null;
    513.         }
    514.         List chunkPaths = listObjectNames(bucketName, ObjectMd5);
    515.         if (null == chunkPaths || chunkPaths.size() == 0) {
    516.             return null;
    517.         }
    518.         Map chunkMap = new HashMap<>(chunkPaths.size());
    519.         for (String chunkName : chunkPaths) {
    520.             Integer partNumber = Integer.parseInt(chunkName.substring(chunkName.indexOf("/") + 1, chunkName.lastIndexOf(".")));
    521.             chunkMap.put(partNumber, chunkName);
    522.         }
    523.         return chunkMap;
    524.     }
    525.  
    526.  
    527.     /**
    528.      * 合并分片文件成对象文件
    529.      *
    530.      * @param chunkBucKetName   分片文件所在存储桶名称
    531.      * @param composeBucketName 合并后的对象文件存储的存储桶名称
    532.      * @param chunkNames        分片文件名称集合
    533.      * @param objectName        合并后的对象文件名称
    534.      * @return true/false
    535.      */
    536.     @SneakyThrows
    537.     public boolean composeObject(String chunkBucKetName, String composeBucketName, List chunkNames, String objectName, boolean isDeleteChunkObject) {
    538.         if (null == chunkBucKetName) {
    539.             chunkBucKetName = chunkBucKet;
    540.         }
    541.         List sourceObjectList = new ArrayList<>(chunkNames.size());
    542.         for (String chunk : chunkNames) {
    543.             sourceObjectList.add(
    544.                     ComposeSource.builder()
    545.                             .bucket(chunkBucKetName)
    546.                             .object(chunk)
    547.                             .build()
    548.             );
    549.         }
    550.         client.composeObject(
    551.                 ComposeObjectArgs.builder()
    552.                         .bucket(composeBucketName)
    553.                         .object(objectName)
    554.                         .sources(sourceObjectList)
    555.                         .build()
    556.         );
    557.         if (isDeleteChunkObject) {
    558.             removeObjects(chunkBucKetName, chunkNames);
    559.         }
    560.         return true;
    561.     }
    562.  
    563.     /**
    564.      * 合并分片文件成对象文件
    565.      *
    566.      * @param bucketName 存储桶名称
    567.      * @param chunkNames 分片文件名称集合
    568.      * @param objectName 合并后的对象文件名称
    569.      * @return true/false
    570.      */
    571.     public boolean composeObject(String bucketName, List chunkNames, String objectName) {
    572.         return composeObject(chunkBucKet, bucketName, chunkNames, objectName, NOT_DELETE_CHUNK_OBJECT);
    573.     }
    574.  
    575.     /**
    576.      * 合并分片文件成对象文件
    577.      *
    578.      * @param bucketName 存储桶名称
    579.      * @param chunkNames 分片文件名称集合
    580.      * @param objectName 合并后的对象文件名称
    581.      * @return true/false
    582.      */
    583.     public boolean composeObject(String bucketName, List chunkNames, String objectName, boolean isDeleteChunkObject) {
    584.         return composeObject(chunkBucKet, bucketName, chunkNames, objectName, isDeleteChunkObject);
    585.     }
    586.  
    587.     /**
    588.      * 合并分片文件，合并成功后删除分片文件
    589.      *
    590.      * @param bucketName 存储桶名称
    591.      * @param chunkNames 分片文件名称集合
    592.      * @param objectName 合并后的对象文件名称
    593.      * @return true/false
    594.      */
    595.     public boolean composeObjectAndRemoveChunk(String bucketName, List chunkNames, String objectName) {
    596.         return composeObject(chunkBucKet, bucketName, chunkNames, objectName, DELETE_CHUNK_OBJECT);
    597.     }
    598.  
    599.  
    600.     /**
    601.      * @param originalFileName
    602.      * @return java.lang.String
    603.      * @Description 生成上传文件名
    604.      * @author exe.wangtaotao
    605.      * @date 2020/10/21 15:07
    606.      */
    607.     private String minFileName(String originalFileName) {
    608.         String suffix = FilenameUtils.getExtension(originalFileName);
    609.         return UUID.randomUUID().toString().replace(SEPARATOR_ACROSS, SEPARATOR_STR).toUpperCase() +"."+ suffix;
    610.     }
    611.  
    612.  
    613.     /**
    614.      * 将分钟数转换为秒数
    615.      *
    616.      * @param expiry 过期时间(分钟数)
    617.      * @return expiry
    618.      */
    619.     private static int expiryHandle(Integer expiry) {
    620.         expiry = expiry * 60;
    621.         if (expiry > 604800) {
    622.             return 604800;
    623.         }
    624.         return expiry;
    625.     }
    626.  
    627.     public Map metadata(String bucketName ,String filename) throws IOException, InvalidKeyException, InvalidResponseException, InsufficientDataException, NoSuchAlgorithmException, ServerException, InternalException, XmlParserException, ErrorResponseException {
    628.  
    629.         return client.getObject(GetObjectArgs.builder().bucket(bucketName).object(filename).build()).headers().toMultimap();
    630.     }
    631.  
    632.     static class Str2IntComparator implements Comparator {
    633.         private final boolean reverseOrder; // 是否倒序
    634.  
    635.         public Str2IntComparator(boolean reverseOrder) {
    636.             this.reverseOrder = reverseOrder;
    637.         }
    638.  
    639.         @Override
    640.         public int compare(String arg0, String arg1) {
    641.             Integer intArg0 = Integer.parseInt(arg0.substring(arg0.indexOf("/") + 1, arg0.lastIndexOf(".")));
    642.             Integer intArg1 = Integer.parseInt(arg1.substring(arg1.indexOf("/") + 1, arg1.lastIndexOf(".")));
    643.             if (reverseOrder) {
    644.                 return intArg1 - intArg0;
    645.             } else {
    646.                 return intArg0 - intArg1;
    647.             }
    648.         }
    649.     }
    FilesController.java

    1. @RestController
    2. @RequestMapping("/files")
    3. public class FilesController {
    4.  
    5.     @Autowired
    6.     private FilesService filesService;
    7.  
    8.     /**
    9.      * 上传文件
    10.      * */
    11.     @PostMapping
    12.     public ResponseEntity save(@RequestParam MultipartFile file) throws Exception {
    13.  
    14.         return ResponseEntity.ok(filesService.save(file));
    15.     }
    16.  
    17.     /**
    18.      * 下载文件
    19.      * */
    20.     @GetMapping
    21.     public ResponseEntity save(HttpServletResponse response, @RequestParam String filename) throws Exception {
    22.  
    23.         filesService.download(response,filename);
    24.         return ResponseEntity.ok().build();
    25.     }
    26.  
    27.     /**
    28.      * 下载文件
    29.      * */
    30.     @GetMapping("/metadata")
    31.     public ResponseEntity metadata(@RequestParam String filename) throws Exception {
    32.  
    33.         return ResponseEntity.ok(filesService.metadata(filename));
    34.     }
    35. }

    FilesServiceImpl.java

    1. @Service
    2. public class FilesServiceImpl implements FilesService {
    3.  
    4.  
    5.     @Autowired
    6.     private MinioUtil minioUtil;
    7.  
    8.     @Value("${minio.bucketName}")
    9.     private String bucketName;
    10.  
    11.     @Override
    12.     @Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRED)
    13.     public Integer save(MultipartFile file) throws Exception {
    14.  
    15.         LocalDate localDate = LocalDate.now();
    16.         String dir = DateTimeFormatter.ofPattern("YYYYMMdd").format(localDate);
    17.         minioUtil.upload(file,bucketName,dir);
    18.         return 1;
    19.     }
    20.  
    21.     @Override
    22.     public void download(HttpServletResponse response , String filename) {
    23.         minioUtil.download(response,bucketName,filename);
    24.     }
    25.  
    26.     @SneakyThrows
    27.     @Override
    28.     public MinioResponseDTO metadata(String filename) {
    29.  
    30.         Map metadataMap = minioUtil.metadata(bucketName,filename);
    31.         String originFileName = (String) ((ArrayList) metadataMap.get("x-amz-meta-originfilename")).get(0);
    32.         String username = (String) ((ArrayList) metadataMap.get("x-amz-meta-username")).get(0);
    33.         originFileName = new String(Base64.getDecoder().decode(originFileName));
    34.         MinioResponseDTO minioResponseDTO = new MinioResponseDTO(filename,originFileName,username);
    35.         return minioResponseDTO;
    36.     }
    37. }

    MinioResponseDTO.java
    1. public class MinioResponseDTO implements Serializable {
    2.  
    3.     private String filename;
    4.  
    5.     private String originFilename;
    6.  
    7.     private String username ;
    8.  
    9.     private String url ;
    10.  
    11.     public MinioResponseDTO(String fileName,String originFilename,String username) {
    12.         this.filename = fileName;
    13.         this.originFilename = originFilename;
    14.         this.username = username;
    15.     }
    16.  
    17.     public MinioResponseDTO(String fileName,String originFilename,String username, String url) {
    18.         this.filename = fileName;
    19.         this.originFilename = originFilename;
    20.         this.username = username;
    21.         this.url = url;
    22.     }
    23.  
    24.     public String getUrl() {
    25.         return url;
    26.     }
    27.  
    28.     public String getFilename() {
    29.         return filename;
    30.     }
    31.  
    32.     public String getOriginFilename() {
    33.         return originFilename;
    34.     }
    35.  
    36.     public String getUsername() {
    37.         return username;
    38.     }
    39. }

  • 相关阅读:
    PHP 图片的合并，微信小程序码合并，文字合并
    避免 PostgreSQL 翻车的关键技巧
    FFmpeg+javacpp+javacv使用
    【学习笔记】 CF850F Rainbow Balls
    K8S之初入师门第一篇熟读手册
    Python中使用 for 循环来拿遍历 List 的值
    Elasticsearch学习（一）
    HIVE数据导入ES并避免字段空值占用空间
    Flutter 常见错误记录总结
    【Qt】Qt5.15、Qt6在线安装（使用国内源）
  • 原文地址：https://blog.csdn.net/madness1010/article/details/126128265