Java 客户端操作 FastDFS 实现文件上传下载替换删除功能

FastDFS 的作者余庆先生已经为我们开发好了 Java 对应的 SDK。这里需要解释一下:作者余庆并没有及时更新最新的 Java SDK 至 Maven 中央仓库,目前中央仓库最新版仍旧是 1.27 版。所以我们需要通过 Github:https://github.com/happyfish100/fastdfs-client-java 下载项目源码,再通过命令 mvn clean install 编译打包导入 Maven 仓库使用即可。

接下来我们通过 Java API 操作 FastDFS 实现文件的上传、下载、替换、删除、查询元数据、查询详情等功能。

文中案例已同步至:

Github:https://github.com/imrhelloworld/fastdfs-javaGitee:https://gitee.com/imrhelloworld/fastdfs-java

创建项目

添加依赖

在项目的 pom.xml 中添加以下依赖。因为我们需要一些常用工具包和单元测试,所以需要引入它们。

<!-- fastdfs java client -->
<dependency>
 <groupId>org.csource</groupId>
 <artifactId>fastdfs-client-java</artifactId>
 <version>1.29-SNAPSHOT</version>
</dependency>
<!-- apache commons lang3 工具包 -->
<dependency>
 <groupId>org.apache.commons</groupId>
 <artifactId>commons-lang3</artifactId>
 <version>3.11</version>
</dependency>
<!-- junit 单元测试 -->
<dependency>
 <groupId>junit</groupId>
 <artifactId>junit</artifactId>
 <version>4.13</version>
 <scope>test</scope>
</dependency>

编写配置文件

fdfs_client.conf

# 超时时间
connect_timeout = 10
network_timeout = 30
# 编码字符集
charset = UTF-8
# tracker 服务器 HTTP 协议下暴露的端口
http.tracker_http_port = 8080
# tracker 服务器的 IP 和端口
tracker_server = 192.168.10.101:22122

工具类

package org.example.client;

import org.apache.commons.lang3.StringUtils;
import org.csource.common.MyException;
import org.csource.common.NameValuePair;
import org.csource.fastdfs.*;

import java.io.*;

/**
 * FastDFS 分布式文件系统 Java 客户端工具类
 * 具体功能:文件上传、下载、替换、删除、查询文件元数据、查看文件详情
 */
public class FastDFSClient {

 // 获取配置文件地址
 private static final String CONF_FILENAME = Thread.currentThread()
   .getContextClassLoader().getResource("").getPath() + "fdfs_client.conf";
 // Storage 存储服务器客户端
 private static StorageClient storageClient = null;

 static {
  try {
   // 加载配置文件
   ClientGlobal.init(CONF_FILENAME);
   // 初始化 Tracker 客户端
   TrackerClient trackerClient = new TrackerClient(ClientGlobal.g_tracker_group);
   // 初始化 Tracker 服务端
   TrackerServer trackerServer = trackerClient.getTrackerServer();
   // 初始化 Storage 服务端
   StorageServer storageServer = trackerClient.getStoreStorage(trackerServer);
   // 初始化 Storage 客户端
   storageClient = new StorageClient(trackerServer, storageServer);
  } catch (IOException e) {
   e.printStackTrace();
  } catch (MyException e) {
   e.printStackTrace();
  }
 }

 /**
  * 文件上传
  *
  * @param inputStream 上传的文件的字节输入流
  * @param fileName 上传的文件的原始名
  * @return
  */
 public static String[] uploadFile(InputStream inputStream, String fileName) {
  try {
   // 准备字节数组
   byte[] fileBuff = null;
   // 文件元数据
   NameValuePair[] metaList = null;
   if (inputStream != null) {
    // 查看文件的长度
    int len = inputStream.available();
    // 初始化元数据数组
    metaList = new NameValuePair[2];
    // 第一组元数据,文件的原始名称
    metaList[0] = new NameValuePair("file_name", fileName);
    // 第二组元数据,文件的长度
    metaList[1] = new NameValuePair("file_length", String.valueOf(len));
    // 创建对应长度的字节数组
    fileBuff = new byte[len];
    // 将输入流中的字节内容,读到字节数组中
    inputStream.read(fileBuff);
   }
   /*
    上传文件。
    参数含义:要上传的文件的内容(使用字节数组传递),上传的文件的类型(扩展名),元数据
    */
   String[] fileids = storageClient.upload_file(fileBuff, getFileExt(fileName), metaList);
   return fileids;
  } catch (IOException e) {
   e.printStackTrace();
  } catch (MyException e) {
   e.printStackTrace();
  }
  return null;
 }

 /**
  * 文件上传
  *
  * @param file  上传的文件
  * @param fileName 上传的文件的原始名
  * @return
  */
 public static String[] uploadFile(File file, String fileName) {
  try (FileInputStream fis = new FileInputStream(file)) {
   return uploadFile(fis, fileName);
  } catch (FileNotFoundException e) {
   e.printStackTrace();
  } catch (IOException e) {
   e.printStackTrace();
  }
  return null;
 }

 /**
  * 获取文件后缀名(不带点)
  *
  * @param fileName
  * @return 如:"jpg" or ""
  */
 private static String getFileExt(String fileName) {
  if (StringUtils.isBlank(fileName) || !fileName.contains(".")) {
   return "";
  }
  return fileName.substring(fileName.lastIndexOf(".") + 1); // 不带最后的点
 }

 /**
  * 获取文件详情
  *
  * @param groupName  组/卷名,默认值:group1
  * @param remoteFileName 文件名,例如:"M00/00/00/wKgKZl9tkTCAJAanAADhaCZ_RF0495.jpg"
  * @return 文件详情
  */
 public static FileInfo getFileInfo(String groupName, String remoteFileName) {
  try {
   return storageClient.get_file_info(groupName == null ? "group1" : groupName, remoteFileName);
  } catch (IOException e) {
   e.printStackTrace();
  } catch (MyException e) {
   e.printStackTrace();
  }
  return null;
 }

 /**
  * 获取元数据
  *
  * @param groupName  组/卷名,默认值:group1
  * @param remoteFileName 文件名,例如:"M00/00/00/wKgKZl9tkTCAJAanAADhaCZ_RF0495.jpg"
  * @return 文件的元数据数组
  */
 public static NameValuePair[] getMetaData(String groupName, String remoteFileName) {
  try {
   // 根据组名和文件名通过 Storage 客户端获取文件的元数据数组
   return storageClient.get_metadata(groupName == null ? "group1" : groupName, remoteFileName);
  } catch (IOException e) {
   e.printStackTrace();
  } catch (MyException e) {
   e.printStackTrace();
  }
  return null;
 }

 /**
  * 文件下载
  *
  * @param groupName  组/卷名,默认值:group1
  * @param remoteFileName 文件名,例如:"M00/00/00/wKgKZl9tkTCAJAanAADhaCZ_RF0495.jpg"
  * @return 文件的字节输入流
  */
 public static InputStream downloadFile(String groupName, String remoteFileName) {
  try {
   // 根据组名和文件名通过 Storage 客户端获取文件的字节数组
   byte[] bytes = storageClient.download_file(groupName == null ? "group1" : groupName, remoteFileName);
   // 返回字节流对象
   InputStream inputStream = new ByteArrayInputStream(bytes);
   return inputStream;
  } catch (IOException e) {
   e.printStackTrace();
  } catch (MyException e) {
   e.printStackTrace();
  }
  return null;
 }

 /**
  * 文件删除
  *
  * @param groupName  组/卷名,默认值:group1
  * @param remoteFileName 文件名,例如:"M00/00/00/wKgKZl9tkTCAJAanAADhaCZ_RF0495.jpg"
  * @return 0为成功,非0为失败
  */
 public static int deleteFile(String groupName, String remoteFileName) {
  int result = -1;
  try {
   // 根据组名和文件名通过 Storage 客户端删除文件
   result = storageClient.delete_file(groupName == null ? "group1" : groupName, remoteFileName);
  } catch (IOException e) {
   e.printStackTrace();
  } catch (MyException e) {
   e.printStackTrace();
  }
  return result;
 }

 /**
  * 修改一个已经存在的文件
  *
  * @param oldGroupName 旧组名
  * @param oldFileName 旧文件名
  * @param file   新文件
  * @param fileName  新文件名
  * @return
  */
 public static String[] modifyFile(String oldGroupName, String oldFileName, File file, String fileName) {
  // 先上传
  String[] fileids = uploadFile(file, fileName);
  if (fileids == null) {
   return null;
  }
  // 再删除
  int delResult = deleteFile(oldGroupName, oldFileName);
  if (delResult != 0) {
   return null;
  }
  return fileids;
 }

}

测试

文件上传

// 文件上传
@Test
public void testUploadFile() {
 String[] fileids = FastDFSClient.uploadFile(new File("D:/china.jpg"), "china.jpg");
 for (String fileid : fileids) {
  System.out.println("fileid = " + fileid);
 }
}

返回值

fileid = group1
fileid = M00/00/00/wKgKZl9xMdiAcOLdAADhaCZ_RF0096.jpg

文件详情

// 查看文件详情
@Test
public void testGetFileInfo() {
 FileInfo fileInfo = FastDFSClient.getFileInfo("group1", "M00/00/00/wKgKZl9xMdiAcOLdAADhaCZ_RF0096.jpg");
 System.out.println("fileInfo = " + fileInfo);
}

返回值:

fileInfo = fetch_from_server = false, file_type = 1, source_ip_addr = 192.168.10.102, file_size = 57704, create_timestamp = 2020-09-28 08:44:08, crc32 = 645874781

文件元数据

// 获取文件数据
@Test
public void testGetMetaData() {
 NameValuePair[] metaDatas = FastDFSClient.getMetaData("group1", "M00/00/00/wKgKZl9xMdiAcOLdAADhaCZ_RF0096.jpg");
 for (NameValuePair metaData : metaDatas) {
  System.out.println(metaData.getName() + "---" + metaData.getValue());
 }
}

返回值:

file_length---57704
file_name---china.jpg

文件下载

// 文件下载
@Test
public void testDownloadFile() {
 InputStream is = FastDFSClient.downloadFile("group1", "M00/00/00/wKgKZl9xMdiAcOLdAADhaCZ_RF0096.jpg");
 try (FileOutputStream fos = new FileOutputStream("D:/wKgKZl9xMdiAcOLdAADhaCZ_RF0096.jpg")) {
  int len = 0;
  byte[] bytes = new byte[1024];
  while ((len = is.read(bytes)) != -1) {
   fos.write(bytes, 0, len);
   fos.flush();
  }
 } catch (FileNotFoundException e) {
  e.printStackTrace();
 } catch (IOException e) {
  e.printStackTrace();
 }
}

文件删除

// 文件删除
@Test
public void testDeleteFile() {
 int result = FastDFSClient.deleteFile("group1", "M00/00/00/wKgKZl9xMdiAcOLdAADhaCZ_RF0096.jpg");
 System.out.println("result = " + result);
}

返回值:

result = 0

文件替换

// 文件替换
@Test
public void testModifyFile() {
 String[] fileids = FastDFSClient.modifyFile("group1", "M00/00/00/wKgKZl9xOS2ASdu8AADhaCZ_RF0898.jpg",
            new File("D:/mhw.jpg"), "mhw.jpg");
 for (String fileid : fileids) {
  System.out.println("fileid = " + fileid);
 }
}

返回值:

fileid = group1
fileid = M00/00/00/wKgKZl9xOeaAFO00AACmo7QBGtA298.jpg

至此 Java 客户端操作 FastDFS 实现文件上传下载替换删除等操作就到这里,下一篇我们带大家搭建 FastDFS 的集群环境,多 Tracker 多 Storage 然后通过 Nginx 代理。

到此这篇关于Java 客户端操作 FastDFS 实现文件上传下载替换删除功能的文章就介绍到这了,更多相关java 文件上传下载替换删除内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们!

时间: 2020-10-16

java实现文件上传下载

本文实例为大家分享了java实现文件上传下载的具体代码,供大家参考,具体内容如下 一.上传 1.前端: <form method="post" action="FileUpload" enctype="multipart/form-data"> <input type="file" name="uploadFile" /> <br/> <input type=&qu

基于Java文件输入输出流实现文件上传下载功能

本文为大家分享了Java实现文件上传下载功能的具体代码,供大家参考,具体内容如下 前端通过form表单的enctype属性,将数据传递方式修改为二进制"流"的形式,服务端(servlet)通过  getInputStream() 获取流信息, 运用java I/O 流的基础操作将流写入到一个服务端临时创建的文件temp中,然后再次利用文件基本操作,读取并截取临时文件内容,根据其中信息创建相应的文件,将读取出来的具体信息写入,下载时,根据提交的文件名称,找到服务器端相应的文件,然后根据输

Java文件上传与文件下载实现方法详解

本文实例讲述了Java文件上传与文件下载实现方法.分享给大家供大家参考,具体如下: Java文件上传 数据上传是客户端向服务器端上传数据,客户端向服务器发送的所有请求都属于数据上传.文件上传是数据上传的一种特例,指客户端向服务器上传文件.即将保存在客户端的文件上传一个副本到服务器,并保存在服务器中. 1.上传表单要求 文件上传要求客户端提交特殊的请求--multipart请求,即包含多部分数据的请求.必须将<form/>标签的enctype属性值设为"multipart/form-d

JavaWeb实现多文件上传及zip打包下载

本文实例为大家分享了javaweb多文件上传及zip打包下载的具体代码,供大家参考,具体内容如下 项目中经常会使用到文件上传及下载的功能.本篇文章总结场景在JavaWeb环境下,多文件上传及批量打包下载功能,包括前台及后台部分. 首先明确一点: 无法通过页面的无刷新ajax请求,直接发下载.上传请求.上传和下载,均需要在整页请求的基础上实现.项目中一般通过构建form表单形式实现这一功能. 一.多文件上传 项目需求为实现多图片上传功能.参考测试了网上找到的众多插件方法后,决定选用Jquery原始

Java 添加、删除、替换、格式化Word中的文本的步骤详解(基于Spire.Cloud.SDK for Java)

Spire.Cloud.SDK for Java提供了TextRangesApi接口可通过addTextRange()添加文本.deleteTextRange()删除文本.updateTextRangeText()替换文本.updateTextRangeFormat()格式化文本等.本文将从以上方法介绍如何来实现对文本的操作.可参考以下步骤进行准备: 一.导入jar文件 创建Maven项目程序,通过maven仓库下载导入.以IDEA为例,新建Maven项目,在pom.xml文件中配置maven仓

Java 添加、替换、删除PDF中的图片的示例代码

概述 本文介绍通过java程序向PDF文档添加图片,以及替换和删除PDF中已有的图片.另外,关于图片的操作还可参考设置PDF 图片背景.设置PDF图片水印.读取PDF中的图片.将PDF保存为图片等文章. 工具:Free Spire.PDF for Java (免费版) Jar获取及导入:官网下载,并解压将lib文件夹下的jar文件导入java程序,或者通过maven仓库下载并导入. jar导入效果: Java代码示例 [示例1]添加图片到PDF import com.spire.pdf.*; i

JS动态添加与删除select中的Option对象(示例代码)

如下所示: 复制代码 代码如下: //动态删除select中的所有options:   function delAllOptions(){        document.getElementById("user_dm").options.length=0;   } //动态删除select中的某一项option:    function delOneOption(index){        document.getElementById("user_dm").o

Java 添加和删除PDF图层的示例代码

在PDF文档中,图层可以使部分内容选择性地被隐藏或显示.通过添加图层,我们可以将文本.图片.表格等元素精确定位于页面指定位置,并可将这些元素进行叠放.组合形成页面的最终效果.本文将介绍如何使用Spire.PDF for Java来添加和删除PDF图层. 使用工具: Free Spire.PDF for Java (免费版) Jar文件获取及导入: 方法1:通过官方网站 下载获取jar包.解压后将lib文件夹下的Spire.Pdf.jar文件导入Java程序.(如下图) 方法2:通过maven仓库

java后台接收app上传的图片的示例代码

整理文档,搜刮出一个java后台接受app上传的图片的示例代码,稍微整理精简一下做下分享 package com.sujinabo.file; import java.io.File; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.util.List; import java.util.UUID; import javax.servlet.S

Angular使用 ng-img-max 调整浏览器中的图片的示例代码

你想在Angular应用程序中进行图片上传,是否想在图片上传之前在前端限制上传图片的尺寸?ng2-img-max模块正是你所要的! ng2-img-max模块会使用web sorkers 进行图片大小的计算,并驻留在主线程中. 我们来看看他的用途: 安装 首先,使用npm 或 Yarn安装模块: $ npm install ng2-img-max blueimp-canvas-to-blob --save # or Yarn : $ yarn add ng2-img-max blueimp-ca

JS实现添加,替换,删除节点元素的方法

本文实例讲述了JS实现添加,替换,删除节点元素的方法.分享给大家供大家参考,具体如下: 一直以来,对于节点操作比较纠结,特别是插入到某某节点之后.居然没有这个方法,以前的我写的方法有问题,是把新节点插入到旧节点的里面去了,还是该用insertBefore方法可以实现 下面是方法: <!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose

java正则替换img标签中src值的方法

主要功能是: 替换html字符串中img标签src的值. 代码如下: package com.junlenet.common.util; import java.util.regex.Matcher; import java.util.regex.Pattern; /** * html处理工具类 * @author huweijun * @date 2016年7月13日 下午7:25:09 */ public class HtmlUtils { /** * 替换指定标签的属性和值 * @para

Java解码H264格式视频流中的图片

本文实例为大家分享了Java解码H264格式视频流中的图片,供大家参考,具体内容如下 引入依赖 <dependency> <groupId>org.bytedeco</groupId> <artifactId>javacv</artifactId> <version>1.4.3</version> </dependency> <dependency> <groupId>org.byted

js动态添加表格逐行添加、删除、遍历取值的实例代码

关于js对表格进行逐行添加,今天抽空整理了一下:新建一个html文件(没有编辑器的可以新建一个demo.txt文件,然后改后缀名为demo.html),把下面代码全部贴进去即可. 功能包括:表格添加一行,表格删除一行,表格遍历取值等. 点击说明:点击添加按钮,则表格添加一行,可进行录入,删除按钮,可删除当前行,其他行不影响.删除或者添加,每行的的编号都会自动变化,套餐和价格是<input/>,内容是 <textarea></textarea>,点击保存按钮的时候,遍历表

Android中复制图片的实例代码

activity_main.xml中的配置 <LinearLayout xmlns:android="http://schemas.android.com/apk/res/android" xmlns:tools="http://schemas.android.com/tools" android:layout_width="match_parent" android:layout_height="match_parent&quo