FastDFS 的作者余慶先生已經為我們開發好了 Java 對應的 SDK。這里需要解釋一下：作者余慶并沒有及時更新最新的 Java SDK 至 Maven 中央倉庫，目前中央倉庫最新版仍舊是 1.27 版。所以我們需要通過 Github：https://github.com/happyfish100/fastdfs-client-java 下載項目源碼，再通過命令 mvn clean install 編譯打包導入 Maven 倉庫使用即可。

接下來我們通過 Java API 操作 FastDFS 實現文件的上傳、下載、替換、刪除、查詢元數據、查詢詳情等功能。

文中案例已同步至：

Github：https://github.com/imrhelloworld/fastdfs-javaGitee：https://gitee.com/imrhelloworld/fastdfs-java

創建項目

添加依賴

在項目的 pom.xml 中添加以下依賴。因為我們需要一些常用工具包和單元測試，所以需要引入它們。

<!-- fastdfs java client --><dependency> <groupId>org.csource</groupId> <artifactId>fastdfs-client-java</artifactId> <version>1.29-SNAPSHOT</version></dependency><!-- apache commons lang3 工具包 --><dependency> <groupId>org.apache.commons</groupId> <artifactId>commons-lang3</artifactId> <version>3.11</version></dependency><!-- junit 單元測試 --><dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>4.13</version> <scope>test</scope></dependency>

編寫配置文件

fdfs_client.conf

# 超時時間connect_timeout = 10network_timeout = 30# 編碼字符集charset = UTF-8# tracker 服務器 HTTP 協議下暴露的端口http.tracker_http_port = 8080# tracker 服務器的 IP 和端口tracker_server = 192.168.10.101:22122

工具類

package org.example.client;import org.apache.commons.lang3.StringUtils;import org.csource.common.MyException;import org.csource.common.NameValuePair;import org.csource.fastdfs.*;import java.io.*;/** * FastDFS 分布式文件系統 Java 客戶端工具類 * 具體功能：文件上傳、下載、替換、刪除、查詢文件元數據、查看文件詳情 */public class FastDFSClient { // 獲取配置文件地址 private static final String CONF_FILENAME = Thread.currentThread() .getContextClassLoader().getResource('').getPath() + 'fdfs_client.conf'; // Storage 存儲服務器客戶端 private static StorageClient storageClient = null; static { try { // 加載配置文件 ClientGlobal.init(CONF_FILENAME); // 初始化 Tracker 客戶端 TrackerClient trackerClient = new TrackerClient(ClientGlobal.g_tracker_group); // 初始化 Tracker 服務端 TrackerServer trackerServer = trackerClient.getTrackerServer(); // 初始化 Storage 服務端 StorageServer storageServer = trackerClient.getStoreStorage(trackerServer); // 初始化 Storage 客戶端 storageClient = new StorageClient(trackerServer, storageServer); } catch (IOException e) { e.printStackTrace(); } catch (MyException e) { e.printStackTrace(); } } /** * 文件上傳 * * @param inputStream 上傳的文件的字節輸入流 * @param fileName 上傳的文件的原始名 * @return */ public static String[] uploadFile(InputStream inputStream, String fileName) { try { // 準備字節數組 byte[] fileBuff = null; // 文件元數據 NameValuePair[] metaList = null; if (inputStream != null) { // 查看文件的長度 int len = inputStream.available(); // 初始化元數據數組 metaList = new NameValuePair[2]; // 第一組元數據，文件的原始名稱 metaList[0] = new NameValuePair('file_name', fileName); // 第二組元數據，文件的長度 metaList[1] = new NameValuePair('file_length', String.valueOf(len)); // 創建對應長度的字節數組 fileBuff = new byte[len]; // 將輸入流中的字節內容，讀到字節數組中 inputStream.read(fileBuff); } /* 上傳文件。 參數含義：要上傳的文件的內容（使用字節數組傳遞），上傳的文件的類型（擴展名），元數據 */ String[] fileids = storageClient.upload_file(fileBuff, getFileExt(fileName), metaList); return fileids; } catch (IOException e) { e.printStackTrace(); } catch (MyException e) { e.printStackTrace(); } return null; } /** * 文件上傳 * * @param file 上傳的文件 * @param fileName 上傳的文件的原始名 * @return */ public static String[] uploadFile(File file, String fileName) { try (FileInputStream fis = new FileInputStream(file)) { return uploadFile(fis, fileName); } catch (FileNotFoundException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } return null; } /** * 獲取文件后綴名（不帶點） * * @param fileName * @return 如：'jpg' or '' */ private static String getFileExt(String fileName) { if (StringUtils.isBlank(fileName) || !fileName.contains('.')) { return ''; } return fileName.substring(fileName.lastIndexOf('.') + 1); // 不帶最后的點 } /** * 獲取文件詳情 * * @param groupName 組/卷名，默認值：group1 * @param remoteFileName 文件名，例如：'M00/00/00/wKgKZl9tkTCAJAanAADhaCZ_RF0495.jpg' * @return 文件詳情 */ public static FileInfo getFileInfo(String groupName, String remoteFileName) { try { return storageClient.get_file_info(groupName == null ? 'group1' : groupName, remoteFileName); } catch (IOException e) { e.printStackTrace(); } catch (MyException e) { e.printStackTrace(); } return null; } /** * 獲取元數據 * * @param groupName 組/卷名，默認值：group1 * @param remoteFileName 文件名，例如：'M00/00/00/wKgKZl9tkTCAJAanAADhaCZ_RF0495.jpg' * @return 文件的元數據數組 */ public static NameValuePair[] getMetaData(String groupName, String remoteFileName) { try { // 根據組名和文件名通過 Storage 客戶端獲取文件的元數據數組 return storageClient.get_metadata(groupName == null ? 'group1' : groupName, remoteFileName); } catch (IOException e) { e.printStackTrace(); } catch (MyException e) { e.printStackTrace(); } return null; } /** * 文件下載 * * @param groupName 組/卷名，默認值：group1 * @param remoteFileName 文件名，例如：'M00/00/00/wKgKZl9tkTCAJAanAADhaCZ_RF0495.jpg' * @return 文件的字節輸入流 */ public static InputStream downloadFile(String groupName, String remoteFileName) { try { // 根據組名和文件名通過 Storage 客戶端獲取文件的字節數組 byte[] bytes = storageClient.download_file(groupName == null ? 'group1' : groupName, remoteFileName); // 返回字節流對象 InputStream inputStream = new ByteArrayInputStream(bytes); return inputStream; } catch (IOException e) { e.printStackTrace(); } catch (MyException e) { e.printStackTrace(); } return null; } /** * 文件刪除 * * @param groupName 組/卷名，默認值：group1 * @param remoteFileName 文件名，例如：'M00/00/00/wKgKZl9tkTCAJAanAADhaCZ_RF0495.jpg' * @return 0為成功，非0為失敗 */ public static int deleteFile(String groupName, String remoteFileName) { int result = -1; try { // 根據組名和文件名通過 Storage 客戶端刪除文件 result = storageClient.delete_file(groupName == null ? 'group1' : groupName, remoteFileName); } catch (IOException e) { e.printStackTrace(); } catch (MyException e) { e.printStackTrace(); } return result; } /** * 修改一個已經存在的文件 * * @param oldGroupName 舊組名 * @param oldFileName 舊文件名 * @param file 新文件 * @param fileName 新文件名 * @return */ public static String[] modifyFile(String oldGroupName, String oldFileName, File file, String fileName) { // 先上傳 String[] fileids = uploadFile(file, fileName); if (fileids == null) { return null; } // 再刪除 int delResult = deleteFile(oldGroupName, oldFileName); if (delResult != 0) { return null; } return fileids; }}

測試

文件上傳

// 文件上傳@Testpublic void testUploadFile() { String[] fileids = FastDFSClient.uploadFile(new File('D:/china.jpg'), 'china.jpg'); for (String fileid : fileids) { System.out.println('fileid = ' + fileid); }}

返回值

fileid = group1fileid = M00/00/00/wKgKZl9xMdiAcOLdAADhaCZ_RF0096.jpg

文件詳情

// 查看文件詳情@Testpublic void testGetFileInfo() { FileInfo fileInfo = FastDFSClient.getFileInfo('group1', 'M00/00/00/wKgKZl9xMdiAcOLdAADhaCZ_RF0096.jpg'); System.out.println('fileInfo = ' + fileInfo);}

返回值：

fileInfo = fetch_from_server = false, file_type = 1, source_ip_addr = 192.168.10.102, file_size = 57704, create_timestamp = 2020-09-28 08:44:08, crc32 = 645874781

文件元數據

// 獲取文件數據@Testpublic void testGetMetaData() { NameValuePair[] metaDatas = FastDFSClient.getMetaData('group1', 'M00/00/00/wKgKZl9xMdiAcOLdAADhaCZ_RF0096.jpg'); for (NameValuePair metaData : metaDatas) { System.out.println(metaData.getName() + '---' + metaData.getValue()); }}

返回值：

file_length---57704file_name---china.jpg

文件下載

// 文件下載@Testpublic void testDownloadFile() { InputStream is = FastDFSClient.downloadFile('group1', 'M00/00/00/wKgKZl9xMdiAcOLdAADhaCZ_RF0096.jpg'); try (FileOutputStream fos = new FileOutputStream('D:/wKgKZl9xMdiAcOLdAADhaCZ_RF0096.jpg')) { int len = 0; byte[] bytes = new byte[1024]; while ((len = is.read(bytes)) != -1) { fos.write(bytes, 0, len); fos.flush(); } } catch (FileNotFoundException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); }}

文件刪除

// 文件刪除@Testpublic void testDeleteFile() { int result = FastDFSClient.deleteFile('group1', 'M00/00/00/wKgKZl9xMdiAcOLdAADhaCZ_RF0096.jpg'); System.out.println('result = ' + result);}

返回值：

result = 0

文件替換

// 文件替換@Testpublic void testModifyFile() { String[] fileids = FastDFSClient.modifyFile('group1', 'M00/00/00/wKgKZl9xOS2ASdu8AADhaCZ_RF0898.jpg', new File('D:/mhw.jpg'), 'mhw.jpg'); for (String fileid : fileids) { System.out.println('fileid = ' + fileid); }}

返回值：

fileid = group1fileid = M00/00/00/wKgKZl9xOeaAFO00AACmo7QBGtA298.jpg

至此 Java 客戶端操作 FastDFS 實現文件上傳下載替換刪除等操作就到這里，下一篇我們帶大家搭建 FastDFS 的集群環境，多 Tracker 多 Storage 然后通過 Nginx 代理。

到此這篇關于Java 客戶端操作 FastDFS 實現文件上傳下載替換刪除功能的文章就介紹到這了,更多相關java 文件上傳下載替換刪除內容請搜索好吧啦網以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持好吧啦網！