FastDFS教程（三）：使用Java代码操作文件

痛定思痛。 2023-10-09 12:23 14阅读 0赞

#### 第一步：导入FastDFS的Jar包 ####

进入https://github.com/happyfish100/fastdfs-client-java，下载文件。可以看到，有很多种生成jar文件的方式，有ant、maven等。

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

#### 第二步：使用API ####

1.  在src/main/resources目录下创建文件fdfs\_client.conf，并添加如下内容
    
    IP和端口根据实际的情况修改。该配置文件的其他选项，参照https://github.com/happyfish100/fastdfs-client-java配置。
    
        connect_timeout = 2
        network_timeout = 30
        charset = ISO8859-1
        http.tracker_http_port = 8080
        http.anti_steal_token = no
        http.secret_key = FastDFS1234567890
        
        tracker_server = IP地址:22122
        tracker_server = IP地址:22122
        tracker_server = IP地址:22122
    
    注1：tracker\_server指向**您自己的tracker服务器**的IP地址和端口，1-n个
    
    注2：除了tracker\_server，其它配置项都是可选的
2.  基本的文件上传代码
    
        /** * Create By: 刘建 * Date: 2019/9/25 * Time: 4:12 PM * Description: No Description */
        public class FastDFSTest { 
        
            @Test
            public void testFastDFS() throws IOException, MyException { 
                //初始化tracker客户端
                ClientGlobal.init("fdfs_client.conf");
                TrackerClient trackerClient = new TrackerClient();
                InputStream in = getClass().getClassLoader().getResourceAsStream("fdfs_client.conf");
                byte[] b = new byte[in.available()];
                in.read(b);
                //不要复用它，每次操作文件都进行此操作
                TrackerServer trackerServer = trackerClient.getConnection();
        
        
                //从tracker获取storage
                StorageClient storageClient = new StorageClient(trackerServer, null);
        
                //上传文件到storage服务器
                String[] result = storageClient.upload_file(b, "txt", null);
                System.out.println(Arrays.toString(result));
            }
        }
3.  封装成Util 下面是Java操作FastDFS进行文件上传、下载和删除的代码。

public final class FastDFSHelper { 
        private static final Logger logger = LoggerFactory.getLogger(FastDFSHelper.class);
        private static TrackerClient trackerClient;
     
        static { 
            try { 
                ClientGlobal.init("fdfs_client.conf");
                trackerClient = new TrackerClient();
            } catch (IOException | MyException e) { 
                logger.error("error", e);
            }
        }
     
        /** * 向FastDFS上传文件 * * @param localFilename 本地文件名 * @return 上传成功，返回组名和该文件在FastDFS中的名称；上传失败，返回null */
        public static void uploadFile(String localFilename) { 
            TrackerServer trackerServer;
            try { 
                trackerServer = trackerClient.getConnection();
            } catch (IOException e) { 
                logger.error("error", e);
                return;
            }
            StorageClient storageClient = new StorageClient(trackerServer, null);
            try { 
                String[] arr = storageClient.upload_file(localFilename, null, null);
                if (arr == null || arr.length != 2) { 
                    logger.error("向FastDFS上传文件失败");
                } else { 
                    logger.info("向FastDFS上传文件成功");
                }
            } catch (IOException | MyException e) { 
                logger.error("error", e);
            } finally { 
                closeTrackerServer(trackerServer);
            }
        }
     
        /** * 从FastDFS下载文件 * * @param localFilename 本地文件名 * @param groupName 文件在FastDFS中的组名 * @param remoteFilename 文件在FastDFS中的名称 */
        public static void downloadFile(String localFilename, String groupName, String remoteFilename) { 
           TrackerServer trackerServer;
            try { 
                trackerServer = trackerClient.getConnection();
            } catch (IOException e) { 
                logger.error("error", e);
                return;
            }
            StorageClient storageClient = new StorageClient(trackerServer, null);
            File file = new File(localFilename);
            try (BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream(file))) { 
                byte[] content = storageClient.download_file(groupName, remoteFilename);
                if (content == null || content.length == 0) { 
                    logger.error("文件大小为空！");
                    boolean flag = file.delete();
                    logger.info("删除文件结果：{}", flag);
                    return;
                }
                bos.write(content);
                logger.info("成功下载文件： " + localFilename);
            } catch (IOException | MyException e) { 
                logger.error("error", e);
            } finally { 
                closeTrackerServer(trackerServer);
            }
        }
     
        /** * 从FastDFS删除文件 * * @param localFilename 本地文件名 * @param groupName 文件在FastDFS中的组名 * @param remoteFilename 文件在FastDFS中的名称 */
        public static void deleteFile(String localFilename, String groupName, String remoteFilename) { 
            TrackerServer trackerServer;
            try { 
                trackerServer = trackerClient.getConnection();
            } catch (IOException e) { 
                logger.error("error", e);
                return;
            }
            StorageClient storageClient = new StorageClient(trackerServer, null);
            try { 
                int i = storageClient.delete_file(groupName, remoteFilename);
                if (i == 0) { 
                    logger.info("FastDFS删除文件成功");
                } else { 
                    logger.info("FastDFS删除文件失败");
                }
            } catch (IOException | MyException e) { 
                logger.error("error", e);
            } finally { 
                closeTrackerServer(trackerServer);
            }
        }
     
        private static void closeTrackerServer(TrackerServer trackerServer) { 
            try { 
                if (trackerServer != null) { 
                    logger.info("关闭trackerServer连接");
                    trackerServer.close();
                }
            } catch (IOException e) { 
                logger.error("error", e);
            }
        }
    }

上述代码中，因为配置文件 fdfs\_client.conf 是不变的，而且 trackerClient 是通过读取 fdfs\_client.conf 文件来创建的，所以复用了 trackerClient 。 trackerServer 最好不要复用，因为通过源码可以发现，每次通过 trackerClient.getConnection 获取连接的时候，都会在所有的 trackerServer 中选一个；如果复用，则 trackerServer 就被固定成了一个，失去了多个 trackerServer 的意义。每次操作结束，只需要关闭 trackerServer 。因为从源码中可以发现，作者已经为我们调用了 storageServer.close 方法，并将对象置空。

在实际应用中，应该记录下本地文件名和FastDFS中组名与文件名称的映射关系，在此省略。

参考博客

1、[在web项目中使用][web]

[web]: https://blog.csdn.net/u012946310/article/details/81567320

发表评论取消回复

表情：

评论列表（有 0 条评论，14人围观）

还没有评论，来说两句吧...

相关阅读

相关 FastDFS教程（三）：使用Java代码操作文件

第一步：导入FastDFS的Jar包进入https://github.com/happyfish100/fastdfs-client-java，下载文件。可以看到，有很

痛定思痛。/ 2023年10月09日 12:23/ 0 赞/ 15 阅读

相关【FastDFS】分布式文件系统FastDFS基本操作

FastDFS基本操作上传文件 [root@CentOSX ~] fdfs_upload_file /etc/fdfs/client.conf inst

左手的ㄟ右手/ 2023年10月05日 14:44/ 0 赞/ 70 阅读

相关 fastdfs-client使用教程

FastDfs客户端使用文档 fastdfs-client支持框架 fastdfs-client目前支持的框架有springboot1.x 、springboot2

短命女/ 2023年02月25日 02:24/ 0 赞/ 6 阅读

相关 fastDFS 使用fastDFS实现文件上传和下载

[2019独角兽企业重金招聘Python工程师标准>>> ][2019_Python_] ![hot3.png][] 1. 搭建环境这里我们使用javaApi测试文件

清疚/ 2022年10月02日 06:42/ 0 赞/ 20 阅读

相关 Java文件操作（三）

3.6.1、练习一完成以下功能通过程序输入两个数字，之后进行两个数字的相加操作，并把结果打印输出。要求：如果用户输入的不是数字，则应该提示用户输入错误，之后要求用户

痛定思痛。/ 2022年07月21日 12:16/ 0 赞/ 85 阅读

相关安装fastdfs及java操作

1、安装 libfastcommon git地址：https://github.com/happyfish100/libfastcommon.git 安

旧城等待，/ 2022年05月10日 04:58/ 0 赞/ 172 阅读

相关 ArangoDB教程(三)-使用java操作ArangoDB

package com.haha.ArangoDBTest; import java.util.List; import java.util.

亦凉/ 2022年04月23日 07:04/ 0 赞/ 383 阅读

相关使用java操作FastDFS上传,下载,删除文件

经过我的测试，直接把代码copy就能用了！前提条件：将源码生成为jar包,install到本地maven仓库 1.从github上down下源代码：https://gi

雨点打透心脏的1/2处/ 2022年04月16日 06:56/ 0 赞/ 586 阅读

相关分布式文件管理系统FastDFS搭建教程（FastDFS+nginx+fastdfs-nginx-module）

Why FastDFS? FastDFS是一个开源的轻量级分布式文件系统，它对文件进行管理，功能包括：文件存储、文件同步、文件访问（文件上传、文件下载）等，解决了大容量存

迈不过友情╰/ 2022年04月01日 06:56/ 0 赞/ 818 阅读

相关 FastDFS Java Api 使用教程

前言上一篇文章[分布式文件管理系统FastDFS搭建教程（FastDFS+nginx+fastdfs-nginx-module）][FastDFS_FastDFS_ng

绝地灬酷狼/ 2022年03月31日 04:37/ 0 赞/ 602 阅读