您的位置 首页 java

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

智云科技 发布于 2023年5月5日 评论关闭 阅读(118)

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

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

　　文中案例已同步至：

  • Github：
  • Gitee：

　　

创建项目

　　

　　

添加依赖

　　

　　 在 项目的 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_FI len AME = 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 代理。

您的 点赞 和 转发 是对我最大的支持。

关注 哈喽沃德先生 「文档 + 视频」每篇文章都配有专门视频讲解，学习更轻松噢 ~

标签:
打赏 点赞(2)

文章来源：智云一二三科技

文章标题：Java客户端操作FastDFS实现文件上传下载替换删除

文章地址：https://www.zhihuclub.com/175171.shtml

关于作者: 智云科技

相关文章

热门文章

1分享新浪图床上传接口源码

点赞(897) 阅读(59,832)

2PHP简单实现路由Route功能

点赞(1.11K) 阅读(35,943)

3Tideways、xhprof 和 xhgui 打造 PHP 非侵入式监控平台

点赞(323) 阅读(4,274)

4centos系统如何查看是否安装了mysql

点赞(497) 阅读(3,757)

5curl 工具简述

点赞(467) 阅读(2,960)
网站地图