簡介
FastDFS是阿里用 C 語言編寫的一款開源的分布式文件系統(tǒng)。
上圖可以看出他的架構包括Tracker server 和 Storage server??蛻舳苏埱?Tracker server 進行文件上傳、下載,通過 Tracker server 調度最終由 Storage server 完成文件上傳和下載。
Tracker server:調度服務器,負載均衡和調度,通過 Tracker server 在文件上傳時可以根據(jù)一些策略找到 Storage server 提供文件上傳服務。
Storage server:存儲服務器,文件存儲,客戶端上傳的文件最終存儲在 Storage 服務器上。
服務端兩個角色:
Tracker:管理集群,tracker 也可以實現(xiàn)集群。每個 tracker 節(jié)點地位平等。收集 Storage 集群的狀態(tài)。
Storage:實際保存文件 Storage 分為多個組,每個組之間保存的文件是不同的。每個組內部可以有多個成員,組成員內部保存的內容是一樣的,組成員的地位是一致的,沒有主從的概念。
文件上傳流程
客戶端上傳文件后存儲服務器將文件 ID 返回給客戶端,此文件 ID 用于以后訪問該文件的索引信息。文件索引信息包括:組名,虛擬磁盤路徑,數(shù)據(jù)兩級目錄,文件名。
組名:文件上傳后所在的 storage 組名稱:group1。
虛擬磁盤路徑:storage 配置的虛擬路徑,與磁盤選項 store_path對應。如果配置了store_path0 則是 M00,如果配置了 store_path1 則是 M01
數(shù)據(jù)兩級目錄:storage 服務器在每個虛擬磁盤路徑下創(chuàng)建的兩級目錄,用于存儲數(shù)據(jù)文件。:/02/44
文件名:與文件上傳時不同。是由存儲服務器根據(jù)特定信息生成,文件名包含:源存儲服務器 IP 地址、文件創(chuàng)建時間戳、文件大小、隨機數(shù)和文件拓展名等信息。(后面一長串)
文件下載流程
電商概念
SPU(標準產品單位):iphone7就是一個SPU,與商家,與顏色、款式、套餐都無關,屬性值、特性相同的商品就可以稱為一個SPU。
SKU(庫存量單位):紡織品中一個SKU通常表示:規(guī)格、顏色、款式,物理上不可分割的最小存貨單元。
demo
1:手動引入jar包到maven本地倉庫
2:pom文件中引入
<dependencies> <dependency> <groupId>org.csource.fastdfs</groupId> <artifactId>fastdfs</artifactId> <version>1.2</version> </dependency> </dependencies>
3:配置文件fdfs_client.conf (可以更改服務器地址)
# connect timeout in seconds # default value is 30s connect_timeout=30 # network timeout in seconds # default value is 30s network_timeout=60 # the base path to store log files base_path=/home/fastdfs # tracker_server can ocur more than once, and tracker_server format is # "host:port", host can be hostname or ip address tracker_server=192.168.25.133:22122 #standard log level as syslog, case insensitive, value list: ### emerg for emergency ### alert ### crit for critical ### error ### warn for warning ### notice ### info ### debug log_level=info # if use connection pool # default value is false # since V4.05 use_connection_pool = false # connections whose the idle time exceeds this time will be closed # unit: second # default value is 3600 # since V4.05 connection_pool_max_idle_time = 3600 # if load FastDFS parameters from tracker server # since V4.05 # default value is false load_fdfs_parameters_from_tracker=false # if use storage ID instead of IP address # same as tracker.conf # valid only when load_fdfs_parameters_from_tracker is false # default value is false # since V4.05 use_storage_id = false # specify storage ids filename, can use relative or absolute path # same as tracker.conf # valid only when load_fdfs_parameters_from_tracker is false # since V4.05 storage_ids_filename = storage_ids.conf #HTTP settings http.tracker_server_port=80 #use "#include" directive to include HTTP other settiongs ##include http.conf
4:測試類(參考文件上傳步驟理解)
public class Test { public static void main(String[] args) throws FileNotFoundException, IOException, Exception { //1. 加載配置文件 ClientGlobal.init("C:\study\java\fastDFSdemo\src\main\resources\fdfs_client.conf"); //2. 構建一個管理者客戶端 TrackerClient client = new TrackerClient(); //3. 連接管理者服務端 TrackerServer trackerServer = client.getConnection(); //4. 聲明存儲服務端 StorageServer storageServer = null; //5. 獲取存儲服務器的客戶端對象 StorageClient storageClient = new StorageClient(trackerServer, storageServer); //6. 上傳文件(文件位置,文件擴展名,文件詳細信息) String[] strings = storageClient.upload_file("C:\study\文字.jpg", "jpg", null); //7. 顯示上傳結果 file_id for (String str : strings) { System.out.println(str); } } }
5:結果(組名和圖片路徑)
6:在瀏覽器中測試