springboot集成fastDfs过程代码实例

springboot集成fastDfs过程代码实例

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

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 ResultDataUthttp://il.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 uploadFileShttp://tream(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){

ResultData 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;

}

}

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。