关于java:Docker-Spring-Boot-FastDFS-搭建一套分布式文件服务器太强了

37次阅读

共计 5804 个字符，预计需要花费 15 分钟才能阅读完成。

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

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

能返回 url 就意见搭建胜利

这样 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)

创立 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)@SpringBootTestpublic 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"); }}

运行测试类

返回的 url 就是能拜访的地址

原文链接：https://blog.csdn.net/qq_3775…

版权申明：本文为 CSDN 博主「kalibiubiubiu」的原创文章，遵循 CC 4.0 BY-SA 版权协定，转载请附上原文出处链接及本申明。

近期热文举荐：

1.1,000+ 道 Java 面试题及答案整顿 (2021 最新版)

2. 别在再满屏的 if/ else 了，试试策略模式，真香！！

3. 卧槽！Java 中的 xx ≠ null 是什么新语法？

4.Spring Boot 2.6 正式公布，一大波新个性。。

5.《Java 开发手册（嵩山版）》最新公布，速速下载！

感觉不错，别忘了顺手点赞 + 转发哦！

正文完
java
发表至： java
2021-11-24
 0
关于java:MyBatisPlus之分页插件使用
关于java:java开发之JVM基础知识分享
关于java:原来-springxml-配置的-destroymethod-需要用到向虚拟机注册钩子来实现
力扣(LeetCode)47