导航：首页 > 互联网科技 >

高可用高性能分布式文件系统FastDFS实践Java程序

发表于：2024-11-28 作者：千家信息网编辑

千家信息网最后更新 2024年11月28日，在前篇高可用高性能分布式文件系统FastDFS进阶keepalived+nginx对多tracker进行高可用热备中已介绍搭建高可用的分布式文件系统架构。那怎么在程序中调用，其实网上有很多栗子，这

千家信息网最后更新 2024年11月28日高可用高性能分布式文件系统FastDFS实践Java程序

　　在前篇高可用高性能分布式文件系统FastDFS进阶keepalived+nginx对多tracker进行高可用热备中已介绍搭建高可用的分布式文件系统架构。

　　那怎么在程序中调用，其实网上有很多栗子，这里在他们的基础上作个简单的介绍。

下载源码并加入本地仓库

官网Java客户端源代码：https://github.com/happyfish200/fastdfs-client-java

打开源码后执行maven install 将代码打成jar到本地maven仓库(这步可自行 google)

示例源码

然后创建一个Demo工程，这里采用spring mvc模式创建。

在pom中加入引用 maven中依赖jar包

    org.csource    fastdfs-client-java    1.27-SNAPSHOT

fastdfs-client.properties

在resources的properties文件夹中创建配置文件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 = 10.0.11.201:22122,10.0.11.202:22122,10.0.11.203:22122

创建FastDFSClient工具类

package com.james.utils;import org.csource.common.MyException;import org.csource.common.NameValuePair;import org.csource.fastdfs.*;import java.io.BufferedOutputStream;import java.io.IOException;import java.net.URLDecoder;/** * Created by James on 2015/11/14. * FastDFS文件上传 */public class FastDFSClientUtils {    private TrackerClient trackerClient = null;    private TrackerServer trackerServer = null;    private StorageServer storageServer = null;    private StorageClient1 storageClient = null;    public FastDFSClientUtils(String conf) throws Exception {        if (conf.contains("classpath:")) {            String path = this.getClass().getResource("/").getPath();            conf = conf.replace("classpath:", URLDecoder.decode(path, "UTF-8"));        }        ClientGlobal.init(conf);        trackerClient = new TrackerClient();        trackerServer = trackerClient.getConnection();        storageServer = null;        storageClient = new StorageClient1(trackerServer, storageServer);    }        /**     * 上传文件方法     * Title: uploadFile
     * Description: 
     *     * @param fileName 文件全路径     * @param extName  文件扩展名，不包含（.）     * @param metas    文件扩展信息     * @return     * @throws Exception     */    public String uploadFile(String fileName, String extName, NameValuePair[] metas) {        String result = null;                try {            result = storageClient.upload_file1(fileName, extName, metas);        } catch (IOException e) {            e.printStackTrace();        } catch (MyException e) {            e.printStackTrace();        }        return result;    }        /**     * 上传文件,传fileName     *     * @param fileName 文件的磁盘路径名称 如：D:/image/aaa.jpg     * @return null为失败     */    public String uploadFile(String fileName) {            return uploadFile(fileName, null, null);    }        /**     * @param fileName 文件的磁盘路径名称 如：D:/image/aaa.jpg     * @param extName  文件的扩展名 如 txt jpg等     * @return null为失败     */    public String uploadFile(String fileName, String extName) {            return uploadFile(fileName, extName, null);    }        /**     * 上传文件方法     * Title: uploadFile
     * Description: 
     *     * @param fileContent 文件的内容，字节数组     * @param extName     文件扩展名     * @param metas       文件扩展信息     * @return     * @throws Exception     */    public String uploadFile(byte[] fileContent, String extName, NameValuePair[] metas) {        String result = null;                try {            result = storageClient.upload_file1(fileContent, extName, metas);        } catch (IOException e) {            e.printStackTrace();        } catch (MyException e) {            e.printStackTrace();        }        return result;    }        /**     * 上传文件     *     * @param fileContent 文件的字节数组     * @return null为失败     * @throws Exception     */    public String uploadFile(byte[] fileContent) throws Exception {            return uploadFile(fileContent, null, null);    }    /**     * 上传文件     *     * @param fileContent 文件的字节数组     * @param extName     文件的扩展名 如 txt  jpg png 等     * @return null为失败     */    public String uploadFile(byte[] fileContent, String extName) {            return uploadFile(fileContent, extName, null);    }    /**     * 文件下载到磁盘     *     * @param path   图片路径     * @param output 输出流 中包含要输出到磁盘的路径     * @return -1失败,0成功     */    public int download_file(String path, BufferedOutputStream output) {            //byte[] b = storageClient.download_file(group, path);        int result = -1;                try {                    byte[] b = storageClient.download_file1(path);                     try {                         if (b != null) {                    output.write(b);                    result = 0;                }            } catch (Exception e) {            } //用户可能取消了下载            finally {                            if (output != null)                                 try {                        output.close();                    } catch (IOException e) {                        e.printStackTrace();                    }            }        } catch (Exception e) {            e.printStackTrace();        }        return result;    }        /**     * 获取文件数组     *     * @param path 文件的路径 如group1/M00/00/00/wKgRsVjtwpSAXGwkAAAweEAzRjw471.jpg     * @return     */    public byte[] download_bytes(String path) {            byte[] b = null;            try {            b = storageClient.download_file1(path);        } catch (IOException e) {            e.printStackTrace();        } catch (MyException e) {            e.printStackTrace();        }        return b;    }        /**     * 删除文件     *     * @param group       组名 如：group1     * @param storagePath 不带组名的路径名称 如：M00/00/00/wKgRsVjtwpSAXGwkAAAweEAzRjw471.jpg     * @return -1失败,0成功     */    public Integer delete_file(String group, String storagePath) {            int result = -1;                    try {            result = storageClient.delete_file(group, storagePath);        } catch (IOException e) {            e.printStackTrace();        } catch (MyException e) {            e.printStackTrace();        }        return result;    }        /**     * @param storagePath 文件的全部路径 如：group1/M00/00/00/wKgRsVjtwpSAXGwkAAAweEAzRjw471.jpg     * @return -1失败,0成功     * @throws IOException     * @throws Exception     */    public Integer delete_file(String storagePath) {            int result = -1;         try {            result = storageClient.delete_file1(storagePath);        } catch (IOException e) {            e.printStackTrace();        } catch (MyException e) {            e.printStackTrace();        }        return result;    }}

Java客户端文件上传、下载、删除和元数据获取测试：

package com.james.fdfs;import org.junit.Test;import java.io.File;import java.util.HashMap;import java.util.Iterator;import java.util.Map;import  com.james.utils.FastDFSClientUtils;public class FastDFSClientUtilsTest {    /**     * 文件上传测试     */    @Test        public void testUpload() {        File file = new File("C:\\Users\\James\\Pic\\share.jpg");        Map metaList = new HashMap();        metaList.put("width","1024");        metaList.put("height","768");        String fid = FastDFSClientUtils.uploadFile(file,file.getName(),metaList);        System.out.println("upload local file " + file.getPath() + " ok, fileid=" + fid);                //上传成功返回的文件ID： group1/M00/00/00/wKgAyVgFk9aAB8hwAA-8Q6_7tHw351.jpg        }     /**     * 文件下载测试     */    @Test    public void testDownload() {            int r = FastDFSClientUtils.download_file("group1/M00/00/00/wKgAyVgFk9aAB8hwAA-8Q6_7tHw351.jpg", new File("DownloadFile_fid.jpg"));        System.out.println(r == 0 ? "下载成功" : "下载失败");    }     /**     * 文件删除测试     */    @Test        public void testDelete() {            int r = FastDFSClientUtils.delete_file("group1/M00/00/00/wKgAyVgFk9aAB8hwAA-8Q6_7tHw351.jpg");        System.out.println(r == 0 ? "删除成功" : "删除失败");    }}

如果没有什么问题将会看到打印的日志。