springboot中怎么集成fastDfs
springboot中怎么集成fastDfs,很多新手对此不是很清楚,为了帮助大家解决这个难题,下面小编将为大家详细讲解,有这方面需求的人可以来学习下,希望你能有所收获。
创新互联公司专注于企业全网营销推广、网站重做改版、盐湖网站定制设计、自适应品牌网站建设、H5技术、商城网站建设、集团公司官网建设、成都外贸网站建设公司、高端网站制作、响应式网页设计等建站业务,价格优惠性价比高,为盐湖等各大城市提供网站开发制作服务。
pom.xml 引入依赖
com.github.tobato fastdfs-client 1.26.1-RELEASE
application.properties 配置
# fastDfs配置 fdfs.connect-timeout=600 fdfs.so-timeout=1500 fdfs.trackerList=192.168.1.207:22122 fdfs.thumbImage.height=150 fdfs.thumbImage.width=150 spring.jmx.enabled=false fdfs.pool.max-total=200 storage.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
FastDfsClientUtil 工具类
@Slf4j @Component public class FastDfsClientUtil { @Autowired private FastFileStorageClient storageClient; /** * @Author AlanMa * @Description MultipartFile类型的文件上传ַ * @Date 2019/11/12 * @Param [file] * @return com.hiynn.data.visual.file.vo.ResultData*/ public ResultData 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 */ public ResultData 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 */ public ResultData 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 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){ ResultDataresultData = 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; } }
看完上述内容是否对您有帮助呢?如果还想对相关知识有进一步的了解或阅读更多相关文章,请关注创新互联行业资讯频道,感谢您对创新互联的支持。
网页名称:springboot中怎么集成fastDfs
本文地址:http://scyanting.com/article/jojhps.html