本篇文章给大家分享的是有关如何在Java项目中利用FasfDFS实现一个文件上传下载功能，小编觉得挺实用的，因此分享给大家学习，希望大家阅读完这篇文章后可以有所收获，话不多说，跟着小编一起来看看吧。
一 : 添加配置文件
当完成以上操作之后可以添加链接FastDFS服务器的配置文件 fastdfs-client.properties
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可以使用逗号“ , ”分隔
二 : 加载配置文件
测试加载配置文件
@Testpublic void initConifg() throws Exception { // 加载配置文件 ClientGlobal.initByProperties("config/fastdfs-client.properties"); System.out.println("ClientGlobal.configInfo():" + ClientGlobal.configInfo());}输出结果
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.初始化连接信息
//成员变量TrackerServer trackerServer = null;StorageServer storageServer = null;StorageClient storageClient = null;@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.上传文件
@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下载文件，然后将数据存储到本地。如果通过浏览器下载，同理将数据写入文件即可
@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.获取元数据信息
@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.获取文件信息
@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.删除文件
当数据测试完整之后，试试能否删除吧
@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实现上传下载等功能的代码，如果需要可以封装成工具类使用。
以下是个人封装好的工具类
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"); } } public static String[] uploadFile(String filePath, String fileName) { return uploadFile(null, filePath, fileName); } public static String[] uploadFile(byte[] fileBuff, String fileName) { return uploadFile(fileBuff, null, fileName); } 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]; } 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; } 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; }}以上就是如何在Java项目中利用FasfDFS实现一个文件上传下载功能，小编相信有部分知识点可能是我们日常工作会见到或用到的。希望你能通过这篇文章学到更多知识。更多详情敬请关注编程网行业资讯频道。
