一、在外鏈網址已屏蔽?下載客戶端，解壓后并執行ant命令，在E:\tools\libs\fastdfs\fastdfs-client-java-master\src\build下會生成fastdfs_client.jar如圖示

二、mvn安裝fastdfs_client.jar，在cmd中執行命令

mvn install:install-file -DgroupId=org.csource -DartifactId=fastdfs-client-java -Dversion=5.0.4 -Dpackaging=jar -Dfile=D:\fastdfs_client.jar

三、在eclipse中新建maven項目fastdfs-demo，在pom.xml中加入依賴如下

xsi:schemaLocation="外鏈網址已屏蔽;外鏈網址已屏蔽">

4.0.0

com.leech

fastdfs-demo

0.0.1-SNAPSHOT

jar

fastdfs-demo

外鏈網址已屏蔽;/url>

UTF-8

junit

junit

4.11

test

org.csource

fastdfs-client-java

5.0.4

commons-io

commons-io

2.4

在src/main/resources中新建fdfs_client.conf文件，內容如下

connect_timeout = 2

network_timeout = 30

charset = UTF-8

http.tracker_http_port = 80

http.anti_steal_token = no

http.secret_key = FastDFS1234567890

tracker_server = 192.168.17.112:22122

#tracker_server = 192.168.0.119:22122

在src/main/java中創建TestFastDfs.java如下

package?com.leech.fastdfs.demo;

import?java.io.FileNotFoundException;

import?java.io.FileOutputStream;

import?java.io.IOException;

import?java.util.UUID;

import?mons.io.IOUtils;

import?mon.MyException;

import?mon.NameValuePair;

import?org.csource.fastdfs.ClientGlobal;

import?org.csource.fastdfs.FileInfo;

import?org.csource.fastdfs.StorageClient;

import?org.csource.fastdfs.StorageServer;

import?org.csource.fastdfs.TrackerClient;

import?org.csource.fastdfs.TrackerServer;

import?org.junit.After;

import?org.junit.Before;

import?org.junit.Test;

public?class?TestFastDfs?{

public?String?conf_filename?=?"D:\\stsworkspace\\fastdfs-demo\\src\\main\\resources\\fdfs_client.conf";

//public?String?local_filename?=?"D:\\stsworkspace\\fastdfs-demo\\src\\main\\resources\\fdfs_client.conf";

public?String?local_filename?=?"D:\\stsworkspace\\fastdfs-demo\\src\\main\\resources\\sprites.png";

@Before

public?void?setUp()?throws?Exception?{

}

@After

public?void?tearDown()?throws?Exception?{

}

@Test

public?void?testUpload()?{

try?{

ClientGlobal.init(conf_filename);

TrackerClient?tracker?=?new?TrackerClient();

TrackerServer?trackerServer?=?tracker.getConnection();

StorageServer?storageServer?=?null;

StorageClient?storageClient?=?new?StorageClient(trackerServer,?storageServer);

//??????????NameValuePair?nvp?=?new?NameValuePair("age",?"18");

NameValuePair?nvp?[]?=?new?NameValuePair[]{

new?NameValuePair("age",?"18"),

new?NameValuePair("sex",?"male")

};

String?fileIds[]?=?storageClient.upload_file(local_filename,?"png",?nvp);

System.out.println(fileIds.length);

System.out.println("組名："?+?fileIds[0]);

System.out.println("路徑:?"?+?fileIds[1]);

}?catch?(FileNotFoundException?e)?{

e.printStackTrace();

}?catch?(IOException?e)?{

e.printStackTrace();

}?catch?(MyException?e)?{

e.printStackTrace();

}

}

@Test

public?void?testDownload()?{

try?{

ClientGlobal.init(conf_filename);

TrackerClient?tracker?=?new?TrackerClient();

TrackerServer?trackerServer?=?tracker.getConnection();

StorageServer?storageServer?=?null;

StorageClient?storageClient?=?new?StorageClient(trackerServer,?storageServer);

byte[]?b?=?storageClient.download_file("group1",?"M00/00/00/wKgRcFV_08OAK_KCAAAA5fm_sy874.conf");

System.out.println(b);

IOUtils.write(b,?new?FileOutputStream("D:/"+UUID.randomUUID().toString()+".conf"));

}?catch?(Exception?e)?{

e.printStackTrace();

}

}

@Test

public?void?testGetFileInfo(){

try?{

ClientGlobal.init(conf_filename);

TrackerClient?tracker?=?new?TrackerClient();

TrackerServer?trackerServer?=?tracker.getConnection();

StorageServer?storageServer?=?null;

StorageClient?storageClient?=?new?StorageClient(trackerServer,?storageServer);

FileInfo?fi?=?storageClient.get_file_info("group1",?"M00/00/00/wKgRcFV_08OAK_KCAAAA5fm_sy874.conf");

System.out.println(fi.getSourceIpAddr());

System.out.println(fi.getFileSize());

System.out.println(fi.getCreateTimestamp());

System.out.println(fi.getCrc32());

}?catch?(Exception?e)?{

e.printStackTrace();

}

}

@Test

public?void?testGetFileMate(){

try?{

ClientGlobal.init(conf_filename);

TrackerClient?tracker?=?new?TrackerClient();

TrackerServer?trackerServer?=?tracker.getConnection();

StorageServer?storageServer?=?null;

StorageClient?storageClient?=?new?StorageClient(trackerServer,

storageServer);

NameValuePair?nvps?[]?=?storageClient.get_metadata("group1",?"M00/00/00/wKgRcFV_08OAK_KCAAAA5fm_sy874.conf");

for(NameValuePair?nvp?:?nvps){

System.out.println(nvp.getName()?+?":"?+?nvp.getValue());

}

}?catch?(Exception?e)?{

e.printStackTrace();

}

}

@Test

public?void?testDelete(){

try?{

ClientGlobal.init(conf_filename);

TrackerClient?tracker?=?new?TrackerClient();

TrackerServer?trackerServer?=?tracker.getConnection();

StorageServer?storageServer?=?null;

StorageClient?storageClient?=?new?StorageClient(trackerServer,

storageServer);

int?i?=?storageClient.delete_file("group1",?"M00/00/00/wKgRcFV_08OAK_KCAAAA5fm_sy874.conf");

System.out.println(?i==0???"刪除成功"?:?"刪除失敗:"+i);

}?catch?(Exception?e)?{

e.printStackTrace();

}

}

}

總結

以上是生活随笔為你收集整理的fastdfs java client_fastdfs-client-java操作fastdfs5.0.4的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。