1 <dependency>
2    <groupId>org.csource</groupId>
3    <artifactId>fastdfs-client-java</artifactId>
4    <version>5.0.4</version>
5 </dependency>

package com.hafiz.fastdfs;import java.io.FileNotFoundException;
import java.io.IOException;import org.csource.common.MyException;
import org.csource.fastdfs.ClientGlobal;
import org.csource.fastdfs.StorageClient;
import org.csource.fastdfs.StorageServer;
import org.csource.fastdfs.TrackerClient;
import org.csource.fastdfs.TrackerServer;
import org.junit.Test;import com.taotao.common.utils.FastDFSClient;public class FastdfsTest {private static final String CONFIGLOCATION = "D:\\fastdfs_client.conf";@Testpublic void testUploadImg () {try {// 初始化全局配置。加载client配置文件
            ClientGlobal.init(CONFIGLOCATION);// 创建一个TrackerClient对象TrackerClient trackerClient = new TrackerClient();// 创建一个TrackerServer对象TrackerServer trackerServer = trackerClient.getConnection();// 声明一个StorageServer对象并初始为nullStorageServer storageServer = null;// 获得StorageClient对象StorageClient storageClient = new StorageClient(trackerServer, storageServer);// 直接调用StorageClient对象方法上传文件即可String[] result = storageClient.upload_file("D:\\Documents\\Downloads\\高圆圆2.jpg", "jpg", null);for(String item : result) {System.out.println(item);}trackerServer.close();} catch (FileNotFoundException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();} catch (MyException e) {e.printStackTrace();}}@Testpublic void fastDfsClientTest() {try {FastDFSClient client = new FastDFSClient(CONFIGLOCATION);String imgUrl = client.uploadFile("D:\\Documents\\Downloads\\高圆圆1.jpg", "jpg", null);System.out.println(imgUrl);} catch (Exception e) {e.printStackTrace();}}
}

package com.hafiz.common.utils;import org.csource.common.NameValuePair;
import org.csource.fastdfs.ClientGlobal;
import org.csource.fastdfs.StorageClient1;
import org.csource.fastdfs.StorageServer;
import org.csource.fastdfs.TrackerClient;
import org.csource.fastdfs.TrackerServer;public class FastDFSClient {private TrackerClient trackerClient = null;private TrackerServer trackerServer = null;private StorageServer storageServer = null;private StorageClient1 storageClient = null;public FastDFSClient(String conf) throws Exception {if (conf.contains("classpath:")) {String url = this.getClass().getResource("/").getPath();url = url.substring(1);conf = conf.replace("classpath:", url);}ClientGlobal.init(conf);trackerClient = new TrackerClient();trackerServer = trackerClient.getConnection();storageServer = null;storageClient = new StorageClient1(trackerServer, storageServer);}public String uploadFile(String fileName, String extName, NameValuePair[] metas) throws Exception {return storageClient.upload_file1(fileName, extName, metas);}public String uploadFile(String fileName, String extName) throws Exception {return storageClient.upload_file1(fileName, extName, null);}public String uploadFile(String fileName) throws Exception {return storageClient.upload_file1(fileName, null, null);}public String uploadFile(byte[] fileContent, String extName, NameValuePair[] metas) throws Exception {return storageClient.upload_file1(fileContent, extName, metas);}public String uploadFile(byte[] fileContent, String extName) throws Exception {return storageClient.upload_file1(fileContent, extName, null);}public String uploadFile(byte[] fileContent) throws Exception {return storageClient.upload_file1(fileContent, null, null);}}