SpringBoot集成基於tobato的fastdfs-client實現文件上傳下載和刪除

1. 簡介

  基於tobato的fastdfs-client是一個功能完善的FastDFS客戶端工具，它是在FastDFS作者YuQing發布的客戶端基礎上進行了大量的重構，提供了上傳、下載、刪除、生成縮略圖等API。

2. 安裝FastDFS

  Docker部署FastDFS（附示例代碼）

3. 示例代碼

• 創建工程
  
• 修改pom.xml

<project xmlns="http://maven.apache.org/POM/4.0.0"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
	<modelVersion>4.0.0</modelVersion>
	<groupId>com.c3stones</groupId>
	<artifactId>spirng-boot-fastdfs-demo</artifactId>
	<version>0.0.1-SNAPSHOT</version>
	<name>spirng-boot-fastdfs-demo</name>
	<description>Spring Boot FastDFS Demo</description>

	<parent>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-parent</artifactId>
		<version>2.2.8.RELEASE</version>
		<relativePath />
	</parent>

	<dependencies>
		<dependency>
			<groupId>com.github.tobato</groupId>
			<artifactId>fastdfs-client</artifactId>
			<version>1.26.6</version>
		</dependency>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-thymeleaf</artifactId>
		</dependency>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-web</artifactId>
		</dependency>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-test</artifactId>
		</dependency>
	</dependencies>

	<build>
		<plugins>
			<plugin>
				<groupId>org.springframework.boot</groupId>
				<artifactId>spring-boot-maven-plugin</artifactId>
			</plugin>
		</plugins>
	</build>

</project>

• 創建配置文件application.yml

#fastdfs 配置
fdfs:
  # 讀取時間
  so-timeout: 1500
  # 連接超時時間
  connect-timeout: 600
  # 縮略圖
  thumb-image:
    width: 150
    height: 150
  # Tracker服務
  tracker-list:
    - 192.168.0.100:22122

• 創建配置類

import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.EnableMBeanExport;
import org.springframework.context.annotation.Import;
import org.springframework.jmx.support.RegistrationPolicy;

import com.github.tobato.fastdfs.FdfsClientConfig;

/**
 * FastDFS Client配置
 * 
 * @author CL
 *
 */
@Configuration
@Import(FdfsClientConfig.class)
@EnableMBeanExport(registration = RegistrationPolicy.IGNORE_EXISTING)
public class FdfsConfig {

}

• 創建包裝類

import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.time.LocalDateTime;
import java.util.HashSet;
import java.util.Set;

import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.web.multipart.MultipartFile;

import com.github.tobato.fastdfs.domain.fdfs.MetaData;
import com.github.tobato.fastdfs.domain.fdfs.StorePath;
import com.github.tobato.fastdfs.domain.proto.storage.DownloadByteArray;
import com.github.tobato.fastdfs.service.FastFileStorageClient;

/**
 * FastDFS客戶端包裝類
 * 
 * @author CL
 *
 */
@Component
public class FdfsClientWrapper {

	@Autowired
	private FastFileStorageClient fastFileStorageClient;

	public String uploadFile(MultipartFile file) throws IOException {
		if (file != null) {
			byte[] bytes = file.getBytes();
			long fileSize = file.getSize();
			String originalFilename = file.getOriginalFilename();
			String extension = originalFilename.substring(originalFilename.lastIndexOf(".") + 1);
			return this.uploadFile(bytes, fileSize, extension);
		}
		return null;
	}

	/**
	 * 文件上傳
	 * 
	 * @param bytes     文件字節
	 * @param fileSize  文件大小
	 * @param extension 文件擴展名
	 * @return 返回文件路徑（卷名和文件名）
	 */
	public String uploadFile(byte[] bytes, long fileSize, String extension) {
		ByteArrayInputStream bais = new ByteArrayInputStream(bytes);
		// 元數據
		Set<MetaData> metaDataSet = new HashSet<MetaData>();
		metaDataSet.add(new MetaData("dateTime", LocalDateTime.now().toString()));
		StorePath storePath = fastFileStorageClient.uploadFile(bais, fileSize, extension, metaDataSet);
		return storePath.getFullPath();
	}

	/**
	 * 下載文件
	 * 
	 * @param filePath 文件路徑
	 * @return 文件字節
	 * @throws IOException
	 */
	public byte[] downloadFile(String filePath) throws IOException {
		byte[] bytes = null;
		if (StringUtils.isNotBlank(filePath)) {
			String group = filePath.substring(0, filePath.indexOf("/"));
			String path = filePath.substring(filePath.indexOf("/") + 1);
			DownloadByteArray byteArray = new DownloadByteArray();
			bytes = fastFileStorageClient.downloadFile(group, path, byteArray);
		}
		return bytes;
	}

	/**
	 * 刪除文件
	 * 
	 * @param filePath 文件路徑
	 */
	public void deleteFile(String filePath) {
		if (StringUtils.isNotBlank(filePath)) {
			fastFileStorageClient.deleteFile(filePath);
		}
	}

}

• 創建文件上傳Controller

import java.io.IOException;
import java.net.URLEncoder;

import javax.servlet.ServletOutputStream;
import javax.servlet.http.HttpServletResponse;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.multipart.MultipartFile;

import com.c3stones.wapper.FdfsClientWrapper;

/**
 * 文件上傳Controller
 * 
 * @author CL
 *
 */
@Controller
public class FileUploadController {

	private static Logger log = LoggerFactory.getLogger(FileUploadController.class);

	@Autowired
	private FdfsClientWrapper fdfsClientWrapper;

	/**
	 * 進入上傳頁面
	 * 
	 * @return 路徑
	 */
	@RequestMapping(value = "/")
	public String form() {
		return "form";
	}

	/**
	 * 上傳文件
	 * 
	 * @param file 文件
	 * @return 文件路徑
	 */
	@RequestMapping(value = "upload")
	@ResponseBody
	public String uploadFile(MultipartFile file) {
		String filePath = null;
		try {
			filePath = fdfsClientWrapper.uploadFile(file);
		} catch (IOException e) {
			log.error("上傳文件異常：{}", e);
			return "上傳文件失敗";
		}
		return filePath;
	}

	/**
	 * 下載文件
	 * 
	 * @param filePath 文件路徑
	 * @return
	 */
	@RequestMapping(value = "download")
	public void downloadFile(String filePath, HttpServletResponse response) {
		ServletOutputStream outputStream = null;
		try {
			byte[] bytes = fdfsClientWrapper.downloadFile(filePath);
			String fileName = "fdfs.jpg";
			response.setHeader("Content-disposition", "attachment;filename=" + URLEncoder.encode(fileName, "UTF-8"));
			response.setCharacterEncoding("UTF-8");
			if (bytes != null) {
				outputStream = response.getOutputStream();
				outputStream.write(bytes);
				outputStream.flush();
			}
		} catch (IOException e) {
			log.debug("下載文件輸出流異常：{}", e);
		} finally {
			try {
				if (outputStream != null) {
					outputStream.close();
				}
			} catch (IOException e) {
				log.debug("下載文件關閉流異常：{}", e);
			}
		}
	}

	/**
	 * 刪除文件
	 * 
	 * @param filePath 文件路徑
	 * @return 刪除結果
	 */
	@RequestMapping(value = "delete")
	@ResponseBody
	public String deleteFile(String filePath) {
		fdfsClientWrapper.deleteFile(filePath);
		return "刪除成功";
	}

}

• 創建啟動類

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

/**
 * 啟動類
 * 
 * @author CL
 *
 */
@SpringBootApplication
public class Application {

	public static void main(String[] args) {
		SpringApplication.run(Application.class, args);
	}

}

• 在resource下創建templates/form.html

<!DOCTYPE html>
<html>
<head>
<meta charset="UTF-8">
<title>上傳文件</title>
</head>
<body>
	<form action="/upload" method="post" enctype="multipart/form-data">
		選擇文件：<input type="file" name="file"><br /> 
		<input type="submit" value="提交">
	</form>
</body>
</html>

• 啟動項目

4. 測試

• 文件上傳
    瀏覽器訪問：http://localhost:8080/，選擇一種圖片，點擊提交，記錄返回的文件路徑（卷名+文件名）。
• 文件瀏覽
    瀏覽器訪問：http://192.168.0.100:8888/[filePath]
• 文件下載（下載的文件名為：fdfs.jpg）
    瀏覽器訪問：http://localhost:8080/download?filePath=[filePath]
• 文件刪除
    瀏覽器訪問：http://localhost:8080/delete?filePath=[filePath]

5. 項目地址

  spirng-boot-fastdfs-demo