fastDFS 使用fastDFS实现文件上传和下载

清疚 2022-10-02 06:42 18阅读 0赞

[2019独角兽企业重金招聘Python工程师标准>>> ][2019_Python_] ![hot3.png][]

## **1. 搭建环境** ##

这里我们使用javaApi测试文件的上传，java版本的fastdfs-client地址在： [https://github.com/happyfish100/fastdfs-client-java][https_github.com_happyfish100_fastdfs-client-java] 参考此工程编写测试用例。

### **1）创建maven工程** ###

pom.xml

<dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            
            <dependency>
                <groupId>net.oschina.zcx7878</groupId>
                <artifactId>fastdfs-client-java</artifactId>
                <version>1.27.0.0</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
            <dependency>
                <groupId>org.apache.commons</groupId>
                <artifactId>commons-io</artifactId>
                <version>1.3.2</version>
            </dependency>
        </dependencies>

### **2) 配置 文件** ###

在classpath:config下创建fastdfs-client.properties文件

fastdfs.connect_timeout_in_seconds = 5
    fastdfs.network_timeout_in_seconds = 30
    fastdfs.charset = UTF-8
    fastdfs.tracker_servers = 192.168.101.65:22122

## **2. 文件上传** ##

//上传文件
    @Test
    public void testUpload() {
    	try {
    		ClientGlobal.initByProperties("config/fastdfs‐client.properties");
    		System.out.println("network_timeout=" + ClientGlobal.g_network_timeout + "ms");
    		System.out.println("charset=" + ClientGlobal.g_charset);
    		//创建客户端
    		TrackerClient tc = new TrackerClient();
    		//连接tracker Server
    		TrackerServer ts = tc.getConnection();
    		if (ts == null) {
    			System.out.println("getConnection return null");
    			return;
    		}
    		//获取一个storage server
    		StorageServer ss = tc.getStoreStorage(ts);
    		if (ss == null) {
    			System.out.println("getStoreStorage return null");
    		}
    		//创建一个storage存储客户端
    		StorageClient1 sc1 = new StorageClient1(ts, ss);
    		NameValuePair[] meta_list = null; //new NameValuePair[0];
    		String item = "C:\\Users\\admin\\Desktop\\1.png";
    		String fileid;
    		fileid = sc1.upload_file1(item, "png", meta_list);
    		System.out.println("Upload local file " + item + " ok, fileid=" + fileid);
    	} catch (Exception ex) {
    		ex.printStackTrace();
    	}
    }

## **3. 文件查询** ##

//查询文件
    @Test
    public void testQueryFile() throws IOException, MyException {
    	ClientGlobal.initByProperties("config/fastdfs‐client.properties");
    	TrackerClient tracker = new TrackerClient();
    	TrackerServer trackerServer = tracker.getConnection();
    	StorageServer storageServer = null;
    	StorageClient storageClient = new StorageClient(trackerServer,storageServer);
    	FileInfo fileInfo = storageClient.query_file_info("group1",
    "M00/00/01/wKhlQFrKBSOAW5AWAALcAg10vf4862.png");
    	System.out.println(fileInfo);
    }

## **4. 文件下载** ##

//下载文件
    @Test
    public void testDownloadFile() throws IOException, MyException {
    	ClientGlobal.initByProperties("config/fastdfs‐client.properties");
    	TrackerClient tracker = new TrackerClient();
    	TrackerServer trackerServer = tracker.getConnection();
    	StorageServer storageServer = null;
    	StorageClient1 storageClient1 = new StorageClient1(trackerServer,storageServer);
    	byte[] result =storageClient1.download_file1("group1/M00/00/01/wKhlQFrKBSOAW5AWAALcAg10vf4862.png");
    	File file = new File("d:/1.png");
    	FileOutputStream fileOutputStream = new FileOutputStream(file);
    	fileOutputStream.write(result);
    	fileOutputStream.close();
    }

转载于:https://my.oschina.net/edisonOnCall/blog/3039662

[2019_Python_]: https://my.oschina.net/u/2663968/blog/3061697
[hot3.png]: /images/20220113/c21a51d176cf4ebc819322bd3555cb97.png
[https_github.com_happyfish100_fastdfs-client-java]: https://github.com/happyfish100/fastdfs-client-java