springboot集成fastDfs过程代码实例
这篇文章主要介绍了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=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=
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
@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<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;
}
}
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持无名。
同类资源
- 超大文件MD5效验,端口Ping工具,远程连接等小工具集成
超大文件MD5效验,端口Ping工具,远程连接等小工具集成例子源代码,支持中英文转换纯源码,技术含量看过的人你们...
- Java基于springboot教务管理系统
Java基于springboot教务管理系统本文件感兴趣的可以参考一下,帮助学校管理教务系统,用一个帐号解决学校教务...
- springBootNoMaven实现定时任务功能
springBootNoMaven本文件感兴趣的可以参考一下,不使用maven环境,创建springboot项目,实现了定时任务功能简单...
- AIP集成模块
易语言AIP集成模块例子,添加模块应用后直接可以查看具体的使用方法了。...
- 祥云模块1.8集成大漠3.1254天使3.007免注册调用与大漠多线程
易语言祥云模块1.8集成大漠3.1254天使3.007免注册调用与大漠多线程例子,添加模块应用后直接可以查看具体的...
- 管理集成RK816技术手册
RK816技术手册,RK816是一种复杂的电源管理集成电路,可以提供一个完整的电源管理解决方案,只有很少的外部组件...
- 大漠模块集成免费版和收费版及常用功能
易语言大漠模块集成免费版和收费版及常用功能例子源代码,分享一下自己做的模块,集成免费版3.1233的大漠,以及...
- 个人常用大漠插件模块开源,集成了3.1233和7.1926版
易语言个人常用大漠插件模块开源例子源代码,之前分享了个人用的大漠模块1.0版,今天重新修改了下,现在分享源...
- 简单的追梦模块集成了反调试
易语言简单的模块集成了反调试例子源代码。...
- 个人常用模块集成最新大漠和精易模块和多线程模块
易语言个人常用模块集成最新大漠和精易模块和多线程模块例子源代码,由于那个模块是我才用大漠没多久写的,对...
- 开发集成系统
开发集成系统例子源代码,客户端账号管理系统。...
- php集成封装含教程
易语言php集成封装含教程例子源代码,这是php源码和php教程。...