在上篇文章给大家介绍了FastDFS安装和配置整合Nginx-1.13.3的方法，大家可以点击查看下。
今天使用Java代码实现文件的上传和下载。对此作者提供了Java API支持，下载fastdfs-client-java将源码添加到项目中。或者在Maven项目pom.xml文件中添加依赖
|
1
2
3
4
5
|
<dependency> <groupId>org.csource</groupId> <artifactId>fastdfs-client-java</artifactId> <version>1.27-SNAPSHOT</version></dependency> |
一 : 添加配置文件
当完成以上操作之后可以添加链接FastDFS服务器的配置文件 fastdfs-client.properties
|
1
2
3
4
5
6
7
|
fastdfs.connect_timeout_in_seconds = 5fastdfs.network_timeout_in_seconds = 30fastdfs.charset = UTF-8fastdfs.http_anti_steal_token = falsefastdfs.http_secret_key = FastDFS1234567890fastdfs.http_tracker_http_port = 80fastdfs.tracker_servers = 192.168.1.7:22122 |
因为项目中只使用properties 格式文件，如果需要更多的配置信息，可以查看官方的配置信息
注: 1. 其他的配置项为可选，fastdfs.tracker_servers 为必须选项
2. 多个tracker_servers可以使用逗号“ , ”分隔
二 : 加载配置文件
1. 测试加载配置文件
|
1
2
3
4
5
6
|
@Testpublic void initConifg() throws Exception { // 加载配置文件 ClientGlobal.initByProperties("config/fastdfs-client.properties"); System.out.println("ClientGlobal.configInfo():" + ClientGlobal.configInfo());} |
2. 输出结果
|
1
2
3
4
5
6
7
8
9
|
ClientGlobal.configInfo():{ g_connect_timeout(ms) = 5000 g_network_timeout(ms) = 30000 g_charset = UTF-8 g_anti_steal_token = false g_secret_key = FastDFS1234567890 g_tracker_http_port = 80 trackerServers = 192.168.1.7:22122} |
当出现上面和配置文件一致的输出结果时候，说明加载配置文件已经成功。
三:功能实现
由于是使用Junit做测试，为了方便在开始执行之前，初始化配置文件和获取连接，同时没有捕获异常全部抛出
1.初始化连接信息
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
|
//成员变量TrackerServer trackerServer = null;StorageServer storageServer = null;StorageClient storageClient = null;/** * 初始化连接信息 * @author: wrh45 * @date: 2017年8月5日下午8:08:57 */@Beforepublic void init() throws Exception { // 加载配置文件 ClientGlobal.initByProperties("config/fastdfs-client.properties"); // 获取连接 TrackerClient trackerClient = new TrackerClient(); trackerServer = trackerClient.getConnection(); storageClient = new StorageClient(trackerServer, storageServer);} |
注: 如果出现连接超时异常：java.net.SocketTimeoutException: connect timed out
1 .查看服务器地址和端口是否正确
2 .请查看服务器TrackerServer和StorageServer服务端口是否开启。默认为22122和23000
2.上传文件
|
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
|
/** * 上传图片 * @throws Exception * @author: wrh45 * @date: 2017年8月5日下午7:09:23 */@Testpublic void uploadFileOfByte() throws Exception { // 获取文件字节信息 file = new File("src/test/resources/pic/Ace.jpg"); FileInputStream inputStream = new FileInputStream(file); byte[] file_buff = new byte[(int) file.length()]; inputStream.read(file_buff); // 获取文件扩展名 String fileName = file.getName(); String extName = null; if (fileName.contains(".")) { extName = fileName.substring(fileName.lastIndexOf(".") + 1); } else { return; } // 图片元数据,如果设置为空，那么服务器上不会生成-m的原数据文件 NameValuePair[] meta_list = new NameValuePair[2]; meta_list[0] = new NameValuePair("fileName", "测试专用"); meta_list[1] = new NameValuePair("length", "测试专用"); // 文件上传，返回组名和访问地址 String[] upload_file = storageClient.upload_file(file_buff, extName, meta_list); System.out.println(Arrays.asList(upload_file));} |
下面是执行结果
已经将图片上传到服务器，同时返回了图片地址。那么通过这个地址试试能否访问
OK，在浏览器输入地址后，成功返回了图片信息
3.下载文件
这里通过storageClient下载文件，然后将数据存储到本地。如果通过浏览器下载，同理将数据写入文件即可
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
|
/** * 下载图片 * @throws Exception * @author: wrh45 * @date: 2017年8月5日下午8:09:10 */@Testpublic void downLoadFile() throws Exception { // 下载文件，返回字节数组 byte[] file_buff = storageClient.download_file("group1", "M00/00/00/wKgBB1l-EwyAGvxuAAWkdYkPHEE854.jpg"); // 将数据写文件中 File file = new File("src/test/resources/pic/Ace2.jpg"); FileOutputStream outStream = new FileOutputStream(file); outStream.write(file_buff); outStream.flush(); outStream.close();} |
下面是执行结果，不出意外是可以成功执行的
4.获取元数据信息
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
|
/** * 元数据信息 * @throws Exception * @author: wrh45 * @date: 2017年8月5日下午8:09:38 */@Testpublic void metaData() throws Exception { // 上传图片的时候，元数据若为空将无法生存-m的原数据文件。获取时候此处将抛出NullPointerException NameValuePair[] get_metadata = storageClient.get_metadata("group1", "M00/00/00/wKgBB1l-EwyAGvxuAAWkdYkPHEE854.jpg"); for (NameValuePair nameValuePair: get_metadata) { System.out.println("name: " + nameValuePair.getName() + " value: " + nameValuePair.getValue()); }} |
以下是执行结果，获取到的数据和上传的数据一样
name: fileName value: 测试专用
name: length value: 测试专用
5.获取文件信息
|
1
2
3
4
5
6
7
8
9
10
11
12
13
|
/** * 获取文件信息 * @author: wrh45 * @date: 2017年8月7日下午9:02:47 */@Testpublic void getFileInfo() throws Exception { FileInfo fileInfo = storageClient.get_file_info("group1", "M00/00/00/wKgBB1l-EwyAGvxuAAWkdYkPHEE854.jpg"); System.out.println("CRC32签名：" + fileInfo.getCrc32()); System.out.println("文件大小：" + fileInfo.getFileSize()); System.out.println("服务器地址：" + fileInfo.getSourceIpAddr()); System.out.println("创建时间：" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(fileInfo.getCreateTimestamp()));} |
输出结果
CRC32签名：-1995498431
文件大小：369781
服务器地址：192.168.1.7
创建时间：2017-08-07 20-24-56
6.删除文件
当数据测试完整之后，试试能否删除吧
|
1
2
3
4
5
6
7
8
9
10
11
12
|
/** * 删除文件 * @throws Exception * @author: wrh45 * @date: 2017年8月7日下午9:10:04 */@Testpublic void deleteFile() throws Exception { // 返回0成功，否则返回错误吗 int code = storageClient.delete_file("group1", "M00/00/00/wKgBB1l-EwyAGvxuAAWkdYkPHEE854.jpg"); System.out.println(code);} |
删除之后输出结果为0，如果出现非0结果，那么返回的是错误代码
以上是Java实现上传下载等功能的代码，如果需要可以封装成工具类使用。
以下是个人封装好的工具类
|
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
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
|
/** * 上传文件工具类 * @ClassName: FileUploadUtils * @author wrh45 * @date 2017年8月8日下午4:14:31 */public class FileUploadUtils { private static TrackerClient trackerClient = null; private static TrackerServer trackerServer = null; private static StorageServer storageServer = null; private static StorageClient storageClient = null; private static final String groupName = "group1"; static { // 加载配置文件 try { ClientGlobal.initByProperties("config/fastdfs-client.properties"); // System.out.println("ClientGlobal.configInfo():" + // ClientGlobal.configInfo()); } catch (IOException | MyException e) { e.printStackTrace(); System.out.println("load config file fail"); } } /* * 初始化连接数据 */ private static void init() { try { trackerClient = new TrackerClient(); trackerServer = trackerClient.getConnection(); storageClient = new StorageClient(trackerServer, storageServer); } catch (IOException e) { e.printStackTrace(); System.out.println("init fail"); } } /** * 上传文件 * @param filePath 文件路径 * @param fileName 文件名称 * @return 文件存储信息 * @author: wrh45 * @date: 2017年8月5日下午11:10:38 */ public static String[] uploadFile(String filePath, String fileName) { return uploadFile(null, filePath, fileName); } /** * 上传文件 * @param fileBuff 文件字节数组 * @param fileName 文件名称 * @return 文件存储信息 * @author: wrh45 * @date: 2017年8月5日下午11:10:38 */ public static String[] uploadFile(byte[] fileBuff, String fileName) { return uploadFile(fileBuff, null, fileName); } /** * 上传文件 * @param file_buff 文件字节数组 * @param filePath 文件路径 * @param fileName 文件名称 * @return 文件存储信息 * @author: wrh45 * @date: 2017年8月5日下午10:58:19 */ private static String[] uploadFile(byte[] fileBuff, String filePath, String fileName) { try { if (fileBuff == null && filePath == null) { return new String[0]; } // 初始化数据 if (storageClient == null) { init(); } // 获取文件扩展名称 String fileExtName = ""; if (fileName != null && !"".equals(fileName) && fileName.contains(".")) { fileExtName = fileName.substring(fileName.lastIndexOf(".") + 1); } else { return new String[0]; } // 设置图片元数据 NameValuePair[] metaList = new NameValuePair[3]; metaList[0] = new NameValuePair("fileName", fileName); metaList[1] = new NameValuePair("fileExtName", fileExtName); metaList[2] = new NameValuePair("fileSize", String.valueOf(fileBuff.length)); // 上传文件 String[] uploadFile = null; if (fileBuff != null && filePath == null) { if (fileBuff.length == 0) { return new String[0]; } uploadFile = storageClient.upload_file(fileBuff, fileExtName, metaList); } else { //路径匹配Windown和Linux if ("".equals(filePath) || !(filePath.matches("^[a-zA-Z]:{1}([\u4e00-\u9fa5\\w/_\\\\-]+)$") || filePath.matches("^(/[\u4e00-\u9fa5\\w_-]+)+$"))) { return new String[0]; } uploadFile = storageClient.upload_file(filePath, fileExtName, metaList); } return uploadFile == null ? new String[0] : uploadFile; } catch (Exception e) { e.printStackTrace(); } finally { try { if (trackerServer != null) { trackerServer.close(); trackerServer = null; } if (storageServer != null) { storageServer.close(); storageServer = null; } } catch (IOException e) { e.printStackTrace(); } } return new String[0]; } /** * 删除服务器文件 * @param remoteFileName 文件在服务器中名称 * @author: wrh45 * @date: 2017年8月6日上午12:15:22 */ public static int deleteFile(String remoteFileName) { try { if (remoteFileName == null || "".equals(remoteFileName) || !remoteFileName.contains(groupName)) { return -1; } if (storageClient == null) { init(); } String fileURL = remoteFileName.substring(remoteFileName.indexOf(groupName)); String group = fileURL.substring(0, remoteFileName.indexOf("/") + 1); String fileName = fileURL.substring(remoteFileName.indexOf("/") + 2); int code = storageClient.delete_file(group, fileName); return code; } catch (Exception e) { e.printStackTrace(); System.out.println("The File Delete Fail"); } return -1; } /** * 获取文件信息 * @param groupName 组名 * @param remoteFilename 远程文件名 * @return * @author: wrh45 * @date: 2017年8月8日上午12:25:26 */ public static FileInfo getFileInfo(String groupName, String remoteFilename) { try { if (storageClient == null) { init(); } FileInfo fileInfo = storageClient.get_file_info(groupName, remoteFilename); return fileInfo; } catch (Exception e) { e.printStackTrace(); System.out.println("Get File Info Fail"); } return null; }} |
总结
以上所述是小编给大家介绍的FasfDFS整合Java实现文件上传下载功能实例详解，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对服务器之家网站的支持！
原文链接：http://www.cnblogs.com/immortal-ghost/p/7300185.html
