java fastdfs客户端使用实例代码

class="properties" name="code">connect_timeout = 2network_timeout = 30charset = UTF-8http.tracker_http_port = 8080http.anti_steal_token = nohttp.secret_key = FastDFS1234567890tracker_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;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"; }

package com.chuanliu.platform.activity.fm.manager;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; } }

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;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);	}}

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());		}	}}