建站
咨詢
售后
建站咨詢
新聞中心
SpringBoot中怎么將文件上傳至 FastDFS，很多新手對此不是很清楚，為了幫助大家解決這個難題，下面小編將為大家詳細(xì)講解，有這方面需求的人可以來學(xué)習(xí)下，希望你能有所收獲。
創(chuàng)新互聯(lián)是一家專注于成都網(wǎng)站設(shè)計、網(wǎng)站制作與策劃設(shè)計,通江網(wǎng)站建設(shè)哪家好?創(chuàng)新互聯(lián)做網(wǎng)站,專注于網(wǎng)站建設(shè)10余年,網(wǎng)設(shè)計領(lǐng)域的專業(yè)建站公司;建站業(yè)務(wù)涵蓋:通江等地區(qū)。通江做網(wǎng)站價格咨詢:13518219792
一、什么是FastDFS
FastDFS 是一個開源的輕量級分布式文件系統(tǒng)，它解決了大數(shù)據(jù)量存儲和負(fù)載均衡等問題，特別適合以中小文件（建議范圍：4 KB < file_size < 500 MB）為載體的在線服務(wù)，如相冊網(wǎng)站、視頻網(wǎng)站等
FastDFS 由 C 語言開發(fā)，支持 Linux、FreeBSD 等 UNIX 系統(tǒng)類 Google FS，不是通用的文件系統(tǒng)，只能通過專有 API 訪問，目前提供了 C、Java 和 PHP API，為互聯(lián)網(wǎng)應(yīng)用量身定做，解決了大容量文件存儲問題，追求高性能和高擴(kuò)展性，F(xiàn)astDFS 可以看做是基于文件的 Key Value Pair 存儲系統(tǒng)，稱作分布式文件存儲服務(wù)會更合適。
FastDFS 特性
文件不分塊存儲，上傳的文件和 OS 文件系統(tǒng)中的文件一一對應(yīng)
支持相同內(nèi)容的文件只保存一份，節(jié)約磁盤空間
下載文件支持 HTTP 協(xié)議，可以使用內(nèi)置 Web Server，也可以和其他 Web Server 配合使用
支持在線擴(kuò)容
支持主從文件
存儲服務(wù)器上可以保存文件屬性（meta-data）V2.0 網(wǎng)絡(luò)通信采用 libevent，支持大并發(fā)訪問，整體性能更好
FastDFS 相關(guān)概念
FastDFS 服務(wù)端有三個角色：跟蹤服務(wù)器（Tracker Server）、存儲服務(wù)器（Storage Server）和客戶端（Client）
Tracker Server：跟蹤服務(wù)器，主要做調(diào)度工作，起負(fù)載均衡的作用。在內(nèi)存記錄集群中所有存儲組和存儲服務(wù)器的狀態(tài)信息，是客戶端和數(shù)據(jù)服務(wù)器交互的樞紐。相比 GFS 中的 Master 更為精簡，不記錄文件索引信息，占用的內(nèi)存量很少。
Storage Server：存儲服務(wù)器（又稱存儲節(jié)點或數(shù)據(jù)服務(wù)器），文件和文件屬性（Meta Data）都保存到存儲服務(wù)器上。Storage Server 直接利用 OS 的文件系統(tǒng)調(diào)用管理文件。
Client：客戶端，作為業(yè)務(wù)請求的發(fā)起方，通過專有接口，使用 TCP/IP 協(xié)議與跟蹤器服務(wù)器或存儲節(jié)點進(jìn)行數(shù)據(jù)交互。FastDFS 向使用者提供基本文件訪問接口，如 upload、download、append、delete 等，以客戶端庫的方式提供給用戶使用。
Tracker 相當(dāng)于 FastDFS 的大腦，不論是上傳還是下載都是通過 Tracker 來分配資源；客戶端一般可以使用 Ngnix 等靜態(tài)服務(wù)器來調(diào)用或者做一部分的緩存；存儲服務(wù)器內(nèi)部分為卷（或者叫做組），卷與卷之間是平行的關(guān)系，可以根據(jù)資源的使用情況隨時增加，卷內(nèi)服務(wù)器文件相互同步備份，以達(dá)到容災(zāi)的目的。
上傳機(jī)制
首先客戶端請求 Tracker 服務(wù)獲取到存儲服務(wù)器的 IP 地址和端口；
然后客戶端根據(jù)返回的 IP 地址和端口號請求上傳文件；
存儲服務(wù)器接收到請求后生產(chǎn)文件，并且將文件內(nèi)容寫入磁盤并返回給客戶端 file_id、路徑信息、文件名等信息，客戶端保存相關(guān)信息上傳完畢。
下載機(jī)制
客戶端帶上文件名信息請求 Tracker 服務(wù)獲取到存儲服務(wù)器的 IP 地址和端口；
然后客戶端根據(jù)返回的 IP 地址和端口號請求下載文件，存儲服務(wù)器接收到請求后返回文件給客戶端。
二、Spring Boot 集成 FastDFS
本節(jié)示例項目會在上一節(jié)項目的基礎(chǔ)上進(jìn)行構(gòu)建開發(fā)，從前端上傳文件到后臺后，直接傳遞到 FastDFS 集群中，并返回文件存儲的地址。
POM包配置
引入 FastDFS 的 Java 客戶端：
org.csource fastdfs-client-java 1.27-SNAPSHOT
FastDFS配置
項目 resources 目錄下添加fdfs_client.conf文件，配置文件設(shè)置了連接的超時時間、編碼格式以及 tracker_server 地址等信息。
connect_timeout = 60 # 連接超時時間 network_timeout = 60 # 網(wǎng)絡(luò)超時時間 charset = UTF-8 # 編碼格式 http.tracker_http_port = 8080 #tracker 端口 http.anti_steal_token = no #token 防盜鏈功能 http.secret_key = 123456 #密鑰 # tracer server 列表，多個 tracer server 的話，分行列出 tracker_server = 192.168.53.85:22122 tracker_server = 192.168.53.86:22122
封裝 FastDFS 上傳工具類
封裝 FastDFSFile，文件基礎(chǔ)信息包括文件名、內(nèi)容、文件類型、作者等。
public class FastDFSFile {
private String name;
private byte[] content;
private String ext;
private String md5;
private String author;
//省略getter、setter
}接下來封裝 FastDFSClient 類，F(xiàn)astDFSClient 主要封裝最基礎(chǔ)的操作，包含上傳、下載、刪除等方法。FastDFSFile 任務(wù)可以是 FastDFS 上傳文件的封裝，操作時每一個文件對應(yīng)一個實例。
首先在類加載的時候讀取配置信息，并進(jìn)行初始化。
static {
try {
String filePath = new ClassPathResource("fdfs_client.conf").getFile().getAbsolutePath();
//ClientGlobal.init 方法會讀取配置文件，并初始化對應(yīng)的屬性。
ClientGlobal.init(filePath);
} catch (Exception e) {
logger.error("FastDFS Client Init Fail!",e);
}
}文件上傳
使用 FastDFS 提供的客戶端 storageClient 來進(jìn)行文件上傳，最后將上傳結(jié)果返回。
public static String[] upload(FastDFSFile file) {
logger.info("File Name: " + file.getName() + "File Length:" + file.getContent().length);
//文件屬性信息
NameValuePair[] meta_list = new NameValuePair[1];
meta_list[0] = new NameValuePair("author", file.getAuthor());
long startTime = System.currentTimeMillis();
String[] uploadResults = null;
StorageClient storageClient=null;
try {
//獲取
storageClient = getStorageClient();
//上傳
uploadResults = storageClient.upload_file(file.getContent(), file.getExt(), meta_list);
} catch (IOException e) {
logger.error("IO Exception when uploadind the file:" + file.getName(), e);
} catch (Exception e) {
logger.error("Non IO Exception when uploadind the file:" + file.getName(), e);
}
logger.info("upload_file time used:" + (System.currentTimeMillis() - startTime) + " ms");
//驗證上傳結(jié)果
if (uploadResults == null && storageClient!=null) {
logger.error("upload file fail, error code:" + storageClient.getErrorCode());
}
//上傳文件成功會返回 groupName。
logger.info("upload file successfully!!!" + "group_name:" + uploadResults[0] + ", remoteFileName:" + " " + uploadResults[1]);
return uploadResults;
}NameValuePair，主要存儲文件的一些基礎(chǔ)屬性，如作者信息、創(chuàng)建時間等；
getStorageClient()，封裝了獲取客戶端的方法。
首先獲取 TrackerServer 信息，使用 TrackerServer 構(gòu)建出每次操作的客戶端實例 StorageClient。詳細(xì)代碼如下：
private static StorageClient getStorageClient() throws IOException {
TrackerServer trackerServer = getTrackerServer();
StorageClient storageClient = new StorageClient(trackerServer, null);
return storageClient;
}下面為封裝獲取 TrackerServer 的方法：
private static TrackerServer getTrackerServer() throws IOException {
TrackerClient trackerClient = new TrackerClient();
TrackerServer trackerServer = trackerClient.getConnection();
return trackerServer;
}獲取文件
根據(jù) groupName 和文件名獲取文件信息。group 也可稱為卷，同組內(nèi)服務(wù)器上的文件是完全相同的，同一組內(nèi)的 storage server 之間是對等的，文件上傳、刪除等操作可以在任意一臺 storage server 上進(jìn)行。
public static FileInfo getFile(String groupName, String remoteFileName) {
try {
storageClient = new StorageClient(trackerServer, storageServer);
return storageClient.get_file_info(groupName, remoteFileName);
} catch (IOException e) {
logger.error("IO Exception: Get File from Fast DFS failed", e);
} catch (Exception e) {
logger.error("Non IO Exception: Get File from Fast DFS failed", e);
}
return null;
}下載文件
根據(jù) storageClient 的 API 獲取文件的字節(jié)流并返回：
public static InputStream downFile(String groupName, String remoteFileName) {
try {
StorageClient storageClient = getStorageClient();
byte[] fileByte = storageClient.download_file(groupName, remoteFileName);
InputStream ins = new ByteArrayInputStream(fileByte);
return ins;
} catch (IOException e) {
logger.error("IO Exception: Get File from Fast DFS failed", e);
} catch (Exception e) {
logger.error("Non IO Exception: Get File from Fast DFS failed", e);
}
return null;
}刪除文件
根據(jù)文件名和組刪除對應(yīng)的文件；當(dāng)使用 FastDFS 時，直接調(diào)用 FastDFSClient 對應(yīng)的方法即可。
public static void deleteFile(String groupName, String remoteFileName)
throws Exception {
StorageClient storageClient = getStorageClient();
int i = storageClient.delete_file(groupName, remoteFileName);
logger.info("delete file successfully!!!" + i);
}編寫上傳控制類
從 MultipartFile 中讀取文件信息，然后使用 FastDFSClient 將文件上傳到 FastDFS 集群中，封裝一個 saveFile() 方法用來調(diào)用上面封裝的 FastDFS 工具類，將 MultipartFile 文件上傳到 FastDFS 中，并返回上傳后文件的地址信息。
public String saveFile(MultipartFile multipartFile) throws IOException {
String[] fileAbsolutePath={};
String fileName=multipartFile.getOriginalFilename();
String ext = fileName.substring(fileName.lastIndexOf(".") + 1);
byte[] file_buff = null;
InputStream inputStream=multipartFile.getInputStream();
if(inputStream!=null){
int len1 = inputStream.available();
file_buff = new byte[len1];
inputStream.read(file_buff);
}
inputStream.close();
FastDFSFile file = new FastDFSFile(fileName, file_buff, ext);
try {
fileAbsolutePath = FastDFSClient.upload(file); //upload to fastdfs
} catch (Exception e) {
logger.error("upload file Exception!",e);
}
if (fileAbsolutePath==null) {
logger.error("upload file failed,please upload again!");
}
String path=FastDFSClient.getTrackerUrl()+fileAbsolutePath[0]+ "/"+fileAbsolutePath[1];
return path;
}當(dāng)上傳請求傳遞到后端時，調(diào)用上面方法 saveFile()。
@PostMapping("/upload")
public String singleFileUpload(@RequestParam("file") MultipartFile file,
RedirectAttributes redirectAttributes) {
if (file.isEmpty()) {
redirectAttributes.addFlashAttribute("message", "Please select a file to upload");
return "redirect:uploadStatus";
}
try {
String path=saveFile(file);
redirectAttributes.addFlashAttribute("message",
"You successfully uploaded '" + file.getOriginalFilename() + "'");
redirectAttributes.addFlashAttribute("path","file path url '" + path + "'");
} catch (Exception e) {
logger.error("upload file failed",e);
}
return "redirect:/uploadStatus";
}上傳成功之后，將文件的路徑展示到頁面，效果圖如下：
看完上述內(nèi)容是否對您有幫助呢？如果還想對相關(guān)知識有進(jìn)一步的了解或閱讀更多相關(guān)文章，請關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝您對創(chuàng)新互聯(lián)的支持。
文章名稱：SpringBoot中怎么將文件上傳至FastDFS
網(wǎng)址分享：http://www.ef60e0e.cn/article/pcchdg.html
