一、搭建FastDFS服务
    搭建参考以下文章：
    第一篇：FastDFS详细介绍 https://blog.csdn.net/m0_37797991/article/details/73381648
    第二篇：FastDFS搭建 https://blog.csdn.net/m0_37797991/article/details/73381739
    第三篇：FastDFS整合Nginx https://blog.csdn.net/m0_37797991/article/details/73385161
    第四篇：FastDFS整合SpringMvc实现上传 https://blog.csdn.net/m0_37797991/article/details/73394873

    因为现在最流行的是springboot，所以我们在这次的例子中采用springboot来整合FastDFS

    常用命令：
    上传文件：/usr/bin/fdfs_upload_file /etc/fdfs/client.conf /www/wwwroot/image/1.jpg
    启动storage_nginx：/usr/local/nginx2/sbin/nginx
    启动tracker_nginx：/usr/local/nginx/sbin/nginx
    启动tracker：service fdfs_trackerd start（创建软连接后）
    启动storage：service fdfs_storaged start（创建软连接后：ln -s /usr/bin/fdfs_storaged /usr/local/bin）
    查看storage是否注册到了tracker中：/usr/bin/fdfs_monitor /etc/fdfs/storage.conf

    二、具体的代码
    配置：

    1. #fastdfs配置
    2. fdfs.connect-timeout=600
    3. fdfs.so-timeout=1500
    4. fdfs.trackerList[0]=60.205.229.111:22122
    5. fdfs.thumbImage.height=150
    6. fdfs.thumbImage.width=150
    7. spring.jmx.enabled=false
    8. fdfs.pool.max-total=200

    配置类：

    1. package com.zym.fdfs.config;
    3. import com.github.tobato.fastdfs.FdfsClientConfig;
    4. import org.springframework.context.annotation.Configuration;
    5. import org.springframework.context.annotation.EnableMBeanExport;
    6. import org.springframework.context.annotation.Import;
    7. import org.springframework.jmx.support.RegistrationPolicy;
    9. @Configuration
    10. @Import(FdfsClientConfig.class)//导入client
    11. @EnableMBeanExport(registration= RegistrationPolicy.IGNORE_EXISTING)
    12. public class FastClient {//类名无特定限制
    14. }

    工具类：

    1. package com.zym.fdfs.util;
    3. import cn.hutool.core.codec.Base64;
    4. import com.github.tobato.fastdfs.domain.fdfs.StorePath;
    5. import com.github.tobato.fastdfs.domain.proto.storage.DownloadFileStream;
    6. import com.github.tobato.fastdfs.domain.upload.FastFile;
    7. import com.github.tobato.fastdfs.service.FastFileStorageClient;
    8. import org.springframework.beans.factory.annotation.Autowired;
    9. import org.springframework.stereotype.Component;
    10. import org.springframework.web.multipart.MultipartFile;
    12. import javax.activation.MimetypesFileTypeMap;
    13. import javax.servlet.http.HttpServletRequest;
    14. import javax.servlet.http.HttpServletResponse;
    15. import java.io.File;
    16. import java.io.FileInputStream;
    17. import java.io.IOException;
    18. import java.security.MessageDigest;
    19. import java.text.DecimalFormat;
    20. import java.text.SimpleDateFormat;
    21. import java.util.Date;
    23. @Component
    24. public class FastFileUtil {
    26.     @Autowired
    27.     private FastFileStorageClient fastFileStorageClient;
    29.     /**
    30.      * 定义GB的计算常量
    31.      */
    32.     private static final int GB = 1024 * 1024 * 1024;
    33.     /**
    34.      * 定义MB的计算常量
    35.      */
    36.     private static final int MB = 1024 * 1024;
    37.     /**
    38.      * 定义KB的计算常量
    39.      */
    40.     private static final int KB = 1024;
    42.     /**
    43.      * 格式化小数
    44.      */
    45.     private static final DecimalFormat DF = new DecimalFormat("0.00");
    48.     /**
    49.      * MultipartFile转FastFile
    50.      */
    51.     public static FastFile toFastFile(MultipartFile multipartFile, FileGroup fileGroup) {
    52.         // 获取文件名
    53.         FastFile file = null;
    54.         try {
    55.             // MultipartFile to FastFile
    56.             file = new FastFile.Builder()
    57.                     .withFile(multipartFile.getInputStream()
    58.                             ,multipartFile.getSize()
    59.                             ,multipartFile.getOriginalFilename())
    60.                     .toGroup(fileGroup.getGroup())
    61.                     .build();
    62.         } catch (IOException e) {
    63.             e.printStackTrace();
    64.         }
    65.         return file;
    66.     }
    69.     public StorePath uploadFastFile(MultipartFile multipartFile, FileGroup fileGroup){
    70.         FastFile file = null;
    71.         StorePath storePath = null;
    72.         try {
    73.             // MultipartFile to FastFile
    74.             file = new FastFile.Builder()
    75.                     .withFile(multipartFile.getInputStream()
    76.                             ,multipartFile.getSize()
    77.                             ,getExtensionName(multipartFile.getOriginalFilename()))
    78.                     .toGroup(fileGroup.getGroup())
    79.                     .build();
    80.             storePath = fastFileStorageClient.uploadFile(file);
    81.         } catch (IOException e) {
    82.             e.printStackTrace();
    83.         }
    84.         return storePath;
    85.     }
    88.     /**
    89.      * 获取文件扩展名，不带 .
    90.      */
    91.     public static String getExtensionName(String filename) {
    92.         if ((filename != null) && (filename.length() > 0)) {
    93.             int dot = filename.lastIndexOf('.');
    94.             if ((dot >-1) && (dot < (filename.length() - 1))) {
    95.                 return filename.substring(dot + 1);
    96.             }
    97.         }
    98.         return filename;
    99.     }
    101.     /**
    102.      * Java文件操作 获取不带扩展名的文件名
    103.      */
    104.     public static String getFileNameNoEx(String filename) {
    105.         if ((filename != null) && (filename.length() > 0)) {
    106.             int dot = filename.lastIndexOf('.');
    107.             if ((dot >-1) && (dot < (filename.length()))) {
    108.                 return filename.substring(0, dot);
    109.             }
    110.         }
    111.         return filename;
    112.     }
    114.     /**
    115.      * 文件大小转换
    116.      */
    117.     public static String getSize(long size){
    118.         String resultSize;
    119.         if (size / GB >= 1) {
    120.             //如果当前Byte的值大于等于1GB
    121.             resultSize = DF.format(size / (float) GB) + "GB   ";
    122.         } else if (size / MB >= 1) {
    123.             //如果当前Byte的值大于等于1MB
    124.             resultSize = DF.format(size / (float) MB) + "MB   ";
    125.         } else if (size / KB >= 1) {
    126.             //如果当前Byte的值大于等于1KB
    127.             resultSize = DF.format(size / (float) KB) + "KB   ";
    128.         } else {
    129.             resultSize = size + "B   ";
    130.         }
    131.         return resultSize;
    132.     }
    135.     /**
    136.      * 将文件名解析成文件的上传路径
    137.      */
    138.     public static File upload(MultipartFile file, String filePath) {
    139.         Date date = new Date();
    140.         SimpleDateFormat format = new SimpleDateFormat("yyyyMMddhhmmssS");
    141.         String name = getFileNameNoEx(file.getOriginalFilename());
    142.         String suffix = getExtensionName(file.getOriginalFilename());
    143.         String nowStr = "-" + format.format(date);
    144.         try {
    145.             String fileName = name + nowStr + "." + suffix;
    146.             String path = filePath + fileName;
    147.             // getCanonicalFile 可解析正确各种路径
    148.             File dest = new File(path).getCanonicalFile();
    149.             // 检测是否存在目录
    150.             if (!dest.getParentFile().exists()) {
    151.                 dest.getParentFile().mkdirs();
    152.             }
    153.             // 文件写入
    154.             file.transferTo(dest);
    155.             return dest;
    156.         } catch (Exception e) {
    157.             e.printStackTrace();
    158.         }
    159.         return null;
    160.     }
    162.     public static String fileToBase64(File file) throws Exception {
    163.         FileInputStream inputFile = new FileInputStream(file);
    164.         String base64;
    165.         byte[] buffer = new byte[(int)file.length()];
    166.         inputFile.read(buffer);
    167.         inputFile.close();
    168.         base64= Base64.encode(buffer);
    169.         return base64.replaceAll("[\\s*\t\n\r]", "");
    170.     }
    173.     public static String getFileType(String type) {
    174.         String documents = "txt doc pdf ppt pps xlsx xls docx";
    175.         String music = "mp3 wav wma mpa ram ra aac aif m4a";
    176.         String video = "avi mpg mpe mpeg asf wmv mov qt rm mp4 flv m4v webm ogv ogg";
    177.         String image = "bmp dib pcp dif wmf gif jpg tif eps psd cdr iff tga pcd mpt png jpeg";
    178.         if(image.contains(type)){
    179.             return "图片";
    180.         } else if(documents.contains(type)){
    181.             return "文档";
    182.         } else if(music.contains(type)){
    183.             return "音乐";
    184.         } else if(video.contains(type)){
    185.             return "视频";
    186.         } else {
    187.             return "其他";
    188.         }
    189.     }
    191.     public static String getFileTypeByMimeType(String type) {
    192.         String mimeType = new MimetypesFileTypeMap().getContentType("." + type);
    193.         return mimeType.split("/")[0];
    194.     }
    196.     public static void checkSize(long maxSize, long size) throws Exception {
    197.         // 1M
    198.         int len = 1024 * 1024;
    199.         if(size > (maxSize * len)){
    200.             throw new Exception("文件超出规定大小");
    201.         }
    202.     }
    206.     private static String getMd5(byte[] bytes) {
    207.         // 16进制字符
    208.         char[] hexDigits = {'0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'a', 'b', 'c', 'd', 'e', 'f'};
    209.         try {
    210.             MessageDigest mdTemp = MessageDigest.getInstance("MD5");
    211.             mdTemp.update(bytes);
    212.             byte[] md = mdTemp.digest();
    213.             int j = md.length;
    214.             char[] str = new char[j * 2];
    215.             int k = 0;
    216.             // 移位 输出字符串
    217.             for (byte byte0 : md) {
    218.                 str[k++] = hexDigits[byte0 >>> 4 & 0xf];
    219.                 str[k++] = hexDigits[byte0 & 0xf];
    220.             }
    221.             return new String(str);
    222.         } catch (Exception e) {
    223.             e.printStackTrace();
    224.         }
    225.         return null;
    226.     }
    228.     /**
    229.      * 下载文件
    230.      * @param request /
    231.      * @param response /
    232.      * @param path /
    233.      */
    234.     public void downloadFile(HttpServletRequest request, HttpServletResponse response, String path){
    235.         response.setHeader("Content-Disposition", "attachment; filename="+getFileName(path));
    236.         response.setCharacterEncoding(request.getCharacterEncoding());
    237.         response.setContentType("application/octet-stream");
    239.         DownloadFileStream downloadCallback = null;
    240.         try {
    241.             downloadCallback = new DownloadFileStream(response.getOutputStream());
    242.         } catch (IOException e) {
    243.             e.printStackTrace();
    244.         }
    245.         StorePath storePath = StorePath.parseFromUrl(path);
    246.         fastFileStorageClient.downloadFile(storePath.getGroup(),storePath.getPath(),downloadCallback);
    247.         try {
    248.             response.flushBuffer();
    249.         } catch (IOException e) {
    250.             e.printStackTrace();
    251.         }
    253.     }
    255.     // 删除文件
    256.     public void deleteFile(String path){
    257.         fastFileStorageClient.deleteFile(path);
    258.     }
    262.     /**
    263.      * 文件路径获取文件名
    264.      */
    265.     public static String getFileName(String filePath) {
    266.         if ((filePath != null) && (filePath.length() > 0)) {
    267.             int dot = filePath.lastIndexOf('/');
    268.             if ((dot >-1) && (dot < (filePath.length() - 1))) {
    269.                 return filePath.substring(dot + 1);
    270.             }
    271.         }
    272.         return filePath;
    273.     }
    274. }

    controller：

    1. package com.zym.fdfs.controller;
    3. import com.github.tobato.fastdfs.domain.fdfs.StorePath;
    4. import com.zym.fdfs.util.FastFileUtil;
    5. import com.zym.fdfs.util.FileGroup;
    6. import io.swagger.annotations.Api;
    7. import io.swagger.annotations.ApiOperation;
    8. import io.swagger.annotations.ApiParam;
    9. import org.springframework.beans.factory.annotation.Autowired;
    10. import org.springframework.web.bind.annotation.*;
    11. import org.springframework.web.multipart.MultipartFile;
    13. import java.io.IOException;
    15. @Api(tags = "FastDFS测试")
    16. @RestController
    17. @RequestMapping("/api/fastdfs")
    18. public class FileController {
    20.     @Autowired
    21.     private FastFileUtil fastFileUtil;
    23.     @ResponseBody
    24.     @ApiOperation(value = "上传文件",httpMethod = "POST")
    25.     @PostMapping("/upload")
    26.     public String uploadFile(@ApiParam("文件") MultipartFile file) throws IOException {
    27.         StorePath storePath = fastFileUtil.uploadFastFile(file,FileGroup.AVATAR);
    28.         return "文件上传成功，存储地址为："+storePath.getFullPath();
    29.     }
    30. }

    启动项目进行测试：
    image.png
    用swagger模拟上传文件，上传该图片：
    image.png
    用服务器的ip加上该地址去查看图片：
    image.png
    至此，简单的FastDFS与springboot的整合就完成了
    源码地址：https://gitee.com/zym213/springboot_fastdfs.git