Javafastdfs客户端实现上传下载⽂件⼀、项⽬结构
⼆、l
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="/POM/4.0.0"
xmlns:xsi="/2001/XMLSchema-instance"
xsi:schemaLocation="/POM/4.0.0 /xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId&le</groupId>
<artifactId>A01fastdfs</artifactId>
<version>1.0-SNAPSHOT</version>
<dependencies>
<!-- mvnrepository/artifact/7878/fastdfs-client-java -->
<dependency>
<groupId>7878</groupId>
<artifactId>fastdfs-client-java</artifactId>
<version>1.27.0.0</version>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.13</version>
<scope>test</scope>
osi七层和tcp4层关系
</dependency>
<!-- mvnrepository/artifact/org.apachemons/commons-io -->
<dependency>
<groupId>org.apachemons</groupId>
<artifactId>commons-io</artifactId>
<version>1.3.2</version>
mece最后一个e指什么</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<configuration>
<source>1.9</source>
<target>1.9</target>
</configuration>
</plugin>
</plugins>
</build>
</project>
三、fastdfs-client.properties
#http连接超时时间
#tracker和storage⽹络通信超时时间
fastdfswork_timeout_in_seconds=30
#字符编码
fastdfs.charset=utf-8
#tracker服务器地址,多个地址中间⽤英⽂逗号分隔
四、测试
package st;
import org.csource.fastdfs.*;
import org.junit.Test;
import java.io.File;
import java.io.FileOutputStream;
public class MyTest {
/
/上传⽂件
@Test
public void testUpload() {
try {java下载过程
//加载fastdfs-client.properties配置⽂件
ClientGlobal.initByProperties("config/fastdfs-client.properties");
//定义TrackerClient,⽤于请求TrackerServer
TrackerClient trackerClient = new TrackerClient();
//连接tracker
TrackerServer trackerServer = Connection();
//获取storage
StorageServer storeStorage = StoreStorage(trackerServer);
//创建storageClient
StorageClient1 storageClient1 = new StorageClient1(trackerServer, storeStorage);
//向storage服务器上传⽂件
//本地⽂件的路径
String path = "F:/java/";
//上传成功后拿到⽂件Id
String fileId = storageClient1.upload_file1(path, "txt", null);
System.out.println(fileId);//group1/M00/00/
} catch (Exception e) {
e.printStackTrace();
服务商
}
}
//下载⽂件
@Test
public void testDownload() {
try {
//加载fastdfs-client.properties配置⽂件
ClientGlobal.initByProperties("config/fastdfs-client.properties");
//定义TrackerClient,⽤于请求TrackerServer
TrackerClient trackerClient = new TrackerClient();
vb编程基础知识试题
//连接tracker
TrackerServer trackerServer = Connection();
//获取storage
StorageServer storeStorage = StoreStorage(trackerServer);
//创建storageClient
StorageClient1 storageClient1 = new StorageClient1(trackerServer, storeStorage);
//下载⽂件
//⽂件id
String fileId = "group1/M00/00/";
byte[] bytes = storageClient1.download_file1(fileId);
//使⽤输出流保存⽂件
FileOutputStream fileOutputStream = new FileOutputStream(new File("F:/"));
fileOutputStream.write(bytes);
} catch (Exception e) {
e.printStackTrace();oracle更新字段长度
}
}
}
以上就是本⽂的全部内容,希望对⼤家的学习有所帮助,也希望⼤家多多⽀持。