springboot(十八)：使用Spring Boot集成FastDFS

向右看齐 2022-03-25 01:24 245阅读 0赞

上篇文章介绍了[如何使用Spring Boot上传文件][Spring Boot]，这篇文章我们介绍如何使用Spring Boot将文件上传到分布式文件系统FastDFS中。

这个项目会在上一个项目的基础上进行构建。

## 1、pom包配置 ##

我们使用Spring Boot最新版本1.5.9、jdk使用1.8、tomcat8.0。

<dependency>
        <groupId>org.csource</groupId>
        <artifactId>fastdfs-client-java</artifactId>
        <version>1.27-SNAPSHOT</version>
    </dependency>

加入了`fastdfs-client-java`包，用来调用FastDFS相关的API。

## 2、配置文件 ##

resources目录下添加`fdfs_client.conf`文件

connect_timeout = 60
    network_timeout = 60
    charset = UTF-8
    http.tracker_http_port = 8080
    http.anti_steal_token = no
    http.secret_key = 123456
    
    tracker_server = 192.168.53.85:22122
    tracker_server = 192.168.53.86:22122

配置文件设置了连接的超时时间，编码格式以及tracker\_server地址等信息

详细内容参考：[fastdfs-client-java][]

## 3、封装FastDFS上传工具类 ##

封装FastDFSFile，文件基础信息包括文件名、内容、文件类型、作者等。

public class FastDFSFile {
        private String name;
        private byte[] content;
        private String ext;
        private String md5;
        private String author;
        //省略getter、setter

封装FastDFSClient类，包含常用的上传、下载、删除等方法。

首先在类加载的时候读取相应的配置信息，并进行初始化。

static {
        try {
            String filePath = new ClassPathResource("fdfs_client.conf").getFile().getAbsolutePath();;
            ClientGlobal.init(filePath);
            trackerClient = new TrackerClient();
            trackerServer = trackerClient.getConnection();
            storageServer = trackerClient.getStoreStorage(trackerServer);
        } catch (Exception e) {
            logger.error("FastDFS Client Init Fail!",e);
        }
    }

**文件上传**

public static String[] upload(FastDFSFile file) {
        logger.info("File Name: " + file.getName() + "File Length:" + file.getContent().length);
    
        NameValuePair[] meta_list = new NameValuePair[1];
        meta_list[0] = new NameValuePair("author", file.getAuthor());
    
        long startTime = System.currentTimeMillis();
        String[] uploadResults = null;
        try {
            storageClient = new StorageClient(trackerServer, storageServer);
            uploadResults = storageClient.upload_file(file.getContent(), file.getExt(), meta_list);
        } catch (IOException e) {
            logger.error("IO Exception when uploadind the file:" + file.getName(), e);
        } catch (Exception e) {
            logger.error("Non IO Exception when uploadind the file:" + file.getName(), e);
        }
        logger.info("upload_file time used:" + (System.currentTimeMillis() - startTime) + " ms");
    
        if (uploadResults == null) {
            logger.error("upload file fail, error code:" + storageClient.getErrorCode());
        }
        String groupName = uploadResults[0];
        String remoteFileName = uploadResults[1];
    
        logger.info("upload file successfully!!!" + "group_name:" + groupName + ", remoteFileName:" + " " + remoteFileName);
        return uploadResults;
    }

使用FastDFS提供的客户端storageClient来进行文件上传，最后将上传结果返回。

根据groupName和文件名获取文件信息。

public static FileInfo getFile(String groupName, String remoteFileName) {
        try {
            storageClient = new StorageClient(trackerServer, storageServer);
            return storageClient.get_file_info(groupName, remoteFileName);
        } catch (IOException e) {
            logger.error("IO Exception: Get File from Fast DFS failed", e);
        } catch (Exception e) {
            logger.error("Non IO Exception: Get File from Fast DFS failed", e);
        }
        return null;
    }

**下载文件**

public static InputStream downFile(String groupName, String remoteFileName) {
        try {
            storageClient = new StorageClient(trackerServer, storageServer);
            byte[] fileByte = storageClient.download_file(groupName, remoteFileName);
            InputStream ins = new ByteArrayInputStream(fileByte);
            return ins;
        } catch (IOException e) {
            logger.error("IO Exception: Get File from Fast DFS failed", e);
        } catch (Exception e) {
            logger.error("Non IO Exception: Get File from Fast DFS failed", e);
        }
        return null;
    }

**删除文件**

public static void deleteFile(String groupName, String remoteFileName)
            throws Exception {
        storageClient = new StorageClient(trackerServer, storageServer);
        int i = storageClient.delete_file(groupName, remoteFileName);
        logger.info("delete file successfully!!!" + i);
    }

使用FastDFS时，直接调用FastDFSClient对应的方法即可。

## 4、编写上传控制类 ##

从MultipartFile中读取文件信息，然后使用FastDFSClient将文件上传到FastDFS集群中。

public String saveFile(MultipartFile multipartFile) throws IOException {
        String[] fileAbsolutePath={};
        String fileName=multipartFile.getOriginalFilename();
        String ext = fileName.substring(fileName.lastIndexOf(".") + 1);
        byte[] file_buff = null;
        InputStream inputStream=multipartFile.getInputStream();
        if(inputStream!=null){
            int len1 = inputStream.available();
            file_buff = new byte[len1];
            inputStream.read(file_buff);
        }
        inputStream.close();
        FastDFSFile file = new FastDFSFile(fileName, file_buff, ext);
        try {
            fileAbsolutePath = FastDFSClient.upload(file);  //upload to fastdfs
        } catch (Exception e) {
            logger.error("upload file Exception!",e);
        }
        if (fileAbsolutePath==null) {
            logger.error("upload file failed,please upload again!");
        }
        String path=FastDFSClient.getTrackerUrl()+fileAbsolutePath[0]+ "/"+fileAbsolutePath[1];
        return path;
    }

请求控制，调用上面方法`saveFile()`。

@PostMapping("/upload") //new annotation since 4.3
    public String singleFileUpload(@RequestParam("file") MultipartFile file,
                                   RedirectAttributes redirectAttributes) {
        if (file.isEmpty()) {
            redirectAttributes.addFlashAttribute("message", "Please select a file to upload");
            return "redirect:uploadStatus";
        }
        try {
            // Get the file and save it somewhere
            String path=saveFile(file);
            redirectAttributes.addFlashAttribute("message",
                    "You successfully uploaded '" + file.getOriginalFilename() + "'");
            redirectAttributes.addFlashAttribute("path",
                    "file path url '" + path + "'");
        } catch (Exception e) {
            logger.error("upload file failed",e);
        }
        return "redirect:/uploadStatus";
    }

上传成功之后，将文件的路径展示到页面，效果图如下：

![fastDfs_sucees.png][]

在浏览器中访问此Url，可以看到成功通过FastDFS展示：

![fastDfs_pic.png][]

> 这样使用Spring Boot 集成FastDFS的案例就完成了。

**[示例代码-github][-github]**

**[示例代码-码云][-]**

[Spring Boot]: http://www.itmind.net/springboot/2018/01/12/spring-boot-upload-file.html
[fastdfs-client-java]: https://github.com/happyfish100/fastdfs-client-java
[fastDfs_sucees.png]: http://www.itmind.net/assets/images/2018/fastdfs/fastDfs_sucees.png
[fastDfs_pic.png]: http://www.itmind.net/assets/images/2018/fastdfs/fastDfs_pic.png
[-github]: https://github.com/ityouknow/spring-boot-examples
[-]: https://gitee.com/ityouknow/spring-boot-examples

发表评论取消回复

表情：

评论列表（有 0 条评论，245人围观）

还没有评论，来说两句吧...

相关阅读

相关 SpringBoot集成FastDFS

FastDfsConfig @Slf4j @Configuration public class FastDfsConfig {

叁歲伎倆/ 2023年01月21日 02:29/ 0 赞/ 6 阅读

相关 FastDFS与Springboot集成

FastDFS 技术学习，更多知识请访问[https://www.itkc8.com][https_www.itkc8.com] 原文链接：[http://blog.csdn

小灰灰/ 2022年06月08日 05:13/ 0 赞/ 190 阅读

相关 Spring Boot教程(十)：Spring Boot集成jsp

一、项目准备直接使用上个章节的源码，[Spring Boot教程(九)：Spring Boot集成Mapper4][Spring Boot_Spring Boot_Ma

喜欢ヅ旅行/ 2022年05月25日 04:47/ 0 赞/ 435 阅读

相关 Spring Boot教程(十八)：Spring Boot集成shiro ehcache

一、项目准备为了方便，这里直接使用[Spring Boot教程(十六)：Spring Boot集成shiro][Spring Boot_Spring Boot_shir

傷城~/ 2022年05月22日 04:18/ 0 赞/ 378 阅读

相关 SpringBoot2.X (十八): Spring Boot 启动原理

文章目录导言 1、启动类注解 2、\\`run\`\ 方法简单说明

- 日理万妓/ 2022年05月20日 08:29/ 0 赞/ 207 阅读

相关 springboot(十八)：使用Spring Boot集成FastDFS

原文地址：[https://blog.csdn.net/ityouknow/article/details/79078175][https_blog.csdn.net_ityo

我会带着你远行/ 2022年05月14日 08:26/ 0 赞/ 211 阅读

相关 Spring Boot 2 (八)：Spring Boot 集成 Memcached

Memcached 介绍 Memcached 是一个高性能的分布式内存对象缓存系统，用于动态Web应用以减轻数据库负载。它通过在内存中缓存数据和对象来减少读取数据库的次数

Myth丶恋晨/ 2022年03月25日 01:38/ 0 赞/ 219 阅读

相关 springboot(十八)：使用Spring Boot集成FastDFS

上篇文章介绍了[如何使用Spring Boot上传文件][Spring Boot]，这篇文章我们介绍如何使用Spring Boot将文件上传到分布式文件系统FastDFS中。

向右看齐/ 2022年03月25日 01:24/ 0 赞/ 246 阅读

相关 SpringBoot 集成FastDFS(八)

> `FastDFS`是一款高性能的分布式文件系统。主要功能包括：文件存储，文件同步，文件访问（上传下载）。它可以解决高容量和负载均衡的问题。`FastDFS`适合用来做文

青旅半醒/ 2022年01月26日 06:27/ 0 赞/ 319 阅读

相关 springboot(十八)：使用Spring Boot集成FastDFS

转载自纯洁的微笑：[https://blog.csdn.net/ityouknow/article/details/79078175][https_blog.csdn.net_

浅浅的花香味﹌/ 2021年11月26日 23:42/ 0 赞/ 356 阅读