FastDFS整合普通Maven项目(四)

package com.topcheer.fastdfs;
?
import java.io.IOException;
?
import org.csource.fastdfs.ClientGlobal;
import org.csource.fastdfs.StorageClient;
import org.csource.fastdfs.StorageServer;
import org.csource.fastdfs.TrackerClient;
import org.csource.fastdfs.TrackerServer;
?
public class FastDfsUtil {
?
    private static final String conf = "fastdfs-client.conf";
    
    private static TrackerServer trackerServer = null;
    private static StorageServer storageServer = null;
?
    public static StorageClient getStorageClient() {
        StorageClient storageClient = null;
        try {
            // 1 初始化配置文件
            ClientGlobal.init(conf);
?
            // 2 创建tracker的客户端对象
            TrackerClient client = new TrackerClient();
?
            // 3 创建tracker的服务器对象
            trackerServer = client.getConnection();
?
            // 4 创建storage的客户端对象
            storageServer = client.getStoreStorage(trackerServer);
?
            // 5 创建storage的服务器对象
            storageClient = new StorageClient(trackerServer, storageServer);
?
        } catch (Exception e) {
            e.printStackTrace();
        }
        return storageClient;
    }
?
    //关闭资源
    public static void close() {
?
        if (trackerServer != null) {
            try {
                trackerServer.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
?
        if (storageServer != null) {
            try {
                storageServer.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
?
    }
?
}

tracker_server = 192.168.180.104:22122

 public static void uploadFile() {
      
            try {
                String[]  strings = FastDfsUtil.getStorageClient().upload_appender_file("C:\\Users\\asus\\Desktop\\激活码.txt", "txt", null);
                Arrays.asList(strings).forEach(s -> System.out.println(s));
                //group1
               // M00/00/00/wKi0aF3II2yEPlv6AAAAAHp_ifU838.txt
            } catch (IOException e) {
                e.printStackTrace();
            } catch (MyException e) {
                e.printStackTrace();
            }finally {
                FastDfsUtil.close();
            }
    }

 public static void downfile() {
?
        try {
?
            FastDfsUtil.getStorageClient().download_file("group1", "M00/00/00/wKi0aF3II2yEPlv6AAAAAHp_ifU838.txt", "d:/a.txt");
        } catch (IOException e) {
            e.printStackTrace();
        } catch (MyException e) {
            e.printStackTrace();
        }finally {
            FastDfsUtil.close();
        }
    }

  /**
     * delete file from storage server
     *
     * @param group_name      the group name of storage server
     * @param remote_filename filename on storage server
     * @return 0 for success, none zero for fail (error code)
     */
    public static void delFile() {
        try {
            int file = FastDfsUtil.getStorageClient().delete_file("group1", "M00/00/00/wKi0aF3II2yEPlv6AAAAAHp_ifU838.txt");
            System.out.println(file);
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (MyException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally {
            FastDfsUtil.close();
        }
    }