FastDFS与Springboot集成

小灰灰 2022-06-08 05:13 190阅读 0赞

**FastDFS 技术学习，更多知识请访问[https://www.itkc8.com][https_www.itkc8.com]**

原文链接：[http://blog.csdn.net/xyang81/article/details/52850667][http_blog.csdn.net_xyang81_article_details_52850667]

上一篇[《FastDFS分布文件系统Java客户端使用》][FastDFS_Java]基于官方提供的Java客户端库介绍了文件上传、下载和删除的功能。淘宝在今年9月份在官方Java客户端的基础上进行了大量重构，且提供了更多丰富的api，主要新增的特性如下：   
1> 对关键部分代码加入了单元测试，便于理解与服务端的接口交易，提高接口质量   
2> 将以前对byte硬解析风格重构为使用 对象+注解 的形式，尽量增强了代码的可读性   
3> 支持对服务端的连接池管理(commons-pool2)   
4> 支持上传图片时候检查图片格式，并且自动生成缩略图   
5> 和Springboot整合方便

源码下载地址：[https://github.com/tobato/FastDFS\_Client][https_github.com_tobato_FastDFS_Client]

## 整合到Springboot项目流程 ##

> 注意：必须是Springboot项目

### 1、添加pom依赖 ###

<dependency>
        <groupId>com.github.tobato</groupId>
        <artifactId>fastdfs-client</artifactId>
        <version>1.25.2-RELEASE</version>
    </dependency>

### 2、将Fdfs配置引入项目 ###

我将注解配置加在springboot的入口类中：@Import(FdfsClientConfig.class)

@Import(FdfsClientConfig.class)
    @SpringBootApplication
    public class JingtongApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(JingtongApplication.class, args);
        }
    }

### 3、在spring配置文件中加入fdfs相关配置 ###

根据项目当中使用配置文件类型（.yml和.properties选择其中一个），加入相应的配置。

application.yml

fdfs:
      soTimeout: 1500
      connectTimeout: 600
      thumbImage:             #缩略图生成参数
        width: 150
        height: 150
      trackerList:            #TrackerList参数,支持多个
        - 192.168.0.201:22122
        - 192.168.0.202:22122

application.properties

fdfs.soTimeout=1500
    fdfs.connectTimeout=600
    fdfs.thumbImage.width=150
    fdfs.thumbImage.height=150
    fdfs.trackerList[0]=192.168.0.201:22122
    fdfs.trackerList[1]=192.168.0.202:22122

### 4、在项目中使用 ###

客户端主要包括以下接口：   
TrackerClient - TrackerServer接口   
GenerateStorageClient - 一般文件存储接口 (StorageServer接口)   
FastFileStorageClient - 为方便项目开发集成的简单接口(StorageServer接口)   
AppendFileStorageClient - 支持文件续传操作的接口 (StorageServer接口)

笔者在前一个项目当中将fdfs主要用于图片存储，基于FastFileStorageClient接口和springmvc提供的MultipartFile接口封装了一个简单的工具类，方便全局管理与调用。如下所示：

package com.digi_zones.support.fs;
    
    import com.digi_zones.config.AppConfig;
    import com.digi_zones.contacts.AppConstants;
    import com.github.tobato.fastdfs.domain.FileInfo;
    import com.github.tobato.fastdfs.domain.StorePath;
    import com.github.tobato.fastdfs.exception.FdfsUnsupportStorePathException;
    import com.github.tobato.fastdfs.service.FastFileStorageClient;
    import org.apache.commons.io.FilenameUtils;
    import org.apache.commons.lang3.StringUtils;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Component;
    import org.springframework.web.multipart.MultipartFile;
    
    import java.io.ByteArrayInputStream;
    import java.io.IOException;
    import java.nio.charset.Charset;
    
    /** * <p>Description: FastDFS文件上传下载包装类</p> * <p>Copyright: Copyright (c) 2016</p> * * @author 杨信 * @version 1.0 * @date 2016/9/7 */
    @Component
    public class FastDFSClientWrapper {
    
        private final Logger logger = LoggerFactory.getLogger(FastDFSClientWrapper.class);
    
        @Autowired
        private FastFileStorageClient storageClient;
    
        @Autowired
        private AppConfig appConfig;   // 项目参数配置
    
        /** * 上传文件 * @param file 文件对象 * @return 文件访问地址 * @throws IOException */
        public String uploadFile(MultipartFile file) throws IOException {
            StorePath storePath = storageClient.uploadFile(file.getInputStream(),file.getSize(), FilenameUtils.getExtension(file.getOriginalFilename()),null);
            return getResAccessUrl(storePath);
        }
    
        /** * 将一段字符串生成一个文件上传 * @param content 文件内容 * @param fileExtension * @return */
        public String uploadFile(String content, String fileExtension) {
            byte[] buff = content.getBytes(Charset.forName("UTF-8"));
            ByteArrayInputStream stream = new ByteArrayInputStream(buff);
            StorePath storePath = storageClient.uploadFile(stream,buff.length, fileExtension,null);
            return getResAccessUrl(storePath);
        }
    
        // 封装图片完整URL地址
        private String getResAccessUrl(StorePath storePath) {
            String fileUrl = AppConstants.HTTP_PRODOCOL + appConfig.getResHost()
                    + ":" + appConfig.getFdfsStoragePort() + "/" + storePath.getFullPath();
            return fileUrl;
        }
    
        /** * 删除文件 * @param fileUrl 文件访问地址 * @return */
        public void deleteFile(String fileUrl) {
            if (StringUtils.isEmpty(fileUrl)) {
                return;
            }
            try {
                StorePath storePath = StorePath.praseFromUrl(fileUrl);
                storageClient.deleteFile(storePath.getGroup(), storePath.getPath());
            } catch (FdfsUnsupportStorePathException e) {
                logger.warn(e.getMessage());
            }
        }
    }

除了FastDFSClientWrapper类中用到的api，客户端提供的api还有很多，可根据自身的业务需求，将其它接口也添加到工具类中即可。如下所示：

// 上传文件，并添加文件元数据
    StorePath uploadFile(InputStream inputStream, long fileSize, String fileExtName, Set<MateData> metaDataSet);
    // 获取文件元数据
    Set<MateData> getMetadata(String groupName, String path);
    // 上传图片并同时生成一个缩略图
    StorePath uploadImageAndCrtThumbImage(InputStream inputStream, long fileSize, String fileExtName,
                Set<MateData> metaDataSet);
    // 。。。

在项目中使用FastDFSClientWrapper：

@Controller
    public class MyController {
    
        @Autowired
        private FastDFSClientWrapper dfsClient;
    
        // 上传图片
        @RequestMapping(value = "/upload", method = RequestMethod.POST)
        public String upload(MultipartFile file, HttpServletRequest request, HttpServletResponse response) throws Exception {
            // 省略业务逻辑代码。。。
            String imgUrl = dfsClient.uploadFile(file);
            // 。。。。
            return xxxx;
    
        }
    }

*  **FastDFS 技术学习，更多知识请访问[https://www.itkc8.com][https_www.itkc8.com]**

[https_www.itkc8.com]: https://www.itkc8.com
[http_blog.csdn.net_xyang81_article_details_52850667]: http://blog.csdn.net/xyang81/article/details/52850667
[FastDFS_Java]: http://blog.csdn.net/xyang81/article/details/52847311
[https_github.com_tobato_FastDFS_Client]: https://github.com/tobato/FastDFS_Client