SpringBoot整合FastDFS中間件實(shí)現(xiàn)文件分布管理
一、FastDFS簡介
1、FastDFS作用
FastDFS是一個(gè)開源的輕量級(jí)分布式文件系統(tǒng),它對(duì)文件進(jìn)行管理,功能包括:文件存儲(chǔ)、文件同步、文件上傳、文件下載等,解決了大容量存儲(chǔ)和負(fù)載均衡的問題。
2、核心角色
FastDFS是由跟蹤服務(wù)器(trackerserver)、存儲(chǔ)服務(wù)器(storageserver)和客戶端(client)三個(gè)部分組成。
- 跟蹤服務(wù)器
FastDFS的協(xié)調(diào)者,負(fù)責(zé)管理所有的storage server和group,每個(gè)storage在啟動(dòng)后會(huì)連接Tracker,告知自己所屬的group等信息,并保持周期性的心跳,tracker根據(jù)storage的心跳信息,建立group到[storage server list]的映射表。
- 存儲(chǔ)服務(wù)器
以組(group)為單位,一個(gè)group內(nèi)包含多臺(tái)storage機(jī)器,數(shù)據(jù)互為備份,存儲(chǔ)空間以group內(nèi)容量最小的storage為準(zhǔn),所以建議group內(nèi)的多個(gè)storage盡量配置相同,以免造成存儲(chǔ)空間的浪費(fèi)。
- 客戶端
業(yè)務(wù)請(qǐng)求的發(fā)起方,通過專有接口,使用TCP/IP協(xié)議與跟 蹤器服務(wù)器或存儲(chǔ)節(jié)點(diǎn)進(jìn)行數(shù)據(jù)交互。
3、運(yùn)轉(zhuǎn)流程
1、存儲(chǔ)服務(wù)定時(shí)向跟蹤服務(wù)上傳狀態(tài)信息;
2、客戶端發(fā)起請(qǐng)求;
3、跟 蹤器同步存儲(chǔ)器狀態(tài),返回存儲(chǔ)服務(wù)端口和IP;
4、客戶端執(zhí)行文件操作(上傳,下載)等。
二、SpringBoot2整合
1、核心步驟
1)、配置FastDFS執(zhí)行環(huán)境
2)、文件上傳配置
3)、整合Swagger2測(cè)試接口
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:
# 鏈接超時(shí)
connect-timeout: 60
# 讀取時(shí)間
so-timeout: 60
# 生成縮略圖參數(shù)
thumb-image:
width: 150
height: 150
tracker-list: 192.168.72.130:22122
- 核心配置類
@Configuration
@Import(FdfsClientConfig.class)
// Jmx重復(fù)注冊(cè)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
主要用來生成文件上傳的測(cè)試界面。
- 配置代碼類
@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風(fēng)格, 創(chuàng)建人:知了一笑")
.termsOfServiceUrl("https://github.com/cicadasmile")
.version("version 1.0")
.build();
}
}
- 啟動(dòng)類注解
@EnableSwagger2
三、演示案例
1、接口代碼
@RestController
public class FileController {
@Resource
private FileDfsUtil fileDfsUtil ;
/**
* 文件上傳
*/
@ApiOperation(value="上傳文件", notes="測(cè)試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 = "服務(wù)異常" ;
}
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測(cè)試界面
2、調(diào)用文件上傳接口,拿到文件在FastDFS服務(wù)的路徑
3、瀏覽器訪問:http://192.168.72.130/group1/M00/00/00/wKhIgl0n4AKABxQEABhlMYw_3Lo825.png
4、調(diào)用刪除接口,刪除服務(wù)器上圖片
5、清空瀏覽器緩存,再次訪問圖片Url,回返回404
以上就是SpringBoot整合FastDFS中間件實(shí)現(xiàn)文件分布管理的詳細(xì)內(nèi)容,更多關(guān)于SpringBoot FastDFS文件管理的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章!
相關(guān)文章
Java servlet執(zhí)行流程代碼實(shí)例
這篇文章主要介紹了Java servlet執(zhí)行流程代碼實(shí)例,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-02-02
java面試題解LeetCode27二叉樹的鏡像實(shí)例
這篇文章主要為大家介紹了java面試題解LeetCode27二叉樹的鏡像實(shí)例,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-01-01
Java調(diào)用Python的5種方式總結(jié)(不是所有場景都要用微服務(wù))
在Java中調(diào)用Python腳本,可以通過創(chuàng)建Python進(jìn)程并與之進(jìn)行交互來實(shí)現(xiàn),這篇文章主要介紹了Java調(diào)用Python的5種方式,文中通過代碼介紹的非常詳細(xì),需要的朋友可以參考下2025-07-07
詳解Java Bellman-Ford算法原理及實(shí)現(xiàn)
Bellman-Ford算法與Dijkstra算法類似,都是以松弛操作作為基礎(chǔ),Bellman-Ford算法是對(duì)所有邊都進(jìn)行松弛操作,本文將詳解Bellman-Ford算法原理及實(shí)現(xiàn),感興趣的可以了解一下2022-07-07
Spring Cloud Ribbon負(fù)載均衡器處理方法
這篇文章主要介紹了Spring Cloud Ribbon負(fù)載均衡器處理方法,看看是如何獲取服務(wù)實(shí)例,獲取以后做了哪些處理,處理后又是如何選取服務(wù)實(shí)例的,需要的朋友可以參考下2018-02-02
SpringBoot的10個(gè)參數(shù)驗(yàn)證技巧分享
參數(shù)驗(yàn)證很重要,是平時(shí)開發(fā)環(huán)節(jié)中不可少的一部分,但是我想很多后端同事會(huì)偷懶,干脆不錯(cuò),這樣很可能給系統(tǒng)的穩(wěn)定性和安全性帶來嚴(yán)重的危害,那么在Spring Boot應(yīng)用中如何做好參數(shù)校驗(yàn)工作呢,本文提供了10個(gè)小技巧,需要的朋友可以參考下2023-09-09
Java實(shí)現(xiàn)簡單的酒店管理系統(tǒng)
這篇文章主要為大家詳細(xì)介紹了java實(shí)現(xiàn)酒店管理系統(tǒng),文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2020-07-07
基于Restful接口調(diào)用方法總結(jié)(超詳細(xì))
下面小編就為大家?guī)硪黄赗estful接口調(diào)用方法總結(jié)(超詳細(xì))。小編覺得挺不錯(cuò)的,現(xiàn)在就分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧2017-08-08

