一、创建一个maven的web project,叫file-manager:
mvn archetype:create -DgroupId=platform.activity.filemanager -DartifactId=file-manager -DarchetypeArtifactId=maven-archetype-webapp
二、定义一个fastDFS的客户端文件fdfs_client.conf:
connect_timeout = 2 network_timeout = 30 charset = UTF-8 http.tracker_http_port = 8080 http.anti_steal_token = no http.secret_key = FastDFS1234567890 tracker_server = 192.168.1.156:22122 #tracker_server = 192.168.1.188:22122 #storage_server = 192.168.1.155:23000 #no need here
三、定义一个配置接口:
/** * */ package com.chuanliu.platform.activity.fm.manager; import java.io.Serializable; /** * @author Josh Wang(Sheng) * * @email josh_wang23@hotmail.com */ public interface FileManagerConfig extends Serializable { public static final String FILE_DEFAULT_WIDTH = "120"; public static final String FILE_DEFAULT_HEIGHT = "120"; public static final String FILE_DEFAULT_AUTHOR = "Diandi"; public static final String PROTOCOL = "http://"; public static final String SEPARATOR = "/"; public static final String TRACKER_NGNIX_PORT = "8080"; public static final String CLIENT_CONFIG_FILE = "fdfs_client.conf"; }
四、封装一个FastDFS文件Bean
/** * */ package com.chuanliu.platform.activity.fm.manager; /** * @author Josh Wang(Sheng) * * @email josh_wang23@hotmail.com */ public class FastDFSFile implements FileManagerConfig { private static final long serialVersionUID = -996760121932438618L; private String name; private byte[] content; private String ext; private String height = FILE_DEFAULT_HEIGHT; private String width = FILE_DEFAULT_WIDTH; private String author = FILE_DEFAULT_AUTHOR; public FastDFSFile(String name, byte[] content, String ext, String height, String width, String author) { super(); this.name = name; this.content = content; this.ext = ext; this.height = height; this.width = width; this.author = author; } public FastDFSFile(String name, byte[] content, String ext) { super(); this.name = name; this.content = content; this.ext = ext; } public byte[] getContent() { return content; } public void setContent(byte[] content) { this.content = content; } public String getExt() { return ext; } public void setExt(String ext) { this.ext = ext; } public String getHeight() { return height; } public void setHeight(String height) { this.height = height; } public String getWidth() { return width; } public void setWidth(String width) { this.width = width; } public String getAuthor() { return author; } public void setAuthor(String author) { this.author = author; } public String getName() { return name; } public void setName(String name) { this.name = name; } }
五、定义核心的FileManager类,里面包含有上传、删除、获取文件的方法:
/** * */ package com.chuanliu.platform.activity.fm.manager; import java.io.File; import java.io.IOException; import org.apache.log4j.Logger; import org.csource.common.NameValuePair; import org.csource.fastdfs.ClientGlobal; import org.csource.fastdfs.FileInfo; import org.csource.fastdfs.ServerInfo; import org.csource.fastdfs.StorageClient; import org.csource.fastdfs.StorageServer; import org.csource.fastdfs.TrackerClient; import org.csource.fastdfs.TrackerServer; import com.chuanliu.platform.activity.basic.util.LoggerUtils; /** * File Manager used to provide the services to upload / download / delete the files * from FastDFS. * * <note>In this version, FileManager only support single tracker, will enhance this later...</note> * * @author Josh Wang(Sheng) * * @email josh_wang23@hotmail.com */ public class FileManager implements FileManagerConfig { private static final long serialVersionUID = 1L; private static Logger logger = Logger.getLogger(FileManager.class); private static TrackerClient trackerClient; private static TrackerServer trackerServer; private static StorageServer storageServer; private static StorageClient storageClient; static { // Initialize Fast DFS Client configurations try { String classPath = new File(FileManager.class.getResource("/").getFile()).getCanonicalPath(); String fdfsClientConfigFilePath = classPath + File.separator + CLIENT_CONFIG_FILE; logger.info("Fast DFS configuration file path:" + fdfsClientConfigFilePath); ClientGlobal.init(fdfsClientConfigFilePath); trackerClient = new TrackerClient(); trackerServer = trackerClient.getConnection(); storageClient = new StorageClient(trackerServer, storageServer); } catch (Exception e) { LoggerUtils.error(logger, e); } } public static String upload(FastDFSFile file) { LoggerUtils.info(logger, "File Name: " + file.getName() + " File Length: " + file.getContent().length); NameValuePair[] meta_list = new NameValuePair[3]; meta_list[0] = new NameValuePair("width", "120"); meta_list[1] = new NameValuePair("heigth", "120"); meta_list[2] = new NameValuePair("author", "Diandi"); long startTime = System.currentTimeMillis(); String[] uploadResults = null; try { 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) { LoggerUtils.error(logger, "upload file fail, error code: " + storageClient.getErrorCode()); } String groupName = uploadResults[0]; String remoteFileName = uploadResults[1]; String fileAbsolutePath = PROTOCOL + trackerServer.getInetSocketAddress().getHostName() + SEPARATOR + TRACKER_NGNIX_PORT + SEPARATOR + groupName + SEPARATOR + remoteFileName; LoggerUtils.info(logger, "upload file successfully!!! " +"group_name: " + groupName + ", remoteFileName:" + " " + remoteFileName); return fileAbsolutePath; } public static FileInfo getFile(String groupName, String remoteFileName) { try { return storageClient.get_file_info(groupName, remoteFileName); } catch (IOException e) { logger.error("IO Exception: Get File from Fast DFS failed", e); } catch (Exception e) { logger.error("Non IO Exception: Get File from Fast DFS failed", e); } return null; } public static void deleteFile(String groupName, String remoteFileName) throws Exception { storageClient.delete_file(groupName, remoteFileName); } public static StorageServer[] getStoreStorages(String groupName) throws IOException { return trackerClient.getStoreStorages(trackerServer, groupName); } public static ServerInfo[] getFetchStorages(String groupName, String remoteFileName) throws IOException { return trackerClient.getFetchStorages(trackerServer, groupName, remoteFileName); } }
六、Unit Test测试类
package manager; /** * */ import java.io.File; import java.io.FileInputStream; import org.csource.fastdfs.FileInfo; import org.csource.fastdfs.ServerInfo; import org.csource.fastdfs.StorageServer; import org.junit.Test; import org.springframework.util.Assert; import com.chuanliu.platform.activity.fm.manager.FastDFSFile; import com.chuanliu.platform.activity.fm.manager.FileManager; /** * @author Josh Wang(Sheng) * * @email josh_wang23@hotmail.com */ public class TestFileManager { @Test public void upload() throws Exception { File content = new File("C:\\520.jpg"); FileInputStream fis = new FileInputStream(content); byte[] file_buff = null; if (fis != null) { int len = fis.available(); file_buff = new byte[len]; fis.read(file_buff); } FastDFSFile file = new FastDFSFile("520", file_buff, "jpg"); String fileAbsolutePath = FileManager.upload(file); System.out.println(fileAbsolutePath); fis.close(); } @Test public void getFile() throws Exception { FileInfo file = FileManager.getFile("group1", "M00/00/00/wKgBm1N1-CiANRLmAABygPyzdlw073.jpg"); Assert.notNull(file); String sourceIpAddr = file.getSourceIpAddr(); long size = file.getFileSize(); System.out.println("ip:" + sourceIpAddr + ",size:" + size); } @Test public void getStorageServer() throws Exception { StorageServer[] ss = FileManager.getStoreStorages("group1"); Assert.notNull(ss); for (int k = 0; k < ss.length; k++){ System.err.println(k + 1 + ". " + ss[k].getInetSocketAddress().getAddress().getHostAddress() + ":" + ss[k].getInetSocketAddress().getPort()); } } @Test public void getFetchStorages() throws Exception { ServerInfo[] servers = FileManager.getFetchStorages("group1", "M00/00/00/wKgBm1N1-CiANRLmAABygPyzdlw073.jpg"); Assert.notNull(servers); for (int k = 0; k < servers.length; k++) { System.err.println(k + 1 + ". " + servers[k].getIpAddr() + ":" + servers[k].getPort()); } } }
相关代码见附件的zip包。
使用方法:
将zip包解压后,直接在eclipse import existing maven projec。
相关推荐
通过java向fastdfs上传文件实例
FastDFS 整合java实例,欢迎大家下载使用。 恩
java 集成 fastdfs - spring mvc 集成 java 集成 fastdfs - spring mvc 集成 java 集成 fastdfs - spring mvc 集成 java 集成 fastdfs - spring mvc 集成 java 集成 fastdfs - spring mvc 集成
解决 Maven 无法下载 fastdfs-client-java-1.29-SNAPSHOT 依赖,直接下载之后用maven命令存储到本地maven仓库即可。 maven命令 mvn install:install-file -DgroupId=org.csource -DartifactId=fastdfs-client-java ...
fastdfs-client-java-1.27-RELEASE 版本 很实用 spring boot整合fastdfs
fastdfs-client-java-1.27-SNAPSHOT.jar fastdfs-client-java-1.27-SNAPSHOT.pom
FastDFS 搭建,及其JAVA客户端使用FastDFS 搭建,及其JAVA客户端使用FastDFS 搭建,及其JAVA客户端使用
FastDFS文件操作-java,pom.xml引入依赖 <!-- fastDFS依赖就一个 --> <groupId>net.oschina.zcx7878</groupId> <artifactId>fastdfs-client-java <version>1.27.0.0 </dependencies>
FastDFS 整合java实例
fastdfs的客户端java代码实例
fastdfs-client-java-1.25.jar包
经验一:FastDFS文件下载恢复原始文件名 经验二:从文件的使用技巧
FastDFS java client SDK FastDFS Java Client API may be copied only under the terms of the BSD license. 使用ant从源码构建 ant clean package 使用maven从源码安装 mvn clean install 使用maven从jar文件安装...
fastdfs 安装及使用,里面包含了fastdfs安装需要的软件,以及java-api工程,和使用实例
fastdfs-client-java-1.27 客户端,保证可用