SpringBoot整合FastDFS

Java客户端/依赖

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

常用api接口解释

1.uploadFile

uploadFile(String groupName, InputStream inputStream, long fileSize, String fileExtName)

参数

• groupName：上传文件所属的组名。
• inputStream：输入流对象，指向要上传的文件内容。
• fileSize：上传文件的大小，单位为字节。
• fileExtName：上传文件的扩展名。

返回值

返回值：一个 StorePath 对象，其中封装文件的路径和 store 节点的地址。

2.uploadSlaveFile

uploadSlaveFile(String groupName, String masterFilename, InputStream inputStream, long fileSize, String prefixName, String fileExtName)

参数

• groupName：文件上传到的组名。
• masterFilename：主文件的名称。
• inputStream：从文件的输入流对象。
• fileSize：上传从文件的大小，单位为字节。
• prefixName: 从文件名前缀
• fileExtName：从文件的扩展名

返回值

返回值：一个 StorePath 对象，表示成功上传后从文件存储的路径信息。

3.getMetadata

getMetadata(String groupName, String path)

参数

• groupName：文件所属的分组名。
• path：文件的在 FastDFS 存储中真实的路径。

返回值

返回值：Set 集合，其中包含多组 metadata 信息。每一条 metadata 是 k-v 形式的键值对。如果没有找到对应的 metadata 信息，则返回一个空的集合。

4.overwriteMetadata

overwriteMetadata(String groupName, String path, Set metaDataSet)

参数：

• groupName：文件所属的分组名。
• path：文件在 FastDFS 存储中真实的路径。
• metaDataSet：要覆盖的新的 metadata 集合。

返回值：无

5.mergeMetadata

mergeMetadata(String groupName, String path, Set metaDataSet)

参数：

• groupName：文件所属的分组名。
• path：文件在 FastDFS 存储中真实的路径。
• metaDataSet：待合并的metadata集合。

返回值：无

6.queryFileInfo

queryFileInfo(String groupName, String path)

参数：

• groupName：文件所属的组名。
• path：文件在 FastDFS 存储中真实的路径。

返回值

返回值：一个 FileInfo 对象，包含了文件的元数据信息。

7.deleteFile

deleteFile(String groupName, String path)

参数：

• groupName：文件所属的组名。
• path：文件在 FastDFS 存储中真实的路径。

返回值：无

8.downloadFile

downloadFile(String groupName, String path, DownloadCallback callback)

参数

• groupName：文件所属的组名。
• path：文件在 FastDFS 存储中真实的路径。
• callback：下载回调接口对象。

返回值

返回值：一个泛型值对象 T，表示经过回调方法处理后的结果。

9.downloadFile

downloadFile(String groupName, String path, long fileOffset, long fileSize, DownloadCallback callback)

参数

• groupName：文件所属的组名。
• path：文件在 FastDFS 存储中真实的路径。
• fileOffset：文件偏移量，从哪个地方开始下载。
• fileSize：要下载的文件大小。
• callback：下载回调接口对象。

返回值

返回值：一个泛型值对象 T，表示经过回调方法处理后的结果。

代码测试

yml配置

fdfs:
# 超时时间connect_timeout: 5000# 读取时间so_timeout: 30000# 服务地址列表tracker-list: 192.168.29.31:22122
# 解决限制文件大小
spring:servlet:multipart:max-request-size: 1TBmax-file-size: 1TB

工具类

package com.zjl.util;import com.github.tobato.fastdfs.domain.fdfs.StorePath;
import com.github.tobato.fastdfs.domain.proto.storage.DownloadByteArray;
import com.github.tobato.fastdfs.service.FastFileStorageClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpStatus;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Component;
import org.springframework.web.multipart.MultipartFile;import javax.annotation.Resource;
import java.io.IOException;
import java.nio.charset.StandardCharsets;/*** @author: zjl* @datetime: 2024/4/7* @desc:*/
@Component
public class FastdfsUtil {@Resourceprivate FastFileStorageClient storageClient;/*** 上传** @param file* @return*/public String upload(MultipartFile file) {// 获取文件名String filename = file.getOriginalFilename();// 得到文件扩展名String extName = filename.substring(filename.lastIndexOf(".") + 1);StorePath storePath = null;try {// 上传storePath = storageClient.uploadFile(file.getInputStream(), file.getSize(), extName, null);// 这个getFullPath是fastdfs返回的id，可通过这个实现图片浏览、视频播放、文件下载等操作return storePath.getFullPath();} catch (IOException e) {throw new RuntimeException(e);}}/*** 下载文件（写二进制流）* @param path* @return*/public ResponseEntity<byte[]> download(String fileName ,String path,HttpServletRequest request) throws Exception {StorePath storePath = StorePath.parseFromUrl(path);String substring = path.substring(path.lastIndexOf("."));byte[] data = storageClient.downloadFile(storePath.getGroup(), storePath.getPath(), new DownloadByteArray());fileName = this.getFilename(request,fileName);HttpHeaders httpHeaders = new HttpHeaders();// 设置下载响应类型以及文件名httpHeaders.setContentType(MediaType.APPLICATION_OCTET_STREAM);httpHeaders.setContentDispositionFormData("attachment",fileName+substring );return new ResponseEntity<>(data,httpHeaders, HttpStatus.OK);}//解决中文下载问题public String getFilename(HttpServletRequest request, String filename) throws Exception {//ie浏览器的编码格式String[] IEBrowserWords = {"MSIE","Trident","Edge"};String userAgent = request.getHeader("User-Agent");for (String ieBrowserWord : IEBrowserWords) {if(userAgent.contains(ieBrowserWord)){return URLEncoder.encode(filename,"UTF-8");}}//其他浏览器就采用这种编码格式return new String(filename.getBytes("UTF-8"),"ISO-8859-1");}
}

上传

Controller

package com.zjl.controller;import com.zjl.util.FastdfsUtil;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;import javax.annotation.Resource;/*** @author: zjl* @datetime: 2024/4/7* @desc:*/
@RestController
public class MyFileController {@Resourceprivate FastdfsUtil fastdfsUtil;@PostMapping("/upload")public String upload(MultipartFile file){return fastdfsUtil.upload(file);}
}

测试

直接访问这个地址：http://192.168.29.31:8888/group1/M00/00/00/wKgdH2YSNj2ABnBCAAEQeS5bVeM384.jpg

下载

Controller

@GetMapping("/download")public ResponseEntity<byte[]> download(HttpServletRequest request) throws Exception {//假设这是从其他业务层获取的文件路径String filePath = "group1/M00/00/00/wKgdH2YSNj2ABnBCAAEQeS5bVeM384.jpg";String fileName = "Spring权限管理";return fastdfsUtil.download(fileName,filePath,request);}

测试