快捷導(dǎo)航

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

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

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

前言

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

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

實(shí)現(xiàn)思路

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

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

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

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

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

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

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

首先，我們需要下載和安裝FastDFS，在此不再贅述。其次，我們需要添加如下依賴(lài)至項(xiàng)目的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客戶(hù)端，spring-boot-starter-web作為SpringBoot中Web項(xiàng)目的起步依賴(lài)，spring-boot-starter-thymeleaf是Thymeleaf模板引擎的依賴(lài)。

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

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

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

實(shí)現(xiàn)步驟

1. 前端頁(yè)面的實(shí)現(xiàn)

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

<!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>

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

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

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

在src/main/java目錄下新建一個(gè)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) {
                // 獲取文件名稱(chēng)
                String originalFilename = file.getOriginalFilename();
                // 獲取文件擴(kuò)展名
                String extName = originalFilename.substring(originalFilename.lastIndexOf(".") + 1);
                // 執(zhí)行上傳
                result = storageClient.upload_file(file.getBytes(), extName, null);
                logger.info("文件上傳成功，儲(chǔ)存路徑為：" + 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客戶(hù)端進(jìn)行了文件上傳，并通過(guò)SpringBoot后端向前端返回了文件的儲(chǔ)存路徑。如果上傳失敗，則返回上傳失敗信息。

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

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

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

<!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>

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

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

總結(jié)

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

完整代碼請(qǐng)參考文末的GitHub鏈接。