FastDFS文件上传实现_fastdfs上传文件

FastDFS

1、基本概念

FastDFS是一个开源的轻量级分布式文件系统，它对文件进行管理，功能包括：文件存储、文件同步、文件访问（文件上传、文件下载）等，解决了大容量存储和负载均衡的问题。特别适合以文件为载体的在线服务，如相册网站、视频网站等等。

FastDFS特性：

• 文件不分块存储，上传的文件和OS文件系统中的文件一一对应

• 支持相同内容的文件只保存一份，节约磁盘空间

• 下载文件支持HTTP协议，可以使用内置Web Server，也可以和其他Web Server配合使用

• 支持在线扩容

• 支持主从文件

• 存储服务器上可以保存文件属性（meta-data）V2.0网络通信采用libevent，支持大并发访问，整体性能更好

FastDFS为互联网量身定制，充分考虑了冗余备份、负载均衡、线性扩容等机制，并注重高可用、高性能等指标，使用FastDFS很容易搭建一套高性能的文件服务器集群提供文件上传、下载等服务。

FastDFS 架构包括 Tracker server 和 Storage server。客户端请求 Tracker server 进行文件上传、下载，通过Tracker server 调度最终由 Storage server 完成文件上传和下载。

Tracker server 作用是负载均衡和调度，通过 Tracker server 在文件上传时可以根据一些策略找到Storage server 提供文件上传服务。可以将 tracker 称为追踪服务器或调度服务器。Storage server 作用是文件存储，客户端上传的文件最终存储在 Storage 服务器上，Storageserver 没有实现自己的文件系统而是利用操作系统的文件系统来管理文件。可以将storage称为存储服务器。

 

2、文件上传流程

 

客户端上传文件后存储服务器将文件 ID 返回给客户端，此文件 ID 用于以后访问该文件的索引信息。文件索引信息包括：组名，虚拟磁盘路径，数据两级目录，文件名。

 

组名：文件上传后所在的 storage 组名称，在文件上传成功后有storage 服务器返回，需要客户端自行保存。

虚拟磁盘路径：storage 配置的虚拟路径，与磁盘选项store_path*对应。如果配置了store_path0 则是 M00，如果配置了 store_path1 则是 M01，以此类推。

数据两级目录：storage 服务器在每个虚拟磁盘路径下创建的两级目录，用于存储数据文件。

文件名：与文件上传时不同。是由存储服务器根据特定信息生成，文件名包含：源存储服务器 IP 地址、文件创建时间戳、文件大小、随机数和文件拓展名等信息。

3、FastDFS搭建

用docker安装

3.1、拉取镜像

docker pull morunchang/fastdfs

 

3.2、运行tracker

docker run -d --name tracker --net=host morunchang/fastdfs sh tracker.sh

3.3、运行storage

docker run -d --name storage --net=host -e TRACKER_IP=<服务器ip地址>:22122 -e GROUP_NAME=<group name> morunchang/fastdfs sh storage.sh
​
例子：
docker run -d --name storage --net=host -e TRACKER_IP=192.168.80.174:22122 -e GROUP_NAME=group1 morunchang/fastdfs sh storage.sh

• 使用的网络模式是–net=host, <服务器ip地址> 替换为你机器的Ip即可

• <group name> 是组名，即storage的组

• 如果想要增加新的storage服务器，再次运行该命令，注意更换 新组名

 

3.4、修改nginx的配置

进入storage的容器内部，修改nginx.conf

# 进入到storage容器内部
docker exec -it storage  /bin/bash

 

 

进入到容器内部后,修改以下内容：

# 修改Nginx的配置文件
vi /etc/nginx/conf/nginx.conf
​
# 修改Nginx配置内容
 server {
        #默认是8080
        listen       80;
        server_name  localhost;
        
        location ~ /M00 {
                # storage 实际存储图片的位置
            root /data/fast_data/data;
            ngx_fastdfs_module;
        }
}
​
# 进入到Nginx sbin目录从新加载Nginx配置文件
cd /etc/nginx/sbin
# 重新加载配置文件
./nginx -s reload

 

storage存储的位置/data/fast_data/data

 

4、文件上传实现

4.1、创建SpringBoot工程

导入依赖

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.5.3</version>
</parent>
<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <!--fastdfs-->
    <dependency>
        <groupId>com.github.tobato</groupId>
        <artifactId>fastdfs-client</artifactId>
        <version>1.26.5</version>
    </dependency>
</dependencies>

创建fast_dfs.properties配置文件

#socket连接超时时长
fdfs.soTimeout=1500
#连接tracker服务器超时时长
fdfs.connectTimeout=600
fdfs.trackerList=192.168.80.174:22122
#服务器地址
fileServerUrl=http://192.168.80.174/

引导类

package com.qfedu.fastdfs;
​
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
​
@SpringBootApplication
public class FastDFSApplication {
    public static void main(String[] args) {
        SpringApplication.run(FastDFSApplication.class,args);
    }
}
​

fastdfs封装配置类

新建配置类：com.qfedu.fastdfs.config.FdfsConfiguration

package com.qfedu.fastdfs.config;
​
import com.github.tobato.fastdfs.FdfsClientConfig;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.EnableMBeanExport;
import org.springframework.context.annotation.Import;
import org.springframework.jmx.support.RegistrationPolicy;
​
@Configuration
@PropertySource("fast_dfs.properties")
@Import(FdfsClientConfig.class) // 导入FastDFS-Client组件
public class FdfsConfiguration {
}

封装fastdfs客户端：com.itusian.fastdfs.config.FastDFSClientUtil

package com.qfedu.fastdfs.config;
​
import com.github.tobato.fastdfs.domain.fdfs.StorePath;
import com.github.tobato.fastdfs.domain.proto.storage.DownloadCallback;
import com.github.tobato.fastdfs.service.FastFileStorageClient;
import org.apache.commons.io.FilenameUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.web.multipart.MultipartFile;
​
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
​
@Component
public class FastDFSClientUtil {
​
    @Autowired
    private FastFileStorageClient storageClient;
​
    /**
     * 上传
     * @param file
     * @return
     * @throws IOException
     */
    public String uploadFile(MultipartFile file) throws IOException {
        StorePath storePath = storageClient.uploadFile((InputStream) file.getInputStream(), file.getSize(), FilenameUtils.getExtension(file.getOriginalFilename()), null);
        return storePath.getFullPath();
    }
​
    /**
     * 删除
     * @param filePath
     */
    public void delFile(String filePath) {
        storageClient.deleteFile(filePath);
​
    }
​
    /**
     * 下载
     * @param groupName
     * @param path
     * @return
     */
    public byte[] download(String groupName, String path) throws IOException {
        InputStream ins = storageClient.downloadFile(groupName, path, new DownloadCallback<InputStream>() {
            @Override
            public InputStream recv(InputStream ins) throws IOException {
                // 将此ins返回给上面的ins
                return ins;
            }
        });
​
        ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
        byte[] buff = new byte[100];
        int rc = 0;
        while ((rc = ins.read(buff, 0, 100)) > 0) {
            byteArrayOutputStream.write(buff, 0, rc);
        }
        return byteArrayOutputStream.toByteArray();
    }
}

4.2、上传接口

新建controller测试上传：com.qfedu.fastdfs.controller.FileController

package com.qfedu.fastdfs.controller;
​
import com.qfedu.fastdfs.config.FastDFSClientUtil;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;
​
@RestController
@RequestMapping("/file")
public class FileController {
​
    @Autowired
    private FastDFSClientUtil fastDFSClientUtil;
​
    @Value("${fileServerUrl}")
    private String fileServerUrl ;
​
    @PostMapping("/upload")
    public String uploadFile(MultipartFile file) {
        try {
            //判断文件是否存在
            if (file == null) {
                throw new RuntimeException("文件不存在");
            }
            //获取文件的完整名称
            String originalFilename = file.getOriginalFilename();
            if (StringUtils.isEmpty(originalFilename)) {
                throw new RuntimeException("文件不存在");
            }
            String url = fastDFSClientUtil.uploadFile(file);
            return fileServerUrl+url;
​
        } catch (Exception e) {
            e.printStackTrace();
        }
        return "文件上传失败";
    }
}

测试：

 

4.3 、删除接口

添加删除方法

@GetMapping("/del")
public String delFile(String fileId){
    try {
        fastDFSClientUtil.delFile(fileId);
        return "删除成功";
    }catch (Exception e){
        e.printStackTrace();
    }
    return "删除失败";
}

测试：