FasfDFS整合Java实现文件上传下载功能实例详解

在上篇文章给大家介绍了FastDFS安装和配置整合Nginx-1.13.3的方法,大家可以点击查看下。

今天使用Java代码实现文件的上传和下载。对此作者提供了Java API支持,下载fastdfs-client-java将源码添加到项目中。或者在Maven项目pom.xml文件中添加依赖

<dependency>
 <groupId>org.csource</groupId>
 <artifactId>fastdfs-client-java</artifactId>
 <version>1.27-SNAPSHOT</version>
</dependency>

一 : 添加配置文件

当完成以上操作之后可以添加链接FastDFS服务器的配置文件 fastdfs-client.properties

fastdfs.connect_timeout_in_seconds = 5
fastdfs.network_timeout_in_seconds = 30
fastdfs.charset = UTF-8
fastdfs.http_anti_steal_token = false
fastdfs.http_secret_key = FastDFS1234567890
fastdfs.http_tracker_http_port = 80
fastdfs.tracker_servers = 192.168.1.7:22122

因为项目中只使用properties 格式文件,如果需要更多的配置信息,可以查看官方的配置信息

注: 1. 其他的配置项为可选,fastdfs.tracker_servers 为必须选项

2. 多个tracker_servers可以使用逗号“ , ”分隔

二 : 加载配置文件

1. 测试加载配置文件

@Test
public void initConifg() throws Exception {
 // 加载配置文件
 ClientGlobal.initByProperties("config/fastdfs-client.properties");
 System.out.println("ClientGlobal.configInfo():" + ClientGlobal.configInfo());
}

2. 输出结果

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;
/**
 * 初始化连接信息
 * @author: wrh45
 * @date: 2017年8月5日下午8:08:57
 */
@Before
public 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.上传文件

/**
 * 上传图片
 * @throws Exception
 * @author: wrh45
 * @date: 2017年8月5日下午7:09:23
 */
@Test
public 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下载文件,然后将数据存储到本地。如果通过浏览器下载,同理将数据写入文件即可

/**
 * 下载图片
 * @throws Exception
 * @author: wrh45
 * @date: 2017年8月5日下午8:09:10
 */
@Test
public 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.获取元数据信息

/**
 * 元数据信息
 * @throws Exception
 * @author: wrh45
 * @date: 2017年8月5日下午8:09:38
 */
@Test
public 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.获取文件信息

/**
 * 获取文件信息
 * @author: wrh45
 * @date: 2017年8月7日下午9:02:47
 */
@Test
public 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.删除文件

当数据测试完整之后,试试能否删除吧

/**
 * 删除文件
 * @throws Exception
 * @author: wrh45
 * @date: 2017年8月7日下午9:10:04
 */
@Test
public void deleteFile() throws Exception {
 // 返回0成功,否则返回错误吗
 int code = storageClient.delete_file("group1", "M00/00/00/wKgBB1l-EwyAGvxuAAWkdYkPHEE854.jpg");
 System.out.println(code);
}

删除之后输出结果为0,如果出现非0结果,那么返回的是错误代码

以上是Java实现上传下载等功能的代码,如果需要可以封装成工具类使用。

以下是个人封装好的工具类

/**
 * 上传文件工具类
 * @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实现文件上传下载功能实例详解,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对我们网站的支持!

时间: 2017-08-08

Java Servlet简单实例分享(文件上传下载demo)

项目结构 src com servletdemo DownloadServlet.java ShowServlet.java UploadServlet.java WebContent jsp servlet download.html fileupload.jsp input.jsp WEB-INF lib commons-fileupload-1.3.1.jar commons-io-2.4.jar 1.简单实例 ShowServlet.java package com.servletdem

java 文件上传(单文件与多文件)

java 文件上传(单文件与多文件) 一.简述 一个javaWeb项目中,文件上传功能几乎是必不可少的,本人在项目开发中也时常会遇到,以前也没怎么去理它,今天有空学习了一下这方面的知识,于是便将本人学到的SpringMVC中单文件与多文件上传这部分知识做下笔记. 二.单文件上传 1.页面 这里以一个简单的表单提交为例子,文件上传需要将表单的提交方法设置为post,将enctype的值设置为"multipart/form-data". <form action="${pa

Java Web使用Html5 FormData实现多文件上传功能

前一阵子,迭代一个线上的项目,其中有一个图片上传的功能,之前用的ajaxfileupload.js来实现上传的,不过由于ajaxfileupload.js,默认是单文件上传(虽然可以通过修改源码的方法来实现多文件上传),又加上是在移动端做的,所以就打算采用html5的FormData实现多文件上传 首先html页面定义有两种: Html1 <form enctype="multipart/form-data" id="formfile"> <inp

Java与WebUploader相结合实现文件上传功能(实例代码)

之前自己写小项目的时候也碰到过文件上传的问题,没有找到很好的解决方案.虽然之前网找各种解决方案的时候也看到过WebUploader,但没有进一步深究.这次稍微深入了解了些,这里也做个小结. 简单的文件和普通数据上传并保存 jsp页面: <%@ page language="java" contentType="text/html; charset=UTF-8" pageEncoding="UTF-8"%> <!DOCTYPE h

JAVA SFTP文件上传、下载及批量下载实例

1.jsch官方API查看地址(附件为需要的jar) http://www.jcraft.com/jsch/ 2.jsch简介 JSch(Java Secure Channel)是一个SSH2的纯Java实现.它允许你连接到一个SSH服务器,并且可以使用端口转发,X11转发,文件传输等,当然你也可以集成它的功能到你自己的应用程序. SFTP(Secure File Transfer Protocol)安全文件传送协议.可以为传输文件提供一种安全的加密方法.SFTP 为 SSH的一部份,是一种传输

Java 文件上传的实例详解

Java 文件上传的实例详解 java 文件上传 Java文件上传,介绍几种常用的方法,也是经过本人亲手调试过的 1.jspsmartupload 这个组件用起来是挺方便的,不过就是只适合小文件上传,如果大文件上传的话就不行,查看了一下他的代码,m_totalBytes = m_request.getContentLength(); m_binArray = new byte[m_totalBytes];居然把整个上传文件都读到内存去了,那如果是上传几十M的文件,同时几个用户上传,服务器稳挂,不

最详细的文件上传下载实例详解(推荐)

在Web应用系统开发中,文件上传和下载功能是非常常用的功能,今天来讲一下JavaWeb中的文件上传和下载功能的实现. 对于文件上传,浏览器在上传的过程中是将文件以流的形式提交到服务器端的,如果直接使用Servlet获取上传文件的输入流然后再解析里面的请求参数是比较麻烦,所以一般选择采用apache的开源工具common-fileupload这个文件上传组件.这个common-fileupload上传组件的jar包可以去apache官网上面下载,也可以在struts的lib文件夹下面找到,stru

PHP文件上传类实例详解

本文实例讲述了PHP文件上传类.分享给大家供大家参考,具体如下: 这里演示了FileUpload.class.php文件上传类,其中用到了两个常量,可在网站配置文件中定义: define('ROOT_PATH',dirname(__FILE__)); //网站根目录 define('UPDIR','/uploads/'); //上传主目录 具体代码如下: <?php //上传文件类 class FileUpload { private $error; //错误代码 private $maxsiz

PHP文件上传操作实例详解

本文实例分析了PHP文件上传操作.分享给大家供大家参考,具体如下: 文件上传 发生在浏览器向服务器发出的请求中. 文件,对于浏览器来讲,就是表单中的一个特殊类型的数据而已. 浏览器表单中的数据,两种类型: 字符串类型(字节流编码) 文件类型(二进制编码),文件是表单数据中一部分 服务器角度: 在接受浏览器请求时,处理好表单内的数据.根据数据类型不同使用不同处理方法: 字符串类型,存储在$_POST变量中(内存) 文件型数据,存储在上传临时目录中 表单提交时,浏览器会默认的行为: 表单内的的内容都

TP3.2.3框架文件上传操作实例详解

本文实例讲述了TP3.2.3框架文件上传操作.分享给大家供大家参考,具体如下: 上传表单 在ThinkPHP中使用上传功能无需进行特别处理.例如,下面是一个带有附件上传的表单提交: <form action="__URL__/upload" enctype="multipart/form-data" method="post" > <input type="text" name="name"

Java 中HttpURLConnection附件上传的实例详解

Java 中HttpURLConnection附件上传的实例详解 整合了一个自己写的采用Http做附件上传的工具,分享一下! 示例代码: /** * 以Http协议传输文件 * * @author mingxue.zhang@163.com * */ public class HttpPostUtil { private final static char[] MULTIPART_CHARS = "-_1234567890abcdefghijklmnopqrstuvwxyzABCDEFGHIJK

jQuery File Upload文件上传插件使用详解

jQuery File Upload 是一个Jquery文件上传组件,支持多文件上传.取消.删除,上传前缩略图预览.列表显示图片大小,支持上传进度条显示:支持各种动态语言开发的服务器端. 官网链接:https://github.com/blueimp/jQuery-File-Upload/wiki 特点:拖放支持:上传进度条:图像预览:可定制和可扩展的:兼容任何服务器端应用平台(PHP, Python, Ruby on Rails, Java, Node.js, Go etc.). 使用方法:

Bootstrap Fileinput文件上传组件用法详解

最近时间空余,总结了一些关于bootstrap fileinput组件的一些常见用法,特此分享到我们平台,供大家参考,同时也方便以后的查找.本文写的不好还请见谅. 一.效果展示 1.原始的input type='file',简直不忍直视. 2.不做任何装饰的bootstrap fileinput:(bootstrap fileinput初级进化) 3.bootstrap fileinput高级进化:中文化.可拖拽上传.文件扩展名校验(如果不是需要的文件,不让上传) 拖拽上传 上传中 4.boot

Webwork 实现文件上传下载代码详解

本文主要从三个方面给大家介绍webwork文件上传下载知识,包括以下三个方面: 1. 包装 Request 请求 2. 获取文件上传的解析类 3. 项目实战配置和使用 Web上传和下载应该是很普遍的一个需求,无论是小型网站还是大并发访问的交易网站.WebWork 当然也提供了很友好的拦截器来实现对文件的上传,让我们可以专注与业务逻辑的设计和实现,在实现上传和下载时顺便关注了下框架上传下载的实现. 1. 包装 Request 请求 •每次客户端请求 Action 时,都会调用 WebWork 调度

Web Uploader文件上传插件使用详解

WebUploader文件上传组件在现代的浏览器里面能充分发挥HTML5的优势,同时又不摒弃主流IE浏览器,沿用原来的FLASH运行时,兼容IE6+,iOS 6+, android 4+.两套运行时,同样的调用方式,可供用户任意选用. 采用大文件分片并发上传,极大的提高了文件上传效率. 一.功能介绍 分片.并发 分片与并发结合,将一个大文件分割成多块,并发上传,极大地提高大文件的上传速度. 当网络问题导致传输错误时,只需要重传出错分片,而不是整个文件.另外分片传输能够更加实时的跟踪上传进度. 预