FastDFS(2)java客户端

FastDFS 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
public class FastDFSOperation {
    private static boolean hasInited = false;
    private static void Init() {
        synchronized (TXFastDFSOperation.class) {
            if (hasInited)
                return;
            // 读取配置文件
            try {
                File file = new File(Thread.currentThread().getContextClassLoader().getResource("fdfs_client.conf").toURI());
                ClientGlobal.init(file.getAbsolutePath());
                TXFastDFSOperation.hasInited = true;
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
     
    private static StorageClient getStorageClient() throws IOException{
        Init();
        TrackerClient trackerClient = new TrackerClient();
        TrackerServer trackerServer = trackerClient.getConnection();
        ProtoCommon.activeTest(trackerServer.getSocket());
        StorageClient storageClient = new StorageClient(trackerServer, null);
        return storageClient;
    }
    /**
     * 上传文件
     * @param arg文件的输入流
     * @param size文件的大小
     * @param groupname文件要上传的group名称
     * @param flexname文件的类型
     * @return group / index
     */
    public static String[] Uploadfile(InputStream arg, Long size,String groupname,String flexname) {
        String[] stringArray = null;
        NameValuePair[] nvp = null;
        byte[] fileBuffer = null;
        try{
            fileBuffer = changeStreamToByteArray(arg);
            nvp = new NameValuePair[]{new NameValuePair("size", size.toString())};
            stringArray = getStorageClient().upload_file(groupname, fileBuffer, flexname, nvp);
        }catch (Exception e) {
            e.printStackTrace();
        }
        return stringArray;
    }
    /**
     * 成功失败返回值自己去查
     * @param group
     * @param index
     * @return
     */
    public static Integer deleteFile(String group, String index) {
        Integer returnValue = null;
        try{
            returnValue = getStorageClient().delete_file(group, index);
        }catch (Exception e) {
            e.printStackTrace();
        }
        return returnValue;
    }
     
    /**
     * 下载文件
     * @param group文件所在group
     * @param index文件的index
     * @param offset带下载文件的偏移量
     * @param downByte从偏移量往后需要下载的文件大小
     * @return
     */
    public static InputStream DownloadFile(String group, String index, Long offset, Long downByte) {
        InputStream inputStream = null;
        try {
            byte[] fileBuffer = getStorageClient().download_file(group, index, offset, downByte);
            inputStream = new ByteArrayInputStream(fileBuffer);
        } catch (IOException | MyException e) {
            e.printStackTrace();
        }
        return inputStream;
    }
    /**
     * @param group
     * @param index
     * @param offset
     * @param downByte
     * @return
     */
    public static byte[] DownloadFileReByte(String group, String index, Long offset, Long downByte) {
        byte[] fileBuffer = null;
        try {
            fileBuffer = getStorageClient().download_file(group, index, offset, downByte);
        } catch (IOException | MyException e) {
            e.printStackTrace();
        }
        return fileBuffer;
    }
    /**
     * 获取文件大小
     * @param group文件所在的group
     * @param index文件的index
     * @return
     */
    public static Long GetFileSize(String group, String index) {
        FileInfo fileInfo = null;
        Long returnValue = new Long(-1);
        try {
            fileInfo = getStorageClient().get_file_info(group, index);
        } catch (Exception e) {
            e.printStackTrace();
        }
        if(fileInfo != null) {
            returnValue = fileInfo.getFileSize();
        }
        return returnValue;
    }
     
    /**
     * 将文件流转换成字节数组
     * @param is
     * @return
     * @throws IOException
     */
    private static byte[] changeStreamToByteArray(InputStream is) throws IOException {
        ByteArrayOutputStream swapStream = new ByteArrayOutputStream();
        byte[] buff = new byte[100];
        int offset = 0;
        while((offset = is.read(buff, 0, 100)) > 0) {
            swapStream.write(buff, 0, offset);
        }
        byte[] fileBuffer = swapStream.toByteArray();
        return fileBuffer;
    }
}
>