SpringBoot整合FastDFS中間件實現(xiàn)文件分布管理
更新時間：2024年08月02日 09:24:08 作者：飛翔的佩奇
FastDFS是一個開源的輕量級分布式文件系統(tǒng),它對文件進行管理,功能包括：文件存儲、文件同步、文件上傳、文件下載等,解決了大容量存儲和負載均衡的問題,本文介紹了SpringBoot整合FastDFS中間件實現(xiàn)文件分布管理,需要的朋友可以參考下
一、FastDFS簡介
1、FastDFS作用
FastDFS是一個開源的輕量級分布式文件系統(tǒng)，它對文件進行管理，功能包括：文件存儲、文件同步、文件上傳、文件下載等，解決了大容量存儲和負載均衡的問題。
2、核心角色
FastDFS是由跟蹤服務器（trackerserver）、存儲服務器（storageserver）和客戶端（client）三個部分組成。
- 跟蹤服務器
FastDFS的協(xié)調(diào)者，負責管理所有的storage server和group，每個storage在啟動后會連接Tracker，告知自己所屬的group等信息，并保持周期性的心跳，tracker根據(jù)storage的心跳信息，建立group到[storage server list]的映射表。
- 存儲服務器
以組（group）為單位，一個group內(nèi)包含多臺storage機器，數(shù)據(jù)互為備份，存儲空間以group內(nèi)容量最小的storage為準，所以建議group內(nèi)的多個storage盡量配置相同，以免造成存儲空間的浪費。
- 客戶端
業(yè)務請求的發(fā)起方，通過專有接口，使用TCP/IP協(xié)議與跟 蹤器服務器或存儲節(jié)點進行數(shù)據(jù)交互。
3、運轉(zhuǎn)流程
1、存儲服務定時向跟蹤服務上傳狀態(tài)信息；
2、客戶端發(fā)起請求；
3、跟 蹤器同步存儲器狀態(tài)，返回存儲服務端口和IP;
4、客戶端執(zhí)行文件操作（上傳，下載）等。
二、SpringBoot2整合
1、核心步驟
1)、配置FastDFS執(zhí)行環(huán)境
2)、文件上傳配置
3)、整合Swagger2測試接口
2、核心依賴
<!-- FastDFS依賴 -->
<dependency>
<groupId>com.github.tobato</groupId>
<artifactId>fastdfs-client</artifactId>
<version>1.26.5</version>
</dependency>
<!-- Swagger2 核心依賴 -->
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger2</artifactId>
<version>2.6.1</version>
</dependency>
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger-ui</artifactId>
<version>2.6.1</version>
</dependency>
3、配置FastDFS
- 核心配置文件
fdfs:
# 鏈接超時
connect-timeout: 60
# 讀取時間
so-timeout: 60
# 生成縮略圖參數(shù)
thumb-image:
width: 150
height: 150
tracker-list: 192.168.72.130:22122
- 核心配置類
@Configuration
@Import(FdfsClientConfig.class)
// Jmx重復注冊bean的問題
@EnableMBeanExport(registration = RegistrationPolicy.IGNORE_EXISTING)
public class DfsConfig {
}
- 文件工具類
@Component
public class FileDfsUtil {
private static final Logger LOGGER = LoggerFactory.getLogger(FileDfsUtil.class);
@Resource
private FastFileStorageClient storageClient ;
/**
* 上傳文件
*/
public String upload(MultipartFile multipartFile) throws Exception{
String originalFilename = multipartFile.getOriginalFilename().
substring(multipartFile.getOriginalFilename().
lastIndexOf(".") + 1);
StorePath storePath = this.storageClient.uploadImageAndCrtThumbImage(
multipartFile.getInputStream(),
multipartFile.getSize(),originalFilename , null);
return storePath.getFullPath() ;
}
/**
* 刪除文件
*/
public void deleteFile(String fileUrl) {
if (StringUtils.isEmpty(fileUrl)) {
LOGGER.info("fileUrl == >>文件路徑為空...");
return;
}
try {
StorePath storePath = StorePath.parseFromUrl(fileUrl);
storageClient.deleteFile(storePath.getGroup(), storePath.getPath());
} catch (Exception e) {
LOGGER.info(e.getMessage());
}
}
}
4、文件上傳配置
spring:
application:
name: ware-fast-dfs
servlet:
multipart:
enabled: true
max-file-size: 10MB
max-request-size: 20MB
5、配置Swagger2
主要用來生成文件上傳的測試界面。
- 配置代碼類
@Configuration
public class SwaggerConfig {
@Bean
public Docket createRestApi() {
return new Docket(DocumentationType.SWAGGER_2)
.apiInfo(apiInfo())
.select()
.apis(RequestHandlerSelectors.basePackage("com.fast.dfs"))
.paths(PathSelectors.any())
.build();
}
private ApiInfo apiInfo() {
return new ApiInfoBuilder()
.title("SpringBoot利用Swagger構(gòu)建API文檔")
.description("使用RestFul風格, 創(chuàng)建人：知了一笑")
.termsOfServiceUrl("https://github.com/cicadasmile")
.version("version 1.0")
.build();
}
}
- 啟動類注解
@EnableSwagger2
三、演示案例
1、接口代碼
@RestController
public class FileController {
@Resource
private FileDfsUtil fileDfsUtil ;
/**
* 文件上傳
*/
@ApiOperation(value="上傳文件", notes="測試FastDFS文件上傳")
@RequestMapping(value = "/uploadFile",headers="content-type=multipart/form-data", method = RequestMethod.POST)
public ResponseEntity<String> uploadFile (@RequestParam("file") MultipartFile file){
String result ;
try{
String path = fileDfsUtil.upload(file) ;
if (!StringUtils.isEmpty(path)){
result = path ;
} else {
result = "上傳失敗" ;
}
} catch (Exception e){
e.printStackTrace() ;
result = "服務異常" ;
}
return ResponseEntity.ok(result);
}
/**
* 文件刪除
*/
@RequestMapping(value = "/deleteByPath", method = RequestMethod.GET)
public ResponseEntity<String> deleteByPath (){
String filePathName = "group1/M00/00/00/wKhIgl0n4AKABxQEABhlMYw_3Lo825.png" ;
fileDfsUtil.deleteFile(filePathName);
return ResponseEntity.ok("SUCCESS") ;
}
}
2、執(zhí)行流程
1、訪問http://localhost:7010/swagger-ui.html測試界面
2、調(diào)用文件上傳接口，拿到文件在FastDFS服務的路徑
3、瀏覽器訪問：http://192.168.72.130/group1/M00/00/00/wKhIgl0n4AKABxQEABhlMYw_3Lo825.png
4、調(diào)用刪除接口，刪除服務器上圖片
5、清空瀏覽器緩存，再次訪問圖片Url,回返回404
以上就是SpringBoot整合FastDFS中間件實現(xiàn)文件分布管理的詳細內(nèi)容，更多關于SpringBoot FastDFS文件管理的資料請關注腳本之家其它相關文章！
相關文章
Java對象頭是對象內(nèi)存布局的核心部分,存儲元數(shù)據(jù)和運行時狀態(tài),這篇文章主要介紹了Java的對象頭原理與源碼超詳細講解的相關資料,文中通過代碼介紹的非常詳細,需要的朋友可以參考下2025-08-08
這篇文章主要介紹了Java servlet執(zhí)行流程代碼實例,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2020-02-02
這篇文章主要為大家介紹了java面試題解LeetCode27二叉樹的鏡像實例，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2023-01-01
Java調(diào)用Python的5種方式總結(jié)(不是所有場景都要用微服務)
在Java中調(diào)用Python腳本,可以通過創(chuàng)建Python進程并與之進行交互來實現(xiàn),這篇文章主要介紹了Java調(diào)用Python的5種方式,文中通過代碼介紹的非常詳細,需要的朋友可以參考下2025-07-07
詳解Java Bellman-Ford算法原理及實現(xiàn)
Bellman-Ford算法與Dijkstra算法類似，都是以松弛操作作為基礎，Bellman-Ford算法是對所有邊都進行松弛操作，本文將詳解Bellman-Ford算法原理及實現(xiàn)，感興趣的可以了解一下2022-07-07
這篇文章主要介紹了Spring Cloud Ribbon負載均衡器處理方法,看看是如何獲取服務實例，獲取以后做了哪些處理，處理后又是如何選取服務實例的，需要的朋友可以參考下2018-02-02
參數(shù)驗證很重要,是平時開發(fā)環(huán)節(jié)中不可少的一部分,但是我想很多后端同事會偷懶,干脆不錯,這樣很可能給系統(tǒng)的穩(wěn)定性和安全性帶來嚴重的危害,那么在Spring Boot應用中如何做好參數(shù)校驗工作呢,本文提供了10個小技巧,需要的朋友可以參考下2023-09-09
這篇文章主要為大家詳細介紹了java實現(xiàn)酒店管理系統(tǒng)，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2020-07-07
今天在寫代碼的時候需要用到一個生成指定范圍隨機數(shù)的函數(shù)，百度了一下，發(fā)現(xiàn)了很多種方法，這里簡單為大家整理一下，方便需要的朋友2017-08-08
基于Restful接口調(diào)用方法總結(jié)(超詳細)
下面小編就為大家?guī)硪黄赗estful接口調(diào)用方法總結(jié)(超詳細)。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2017-08-08