4. FastDFS在Java项目中开发示例

4.1 在实际项目开发中，FastDFS提供的主要功能

upload：上传文件
download：下载文件
delete：删除文件

4.2 FastDFS文件系统的Java客户端

FastDFS文件系统Java客户端是指采用Java语言编写的一套程序，专门用来访问fastDFS文件系统，其实就是一个jar包。

注意：大家如果能连上mvnrepository上搜索到的用友云提供的fastdfs-client，那大家就下载那个jar包使用，如果连不上，这个jar包需要我们自己来打
**

4.2.1 下载官方的源代码

从https://codeload.github.com/happyfish100/fastdfs-client-java/zip/master上下载FastDFS源代码到本地

4.2.2 解压

4.2.3 采用maven命令编译成jar安装到本地maven库

mvn clean install

4.2.4 在Java程序中使用它提供的API来访问FastDFS文件系统

4.3 文件上传功能的实现

4.3.1 需求

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

4.3.2 实现步骤

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地址

connect_timeout=20
network_timeout=60
charset=UTF-8
http.tracker_http_port=8080
http.anti_steal_token=no
http.secret_key=FastDFS1234567890

tracker_server=47.95.113.235:22122

4）编写代码，进行上传测试

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

package com.gmw.fastdfs;

import org.csource.common.MyException;
import org.csource.fastdfs.*;

import java.io.IOException;

public class FastDFSUtils {
    public static void main(String[] args) {
        //文件上传
        //upload();
        //文件下载
        //download();
        //文件删除
        delete();
    }

    /**
     * 文件上传
     */
    private static void upload() {

        TrackerServer trackerServer = null;
        StorageServer storageServer = null;

        try {
            //读取FastDFS的配置文件用于将所有的tracker的地址读取到内存中
            ClientGlobal.init("fdfs_client.conf");

            TrackerClient trackerClient = new TrackerClient();
            trackerServer = trackerClient.getConnection();
            storageServer = trackerClient.getStoreStorage(trackerServer);

            //定义StorageClient的客户端，需要使用这个对象来完成具体的文件上传、下载和删除操作
            StorageClient storageClient = new StorageClient(trackerServer,storageServer);

            /**
             * 文件上传
             * 参数1：为需要的上传的文件的绝对路径
             * 参数2：为需要上传文件的扩展名
             * 参数3：为文件的属性文件，通常不上传
             *
             * 返回一个String数组 这个数组对我们非常重要，必须要妥善保管建议存入到数据库中
             *
             */
            String[] result = storageClient.upload_file("C:\\Users\\48656\\Pictures\\Saved Pictures\\bg.jpg", "jpg", null);

            for (String s : result) {
                System.out.println(s);
            }

        } catch (IOException e) {
            e.printStackTrace();
        } catch (MyException e) {
            e.printStackTrace();
        } finally {

            if(trackerServer != null){
                try {
                    trackerServer.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }

            if(storageServer != null){
                try {
                    storageServer.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }

        }
    }
}

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

4.4 将文件上传功能中的公共代码进行封装

1）需求

因为使用FastDFS进行文件操作代码大多都是通用的，所以我们这里在FastDFS类中将通用的功能进行封装，并提供上传、下载、删除文件的方法
注意：这里只是简单的封装，如果多线程会有问题

2）实现步骤

A、抽取获取StorageClient的方法

public static StorageClient getStorageClient() throws IOException, MyException {
    //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);
    return storageClient;
}

B、定义两个全局变量

private static TrackerServer trackerServer = null;
private static StorageServer storageServer = null;

C、抽取关闭资源的方法

public static void closeFastDFS() {
    if (storageServer != null) {
        try {
            storageServer.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    if (trackerServer != null) {
        try {
            trackerServer.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

D、改造文件上传的方法

public static void fileUpload(){
    try {
        //1. 获取StorageClient对象
        StorageClient storageClient = getStorageClient();
        //2.上传文件  第一个参数：本地文件路径 第二个参数：上传文件的后缀 第三个参数：文件信息
        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 {
        closeFastDFS();
    }
}

E、下载文件的方法

//下载文件的方法
public static void fileDownload(){
    try {
        //1. 获取StorageClient对象
        StorageClient storageClient = getStorageClient();
        //2.下载文件 返回0表示成功，其它均表示失败
        int num = storageClient.download_file("group1",
                "M00/00/00/wKjrgFxOqueAAPWKAAAAKAM14xY563.txt","E:/bb.txt");
        System.out.println(num);
    } catch (IOException e) {
        e.printStackTrace();
    } catch (MyException e) {
        e.printStackTrace();
    } finally {
        closeFastDFS();
    }
}

F、删除文件的方法

//删除文件的方法
public static void fileDelete(){
    try {
        //1. 获取StorageClient对象
        StorageClient storageClient = getStorageClient();
        //2.删除文件 返回0表示成功，其它均表示失败
        int num = storageClient.delete_file("group1",
                "M00/00/00/wKjrgFxOqueAAPWKAAAAKAM14xY563.txt");
        System.out.println(num);
    } catch (IOException e) {
        e.printStackTrace();
    } catch (MyException e) {
        e.printStackTrace();
    } finally {
        closeFastDFS();
    }
}

G、主方法调用不同的方法进行测试