- sudo fdfs_test %FastDFS%/conf/client.conf upload a.txt
test里测试文件返回链接仅为示例，无法打开正常
配置总结：
很简单，基本只要把conf里local path, server address, port number， group name定义一下即可
没有web UI，这个分布式系统简陋的有点让人无法接受，还好Java API比较简单，功能简单，使用简单
附实例一择，上传文件到指定Group，已修改并测试
不明白为什么明明Cluster里设置了四个Storage Server并且全部可以上传文件成功，但这里只显示一个，实在懒得搞清楚
import java.io.File;
import java.io.FileInputStream;
import org.csource.common.NameValuePair;
import org.csource.fastdfs.ClientGlobal;
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;
/**
- 测试上传
- @author gary
- */
public class TestUpload {
public static void main(String[] args) throws Exception{
// String classPath = new File(TestUpload.class.getResource(“/“).getFile()).getCanonicalPath();
// String configFilePath = classPath + File.separator + “fdfs_client.conf”;
String configFilePath = “/usr/FastDFS/conf/client.conf”;
System.out.println(“配置文件:” + configFilePath);
ClientGlobal.init(configFilePath);
TrackerClient trackerClient = new TrackerClient();
TrackerServer trackerServer = trackerClient.getConnection();
StorageServer storageServer = null;
StorageClient storageClient = new StorageClient(trackerServer, storageServer);
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”, “gary”);
// byte[] file_buff = “F:\pic.jpg”.getBytes(ClientGlobal.g_charset);
File file = new File(“/home/ivan/Downloads/README.txt”);
FileInputStream fis = new FileInputStream(file);
byte[] file_buff = null;
if(fis != null){
int len = fis.available();
file_buff = new byte[len];
fis.read(file_buff);
}
System.out.println(“file length: “ + file_buff.length);
String group_name = null;
StorageServer[] storageServers = trackerClient.getStoreStorages(trackerServer, group_name);
if (storageServers == null) {
System.err.println(“get store storage servers fail, error code: “ + storageClient.getErrorCode());
}else{
System.err.println(“store storage servers count: “ + storageServers.length);
for (int k = 0; k < storageServers.length; k++){
System.err.println(k + 1 + “. “ + storageServers[k].getInetSocketAddress().getAddress().getHostAddress() + “:” + storageServers[k].getInetSocketAddress().getPort());
}
System.err.println(“”);
}
long startTime = System.currentTimeMillis();
// String[] results = storageClient.upload_file(file_buff, “jpg”, meta_list);
String[] results = storageClient.upload_file(“group3”, file_buff, “jpg”, meta_list);
// upload_file(file_buff, “jpg”, meta_list);
System.out.println(“upload_file time used: “ + (System.currentTimeMillis() - startTime) + “ ms”);
if (results == null){
System.err.println(“upload file fail, error code: “ + storageClient.getErrorCode());
return;
}
group_name = results[0];
String remote_filename = results[1];
System.err.println(“group_name: “ + group_name + “, remote_filename: “ + remote_filename);
System.err.println(storageClient.get_file_info(group_name, remote_filename));
ServerInfo[] servers = trackerClient.getFetchStorages(trackerServer, group_name, remote_filename);
if (servers == null){
System.err.println(“get storage servers fail, error code: “ + trackerClient.getErrorCode());
} else {
System.err.println(“storage servers count: “ + servers.length);
for (int k = 0; k < servers.length; k++){
System.err.println(k + 1 + “. “ + servers[k].getIpAddr() + “:” + servers[k].getPort());
}
System.err.println(“”);
}
}
}
此文件系统没有提供遍例文件的AＰＩ, 也不可以自定义上传文件名称，让人实在是无语至极，只能手动保存一份文件名映射凑合着用一下～