FastDFS教程
FastDFS环境搭建
分布式文件系统FastDFS的HTTP访问
FastDFS在Java项目中开发示例
FastDFS在web项目中的应用
FastDFS分布式文件系统集群

FastDFS文件上传功能实现

需求

使用Java客户端,编程操作fastDFS分布式文件系统,上传本地文件到FastDFS服务器上。

实现步骤

1. 使用IDEA创建普通的maven项目,不需要使用

2. 在pom.xml文件中添加我们打包好的FastDFS本地仓库的jar包(FastDFS的java客户端依赖)

<!--加入FastDFS的java客户端依赖-->
<dependencies>
    <dependency>
        <groupId>org.csource</groupId>
        <artifactId>fastdfs-client-java</artifactId>
        <version>1.27-SNAPSHOT</version>
    </dependency>
</dependencies>

可以在这查看jar包里面的内容

3. 拷贝源代码包中的fdfs_client.conf文件到resources目录下,在里面主要配置tracker地址

tracker_server = 192.168.235.128:22122

4. 编写代码,进行上传测试

在com.sxbdqn.fastdfs包下创建FastDFS类,在其中编写上传代码

package com.sxbdqn.fastdfs;
import org.csource.common.MyException;
import org.csource.fastdfs.*;
import java.io.IOException;
public class FastDFS {
    public static void main(String[] args) {
        fileUpload();
    }
    //上传文件的方法
    public static void fileUpload(){
        TrackerServer trackerServer = null;
        StorageServer storageServer = null;
        try {
            //1.加载配置文件,默认去classpath下加载
            ClientGlobal.init("fdfs_client.conf");
            //2.创建TrackerClient对象
            TrackerClient trackerClient = new TrackerClient();
            //3.创建TrackerServer对象
            trackerServer = trackerClient.getConnection();
            //4.创建StorageServler对象
            storageServer = trackerClient.getStoreStorage(trackerServer);
            //5.创建StorageClient对象,这个对象完成对文件的操作
            StorageClient storageClient = new StorageClient(trackerServer,storageServer);
            //6.上传文件  第一个参数:本地文件路径 第二个参数:上传文件的后缀 第三个参数:文件信息
            String [] uploadArray = storageClient.upload_file("D:/aa.txt","txt",null);
            for (String str:uploadArray) {
                System.out.println(str);
            }
        } catch (IOException e) {
            e.printStackTrace();
        } catch (MyException e) {
            e.printStackTrace();
        } finally {
            if(storageServer != null){
                try {
                    storageServer.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if(trackerServer != null){
                try {
                    trackerServer.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }

5. 运行程序,在Linux上,FastDFS存储目录下查看上传文件内容