FastDFS文件上傳功能實(shí)現(xiàn)

需求

使用Java客戶(hù)端，編程操作fastDFS分布式文件系統(tǒng)，上傳本地文件到FastDFS服務(wù)器上。

實(shí)現(xiàn)步驟

1. 使用IDEA創(chuàng)建普通的maven項(xiàng)目，不需要使用

2. 在pom.xml文件中添加我們打包好的FastDFS本地倉(cāng)庫(kù)的jar包(FastDFS的java客戶(hù)端依賴(lài))

<!--加入FastDFS的java客戶(hù)端依賴(lài)-->
<dependencies>
    <dependency>
        <groupId>org.csource</groupId>
        <artifactId>fastdfs-client-java</artifactId>
        <version>1.27-SNAPSHOT</version>
    </dependency>
</dependencies>

可以在這查看jar包里面的內(nèi)容

3. 拷貝源代碼包中的fdfs_client.conf文件到resources目錄下，在里面主要配置tracker地址

tracker_server = 192.168.235.128:22122

4. 編寫(xiě)代碼，進(jìn)行上傳測(cè)試

在com.bjpowernode.fastdfs包下創(chuàng)建FastDFS類(lèi)，在其中編寫(xiě)上傳代碼

package com.bjpowernode.fastdfs;
import org.csource.common.MyException;
import org.csource.fastdfs.*;
import java.io.IOException;
public class FastDFS {
    public static void main(String[] args) {
        fileUpload();
    }
    //上傳文件的方法
    public static void fileUpload(){
        TrackerServer trackerServer = null;
        StorageServer storageServer = null;
        try {
            //1.加載配置文件，默認(rèn)去classpath下加載
            ClientGlobal.init("fdfs_client.conf");
            //2.創(chuàng)建TrackerClient對(duì)象
            TrackerClient trackerClient = new TrackerClient();
            //3.創(chuàng)建TrackerServer對(duì)象
            trackerServer = trackerClient.getConnection();
            //4.創(chuàng)建StorageServler對(duì)象
            storageServer = trackerClient.getStoreStorage(trackerServer);
            //5.創(chuàng)建StorageClient對(duì)象，這個(gè)對(duì)象完成對(duì)文件的操作
            StorageClient storageClient = new StorageClient(trackerServer,storageServer);
            //6.上傳文件  第一個(gè)參數(shù)：本地文件路徑 第二個(gè)參數(shù)：上傳文件的后綴 第三個(gè)參數(shù)：文件信息
            String [] uploadArray = storageClient.upload_file("D:/aa.txt","txt",null);
            for (String str:uploadArray) {
                System.out.println(str);
            }
        } catch (IOException e) {
            e.printStackTrace();
        } catch (MyException e) {
            e.printStackTrace();
        } finally {
            if(storageServer != null){
                try {
                    storageServer.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if(trackerServer != null){
                try {
                    trackerServer.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }

5. 運(yùn)行程序，在Linux上，F(xiàn)astDFS存儲(chǔ)目錄下查看上傳文件內(nèi)容