SpringBoot多文件分布式上傳功能實現(xiàn)

更新時間：2023年06月05日 11:18:01 作者：FeereBug

本文詳細介紹了如何在SpringBoot中實現(xiàn)多文件分布式上傳，并用代碼給出了相應(yīng)的實現(xiàn)思路和實現(xiàn)步驟，感興趣的朋友跟隨小編一起看看吧

前言

在現(xiàn)代化的互聯(lián)網(wǎng)應(yīng)用中，各種形式的上傳都成為了必備的功能之一。而對于大文件上傳以及多文件上傳來說，我們往往需要考慮分布式儲存的方案，以實現(xiàn)高效和可擴展性。

本文將詳細介紹在SpringBoot中實現(xiàn)多文件分布式上傳的方法，我們將使用一個開源軟件FastDFS作為我們的分布式儲存方案。

實現(xiàn)思路

在實現(xiàn)多文件分布式上傳之前，我們需要了解一些必要的預(yù)備知識和技術(shù)：

FastDFS - 一款開源的輕量級分布式文件系統(tǒng)。
SpringBoot - 基于Java的輕量級Web開發(fā)框架。
Thymeleaf - 基于Java的模板引擎。

我們將使用SpringBoot作為我們的后端開發(fā)框架，采用Thymeleaf模板引擎作為我們的前端展示。而FastDFS則作為我們的分布式儲存方案。

總體的實現(xiàn)思路步驟如下：

前端頁面通過SpringBoot后端暴露的RESTful接口，向FastDFS服務(wù)器上傳文件。
后端接收到前端上傳的文件，并通過FastDFS上傳至儲存服務(wù)器。
后端返回文件的儲存路徑，以供前端進行展示。

環(huán)境準(zhǔn)備

在進行實現(xiàn)之前，我們需要對環(huán)境進行一些準(zhǔn)備。

首先，我們需要下載和安裝FastDFS，在此不再贅述。其次，我們需要添加如下依賴至項目的pom.xml文件中：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
	<groupId>org.csource</groupId>
	<artifactId>fastdfs-client-java</artifactId>
	<version>1.29-SNAPSHOT</version>
	<exclusions>
		<exclusion>
			<artifactId>log4j-api</artifactId>
			<groupId>org.apache.logging.log4j</groupId>
		</exclusion>
		<exclusion>
			<artifactId>log4j-core</artifactId>
			<groupId>org.apache.logging.log4j</groupId>
		</exclusion>
	</exclusions>
</dependency>
<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-thymeleaf</artifactId>
</dependency>

其中，fastdfs-client-java是FastDFS的Java客戶端，spring-boot-starter-web作為SpringBoot中Web項目的起步依賴，spring-boot-starter-thymeleaf是Thymeleaf模板引擎的依賴。

為了方便管理FastDFS服務(wù)器的配置，在項目的resources目錄下新建一個名為fdfs_client.conf的文件，添加如下配置：

# 連接超時時間（單位：毫秒）
connect_timeout=600
# 網(wǎng)絡(luò)超時時間（單位：毫秒）
network_timeout=1200
# 編碼字符集
charset=UTF-8
# HTTP訪問服務(wù)的端口號
http.tracker_http_port=8888
# HTTP訪問服務(wù)的IP地址（需要填寫Tracker服務(wù)的地址）
http.tracker_http_ip=tracker:80
# Tracker服務(wù)器列表，多個tracker使用半角逗號分隔
tracker_server=tracker:22122

其中，tracker_http_ip和tracker_server需要根據(jù)實際情況進行配置。

實現(xiàn)步驟

1. 前端頁面的實現(xiàn)

在src/main/resources/templates目錄下新建一個index.html文件，作為我們的前端頁面，添加如下代碼：

<!DOCTYPE html>
<html lang="en"
      xmlns:th="http://www.thymeleaf.org">
<head>
    <meta charset="UTF-8">
    <title>SpringBoot Multiple File Upload</title>
</head>
<body>
    <form th:action="@{/upload}" method="post" enctype="multipart/form-data">
        <input type="file" name="files" multiple>
        <button type="submit">Upload</button>
    </form>
</body>
</html>

在該頁面中，我們向用戶展示了一個用于文件選擇的<input>表單和一個用于提交用戶選擇的文件的<button>按鈕。當(dāng)用戶點擊提交按鈕時，我們將利用SpringBoot后端暴露的/upload接口向FastDFS服務(wù)器上傳文件。

2. 后端接口的實現(xiàn)

在SpringBoot中，我們可以使用@RestController注解定義一個RESTful風(fēng)格的Web服務(wù)，用于接收前端的請求。

在src/main/java目錄下新建一個UploadController.java文件，并添加如下代碼：

package com.example.upload.controller;
import org.csource.common.MyException;
import org.csource.fastdfs.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.multipart.MultipartFile;
import java.io.IOException;
@Controller
public class UploadController {
    private final Logger logger = LoggerFactory.getLogger(this.getClass());
    @Value("${fdfs.conf.path}")
    private String fdfsConfPath;
    @RequestMapping("/")
    public String index() {
        return "index";
    }
    @PostMapping("/upload")
    public String handleFileUpload(@RequestParam("files") MultipartFile[] files, Model model) {
        try {
            // 加載FastDFS的配置文件
            ClientGlobal.init(fdfsConfPath);
            // 創(chuàng)建TrackerClient
            TrackerClient trackerClient = new TrackerClient();
            // 獲取TrackerServer
            TrackerServer trackerServer = trackerClient.getConnection();
            // 獲取StorageServer
            StorageServer storageServer = trackerClient.getStoreStorage(trackerServer);
            // 創(chuàng)建StorageClient
            StorageClient storageClient = new StorageClient(trackerServer, storageServer);
            String[] result = null;
            for (MultipartFile file : files) {
                // 獲取文件名稱
                String originalFilename = file.getOriginalFilename();
                // 獲取文件擴展名
                String extName = originalFilename.substring(originalFilename.lastIndexOf(".") + 1);
                // 執(zhí)行上傳
                result = storageClient.upload_file(file.getBytes(), extName, null);
                logger.info("文件上傳成功，儲存路徑為：" + result[0] + "/" + result[1]);
                model.addAttribute("message", "文件上傳成功");
                model.addAttribute("path", result[0] + "/" + result[1]);
            }
        } catch (IOException | MyException e) {
            logger.error("文件上傳失敗", e);
            model.addAttribute("message", "文件上傳失敗");
        }
        return "result";
    }
}

在上述代碼中，我們使用了@Value注解注入了FastDFS的配置文件路徑。在handleFileUpload方法中，我們使用FastDFS客戶端進行了文件上傳，并通過SpringBoot后端向前端返回了文件的儲存路徑。如果上傳失敗，則返回上傳失敗信息。

除此之外，我們還在index()方法中定義了訪問/路徑時返回的頁面，并在handleFileUpload方法中定義了訪問/upload路徑時的上傳接口。

3. 前端展示頁面的實現(xiàn)

在src/main/resources/templates目錄下新建一個result.html文件，作為文件上傳成功后的頁面，添加如下代碼：

<!DOCTYPE html>
<html lang="en"
      xmlns:th="http://www.thymeleaf.org">
<head>
    <meta charset="UTF-8">
    <title>Upload Result</title>
</head>
<body>
    <h1 th:text="${message}"></h1>
    <p th:text="${path}"></p>
</body>
</html>

在該頁面中，我們使用了Thymeleaf模板引擎的語法，動態(tài)地向用戶展示上傳結(jié)果，并展示了文件的儲存路徑。

至此，我們的多文件分布式上傳功能實現(xiàn)完畢。

總結(jié)

本文詳細介紹了如何在SpringBoot中實現(xiàn)多文件分布式上傳，并用代碼給出了相應(yīng)的實現(xiàn)思路和實現(xiàn)步驟。通過本文的學(xué)習(xí)，讀者可以了解到如何使用FastDFS作為分布式文件儲存方案，如何在SpringBoot中搭建RESTful接口，以及如何使用Thymeleaf模板引擎進行前端展示。希望本文能夠?qū)δ兴鶐椭?/p>

完整代碼請參考文末的GitHub鏈接。