使用Spring Boot集成FastDFS

1、pom包配置

我们使用Spring Boot最新版本1.5.9、jdk使用1.8、tomcat8.0。

Java

加入了 fastdfs-client-java包，用来调用FastDFS相关的API。

2、配置文件

resources目录下添加 fdfs_client.conf文件

使用Spring Boot集成FastDFS

Java

配置文件设置了连接的超时时间，编码格式以及tracker_server地址等信息

3、封装FastDFS上传工具类

封装FastDFSFile，文件基础信息包括文件名、内容、文件类型、作者等。

使用Spring Boot集成FastDFS

Java

封装FastDFSClient类，包含常用的上传、下载、删除等方法。

首先在类加载的时候读取相应的配置信息，并进行初始化。

static{
try{
String filePath =newClassPathResource("fdfs_client.conf").getFile().getAbsolutePath();;
ClientGlobal.init(filePath);
trackerClient =newTrackerClient();
trackerServer = trackerClient.getConnection();
storageServer = trackerClient.getStoreStorage(trackerServer);
}catch(Exception e){
logger.error("FastDFS Client Init Fail!",e);
}
}

文件上传

publicstaticString[] upload(FastDFSFile file){
logger.info("File Name: "+ file.getName()+"File Length:"+ file.getContent().length);
NameValuePair[] meta_list =newNameValuePair[1];
meta_list[0]=newNameValuePair("author", file.getAuthor());
long startTime =System.currentTimeMillis();
String[] uploadResults =null;
try{
storageClient =newStorageClient(trackerServer, storageServer);
uploadResults = storageClient.upload_file(file.getContent(), file.getExt(), meta_list);
}catch(IOException e){
logger.error("IO Exception when uploadind the file:"+ file.getName(), e);
}catch(Exception e){
logger.error("Non IO Exception when uploadind the file:"+ file.getName(), e);
}
logger.info("upload_file time used:"+(System.currentTimeMillis()- startTime)+" ms");
if(uploadResults ==null){
logger.error("upload file fail, error code:"+ storageClient.getErrorCode());
}
String groupName = uploadResults[0];
String remoteFileName = uploadResults[1];
logger.info("upload file successfully!!!"+"group_name:"+ groupName +", remoteFileName:"+" "+ remoteFileName);
return uploadResults;
}