一、FastDFS簡介

1、FastDFS作用

FastDFS是一個開源的輕量級分散式檔案系統，它對檔案進行管理，功能包括：檔案儲存、檔案同步、檔案上傳、檔案下載等，解決了大容量儲存和負載均衡的問題。

安裝連線：

安裝流程詳解

2、核心角色

FastDFS是由跟蹤伺服器（trackerserver）、儲存伺服器（storageserver）和客戶端（client）三個部分組成。

1）跟蹤伺服器

FastDFS的協調者，負責管理所有的storage server和group，每個storage在啟動後會連線Tracker，告知自己所屬的group等資訊，並保持週期性的心跳，tracker根據storage的心跳資訊，建立group到[storage server list]的對映表。

2）儲存伺服器

以組（group）為單位，一個group內包含多臺storage機器，資料互為備份，儲存空間以group內容量最小的storage為準，所以建議group內的多個storage儘量配置相同，以免造成儲存空間的浪費。

3）客戶端

業務請求的發起方，通過專有介面，使用TCP/IP協議與跟蹤器伺服器或儲存節點進行資料互動。

3、運轉流程

1、儲存服務定時向跟蹤服務上傳狀態資訊；
2、客戶端發起請求；
3、跟蹤器同步儲存器狀態，返回儲存服務埠和IP;
4、客戶端執行檔案操作（上傳，下載）等。

二、與SpringBoot2整合

1、核心步驟

1)、配置FastDFS執行環境
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

0. 核心配置檔案

fdfs:
  # 連結超時
  connect-timeout: 60
  # 讀取時間
  so-timeout: 60
  # 生成縮圖引數
  thumb-image:
    width: 150
    height: 150
  tracker-list: 192.168.72.130:22122

1. 核心配置類

@Configuration
@Import(FdfsClientConfig.class)
// Jmx重複註冊bean的問題
@EnableMBeanExport(registration = RegistrationPolicy.IGNORE_EXISTING)
public class DfsConfig {
}

2）檔案工具類

@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

主要用來生成檔案上傳的測試介面。

1）配置程式碼類

@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構建API文件")
                .description("使用RestFul風格, 建立人：知了一笑")
                .termsOfServiceUrl("https://github.com/cicadasmile")
                .version("version 1.0")
                .build();
    }
}

2）啟動類註解

@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、執行流程

1、訪問http://localhost:7010/swagger-ui.html測試介面
2、呼叫檔案上傳介面，拿到檔案在FastDFS服務的路徑
3、瀏覽器訪問：http://192.168.72.130/group1/M00/00/00/wKhIgl0n4AKABxQEABhlMYw_3Lo825.png
4、呼叫刪除介面，刪除伺服器上圖片
5、清空瀏覽器快取，再次訪問圖片Url,回返回404

四、原始碼地址

GitHub地址：知了一笑
https://github.com/cicadasmile/middle-ware-parent
碼雲地址：知了一笑
https://gitee.com/cicadasmile/middle-ware-parent

相關推薦