这篇文章主要介绍了springboot集成fastDfs过程代码实例,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

pom.xml　　引入依赖

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

application.properties　　配置

# fastDfs配置fdfs.connect-timeout=600fdfs.so-timeout=1500fdfs.trackerList=192.168.1.207:22122fdfs.thumbImage.height=150fdfs.thumbImage.width=150spring.jmx.enabled=falsefdfs.pool.max-total=200storage.resHost=http://192.168.1.207/storage.resPort=8888

DfsAutoConfig.java　　自动注入

@Configuration@Import(FdfsClientConfig.class)@EnableMBeanExport(registration = RegistrationPolicy.IGNORE_EXISTING)public class DfsAutoConfig {}

DfsResConfig　　配置映射关系

@Data@Component@ConfigurationProperties("storage")public class DfsResConfig { private String resHost; private String resPort;}F
<em id="__mceDel">FastDfsClientUtil　　工具类<br></em>@Slf4j@Componentpublic class FastDfsClientUtil { @Autowired private FastFileStorageClient storageClient; /** * @Author AlanMa * @Description MultipartFile类型的文件上传ַ * @Date 2019/11/12 * @Param [file] * @return com.hiynn.data.visual.file.vo.ResultData<java.lang.String> */ public ResultData<String> uploadFile(MultipartFile file){ try{ StorePath path = storageClient.uploadFile(file.getInputStream(), file.getSize(), FilenameUtils.getExtension(file.getOriginalFilename()), null); return ResultDataUtil.setSuccessResult(path.getFullPath()); }catch (Exception e){ e.printStackTrace(); return ResultDataUtil.setFailedResult(); } } /** * @Author AlanMa * @Description 普通的文件上传 * @Date 2019/11/12 * @Param [file] * @return com.hiynn.data.visual.file.vo.ResultData<java.lang.String> */ public ResultData<String> uploadFile(File file){ try{ FileInputStream inputStream = new FileInputStream(file); StorePath path = storageClient.uploadFile(inputStream, file.length(), FilenameUtils.getExtension(file.getName()), null); return ResultDataUtil.setSuccessResult(path.getFullPath()); }catch (Exception e){ e.printStackTrace(); return ResultDataUtil.setFailedResult(); } } /** * @Author AlanMa * @Description 带输入流形式的文件上传 * @Date 2019/11/12 * @Param [is, size, fileName] * @return com.hiynn.data.visual.file.vo.ResultData<java.lang.String> */ public ResultData<String> uploadFileStream(InputStream is, long size, String fileName) { StorePath path = storageClient.uploadFile(is, size, fileName, null); return ResultDataUtil.setSuccessResult(path.getFullPath()); } /** * @Author AlanMa * @Description 将一段文本文件写到fastdfs的服务器上 * @Date 2019/11/12 * @Param [content, fileExtension] * @return java.lang.String */ public String uploadFile(String content, String fileExtension) { byte[] buff = content.getBytes(Charset.forName("UTF-8")); ByteArrayInputStream stream = new ByteArrayInputStream(buff); StorePath path = storageClient.uploadFile(stream, buff.length, fileExtension, null); return path.getFullPath(); } /** * @Author AlanMa * @Description 删除文件 * @Date 2019/11/12 * @Param [fileUrl] * @return com.hiynn.data.visual.file.vo.ResultData */ public ResultData deleteFile(String fileUrl) { if (StringUtils.isEmpty(fileUrl)) { return ResultDataUtil.setFailedResult(); } try { StorePath storePath = StorePath.praseFromUrl(fileUrl); storageClient.deleteFile(storePath.getGroup(), storePath.getPath()); return ResultDataUtil.setSuccessResult(); } catch (FdfsUnsupportStorePathException e) { e.printStackTrace(); log.warn(e.getMessage()); return ResultDataUtil.setFailedResult(); } }//// / * @Author AlanMa// * @Description 上传文件图片// * @Date 2019/11/12// * @Param [is, size, fileExtName, metaData]// * @return java.lang.String// */// public String upfileImage(InputStream is, long size, String fileExtName, Set<MateData> metaData) {// StorePath path = storageClient.uploadImageAndCrtThumbImage(is, size, fileExtName, metaData);// return path.getFullPath();// }}

测试

@Slf4j@RestController@RequestMapping("/dfs")public class FileDfsController extends BaseController { @Autowired private FastDfsClientUtil fastDfsClientUtil; @Autowired private DfsResConfig dfsResConfig; @PostMapping("/single") public ResultData singleUpload(@RequestParam("file") MultipartFile file){ ResultData<String> resultData = fastDfsClientUtil.uploadFile(file); if (Objects.equals(ResultEnum.SUCCESS.getCode(), resultData.getCode())) { String url = String.format("%s:%s/%s",dfsResConfig.getResHost(),dfsResConfig.getResPort(),resultData.getData()); return ResultDataUtil.setSuccessResult(url); } return resultData; }}

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。