FasfDFS整合Java實現文件上傳下載

時間 2019-11-17

標籤 fasfdfs 整合 java 實現文件上傳下載欄目 Java 简体版

原文原文鏈接

文章目錄

一 : 添加配置文件

二 : 加載配置文件

1. 測試加載配置文件

2. 輸出配置文件

三:功能實現

1.初始化鏈接信息

2.上傳文件

3.下載文件

4.獲取元數據信息

5.獲取文件信息

6.刪除文件

在上一篇的文章中已經整合了Nginx和FastDFS : FastDFS安裝和配置，整合Nginx-1.13.3html

今天使用Java代碼實現文件的上傳和下載。對此做者提供了Java API支持，下載fastdfs-client-java將源碼添加到項目中。或者在Maven項目pom.xml文件中添加依賴java

<dependency>
    <groupId>org.csource</groupId>
    <artifactId>fastdfs-client-java</artifactId>
    <version>1.27-SNAPSHOT</version>
</dependency>

一 : 添加配置文件

當完成以上操做以後能夠添加連接FastDFS服務器的配置文件 fastdfs-client.propertiesgit

fastdfs.connect_timeout_in_seconds = 5
fastdfs.network_timeout_in_seconds = 30
fastdfs.charset = UTF-8
fastdfs.http_anti_steal_token = false
fastdfs.http_secret_key = FastDFS1234567890
fastdfs.http_tracker_http_port = 80
fastdfs.tracker_servers = 192.168.1.7:22122

由於項目中只使用properties 格式文件，若是須要更多的配置信息，能夠查看官方的配置信息github

注: 1. 其餘的配置項爲可選，fastdfs.tracker_servers 爲必須選項
2. 多個tracker_servers可使用逗號「 , 」分隔數組

二 : 加載配置文件

1. 測試加載配置文件

@Test
public void initConifg() throws Exception {
    // 加載配置文件   
    ClientGlobal.initByProperties("config/fastdfs-client.properties");                          
    System.out.println("ClientGlobal.configInfo():" + ClientGlobal.configInfo());
}

2. 輸出結果

ClientGlobal.configInfo():{
    g_connect_timeout(ms) = 5000
    g_network_timeout(ms) = 30000
    g_charset = UTF-8
    g_anti_steal_token = false
    g_secret_key = FastDFS1234567890
    g_tracker_http_port = 80
    trackerServers = 192.168.1.7:22122
}

當出現上面和配置文件一致的輸出結果時候，說明加載配置文件已經成功。

瀏覽器

三:功能實現

因爲是使用Junit作測試，爲了方便在開始執行以前，初始化配置文件和獲取鏈接，同時沒有捕獲異常所有拋出服務器

1.初始化鏈接信息

//成員變量
TrackerServer trackerServer = null;
StorageServer storageServer = null;
StorageClient storageClient = null;
/**
 * 初始化鏈接信息
 * @author: wrh45
 * @date: 2017年8月5日下午8:08:57
 */
@Before
public void init() throws Exception {
      // 加載配置文件
      ClientGlobal.initByProperties("config/fastdfs-client.properties");
      // 獲取鏈接
      TrackerClient trackerClient = new TrackerClient();
      trackerServer = trackerClient.getConnection();
      storageClient = new StorageClient(trackerServer, storageServer);
}

注:    若是出現鏈接超時異常：java.net.SocketTimeoutException: connect timed out
     1 .查看服務器地址和端口是否正確
     2 .請查看服務器TrackerServer和StorageServer服務端口是否開啓。默認爲22122和23000app

2.上傳文件

/**
 * 上傳圖片
 * @throws Exception
 * @author: wrh45
 * @date: 2017年8月5日下午7:09:23
 */
@Test
public void uploadFileOfByte() throws Exception {
    // 獲取文件字節信息
    file = new File("src/test/resources/pic/Ace.jpg");
    FileInputStream inputStream = new FileInputStream(file);
    byte[] file_buff = new byte[(int) file.length()];
    inputStream.read(file_buff);
  
    // 獲取文件擴展名
    String fileName = file.getName();
    String extName = null;
    if (fileName.contains(".")) {
        extName = fileName.substring(fileName.lastIndexOf(".") + 1);
    } else {
        return;
    }

    // 圖片元數據,若是設置爲空，那麼服務器上不會生成-m的原數據文件
    NameValuePair[] meta_list = new NameValuePair[2];
    meta_list[0] = new NameValuePair("fileName", "測試專用");
    meta_list[1] = new NameValuePair("length", "測試專用");
    // 文件上傳，返回組名和訪問地址
    String[] upload_file = storageClient.upload_file(file_buff, extName, meta_list);
    System.out.println(Arrays.asList(upload_file));
}

下面是執行結果工具

已經將圖片上傳到服務器，同時返回了圖片地址。那麼經過這個地址試試可否訪問
測試

OK，在瀏覽器輸入地址後，成功返回了圖片信息

3.下載文件

這裏經過storageClient下載文件，而後將數據存儲到本地。若是經過瀏覽器下載，同理將數據寫入文件便可

/**
 * 下載圖片
 * @throws Exception
 * @author: wrh45
 * @date: 2017年8月5日下午8:09:10
 */
@Test
public void downLoadFile() throws Exception {
    // 下載文件，返回字節數組
    byte[] file_buff = storageClient.download_file("group1", "M00/00/00/wKgBB1l-EwyAGvxuAAWkdYkPHEE854.jpg");
    // 將數據寫文件中
    File file = new File("src/test/resources/pic/Ace2.jpg");
    FileOutputStream outStream = new FileOutputStream(file);
    outStream.write(file_buff);
    outStream.flush();
    outStream.close();
}

下面是執行結果，不出意外是能夠成功執行的

4.獲取元數據信息

/**
 * 元數據信息
 * @throws Exception
 * @author: wrh45
 * @date: 2017年8月5日下午8:09:38
 */
@Test
public void metaData() throws Exception {
    // 上傳圖片的時候，元數據若爲空將沒法生存-m的原數據文件。獲取時候此處將拋出NullPointerException
    NameValuePair[] get_metadata = storageClient.get_metadata("group1",
        "M00/00/00/wKgBB1l-EwyAGvxuAAWkdYkPHEE854.jpg");
    for (NameValuePair nameValuePair: get_metadata) {
        System.out.println("name: " + nameValuePair.getName() + "  value: " + nameValuePair.getValue());
    }
}

如下是執行結果，獲取到的數據和上傳的數據同樣

name: fileName  value: 測試專用
name: length  value: 測試專用

5.獲取文件信息

/**
 * 獲取文件信息
 * @author: wrh45
 * @date: 2017年8月7日下午9:02:47
 */
@Test
public void getFileInfo() throws Exception {
    FileInfo fileInfo = storageClient.get_file_info("group1", "M00/00/00/wKgBB1l-EwyAGvxuAAWkdYkPHEE854.jpg");

    System.out.println("CRC32簽名：" + fileInfo.getCrc32());
    System.out.println("文件大小：" + fileInfo.getFileSize());
    System.out.println("服務器地址：" + fileInfo.getSourceIpAddr());
    System.out.println("建立時間：" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(fileInfo.getCreateTimestamp()));
}

輸出結果

CRC32簽名：-1995498431
文件大小：369781
服務器地址：192.168.1.7
建立時間：2017-08-07 20-24-56

6.刪除文件

當數據測試完整以後，試試可否刪除吧

/**
 * 刪除文件
 * @throws Exception
 * @author: wrh45
 * @date: 2017年8月7日下午9:10:04
 */
@Test
public void deleteFile() throws Exception {
    // 返回0成功，不然返回錯誤嗎
    int code = storageClient.delete_file("group1", "M00/00/00/wKgBB1l-EwyAGvxuAAWkdYkPHEE854.jpg");
    System.out.println(code);
}

刪除以後輸出結果爲0，若是出現非0結果，那麼返回的是錯誤代碼

以上是Java實現上傳下載等功能的代碼，若是須要能夠封裝成工具類使用。

如下是我的封裝好的工具類

/**
 * 上傳文件工具類
 * @ClassName: FileUploadUtils
 * @author wrh45
 * @date 2017年8月8日下午4:14:31
 */
public class FileUploadUtils {
    private static TrackerClient trackerClient = null;
    private static TrackerServer trackerServer = null;
    private static StorageServer storageServer = null;
    private static StorageClient storageClient = null;
    private static final String groupName = "group1";

    static {
        // 加載配置文件
        try {
            ClientGlobal.initByProperties("config/fastdfs-client.properties");
            // System.out.println("ClientGlobal.configInfo():" +
            // ClientGlobal.configInfo());
        } catch (IOException | MyException e) {
            e.printStackTrace();
            System.out.println("load config file fail");
        }
    }

    /*
     * 初始化鏈接數據
     */
    private static void init() {
        try {
            trackerClient = new TrackerClient();
            trackerServer = trackerClient.getConnection();
            storageClient = new StorageClient(trackerServer, storageServer);
        } catch (IOException e) {
            e.printStackTrace();
            System.out.println("init fail");
        }
    }

    /**
     * 上傳文件
     * @param filePath 文件路徑
     * @param fileName 文件名稱
     * @return 文件存儲信息
     * @author: wrh45
     * @date: 2017年8月5日下午11:10:38
     */
    public static String[] uploadFile(String filePath, String fileName) {
        return uploadFile(null, filePath, fileName);
    }

    /**
     * 上傳文件
     * @param fileBuff 文件字節數組
     * @param fileName 文件名稱
     * @return 文件存儲信息
     * @author: wrh45
     * @date: 2017年8月5日下午11:10:38
     */
    public static String[] uploadFile(byte[] fileBuff, String fileName) {
        return uploadFile(fileBuff, null, fileName);
    }

    /**
     * 上傳文件
     * @param file_buff 文件字節數組
     * @param filePath 文件路徑
     * @param fileName 文件名稱
     * @return 文件存儲信息
     * @author: wrh45
     * @date: 2017年8月5日下午10:58:19
     */
    private static String[] uploadFile(byte[] fileBuff, String filePath, String fileName) {
        try {
            if (fileBuff == null && filePath == null) {
                return new String[0];
            }
            // 初始化數據
            if (storageClient == null) {
                init();
            }

            // 獲取文件擴展名稱
            String fileExtName = "";
            if (fileName != null && !"".equals(fileName) && fileName.contains(".")) {
                fileExtName = fileName.substring(fileName.lastIndexOf(".") + 1);
            } else {
                return new String[0];
            }

            // 設置圖片元數據
            NameValuePair[] metaList = new NameValuePair[3];
            metaList[0] = new NameValuePair("fileName", fileName);
            metaList[1] = new NameValuePair("fileExtName", fileExtName);
            metaList[2] = new NameValuePair("fileSize", String.valueOf(fileBuff.length));
            // 上傳文件
            String[] uploadFile = null;
            if (fileBuff != null && filePath == null) {
                if (fileBuff.length == 0) {
                    return new String[0];
                }
                uploadFile = storageClient.upload_file(fileBuff, fileExtName, metaList);
            } else {
                //路徑匹配Windown和Linux
                if ("".equals(filePath) || !(filePath.matches("^[a-zA-Z]:{1}([\u4e00-\u9fa5\\w/_\\\\-]+)$") || filePath.matches("^(/[\u4e00-\u9fa5\\w_-]+)+$"))) {
                    return new String[0];
                }
                uploadFile = storageClient.upload_file(filePath, fileExtName, metaList);
            }
            return uploadFile == null ? new String[0] : uploadFile;
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                if (trackerServer != null) {
                    trackerServer.close();
                    trackerServer = null;
                }
                if (storageServer != null) {
                    storageServer.close();
                    storageServer = null;
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        return new String[0];
    }

    /**
     * 刪除服務器文件
     * @param remoteFileName  文件在服務器中名稱
     * @author: wrh45
     * @date: 2017年8月6日上午12:15:22
     */
    public static int deleteFile(String remoteFileName) {
        try {
            if (remoteFileName == null || "".equals(remoteFileName) || !remoteFileName.contains(groupName)) {
                return -1;
            }
            if (storageClient == null) {
                init();
            }
            String fileURL = remoteFileName.substring(remoteFileName.indexOf(groupName));
            String group = fileURL.substring(0, remoteFileName.indexOf("/") + 1);
            String fileName = fileURL.substring(remoteFileName.indexOf("/") + 2);
            int code = storageClient.delete_file(group, fileName);
            return code;
        } catch (Exception e) {
            e.printStackTrace();
            System.out.println("The File Delete Fail");
        }
        return -1;
    }

    /**
     * 獲取文件信息
     * @param groupName  組名
     * @param remoteFilename  遠程文件名
     * @return
     * @author: wrh45
     * @date: 2017年8月8日上午12:25:26
     */
    public static FileInfo getFileInfo(String groupName, String remoteFilename) {
        try {
            if (storageClient == null) {
                init();
            }
            FileInfo fileInfo = storageClient.get_file_info(groupName, remoteFilename);
            return fileInfo;
        } catch (Exception e) {
            e.printStackTrace();
            System.out.println("Get File Info Fail");
        }
        return null;
    }
}

整篇博文到此爲止，不足之處請多多指正。