springboot：整合fastdfs

转x33g5p2x  于2022-04-27 转载在 Spring  
字(5.9k)|赞(0)|评价(0)|浏览(546)

springboot：整合fastdfs

一、部署fastdfs

docker部署fastdfs

二、集成

依赖

  1. <!-- FastDFS依赖-->
  2.         <dependency>
  3.             <groupId>com.github.tobato</groupId>
  4.             <artifactId>fastdfs-client</artifactId>
  5.             <version>1.27.2</version>
  6.         </dependency>

配置类

  1. @Configuration
  2. //拥有带有连接池的FastDFS Java客户端
  3. @Import(FdfsClientConfig.class)
  4. //解决JMX重复注册bean的问题
  5. @EnableMBeanExport(registration = RegistrationPolicy.IGNORE_EXISTING)
  6. public class FastDFSClientConfig {
  7. }

yml配置

  1. fdfs:
  2.   reqHost: 127.0.0.1
  3.   reqPort: 8899
  4.   so-timeout: 3000  #socket连接超时时长
  5.   connect-timeout: 1000   #连接tracker服务器超时时长
  6.   thumb-image:  # 略图生成参数，可选
  7.     width: 60
  8.     height: 60
  9.   tracker-list: #TrackerList参数,支持多个，在下方加- ip:port
  10.     - 127.0.0.1:22122

工具类

  1. package com.yolo.yoloblog.util;
  3. import cn.hutool.core.util.StrUtil;
  4. import com.github.tobato.fastdfs.domain.fdfs.MetaData;
  5. import com.github.tobato.fastdfs.domain.fdfs.StorePath;
  6. import com.github.tobato.fastdfs.domain.fdfs.ThumbImageConfig;
  7. import com.github.tobato.fastdfs.domain.proto.storage.DownloadByteArray;
  8. import com.github.tobato.fastdfs.exception.FdfsUnsupportStorePathException;
  9. import com.github.tobato.fastdfs.service.FastFileStorageClient;
  10. import lombok.Data;
  11. import org.apache.commons.io.FilenameUtils;
  12. import org.springframework.beans.factory.annotation.Autowired;
  13. import org.springframework.beans.factory.annotation.Value;
  14. import org.springframework.stereotype.Component;
  15. import org.springframework.web.multipart.MultipartFile;
  17. import java.io.*;
  18. import java.nio.charset.StandardCharsets;
  19. import java.util.List;
  20. import java.util.Set;
  21. import java.util.zip.ZipEntry;
  22. import java.util.zip.ZipOutputStream;
  24. @Component
  25. @Data
  26. public class FastDFSUtil {
  28.     @Autowired
  29.     private FastFileStorageClient storageClient;
  31.     //缩略图处理
  32.     @Autowired
  33.     private ThumbImageConfig thumbImageConfig;
  35.     //fastDFS用nginx的连接
  36.     @Value("${fdfs.reqHost}")
  37.     private String reqHost;
  39.     //fastDFS用nginx的连接
  40.     @Value("${fdfs.reqPort}")
  41.     private String reqPort;
  43.     /**
  44.      *	MultipartFile类型的文件上传ַ
  45.      * @param file
  46.      * @return fastDfs文件保存路径
  47.      * @throws IOException
  48.      */
  49.     public String uploadFile(MultipartFile file) throws IOException {
  50.         StorePath path = storageClient.uploadFile(file.getInputStream(), file.getSize(),
  51.                 FilenameUtils.getExtension(file.getOriginalFilename()), null);
  52.         return path.getFullPath();
  53.     }
  55.     /**
  56.      * 普通的文件上传
  57.      * @param file
  58.      * @return fastDfs文件保存路径
  59.      * @throws IOException
  60.      */
  61.     public String uploadFile(File file) throws IOException {
  62.         FileInputStream inputStream = new FileInputStream(file);
  63.         StorePath path = storageClient.uploadFile(inputStream, file.length(),
  64.                 FilenameUtils.getExtension(file.getName()), null);
  65.         return path.getFullPath();
  66.     }
  68.     /**
  69.      * 带输入流形式的文件上传
  70.      * @param is 输入流
  71.      * @param fileSize 文件大小
  72.      * @param fileExtName 文件拓展名
  73.      * @return fastDfs文件保存路径
  74.      */
  75.     public String uploadFileStream(InputStream is, long fileSize, String fileExtName) {
  76.         StorePath path = storageClient.uploadFile(is, fileSize, fileExtName, null);
  77.         return path.getFullPath();
  78.     }
  80.     /**
  81.      * 文件上传
  82.      * @param bytes     文件字节
  83.      * @param fileSize  文件大小
  84.      * @param fileExtName 文件扩展名
  85.      * @return fastDfs文件保存路径
  86.      */
  87.     public String uploadFile(byte[] bytes, long fileSize, String fileExtName) {
  88.         ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(bytes);
  89.         StorePath storePath = storageClient.uploadFile(byteArrayInputStream, fileSize, fileExtName, null);
  90.         return storePath.getFullPath();
  91.     }
  93.     /**
  94.      * 将一段文本文件写到fastdfs的服务器上
  95.      * @param content 文本内容
  96.      * @param fileExtName 文件扩展名
  97.      * @return fastDfs文件保存路径
  98.      */
  99.     public String uploadFile(String content, String fileExtName) {
  100.         byte[] buff = content.getBytes(StandardCharsets.UTF_8);
  101.         ByteArrayInputStream stream = new ByteArrayInputStream(buff);
  102.         StorePath storePath = storageClient.uploadFile(stream, buff.length, fileExtName, null);
  103.         return storePath.getFullPath();
  104.     }
  106.     /**
  107.      * 上传图片文件和缩略图
  108.      * @param is 输入流
  109.      * @param size 文件大小
  110.      * @param fileExtName 文件扩展名
  111.      * @param metaData 可以为null
  112.      * @return 原始图片地址和缩略图地址
  113.      */
  114.     public String[] upFileImage(InputStream is, long size, String fileExtName, Set<MetaData> metaData) {
  115.         StorePath storePath = storageClient.uploadImageAndCrtThumbImage(is, size, fileExtName, metaData);
  116.         String imagePath = storePath.getFullPath();
  117.         String thumbImagePath = thumbImageConfig.getThumbImagePath(imagePath);
  118.         return new String[]{imagePath,thumbImagePath};
  119.     }
  121.     /**
  122.      * 删除文件
  123.      * @param fileUrl
  124.      */
  125.     public void deleteFile(String fileUrl) {
  126.         if (StrUtil.isEmpty(fileUrl)) {
  127.             return;
  128.         }
  129.         try{
  130.             StorePath storePath = StorePath.parseFromUrl(fileUrl);
  131.             storageClient.deleteFile(storePath.getGroup(), storePath.getPath());
  132.         } catch (FdfsUnsupportStorePathException e) {
  133.             e.printStackTrace();
  134.         }
  135.     }
  137.     /**
  138.      * 下载文件
  139.      * @param fileUrl
  140.      */
  141.     public byte[] downloadFile(String fileUrl) {
  142.         if (StrUtil.isEmpty(fileUrl)) {
  143.             return null;
  144.         }
  145.         StorePath storePath = StorePath.parseFromUrl(fileUrl);
  146.         return storageClient.downloadFile(storePath.getGroup(), storePath.getPath(), new DownloadByteArray());
  147.     }
  149.     /**
  150.      * 下载文件
  151.      * @param fileUrl
  152.      */
  153.     public InputStream download(String fileUrl ) {
  154.         if (StrUtil.isEmpty(fileUrl)) {
  155.             return null;
  156.         }
  157.         StorePath storePath = StorePath.parseFromUrl(fileUrl);
  158.         return storageClient.downloadFile(storePath.getGroup(), storePath.getPath(), (InputStream ins)->{
  159.                 // 将此ins返回给上面的inputStream
  160.                 return ins;
  161.             });
  162.     }
  164.     /**
  165.      * 批量下载文件
  166.      * @param fileUrlList
  167.      */
  168.     public InputStream downloadFile(List<String> fileUrlList){
  169.         byte[] buffer = new byte[1024];
  170.         // 创建一个新的 byte 数组输出流，它具有指定大小的缓冲区容量
  171.         ByteArrayOutputStream baos = new ByteArrayOutputStream();
  172.         //创建一个新的缓冲输出流，以将数据写入指定的底层输出流
  173.         BufferedOutputStream fos = new BufferedOutputStream(baos);
  174.         ZipOutputStream zos = new ZipOutputStream(fos);
  175.         try{
  176.             for (String fileUrl:fileUrlList){
  177.                 if (StrUtil.isNotEmpty(fileUrl)) {
  178.                     StorePath storePath = StorePath.parseFromUrl(fileUrl);
  179.                     byte[] bytes =  storageClient.downloadFile(storePath.getGroup(), storePath.getPath(), new DownloadByteArray()) ;
  180.                     //压缩文件内的文件名称
  181.                     String fileName = StrUtil.subSuf(fileUrl,fileUrl.lastIndexOf("/")+1);
  182.                     zos.putNextEntry(new ZipEntry(fileName));
  183.                     zos.write(bytes);
  184.                     zos.closeEntry();
  185.                 }
  186.             }
  187.             zos.close();
  188.             fos.flush();
  189.             InputStream is = new ByteArrayInputStream(baos.toByteArray());
  190.             return is;
  191.         }catch (Exception e){
  192.             e.printStackTrace();
  193.         }
  194.         return null;
  195.     }
  197.     /**
  198.      * 封装文件通过浏览器直接访问文件的地址
  199.      * @param fileUrl
  200.      * @return 
  201.      */
  202.     public String getViewAccessUrl(String fileUrl) {
  203.         return "http://" + reqHost + ":" + reqPort + "/" + fileUrl;
  204.     }
  206. }

控制器

  1. @PostMapping("/upload")
  2.     public String upload(@RequestParam("file") MultipartFile file) throws IOException {
  3.         String path = fastDFSUtil.uploadFile(file);
  4.         return fastDFSUtil.getViewAccessUrl(path);
  5.     }

版权说明 : 本文为转载文章, 版权归原作者所有 版权申明

原文链接 : https://blog.csdn.net/weixin_43296313/article/details/124433959

内容来源于网络，如有侵权，请联系作者删除！

springboot

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com