FastDFS文件上传和下载（java代码实现）
FastDFS的體系結構
FastDFS 主要包括Tracker Server 和 Storage Server。Tracker server 是 FastDFS 文件系統(tǒng)的協(xié)調(diào)者，主要作用是負載均衡和調(diào)度選擇 Storage server 進行文件存儲。
FastDFS文件上傳
Storage Server 定期向Tracker Server 發(fā)送狀態(tài)信息，保持心跳連接。
客戶端發(fā)起文件上傳請求。
Tracker Server 查詢所有與它保持連接的 Storage Server ，調(diào)度找到一個合適的 Storage Server。
Tracker Server 向客戶端返回該 Storage Server 的相關信息，包括 Storage Server 的 ip 和端口號。
客戶端通過 ip 和端口號與 Storage Server 建立連接，發(fā)送文件數(shù)據(jù)
Storage Server 生成唯一的路徑名 file_id ，file_id 由分組名（group）和文件路徑名（url）拼接而成。
Storage Server 將接收到的內(nèi)容寫入當前服務器磁盤中，并向客戶端返回 file_id 信息，客戶端按需要進行保存相關信息。
java代碼實現(xiàn)
/*** 文件上傳* @param file* @return*/public static String[] upload(MyFile file) {try {// 創(chuàng)建TrackerClient客戶端對象TrackerClient trackerClient = new TrackerClient();// 通過TrackerClient對象獲取TrackerServer信息TrackerServer trackerServer = trackerClient.getConnection();// 獲取StorageClient對象StorageClient storageClient = new StorageClient(trackerServer,null);NameValuePair[] meta_list = new NameValuePair[]{new NameValuePair(file.getAuthor()), new NameValuePair(file.getName())};String[] strings = storageClient.upload_file(file.getContent(), file.getExt(), meta_list);return strings;// strings[0]==group1 strings[1]=M00/00/00/wKjThF1aW9CAOUJGAAClQrJOYvs424.jpg} catch (Exception e) {e.printStackTrace();}return null;}FastDFS文件下載
Storage Server 定期向Tracker Server 發(fā)送狀態(tài)信息，保持心跳連接。
客戶端發(fā)起文件下載請求。
Tracker Server 查詢所有與它保持連接的 Storage Server ，調(diào)度找到一個合適的 Storage Server。
Tracker Server 向客戶端返回該 Storage Server 的相關信息，包括 Storage Server 的 ip 和端口號。
客戶端通過 ip 和端口號與 Storage Server 建立連接，客戶端向 Storage Server 請求文件數(shù)據(jù)（攜帶分組號和文件路徑參數(shù)）
Storage Server 同一組之間同步線程，共享文件數(shù)據(jù)，因此即便是不同的 Storage Server 仍能找到對應的文件地址。
Storage Server 發(fā)送給客戶端對應的文件數(shù)據(jù)，客戶端通過 io 流下載文件數(shù)據(jù)到本地
java代碼實現(xiàn)
public static InputStream downFile(String groupName,String remoteFileName){try {//創(chuàng)建TrackerClient對象TrackerClient trackerClient = new TrackerClient();//通過TrackerClient對象創(chuàng)建TrackerServerTrackerServer trackerServer = trackerClient.getConnection();//通過TrackerServer創(chuàng)建StorageClientStorageClient storageClient = new StorageClient(trackerServer,null);//通過StorageClient下載文件byte[] fileByte = storageClient.download_file(groupName, remoteFileName);//將字節(jié)數(shù)組轉(zhuǎn)換成字節(jié)輸入流return new ByteArrayInputStream(fileByte);} catch (Exception e) {e.printStackTrace();}return null;}總結
以上是生活随笔為你收集整理的FastDFS文件上传和下载（java代码实现）的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 2873-36-1，Gancidin W
- 下一篇： 队列元素排序