标签:配置 ast net print dom dfs test osc init
配置文件
dfs.properties
## fastdfs-client
fastdfs.connect_timeout_in_seconds=5
fastdfs.network_timeout_in_seconds=30
fastdfs.charset=UTF-8
fastdfs.http_anti_steal_token=true
fastdfs.http_secret_key=FastDFS1234567890
fastdfs.http_tracker_http_port=80
fastdfs.tracker_servers=file.ljzsg.com:22122
http_secret_key 对应 /etc/fdfs/http.conf 的http.anti_steal.secret_key
POM
<dependency>
<groupId>net.oschina.zcx7878</groupId>
<artifactId>fastdfs-client-java</artifactId>
<version>1.27.0.0</version>
</dependency>
上传
@Test
public void upload() {
try {
// 初始化全局配置。加载一个配置文件。
ClientGlobal.initByProperties("dfs.properties");
// 创建一个TrackerClient对象。
TrackerClient trackerClient = new TrackerClient();
// 创建一个TrackerServer对象。
TrackerServer trackerServer = trackerClient.getConnection();
// 声明一个StorageServer对象,null。
StorageServer storageServer = null;
// 获得StorageClient对象。
StorageClient storageClient = new StorageClient(trackerServer, storageServer);
// 直接调用StorageClient对象方法上传文件即可。
String[] strings;
strings = storageClient.upload_file("D:\\test.jpg", "jpg", null);
for (String string : strings) {
System.out.println(string);
//group1/
//M00/00/00/wKgCx1wHQ-aAYvtmAACxjYqFSkc019.jpg
}
} catch (Exception e) {
e.printStackTrace();
}
}
下载
@Test
public void download(){
try {
// 初始化全局配置。加载一个配置文件
ClientGlobal.initByProperties("dfs.properties");
// 创建一个TrackerClient对象
TrackerClient tracker = new TrackerClient();
// 创建一个TrackerServer对象。
TrackerServer trackerServer = tracker.getConnection();
// 声明一个StorageServer对象,
StorageServer storageServer = null;
// 获得StorageClient对象
StorageClient storageClient = new StorageClient(trackerServer, storageServer);
byte[] b = storageClient.download_file("group1", "M00/00/00/wKgCx1wHQ-aAYvtmAACxjYqFSkc019.jpg");
System.out.println(b);
// 将下载的文件流保存
IOUtils.write(b, new FileOutputStream("D:/"+UUID.randomUUID().toString()+".jpg"));
} catch (Exception e) {
e.printStackTrace();
}
}
标签:配置 ast net print dom dfs test osc init
原文地址:https://www.cnblogs.com/menxn/p/10070703.html