首先说一下从零开始自己去搭一个fastdfs有多不顺，搭起来步骤繁琐,很麻烦，后来看到有人把做好的docker镜像传出来了，那搭建起来就很容易了
有服务器的可以自己在服务器上玩玩,没有的可以新建一个centos7.5虚拟机玩玩，遇到虚拟机不能上网和换阿里云的源的问题可以参考：
《解决centos7虚拟机不能上网并换成阿里云的源 》
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就搭建好啦
下面进入springboot整合部分
加入依赖
<dependency> <groupId>com.github.tobato</groupId> <artifactId>fastdfs-client</artifactId> <version>1.26.2</version> </dependency>
在springboot启动类上加
@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) @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"); } }
运行测试类
返回的url就是能访问的地址
最后一张看效果
