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

需求

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

實現(xiàn)步驟

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

2. 在pom.xml文件中添加我們打包好的FastDFS本地倉庫的jar包(FastDFS的java客戶端依賴)

<!--加入FastDFS的java客戶端依賴-->
<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. 編寫代碼，進行上傳測試

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

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.加載配置文件，默認去classpath下加載
            ClientGlobal.init("fdfs_client.conf");
            //2.創(chuàng)建TrackerClient對象
            TrackerClient trackerClient = new TrackerClient();
            //3.創(chuàng)建TrackerServer對象
            trackerServer = trackerClient.getConnection();
            //4.創(chuàng)建StorageServler對象
            storageServer = trackerClient.getStoreStorage(trackerServer);
            //5.創(chuàng)建StorageClient對象，這個對象完成對文件的操作
            StorageClient storageClient = new StorageClient(trackerServer,storageServer);
            //6.上傳文件  第一個參數(shù)：本地文件路徑 第二個參數(shù)：上傳文件的后綴 第三個參數(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. 運行程序，在Linux上，F(xiàn)astDFS存儲目錄下查看上傳文件內(nèi)容