FastDFS 服務端安裝參考文章：分布式檔案系統之 FastDFS
安裝 FastDFS Java 客戶端
先從 GitHub 上將專案原始碼克隆下來：
$ git clone https://github.com/happyfish100/fastdfs-client-java.git
然后不要忘了部署到 Nexus 依賴私服：
$ mvn clean install deploy
最后在需要用到的專案中添加 POM 依賴即可：
<!-- FastDFS Begin -->
<dependency>
<groupId>org.csource</groupId>
<artifactId>fastdfs-client-java</artifactId>
<version>1.27-SNAPSHOT</version>
</dependency>
<!-- FastDFS End -->
引入依賴以后在 application.yml 中添加 FastDFS 服務端配置：
fastdfs:
base:
# 一般為 Nginx 代理地址
url: http://{fastdfs_server ip}/
storage:
type: fastdfs
fastdfs:
tracker_server: {tracker_server ip}
創建 FastDFS 工具類
定義檔案存盤介面
package com.antoniopeng.fastdfs.service.upload;
/**
* 檔案存盤服務介面
*/
public interface StorageService {
/**
* 上傳檔案
*
* @param data 檔案的二進制內容
* @param extName 擴展名
* @return 上傳成功后回傳生成的檔案 id；失敗回傳 null
*/
public String upload(byte[] data, String extName);
/**
* 洗掉檔案
*
* @param fileId 被洗掉的檔案id
* @return 洗掉成功后回傳 0，失敗后回傳錯誤代碼
*/
public int delete(String fileId);
}
實作檔案存盤介面
package com.antoniopeng.fastdfs.service.upload;
import org.csource.common.NameValuePair;
import org.csource.fastdfs.ClientGlobal;
import org.csource.fastdfs.StorageClient1;
import org.csource.fastdfs.StorageServer;
import org.csource.fastdfs.TrackerClient;
import org.csource.fastdfs.TrackerGroup;
import org.csource.fastdfs.TrackerServer;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.beans.factory.annotation.Value;
import java.io.File;
import java.io.FileWriter;
import java.io.IOException;
import java.io.PrintWriter;
/**
* 檔案存盤服務實作
*/
public class FastDFSStorageService implements StorageService, InitializingBean {
private static final Logger logger = LoggerFactory.getLogger(FastDFSStorageService.class);
private TrackerClient trackerClient;
@Value("${storage.fastdfs.tracker_server}")
private String trackerServer;
@Override
public String upload(byte[] data, String extName) {
TrackerServer trackerServer = null;
StorageServer storageServer = null;
StorageClient1 storageClient1 = null;
try {
NameValuePair[] meta_list = null; // new NameValuePair[0];
trackerServer = trackerClient.getConnection();
if (trackerServer == null) {
logger.error("getConnection return null");
}
storageServer = trackerClient.getStoreStorage(trackerServer);
storageClient1 = new StorageClient1(trackerServer, storageServer);
String fileid = storageClient1.upload_file1(data, extName, meta_list);
logger.debug("uploaded file <{}>", fileid);
return fileid;
} catch (Exception ex) {
logger.error("Upload fail", ex);
return null;
} finally {
if (storageServer != null) {
try {
storageServer.close();
} catch (IOException e) {
e.printStackTrace();
}
}
if (trackerServer != null) {
try {
trackerServer.close();
} catch (IOException e) {
e.printStackTrace();
}
}
storageClient1 = null;
}
}
@Override
public int delete(String fileId) {
TrackerServer trackerServer = null;
StorageServer storageServer = null;
StorageClient1 storageClient1 = null;
int index = fileId.indexOf('/');
String groupName = fileId.substring(0, index);
try {
trackerServer = trackerClient.getConnection();
if (trackerServer == null) {
logger.error("getConnection return null");
}
storageServer = trackerClient.getStoreStorage(trackerServer, groupName);
storageClient1 = new StorageClient1(trackerServer, storageServer);
int result = storageClient1.delete_file1(fileId);
return result;
} catch (Exception ex) {
logger.error("Delete fail", ex);
return 1;
} finally {
if (storageServer != null) {
try {
storageServer.close();
} catch (IOException e) {
e.printStackTrace();
}
}
if (trackerServer != null) {
try {
trackerServer.close();
} catch (IOException e) {
e.printStackTrace();
}
}
storageClient1 = null;
}
}
@Override
public void afterPropertiesSet() throws Exception {
File confFile = File.createTempFile("fastdfs", ".conf");
PrintWriter confWriter = new PrintWriter(new FileWriter(confFile));
confWriter.println("tracker_server=" + trackerServer);
confWriter.close();
ClientGlobal.init(confFile.getAbsolutePath());
confFile.delete();
TrackerGroup trackerGroup = ClientGlobal.g_tracker_group;
trackerClient = new TrackerClient(trackerGroup);
logger.info("Init FastDFS with tracker_server : {}", trackerServer);
}
}
創建檔案存盤工廠類
package com.antoniopeng.fastdfs.service.upload;
import org.springframework.beans.factory.FactoryBean;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.beans.factory.config.AutowireCapableBeanFactory;
import java.util.HashMap;
import java.util.Map;
/**
* 檔案存盤服務工廠類
*/
public class StorageFactory implements FactoryBean<StorageService> {
@Autowired
private AutowireCapableBeanFactory acbf;
/**
* 存盤服務的型別，目前僅支持fastdfs
*/
@Value("${storage.type}")
private String type;
private Map<String, Class<? extends StorageService>> classMap;
public StorageFactory() {
classMap = new HashMap<>();
classMap.put("fastdfs", FastDFSStorageService.class);
}
@Override
public StorageService getObject() throws Exception {
Class<? extends StorageService> clazz = classMap.get(type);
if (clazz == null) {
throw new RuntimeException("Unsupported storage type [" + type + "], valid are " + classMap.keySet());
}
StorageService bean = clazz.newInstance();
acbf.autowireBean(bean);
acbf.initializeBean(bean, bean.getClass().getSimpleName());
return bean;
}
@Override
public Class<?> getObjectType() {
return StorageService.class;
}
@Override
public boolean isSingleton() {
return true;
}
}
組態檔存盤工廠類
package com.antoniopeng.fastdfs.service.upload;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/**
* Java 配置方式定義 StorageFactory 的 Bean 使其可以被依賴注入
*/
@Configuration
public class FastDFSConfiguration {
@Bean
public StorageFactory storageFactory() {
return new StorageFactory();
}
}
創建 FastDFS 訪問控制器
package com.antoniopeng.fastdfs.controller.upload;
import com.antoniopeng.fastdfs.service.upload.StorageService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.CrossOrigin;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;
import java.io.IOException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@CrossOrigin(origins = "*", maxAge = 3600)
@RestController
public class UploadController {
@Value("${fastdfs.base.url}")
private String FASTDFS_BASE_URL;
@Autowired
private StorageService storageService;
/**
* 檔案上傳
*
* @param dropFile Dropzone
* @param editorFiles wangEditor
* @return
*/
@RequestMapping(value = "https://www.cnblogs.com/antoniopeng/archive/2020/12/23/upload", method = RequestMethod.POST)
public Map<String, Object> upload(MultipartFile dropFile, MultipartFile[] editorFiles) {
Map<String, Object> result = new HashMap<>();
// Dropzone 上傳
if (dropFile != null) {
result.put("fileName", writeFile(dropFile));
}
// wangEditor 上傳
if (editorFiles != null && editorFiles.length > 0) {
List<String> fileNames = new ArrayList<>();
for (MultipartFile editorFile : editorFiles) {
fileNames.add(writeFile(editorFile));
}
result.put("errno", 0);
result.put("data", fileNames);
}
return result;
}
/**
* 將圖片寫入指定目錄
*
* @param multipartFile
* @return 回傳檔案完整路徑
*/
private String writeFile(MultipartFile multipartFile) {
// 獲取檔案后綴
String oName = multipartFile.getOriginalFilename();
String extName = oName.substring(oName.lastIndexOf(".") + 1);
// 檔案存放路徑
String url = null;
try {
String uploadUrl = storageService.upload(multipartFile.getBytes(), extName);
url = FASTDFS_BASE_URL + uploadUrl;
} catch (IOException e) {
e.printStackTrace();
}
// 回傳檔案完整路徑
return url;
}
}
- 文章作者：彭超
- 本文首發于個人博客：https://antoniopeng.com
- 著作權宣告：本博客所有文章除特別宣告外，均采用 CC BY-NC-SA 4.0 許可協議，轉載請注明來自 彭超的博客！
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/239440.html
標籤：其他
上一篇：分布式檔案系統之 FastDFS