Docker + FastDFS + Spring Boot 一键式搭建分布式文件服务器

我会带着你远行 2021-09-07 06:14 340阅读 0赞

![0d74c477bb1ec35ed9e7d28c7414d05e.gif][]

首先说一下从零开始自己去搭一个fastdfs挺麻烦，后来看到有人把做好的 docker 镜像传出来了，那搭建起来就很容易了

有服务器的可以自己在服务器上玩玩,没有的可以新建一个centos7.5虚拟机玩玩，遇到虚拟机不能上网和换阿里云的源的问题可以参考https://blog.csdn.net/qq\_37759106/article/details/82985113这篇文章

PS：更多 Docker 和 Spring Boot 的文章可以关注微信公众号「Java后端」回复「666」下载技术栈手册。

**1.第一步安装docker:**

** **在 root 权限下

yum install -y docker-io #安装docker
    service docker star #启动docker
    docker -v # 查看docker版本

**2. 拉取镜像**

docker pull qbanxiaoli/fastdfs

**启动 fastdfs**

docker run -d --restart=always --privileged=true --net=host --name=fastdfs -e IP=192.168.127.131 -e WEB_PORT=80 -v ${HOME}/fastdfs:/var/local/fdfs qbanxiaoli/fastdfs

IP 后面是你的服务器公网ip或者虚拟机的IP，-e WEB_PORT=80 指定 nginx 端口

**测试fastdfs是否搭建成功**

docker exec -it fastdfs /bin/bash
    echo "Hello FastDFS!">index.html
    fdfs_test /etc/fdfs/client.conf upload index.html

![51c1d980bb72b424436147c53aff226c.png][]

能返回 url 就意见搭建成功

![f3b3014efcf2cbe8452499be46bd5578.png][]

这样 fastdfs 就搭建好啦

**下面进入 Spring Boot 整合部分**

<groupId>com.github.tobato</groupId>
       <artifactId>fastdfs-client</artifactId>
    <version>1.26.2</version>

在 Spring Boot 启动类上加

@Import(FdfsClientConfig.class)
    @EnableMBeanExport(registration = RegistrationPolicy.IGNORE_EXISTING)

![a2775a438eaffc156f79bbd1e3fdf1c4.png][]

**创建FastDFSClient工具类**

package com.yd.client.common;
     
    import com.github.tobato.fastdfs.conn.FdfsWebServer;
    import com.github.tobato.fastdfs.domain.StorePath;
    import com.github.tobato.fastdfs.proto.storage.DownloadByteArray;
    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.*;
     
    @Component
    public class FastDFSClient {
     
        private static Logger log =LoggerFactory.getLogger(FastDFSClient.class);
     
        private static FastFileStorageClient fastFileStorageClient;
     
        private static FdfsWebServer fdfsWebServer;
     
        @Autowired
        public void setFastDFSClient(FastFileStorageClient fastFileStorageClient, FdfsWebServer fdfsWebServer) {
            FastDFSClient.fastFileStorageClient = fastFileStorageClient;
            FastDFSClient.fdfsWebServer = fdfsWebServer;
        }
     
        /**
         * @param multipartFile 文件对象
         * @return 返回文件地址
         * @author qbanxiaoli
         * @description 上传文件
         */
        public static String uploadFile(MultipartFile multipartFile) {
            try {
                StorePath storePath = fastFileStorageClient.uploadFile(multipartFile.getInputStream(), multipartFile.getSize(), FilenameUtils.getExtension(multipartFile.getOriginalFilename()), null);
                return storePath.getFullPath();
            } catch (IOException e) {
                log.error(e.getMessage());
                return null;
            }
        }
     
        /**
         * @param multipartFile 图片对象
         * @return 返回图片地址
         * @author qbanxiaoli
         * @description 上传缩略图
         */
        public static String uploadImageAndCrtThumbImage(MultipartFile multipartFile) {
            try {
                StorePath storePath = fastFileStorageClient.uploadImageAndCrtThumbImage(multipartFile.getInputStream(), multipartFile.getSize(), FilenameUtils.getExtension(multipartFile.getOriginalFilename()), null);
                return storePath.getFullPath();
            } catch (Exception e) {
                log.error(e.getMessage());
                return null;
            }
        }
     
        /**
         * @param file 文件对象
         * @return 返回文件地址
         * @author qbanxiaoli
         * @description 上传文件
         */
        public static String uploadFile(File file) {
            try {
                FileInputStream inputStream = new FileInputStream(file);
                StorePath storePath = fastFileStorageClient.uploadFile(inputStream, file.length(), FilenameUtils.getExtension(file.getName()), null);
                return storePath.getFullPath();
            } catch (Exception e) {
                log.error(e.getMessage());
                return null;
            }
        }
     
        /**
         * @param file 图片对象
         * @return 返回图片地址
         * @author qbanxiaoli
         * @description 上传缩略图
         */
        public static String uploadImageAndCrtThumbImage(File file) {
            try {
                FileInputStream inputStream = new FileInputStream(file);
                StorePath storePath = fastFileStorageClient.uploadImageAndCrtThumbImage(inputStream, file.length(), FilenameUtils.getExtension(file.getName()), null);
                return storePath.getFullPath();
            } catch (Exception e) {
                log.error(e.getMessage());
                return null;
            }
        }
     
        /**
         * @param bytes byte数组
         * @param fileExtension 文件扩展名
         * @return 返回文件地址
         * @author qbanxiaoli
         * @description 将byte数组生成一个文件上传
         */
        public static String uploadFile(byte[] bytes, String fileExtension) {
            ByteArrayInputStream stream = new ByteArrayInputStream(bytes);
            StorePath storePath = fastFileStorageClient.uploadFile(stream, bytes.length, fileExtension, null);
            return storePath.getFullPath();
        }
     
        /**
         * @param fileUrl 文件访问地址
         * @param file 文件保存路径
         * @author qbanxiaoli
         * @description 下载文件
         */
        public static boolean downloadFile(String fileUrl, File file) {
            try {
                StorePath storePath = StorePath.praseFromUrl(fileUrl);
                byte[] bytes = fastFileStorageClient.downloadFile(storePath.getGroup(), storePath.getPath(), new DownloadByteArray());
                FileOutputStream stream = new FileOutputStream(file);
                stream.write(bytes);
            } catch (Exception e) {
                log.error(e.getMessage());
                return false;
            }
            return true;
        }
     
        /**
         * @param fileUrl 文件访问地址
         * @author qbanxiaoli
         * @description 删除文件
         */
        public static boolean deleteFile(String fileUrl) {
            if (StringUtils.isEmpty(fileUrl)) {
                return false;
            }
            try {
                StorePath storePath = StorePath.praseFromUrl(fileUrl);
                fastFileStorageClient.deleteFile(storePath.getGroup(), storePath.getPath());
            } catch (Exception e) {
                log.error(e.getMessage());
                return false;
            }
            return true;
        }
     
        // 封装文件完整URL地址
        public static String getResAccessUrl(String path) {
            String url = fdfsWebServer.getWebServerUrl() + path;
            log.info("上传文件地址为：\n" + url);
            return url;
        }
     
    }

**配置yml文件**

# 分布式文件系统fastdfs配置
    fdfs:
      # socket连接超时时长
      soTimeout: 1500
      # 连接tracker服务器超时时长
      connectTimeout: 600
      pool:
        # 从池中借出的对象的最大数目
        max-total: 153
        # 获取连接时的最大等待毫秒数100
        max-wait-millis: 102
      # 缩略图生成参数，可选
      thumbImage:
        width: 150
        height: 150
      # 跟踪服务器tracker_server请求地址,支持多个，这里只有一个，如果有多个在下方加- x.x.x.x:port
      trackerList:
        - 192.168.127.131:22122
      #
      # 存储服务器storage_server访问地址
      web-server-url: http://192.168.127.131/
      spring:
        http:
          multipart:
            max-file-size: 100MB # 最大支持文件大小
            max-request-size: 100MB # 最大支持请求大小

测试类
    @RunWith(SpringRunner.class)
    @SpringBootTest
    public class FileClientApplicationTests {
     
      @Test
      public void Upload() {
        String fileUrl = this.getClass().getResource("/test.jpg").getPath();
        File file = new File(fileUrl);
        String str = FastDFSClient.uploadFile(file);
        FastDFSClient.getResAccessUrl(str);
      }
     
      @Test
      public void Delete() {
        FastDFSClient.deleteFile("group1/M00/00/00/rBEAClu8OiSAFbN_AAbhXQnXzvw031.jpg");
      }
    }

**运行测试类**

**![2e453173e2ce9fa9ce3d00b1504c05d1.png][]**

**返回的 url 就是能访问的地址**

**![60ad31d730e6d5108d6741a3c1034440.png][]**

作者：kalibiubiubiu

blog.csdn.net/qq\_37759106/article/details/82981023

交流群已成立
    公众号运营至今，离不开小伙伴们的支持。为了给小伙伴们提供一个互相交流的平台，特地开通了官方交流群。扫描下方二维码备注 进群 或者关注公众号 Java后端 后获取进群通道。

推荐阅读 
    1. 推荐几个好玩的 GitHub 项目
    2. 推荐几个程序员常用的软件
    3. 图解 Spring 解决循环依赖

[0d74c477bb1ec35ed9e7d28c7414d05e.gif]: /images/20210730/806e04da246f4aef823fd1dc58f69801.png
[51c1d980bb72b424436147c53aff226c.png]: /images/20210730/0d95a4a2f49b42b5ac7fa4ee7708d5d7.png
[f3b3014efcf2cbe8452499be46bd5578.png]: /images/20210730/c2e8edb719fa4c82a34ccf694e11058d.png
[a2775a438eaffc156f79bbd1e3fdf1c4.png]: /images/20210730/b9cf76d731994179ab2de496537cf396.png
[2e453173e2ce9fa9ce3d00b1504c05d1.png]: /images/20210730/7eb38cb589984532912afc356923705e.png
[60ad31d730e6d5108d6741a3c1034440.png]: /images/20210730/64564c147cc34b2d9f6d4d2b2d5f792a.png