java如何使用fastdfs

FastDFS Java 客户端使用指南

环境准备

确保已安装 FastDFS 服务端并正常运行。下载 Java 客户端依赖库，推荐使用官方提供的 fastdfs-client-java 或社区维护的版本。Maven 依赖如下：

<dependency>
    <groupId>org.csource</groupId>
    <artifactId>fastdfs-client-java</artifactId>
    <version>1.29</version>
</dependency>

配置文件

在 resources 目录下创建 fdfs_client.conf 文件，配置 Tracker 服务器地址：

tracker_server=192.168.1.100:22122
connect_timeout=30
network_timeout=60
charset=UTF-8
http.tracker_http_port=8080

初始化客户端

通过加载配置文件初始化全局客户端：

static {
    try {
        ClientGlobal.init("fdfs_client.conf");
    } catch (Exception e) {
        e.printStackTrace();
    }
}

文件上传示例

创建 TrackerClient 和 StorageClient 实例进行文件上传：

TrackerClient trackerClient = new TrackerClient();
TrackerServer trackerServer = trackerClient.getConnection();
StorageServer storageServer = null;
StorageClient storageClient = new StorageClient(trackerServer, storageServer);

String[] uploadResults = storageClient.upload_file(
    "local_file_path", 
    "file_ext", 
    null
);
System.out.println("Group: " + uploadResults[0] + ", Path: " + uploadResults[1]);

文件下载示例

通过文件 ID（包含 group 和 path）下载文件：

byte[] fileBytes = storageClient.download_file(
    "group1", 
    "M00/00/00/wKgBZFn_ABC123.jpg"
);
Files.write(Paths.get("downloaded_file.jpg"), fileBytes);

文件删除示例

使用文件 ID 删除远程文件：

int result = storageClient.delete_file("group1", "M00/00/00/wKgBZFn_ABC123.jpg");
System.out.println(result == 0 ? "删除成功" : "删除失败");

注意事项

• 文件 ID 包含 group 和远程路径两部分，需完整保存
• 上传时若未指定扩展名，需手动添加如 .jpg
• 网络超时参数应根据实际环境调整
• 生产环境建议使用连接池管理 TrackerServer 连接

异常处理

捕获 FastDFS 可能抛出的异常：

try {
    // FastDFS 操作代码
} catch (IOException | MyException e) {
    e.printStackTrace();
    // 自定义异常处理逻辑
}