|
|
|
@ -19,58 +19,77 @@ import org.csource.fastdfs.StorageServer;
|
|
|
|
import org.csource.fastdfs.TrackerClient;
|
|
|
|
import org.csource.fastdfs.TrackerClient;
|
|
|
|
import org.csource.fastdfs.TrackerServer;
|
|
|
|
import org.csource.fastdfs.TrackerServer;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
|
|
|
* FastDfsService 类实现了 DfsService 接口，用于与 FastDFS 分布式文件系统进行交互。
|
|
|
|
|
|
|
|
* 该类采用单例模式，确保在整个应用中只有一个实例与 FastDFS 进行通信。
|
|
|
|
|
|
|
|
*/
|
|
|
|
public class FastDfsService implements DfsService {
|
|
|
|
public class FastDfsService implements DfsService {
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 单例实例
|
|
|
|
private static FastDfsService instance = null;
|
|
|
|
private static FastDfsService instance = null;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 基础 URL，用于构建文件的完整 HTTP 访问路径
|
|
|
|
private String baseUrl = "";
|
|
|
|
private String baseUrl = "";
|
|
|
|
|
|
|
|
// DMS 基础 URL，用于构建 DMS 文件的完整 HTTP 访问路径
|
|
|
|
private String dmsBaseUrl = "";
|
|
|
|
private String dmsBaseUrl = "";
|
|
|
|
|
|
|
|
// 默认图片 URL
|
|
|
|
private String defaultPicUrl = "";
|
|
|
|
private String defaultPicUrl = "";
|
|
|
|
|
|
|
|
|
|
|
|
//private static Logger logger = Logger.getLogger(FastDfsService.class.getName());
|
|
|
|
// 配置文件中基础 URL 的键名
|
|
|
|
|
|
|
|
|
|
|
|
private static String BASE_URL = "httpBaseUrl";
|
|
|
|
private static String BASE_URL = "httpBaseUrl";
|
|
|
|
|
|
|
|
// 配置文件中 DMS 基础 URL 的键名
|
|
|
|
private static String DMS_BASE_URL = "dmsBaseUrl";
|
|
|
|
private static String DMS_BASE_URL = "dmsBaseUrl";
|
|
|
|
|
|
|
|
// 配置文件中默认图片 URL 的键名
|
|
|
|
private static String DEFAULT_PIC_URL = "defaultPicUrl";
|
|
|
|
private static String DEFAULT_PIC_URL = "defaultPicUrl";
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// FastDFS 键名，用于元数据中存储文件的唯一标识
|
|
|
|
private static String FAST_DFS_KEY = "FastDfsKey";
|
|
|
|
private static String FAST_DFS_KEY = "FastDfsKey";
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* bucket name
|
|
|
|
* 存储文件的桶名
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
private final String bucketName;
|
|
|
|
private final String bucketName;
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* constructor with bucketName
|
|
|
|
* 私有构造函数，用于初始化 FastDfsService 实例。
|
|
|
|
|
|
|
|
* 该构造函数会读取 FastDFS 配置文件，并初始化客户端全局配置。
|
|
|
|
*
|
|
|
|
*
|
|
|
|
* @param bucketName bucket name
|
|
|
|
* @param bucketName 存储文件的桶名
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
private FastDfsService(String bucketName) {
|
|
|
|
private FastDfsService(String bucketName) {
|
|
|
|
this.bucketName = bucketName;
|
|
|
|
this.bucketName = bucketName;
|
|
|
|
String configFilePath = null;
|
|
|
|
String configFilePath = null;
|
|
|
|
try {
|
|
|
|
|
|
|
|
configFilePath = FastDfsService.class.getResource("/").toURI().getPath() + "fdfs_client.conf";
|
|
|
|
|
|
|
|
} catch (URISyntaxException e1) {
|
|
|
|
|
|
|
|
Exception e = new Exception("Cann't found fdfs_client.conf file under " + FastDfsService.class.getResource("/"));
|
|
|
|
|
|
|
|
handleException(e);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
|
|
|
|
// 获取 FastDFS 配置文件的路径
|
|
|
|
|
|
|
|
configFilePath = FastDfsService.class.getResource("/").toURI().getPath() + "fdfs_client.conf";
|
|
|
|
|
|
|
|
} catch (URISyntaxException e1) {
|
|
|
|
|
|
|
|
// 若无法找到配置文件，抛出异常并处理
|
|
|
|
|
|
|
|
Exception e = new Exception("Cann't found fdfs_client.conf file under " + FastDfsService.class.getResource("/"));
|
|
|
|
|
|
|
|
handleException(e);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
try {
|
|
|
|
|
|
|
|
// 初始化 FastDFS 客户端全局配置
|
|
|
|
ClientGlobal.init(configFilePath);
|
|
|
|
ClientGlobal.init(configFilePath);
|
|
|
|
|
|
|
|
// 读取配置文件
|
|
|
|
IniFileReader reader = new IniFileReader(configFilePath);
|
|
|
|
IniFileReader reader = new IniFileReader(configFilePath);
|
|
|
|
|
|
|
|
// 设置基础 URL
|
|
|
|
setBaseUrl(reader.getStrValue(BASE_URL));
|
|
|
|
setBaseUrl(reader.getStrValue(BASE_URL));
|
|
|
|
|
|
|
|
// 设置 DMS 基础 URL
|
|
|
|
setDmsBaseUrl(reader.getStrValue(DMS_BASE_URL));
|
|
|
|
setDmsBaseUrl(reader.getStrValue(DMS_BASE_URL));
|
|
|
|
|
|
|
|
// 设置默认图片 URL
|
|
|
|
setDefaultPicUrl(reader.getStrValue(DEFAULT_PIC_URL));
|
|
|
|
setDefaultPicUrl(reader.getStrValue(DEFAULT_PIC_URL));
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
|
|
|
// 处理初始化过程中出现的异常
|
|
|
|
handleException(e);
|
|
|
|
handleException(e);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* Get instance of FastDfsService, for Singleton
|
|
|
|
* 获取 FastDfsService 单例实例的方法。
|
|
|
|
* @param bucketName bucket name
|
|
|
|
* 采用双重检查锁定机制确保线程安全。
|
|
|
|
* @return instance of FastDfsService
|
|
|
|
*
|
|
|
|
|
|
|
|
* @param bucketName 存储文件的桶名
|
|
|
|
|
|
|
|
* @return FastDfsService 单例实例
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
public static synchronized FastDfsService getInstance(String bucketName) {
|
|
|
|
public static synchronized FastDfsService getInstance(String bucketName) {
|
|
|
|
if (null == instance) {
|
|
|
|
if (null == instance) {
|
|
|
|
@ -80,11 +99,11 @@ public class FastDfsService implements DfsService {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* Delete file on file system.
|
|
|
|
* 从文件系统中删除指定的文件。
|
|
|
|
*
|
|
|
|
*
|
|
|
|
* @param remotePath remote file path
|
|
|
|
* @param remotePath 远程文件路径
|
|
|
|
* @param key Key, not used in FastDFS
|
|
|
|
* @param key 文件的键，在 FastDFS 中未使用
|
|
|
|
* @return true|false
|
|
|
|
* @return 删除成功返回 true，失败返回 false
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|
public boolean deleteObject(String remotePath, String key) {
|
|
|
|
public boolean deleteObject(String remotePath, String key) {
|
|
|
|
@ -92,21 +111,28 @@ public class FastDfsService implements DfsService {
|
|
|
|
TrackerClient trackerClient = new TrackerClient();
|
|
|
|
TrackerClient trackerClient = new TrackerClient();
|
|
|
|
TrackerServer trackerServer = null;
|
|
|
|
TrackerServer trackerServer = null;
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
|
|
|
|
// 获取 Tracker 服务器连接
|
|
|
|
trackerServer = trackerClient.getConnection();
|
|
|
|
trackerServer = trackerClient.getConnection();
|
|
|
|
|
|
|
|
// 创建存储客户端
|
|
|
|
StorageClient storageClient = new StorageClient(trackerServer, null);
|
|
|
|
StorageClient storageClient = new StorageClient(trackerServer, null);
|
|
|
|
|
|
|
|
// 调用 FastDFS API 删除文件
|
|
|
|
result = storageClient.delete_file(bucketName, remotePath);
|
|
|
|
result = storageClient.delete_file(bucketName, remotePath);
|
|
|
|
} catch(Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
|
|
|
// 处理删除过程中出现的异常
|
|
|
|
handleException(e);
|
|
|
|
handleException(e);
|
|
|
|
} finally {
|
|
|
|
} finally {
|
|
|
|
if (null != trackerServer) {
|
|
|
|
if (null != trackerServer) {
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
|
|
|
|
// 关闭 Tracker 服务器连接
|
|
|
|
trackerServer.close();
|
|
|
|
trackerServer.close();
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
|
|
|
// 处理关闭连接时出现的异常
|
|
|
|
handleException(e);
|
|
|
|
handleException(e);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if (0 != result) {
|
|
|
|
if (0 != result) {
|
|
|
|
|
|
|
|
// 删除失败，记录日志并返回 false
|
|
|
|
//logger.info("delete faild, the faild code is: " + result);
|
|
|
|
//logger.info("delete faild, the faild code is: " + result);
|
|
|
|
return false;
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
@ -114,26 +140,33 @@ public class FastDfsService implements DfsService {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* Find the whole url
|
|
|
|
* 根据远程路径构建文件的完整 HTTP 访问路径。
|
|
|
|
*
|
|
|
|
*
|
|
|
|
* @param remotePath remote path
|
|
|
|
* @param remotePath 远程文件路径
|
|
|
|
* @return the whole url
|
|
|
|
* @return 文件的完整 HTTP 访问路径
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|
public String getHttpPath(String remotePath) {
|
|
|
|
public String getHttpPath(String remotePath) {
|
|
|
|
return baseUrl + "/" + bucketName + "/" + remotePath;
|
|
|
|
return baseUrl + "/" + bucketName + "/" + remotePath;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
|
|
|
* 根据 DMS 文件路径构建其完整的 HTTP 访问路径。
|
|
|
|
|
|
|
|
*
|
|
|
|
|
|
|
|
* @param dmsFilePath DMS 文件路径
|
|
|
|
|
|
|
|
* @return DMS 文件的完整 HTTP 访问路径
|
|
|
|
|
|
|
|
*/
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|
public String getDmsHttpPath(String dmsFilePath) {
|
|
|
|
public String getDmsHttpPath(String dmsFilePath) {
|
|
|
|
return dmsBaseUrl + dmsFilePath;
|
|
|
|
return dmsBaseUrl + dmsFilePath;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* Get the file, and return DfsFile object
|
|
|
|
* 从文件系统中获取指定的文件。
|
|
|
|
*
|
|
|
|
*
|
|
|
|
* @param remotePath remote path
|
|
|
|
* @param remotePath 远程文件路径
|
|
|
|
* @param key Key, not used in FastDFS, can be null
|
|
|
|
* @param key 文件的键，在 FastDFS 中未使用，可以为 null
|
|
|
|
* @return DfsFile object or null if fail
|
|
|
|
* @return 若获取成功，返回 DfsFile 对象；否则返回 null
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|
public DfsFile getObject(String remotePath, String key) {
|
|
|
|
public DfsFile getObject(String remotePath, String key) {
|
|
|
|
@ -141,59 +174,75 @@ public class FastDfsService implements DfsService {
|
|
|
|
TrackerServer trackerServer = null;
|
|
|
|
TrackerServer trackerServer = null;
|
|
|
|
StorageServer storageServer = null;
|
|
|
|
StorageServer storageServer = null;
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
|
|
|
|
// 获取 Tracker 服务器连接
|
|
|
|
trackerServer = trackerClient.getConnection();
|
|
|
|
trackerServer = trackerClient.getConnection();
|
|
|
|
|
|
|
|
// 获取存储服务器
|
|
|
|
storageServer = trackerClient.getFetchStorage(trackerServer, bucketName, remotePath);
|
|
|
|
storageServer = trackerClient.getFetchStorage(trackerServer, bucketName, remotePath);
|
|
|
|
|
|
|
|
// 创建存储客户端
|
|
|
|
StorageClient storageClient = new StorageClient(trackerServer, storageServer);
|
|
|
|
StorageClient storageClient = new StorageClient(trackerServer, storageServer);
|
|
|
|
|
|
|
|
// 下载文件
|
|
|
|
byte[] bytes = storageClient.download_file(this.bucketName, remotePath);
|
|
|
|
byte[] bytes = storageClient.download_file(this.bucketName, remotePath);
|
|
|
|
if (null != bytes) {
|
|
|
|
if (null != bytes) {
|
|
|
|
|
|
|
|
// 获取文件的元数据
|
|
|
|
NameValuePair[] value_pairs = storageClient.get_metadata(bucketName, remotePath);
|
|
|
|
NameValuePair[] value_pairs = storageClient.get_metadata(bucketName, remotePath);
|
|
|
|
Map<String, String> metadata = new HashMap<String, String>();
|
|
|
|
Map<String, String> metadata = new HashMap<String, String>();
|
|
|
|
for (int i = 0; i < value_pairs.length; i++) {
|
|
|
|
for (int i = 0; i < value_pairs.length; i++) {
|
|
|
|
|
|
|
|
// 将元数据存储到 Map 中
|
|
|
|
metadata.put(value_pairs[i].getName(), value_pairs[i].getValue());
|
|
|
|
metadata.put(value_pairs[i].getName(), value_pairs[i].getValue());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
// 创建 DfsFile 对象
|
|
|
|
DfsFile dfsFile = new DfsFile(metadata.get(FAST_DFS_KEY), bytes, metadata);
|
|
|
|
DfsFile dfsFile = new DfsFile(metadata.get(FAST_DFS_KEY), bytes, metadata);
|
|
|
|
return dfsFile;
|
|
|
|
return dfsFile;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
} catch (Exception e){
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
|
|
|
// 处理获取文件过程中出现的异常
|
|
|
|
handleException(e);
|
|
|
|
handleException(e);
|
|
|
|
} finally {
|
|
|
|
} finally {
|
|
|
|
if (null != storageServer) {
|
|
|
|
if (null != storageServer) {
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
|
|
|
|
// 关闭存储服务器连接
|
|
|
|
storageServer.close();
|
|
|
|
storageServer.close();
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
|
|
|
// 处理关闭连接时出现的异常
|
|
|
|
handleException(e);
|
|
|
|
handleException(e);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if (null != trackerServer) {
|
|
|
|
if (null != trackerServer) {
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
|
|
|
|
// 关闭 Tracker 服务器连接
|
|
|
|
trackerServer.close();
|
|
|
|
trackerServer.close();
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
|
|
|
// 处理关闭连接时出现的异常
|
|
|
|
handleException(e);
|
|
|
|
handleException(e);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
// 获取文件失败，记录日志并返回 null
|
|
|
|
//logger.info("Get object failed, get null object");
|
|
|
|
//logger.info("Get object failed, get null object");
|
|
|
|
return null;
|
|
|
|
return null;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* Get the file list of file system.
|
|
|
|
* 获取文件系统中的文件列表。
|
|
|
|
* Not implement at the moment, because FastDFS API not support.
|
|
|
|
* 目前由于 FastDFS API 不支持，该方法未实现。
|
|
|
|
|
|
|
|
*
|
|
|
|
|
|
|
|
* @return 始终返回 null
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|
public List<DfsFile> listObjects() {
|
|
|
|
public List<DfsFile> listObjects() {
|
|
|
|
//to do
|
|
|
|
// 待实现
|
|
|
|
//Because fastDFS api do not support list object method.
|
|
|
|
// 因为 FastDFS API 不支持列出对象的方法
|
|
|
|
return null;
|
|
|
|
return null;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* Upload the file to file system by file path
|
|
|
|
* 通过文件路径将文件上传到文件系统。
|
|
|
|
|
|
|
|
* 该方法会将文件转换为 File 对象，然后调用 putObject(File file, String key, Map<String, String> metadata) 方法进行上传。
|
|
|
|
*
|
|
|
|
*
|
|
|
|
* @param filePath local file path.
|
|
|
|
* @param filePath 本地文件路径
|
|
|
|
* @param key Key, not used in FastDFS, can be null
|
|
|
|
* @param key 文件的键，在 FastDFS 中未使用，可以为 null
|
|
|
|
* @param metadata metadata for file, can be null
|
|
|
|
* @param metadata 文件的元数据，可以为 null
|
|
|
|
* @return DfsFile object or null if fail
|
|
|
|
* @return 若上传成功，返回 DfsPath 对象；否则返回 null
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|
public DfsPath putObject(String filePath, String key, Map<String, String> metadata) {
|
|
|
|
public DfsPath putObject(String filePath, String key, Map<String, String> metadata) {
|
|
|
|
@ -202,13 +251,13 @@ public class FastDfsService implements DfsService {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* Upload the file to file system by bytes
|
|
|
|
* 通过字节数组将文件上传到文件系统。
|
|
|
|
*
|
|
|
|
*
|
|
|
|
* @param bytes bytes
|
|
|
|
* @param bytes 文件的字节数组
|
|
|
|
* @param key Key, not used in FastDFS
|
|
|
|
* @param key 文件的键，在 FastDFS 中未使用
|
|
|
|
* @param metadata metadata for file, can be null
|
|
|
|
* @param metadata 文件的元数据，可以为 null
|
|
|
|
* @param extName extName for file, can be null
|
|
|
|
* @param extName 文件的扩展名，可以为 null
|
|
|
|
* @return DfsPath object or null if fail
|
|
|
|
* @return 若上传成功，返回 DfsPath 对象；否则返回 null
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|
public DfsPath putObject(byte[] bytes, String key, Map<String, String> metadata, String extName) {
|
|
|
|
public DfsPath putObject(byte[] bytes, String key, Map<String, String> metadata, String extName) {
|
|
|
|
@ -216,147 +265,215 @@ public class FastDfsService implements DfsService {
|
|
|
|
TrackerServer trackerServer = null;
|
|
|
|
TrackerServer trackerServer = null;
|
|
|
|
StorageServer storageServer = null;
|
|
|
|
StorageServer storageServer = null;
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
|
|
|
|
// 获取 Tracker 服务器连接
|
|
|
|
trackerServer = trackerClient.getConnection();
|
|
|
|
trackerServer = trackerClient.getConnection();
|
|
|
|
|
|
|
|
// 获取存储服务器列表
|
|
|
|
StorageServer[] storageServers = trackerClient.getStoreStorages(trackerServer, bucketName);
|
|
|
|
StorageServer[] storageServers = trackerClient.getStoreStorages(trackerServer, bucketName);
|
|
|
|
if (null != storageServers) {
|
|
|
|
if (null != storageServers) {
|
|
|
|
|
|
|
|
// 选择第一个存储服务器
|
|
|
|
storageServer = storageServers[0];
|
|
|
|
storageServer = storageServers[0];
|
|
|
|
|
|
|
|
// 创建存储客户端
|
|
|
|
StorageClient storageClient = new StorageClient(trackerServer, storageServer);
|
|
|
|
StorageClient storageClient = new StorageClient(trackerServer, storageServer);
|
|
|
|
|
|
|
|
|
|
|
|
NameValuePair[] meta_list;
|
|
|
|
NameValuePair[] meta_list;
|
|
|
|
int i = 0;
|
|
|
|
int i = 0;
|
|
|
|
if (null == metadata) {
|
|
|
|
if (null == metadata) {
|
|
|
|
|
|
|
|
// 若元数据为空，创建一个包含一个元素的元数据数组
|
|
|
|
meta_list = new NameValuePair[1];
|
|
|
|
meta_list = new NameValuePair[1];
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
|
|
|
|
// 若元数据不为空，创建一个包含元数据和 FastDFS 键的数组
|
|
|
|
meta_list = new NameValuePair[metadata.size() + 1];
|
|
|
|
meta_list = new NameValuePair[metadata.size() + 1];
|
|
|
|
for (Map.Entry<String, String> entry : metadata.entrySet()) {
|
|
|
|
for (Map.Entry<String, String> entry : metadata.entrySet()) {
|
|
|
|
meta_list[i++] = new NameValuePair(entry.getKey(), entry.getValue());
|
|
|
|
meta_list[i++] = new NameValuePair(entry.getKey(), entry.getValue());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
// 添加 FastDFS 键到元数据数组
|
|
|
|
meta_list[i] = new NameValuePair(FAST_DFS_KEY, key);
|
|
|
|
meta_list[i] = new NameValuePair(FAST_DFS_KEY, key);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 调用 FastDFS API 上传文件
|
|
|
|
String[] results = storageClient.upload_file(bytes, extName, meta_list);
|
|
|
|
String[] results = storageClient.upload_file(bytes, extName, meta_list);
|
|
|
|
|
|
|
|
|
|
|
|
if (null == results) {
|
|
|
|
if (null == results) {
|
|
|
|
|
|
|
|
// 上传失败，记录日志并返回 null
|
|
|
|
//logger.info("upload file fail, error codes: " + storageClient.getErrorCode());
|
|
|
|
//logger.info("upload file fail, error codes: " + storageClient.getErrorCode());
|
|
|
|
return null;
|
|
|
|
return null;
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
|
|
|
|
// 获取远程文件名
|
|
|
|
String remote_fileName = results[1];
|
|
|
|
String remote_fileName = results[1];
|
|
|
|
|
|
|
|
// 构建文件的完整 HTTP 访问路径
|
|
|
|
String httpPath = this.getHttpPath(remote_fileName);
|
|
|
|
String httpPath = this.getHttpPath(remote_fileName);
|
|
|
|
|
|
|
|
// 创建 DfsPath 对象
|
|
|
|
DfsPath dfsPath = new DfsPath(httpPath, remote_fileName);
|
|
|
|
DfsPath dfsPath = new DfsPath(httpPath, remote_fileName);
|
|
|
|
return dfsPath;
|
|
|
|
return dfsPath;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
|
|
|
// 处理上传过程中出现的异常
|
|
|
|
handleException(e);
|
|
|
|
handleException(e);
|
|
|
|
} finally {
|
|
|
|
} finally {
|
|
|
|
if (null != storageServer) {
|
|
|
|
if (null != storageServer) {
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
|
|
|
|
// 关闭存储服务器连接
|
|
|
|
storageServer.close();
|
|
|
|
storageServer.close();
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
|
|
|
// 处理关闭连接时出现的异常
|
|
|
|
handleException(e);
|
|
|
|
handleException(e);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if (null != trackerServer) {
|
|
|
|
if (null != trackerServer) {
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
|
|
|
|
// 关闭 Tracker 服务器连接
|
|
|
|
trackerServer.close();
|
|
|
|
trackerServer.close();
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
|
|
|
// 处理关闭连接时出现的异常
|
|
|
|
handleException(e);
|
|
|
|
handleException(e);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
// 上传失败，记录日志并返回 null
|
|
|
|
//logger.info("Upload file faild, because can not get storage servers!");
|
|
|
|
//logger.info("Upload file faild, because can not get storage servers!");
|
|
|
|
return null;
|
|
|
|
return null;
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* Upload the file to file system
|
|
|
|
* 将文件上传到文件系统。
|
|
|
|
|
|
|
|
* 该方法会将文件转换为字节数组，然后调用 putObject(byte[] bytes, String key, Map<String, String> metadata, String extName) 方法进行上传。
|
|
|
|
*
|
|
|
|
*
|
|
|
|
* @param file file
|
|
|
|
* @param file 文件对象
|
|
|
|
* @param key Key, not used in FastDFS, can be null
|
|
|
|
* @param key 文件的键，在 FastDFS 中未使用，可以为 null
|
|
|
|
* @param metadata metadata for file , can be null
|
|
|
|
* @param metadata 文件的元数据，可以为 null
|
|
|
|
* @return DfsPath object or null if fail
|
|
|
|
* @return 若上传成功，返回 DfsPath 对象；否则返回 null
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|
public DfsPath putObject(File file, String key, Map<String, String> metadata) {
|
|
|
|
public DfsPath putObject(File file, String key, Map<String, String> metadata) {
|
|
|
|
FileInputStream in = null;
|
|
|
|
FileInputStream in = null;
|
|
|
|
byte[] file_buff = null;
|
|
|
|
byte[] file_buff = null;
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
|
|
|
|
// 打开文件输入流
|
|
|
|
in = new FileInputStream(file);
|
|
|
|
in = new FileInputStream(file);
|
|
|
|
if (null != in) {
|
|
|
|
if (null != in) {
|
|
|
|
|
|
|
|
// 获取文件长度
|
|
|
|
int len = in.available();
|
|
|
|
int len = in.available();
|
|
|
|
|
|
|
|
// 创建字节数组
|
|
|
|
file_buff = new byte[len];
|
|
|
|
file_buff = new byte[len];
|
|
|
|
|
|
|
|
// 读取文件内容到字节数组
|
|
|
|
in.read(file_buff);
|
|
|
|
in.read(file_buff);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
|
|
|
// 处理读取文件过程中出现的异常
|
|
|
|
handleException(e);
|
|
|
|
handleException(e);
|
|
|
|
} finally {
|
|
|
|
} finally {
|
|
|
|
if (null != in) {
|
|
|
|
if (null != in) {
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
|
|
|
|
// 关闭文件输入流
|
|
|
|
in.close();
|
|
|
|
in.close();
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
|
|
|
// 处理关闭流时出现的异常
|
|
|
|
handleException(e);
|
|
|
|
handleException(e);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
String file_ext_name = "";
|
|
|
|
String file_ext_name = "";
|
|
|
|
if (file.getName().lastIndexOf(".") > 0) {
|
|
|
|
if (file.getName().lastIndexOf(".") > 0) {
|
|
|
|
|
|
|
|
// 获取文件扩展名
|
|
|
|
file_ext_name = file.getName().substring(file.getName().lastIndexOf(".") + 1);
|
|
|
|
file_ext_name = file.getName().substring(file.getName().lastIndexOf(".") + 1);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
// 调用 putObject(byte[] bytes, String key, Map<String, String> metadata, String extName) 方法上传文件
|
|
|
|
return putObject(file_buff, key, metadata, file_ext_name);
|
|
|
|
return putObject(file_buff, key, metadata, file_ext_name);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
|
|
|
* 获取基础 URL。
|
|
|
|
|
|
|
|
*
|
|
|
|
|
|
|
|
* @return 基础 URL
|
|
|
|
|
|
|
|
*/
|
|
|
|
public String getBaseUrl() {
|
|
|
|
public String getBaseUrl() {
|
|
|
|
return baseUrl;
|
|
|
|
return baseUrl;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
|
|
|
* 设置基础 URL。
|
|
|
|
|
|
|
|
*
|
|
|
|
|
|
|
|
* @param baseUrl 要设置的基础 URL
|
|
|
|
|
|
|
|
*/
|
|
|
|
private void setBaseUrl(String baseUrl) {
|
|
|
|
private void setBaseUrl(String baseUrl) {
|
|
|
|
this.baseUrl = baseUrl;
|
|
|
|
this.baseUrl = baseUrl;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
|
|
|
* 获取 DMS 基础 URL。
|
|
|
|
|
|
|
|
*
|
|
|
|
|
|
|
|
* @return DMS 基础 URL
|
|
|
|
|
|
|
|
*/
|
|
|
|
public String getDmsBaseUrl() {
|
|
|
|
public String getDmsBaseUrl() {
|
|
|
|
return dmsBaseUrl;
|
|
|
|
return dmsBaseUrl;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
|
|
|
* 设置 DMS 基础 URL。
|
|
|
|
|
|
|
|
*
|
|
|
|
|
|
|
|
* @param dmsBaseUrl 要设置的 DMS 基础 URL
|
|
|
|
|
|
|
|
*/
|
|
|
|
public void setDmsBaseUrl(String dmsBaseUrl) {
|
|
|
|
public void setDmsBaseUrl(String dmsBaseUrl) {
|
|
|
|
this.dmsBaseUrl = dmsBaseUrl;
|
|
|
|
this.dmsBaseUrl = dmsBaseUrl;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
|
|
|
* 获取默认图片 URL。
|
|
|
|
|
|
|
|
*
|
|
|
|
|
|
|
|
* @return 默认图片 URL
|
|
|
|
|
|
|
|
*/
|
|
|
|
public String getDefaultPicUrl() {
|
|
|
|
public String getDefaultPicUrl() {
|
|
|
|
return defaultPicUrl;
|
|
|
|
return defaultPicUrl;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
|
|
|
* 设置默认图片 URL。
|
|
|
|
|
|
|
|
*
|
|
|
|
|
|
|
|
* @param defaultPicUrl 要设置的默认图片 URL
|
|
|
|
|
|
|
|
*/
|
|
|
|
public void setDefaultPicUrl(String defaultPicUrl) {
|
|
|
|
public void setDefaultPicUrl(String defaultPicUrl) {
|
|
|
|
this.defaultPicUrl = defaultPicUrl;
|
|
|
|
this.defaultPicUrl = defaultPicUrl;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* Handle Exception
|
|
|
|
* 处理异常的方法。
|
|
|
|
* @param e exception
|
|
|
|
* 根据异常类型抛出不同的 DfsException 异常。
|
|
|
|
|
|
|
|
*
|
|
|
|
|
|
|
|
* @param e 要处理的异常
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
private void handleException(Exception e) {
|
|
|
|
private void handleException(Exception e) {
|
|
|
|
if (e instanceof IOException) {
|
|
|
|
if (e instanceof IOException) {
|
|
|
|
|
|
|
|
// 处理 IOException，抛出 DfsException，错误码为 100
|
|
|
|
//logger.error("Exception occured : DFSException code: 100," + " exception message :" + e.getMessage());
|
|
|
|
//logger.error("Exception occured : DFSException code: 100," + " exception message :" + e.getMessage());
|
|
|
|
throw new DfsException("100", e.getMessage());
|
|
|
|
throw new DfsException("100", e.getMessage());
|
|
|
|
} else if (e instanceof FileNotFoundException) {
|
|
|
|
} else if (e instanceof FileNotFoundException) {
|
|
|
|
|
|
|
|
// 处理 FileNotFoundException，抛出 DfsException，错误码为 200
|
|
|
|
//logger.error("Exception occured : DFSException code: 200," + " exception message : file not found." + e.getMessage());
|
|
|
|
//logger.error("Exception occured : DFSException code: 200," + " exception message : file not found." + e.getMessage());
|
|
|
|
throw new DfsException("200", e.getMessage());
|
|
|
|
throw new DfsException("200", e.getMessage());
|
|
|
|
} else if (e instanceof MyException) {
|
|
|
|
} else if (e instanceof MyException) {
|
|
|
|
|
|
|
|
// 处理 MyException，抛出 DfsException，错误码为 300
|
|
|
|
//logger.error("Exception occured : DFSException code: 300," + " exception message :" + e.getMessage());
|
|
|
|
//logger.error("Exception occured : DFSException code: 300," + " exception message :" + e.getMessage());
|
|
|
|
throw new DfsException("300", e.getMessage());
|
|
|
|
throw new DfsException("300", e.getMessage());
|
|
|
|
} else if (e instanceof Exception) {
|
|
|
|
} else if (e instanceof Exception) {
|
|
|
|
|
|
|
|
// 处理其他异常，抛出 DfsException，错误码为 400
|
|
|
|
//logger.error("Exception occured : DFSException code: 400," + " exception message :" + e.getMessage());
|
|
|
|
//logger.error("Exception occured : DFSException code: 400," + " exception message :" + e.getMessage());
|
|
|
|
throw new DfsException("400", e.getMessage());
|
|
|
|
throw new DfsException("400", e.getMessage());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
/**
|
|
|
|
public String getDefaultPath(String type) {
|
|
|
|
* 根据类型获取默认路径。
|
|
|
|
if("PICTURE".equalsIgnoreCase(type)) {
|
|
|
|
* 如果类型为 "PICTURE"，则返回默认图片 URL；否则也返回默认图片 URL。
|
|
|
|
return defaultPicUrl;
|
|
|
|
*
|
|
|
|
}
|
|
|
|
* @param type 路径类型
|
|
|
|
return defaultPicUrl;
|
|
|
|
* @return 默认路径
|
|
|
|
}
|
|
|
|
*/
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
|
|
|
public String getDefaultPath(String type) {
|
|
|
|
|
|
|
|
if ("PICTURE".equalsIgnoreCase(type)) {
|
|
|
|
|
|
|
|
return defaultPicUrl;
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
return defaultPicUrl;
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
Anayigeren
7 months ago