fastdfs删除过期文件_SpringBoot2.0整合FastDFS

前一篇&＃xff0c;我们使用docker来部署FastDFS(见使用Docker来搭建fastdfs)&＃xff0c;这一天我们来试着使用SpringBoot2.0来访问FastDFS

采用maven配置

1、配置依赖包&＃xff0c;修改pom文件

com.github.tobato fastdfs-client 1.26.5

2、springboot配置文件添加

fdfs: # 链接超时 connect-timeout: 60 # 读取时间 so-timeout: 60 # 生成缩略图参数 thumb-image: width: 150 height: 150 tracker-list: 192.168.72.130:22122

3、核心配置类

import org.springframework.context.annotation.Configuration;import org.springframework.context.annotation.EnableMBeanExport;import org.springframework.context.annotation.Import;import org.springframework.jmx.support.RegistrationPolicy;import com.github.tobato.fastdfs.FdfsClientConfig;&＃64;Configuration&＃64;Import(FdfsClientConfig.class)// Jmx重复注册bean的问题&＃64;EnableMBeanExport(registration &＃61; RegistrationPolicy.IGNORE_EXISTING)public class DfsConfig {}

4、文件工具类&＃xff0c;自己按实际去修改

&＃64;Slf4jpublic class FileDfsUtil { &＃64;Resource private FastFileStorageClient storageClient ; /** * 上传文件 */ public String upload(MultipartFile multipartFile) throws Exception{ String originalFilename &＃61; multipartFile.getOriginalFilename(). substring(multipartFile.getOriginalFilename(). lastIndexOf(".") &＃43; 1); StorePath storePath &＃61; this.storageClient.uploadImageAndCrtThumbImage( multipartFile.getInputStream(), multipartFile.getSize(),originalFilename , null); return storePath.getFullPath() ; } /** * 删除文件 */ public void deleteFile(String fileUrl) { if (StringUtils.isEmpty(fileUrl)) { log.info("fileUrl &＃61;&＃61; >>文件路径为空..."); return; } try { StorePath storePath &＃61; StorePath.parseFromUrl(fileUrl); storageClient.deleteFile(storePath.getGroup(), storePath.getPath()); } catch (Exception e) { log.info(e.getMessage()); } }

4、请求代码示例

&＃64;RequestMapping("/fastDfs")&＃64;ResponseBodypublic Object fastDfs() throws IOException{File fileRoot&＃61;new File("F:/images");File[] files&＃61;fileRoot.listFiles(); for(File file:files){ FileInputStream inputFile &＃61; new FileInputStream(file); byte[] buffer &＃61; new byte[(int)file.length()]; inputFile.read(buffer); inputFile.close(); return fileDfsUtil.uploadFile(Base64Utils.encodeToString(buffer), "jpg"); } return 1;}

请求上面接口后返回

访问 nginx地址

http://127.0.0.1:8888/group1/M00/00/00/rBAGil5Xb5aAON-EAAJV6tHqsvQ252.jpg

可以显示图片&＃xff0c;即为成功

需要注意的是必须保证springboot所在服务器可以访问storage的网络 例如可以访问storage:23000端口(当然tracker的端口也必须可以访问)