胖虎的工具箱-编程导航 胖虎的工具箱-编程导航

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

2年前 (2022) 程序员胖胖胖虎阿
314 0 0

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

首先说一下从零开始自己去搭一个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

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

能返回 url 就意见搭建成功

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

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

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

创建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");
  }
}









  运行测试类

 



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

 



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

 


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



  作者：kalibiubiubiu

 


blog.csdn.net/qq_37759106/article/details/82981023



   
   
   

 
    
    
    

  
     
     
     
交流群已成立

 
    
    
    


   
   
   


   
   
   

 
    
    
    

  
     
     
     

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

  
     
     
     

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

 
    
    
    


   
   
   



   
   
   

 
    
    
    推荐阅读 

   
   
   


   
   
   

 
    
    
    1. 推荐几个好玩的 GitHub 项目

   
   
   


   
   
   

 
    
    
    2. 推荐几个程序员常用的软件

   
   
   


   
   
   

 
    
    
    3.
 
    
    
     图解 Spring 解决循环依赖

   
   
   


   
   
   

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

本文分享自微信公众号 - Java后端（web_resource）。
如有侵权，请联系 support@oschina.cn 删除。
本文参与“OSC源创计划”，欢迎正在阅读的你也加入，一起分享。

版权声明：程序员胖胖胖虎阿 发表于 2022年11月24日 上午1:32。
转载请注明：Docker + FastDFS + Spring Boot 一键式搭建分布式文件服务器 | 胖虎的工具箱-编程导航

相关文章

IntelliJ IDEA2021激活码(idea的专业版破解教程,最新有效IDEA激活码)
程序员胖胖胖虎阿
234
IntelliJ IDEA2022.2激活破解教程(IntelliJ IDEA2019 破解教程,激活至2099年)
程序员胖胖胖虎阿
247
IntelliJ IDEA正版注册码(IntelliJ IDEA2022.1破解版每日更新)
程序员胖胖胖虎阿
281
JavaEE——Session会话追踪的实现机制
程序员胖胖胖虎阿
220
从零学习Spring Boot-入门起步
程序员胖胖胖虎阿
294
JVM面试题(面试必备)
程序员胖胖胖虎阿
209

暂无评论

暂无评论...
致力于称为最好的程序员导航网站

友链申请 免责声明 关于我们

Copyright © 2022  胖虎的工具箱-编程导航   陇ICP备2022001249号