FastFDS(六) FastDFS 的java API

「爱情、让人受尽委屈。」 2022-12-27 08:18 313阅读 0赞

参考官网: [https://gitee.com/fastdfs100/fastdfs-client-java][https_gitee.com_fastdfs100_fastdfs-client-java]

## 1、首先需要搭建 FastDFS 客户端Java开发环境 ##

① 项目中使用maven进行依赖管理，可以在pom.xml中引入如下依赖即可：

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

以上的jar包的引入会出现问题:

Could not find artifact org.csource:fastdfs-client-java:pom:1.29-SNAPSHOT in aliyun

这是因为此jar包需要手工打包并引入，在它的官网上已经有说明.

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5neWluZ2NoZW5ncWk_size_16_color_FFFFFF_t_70][]

具体流程请参考:     [打包fastdfs依赖][fastdfs]

② 引入配置文件

可直接复制 导入的包中的 fastdfs-client.properties.sample 或者 fdfs\_client.conf.sample(只要一个即可)，到你的项目中，去掉.sample。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5neWluZ2NoZW5ncWk_size_16_color_FFFFFF_t_70 1][]

## 2. 编写java程序。  ##

1） 案例一: 测试读取fastdfs配置文件.

public static void main(String[] args) throws IOException {
            String conf_filename = "fdfs_client.conf";
            IniFileReader iniFileReader = new IniFileReader(conf_filename);
            System.out.println("getConfFilename: " + iniFileReader.getConfFilename());
            System.out.println("connect_timeout: " + iniFileReader.getIntValue("connect_timeout", 3));
            System.out.println("network_timeout: " + iniFileReader.getIntValue("network_timeout", 45));
            System.out.println("charset: " + iniFileReader.getStrValue("charset"));
            System.out.println("http.tracker_http_port: " + iniFileReader.getIntValue("http.tracker_http_port", 8080));
            System.out.println("http.anti_steal_token: " + iniFileReader.getBoolValue("http.anti_steal_token", false));
            System.out.println("http.secret_key: " + iniFileReader.getStrValue("http.secret_key"));
            String[] tracker_servers = iniFileReader.getValues("tracker_server");
            if (tracker_servers != null) {
                System.out.println("tracker_servers.length: " + tracker_servers.length);
                for (int i = 0; i < tracker_servers.length; i++) {
                    System.out.println(String.format("tracker_servers[%s]: %s", i, tracker_servers[i]));
                }
            }
        }

2)案例二 : 测试文件上传, 下载.

String conf_filename = "fdfs_client.conf";   //配置文件
    
            //初始化参数
            ClientGlobal.init(conf_filename);
            System.out.println("network_timeout=" + ClientGlobal.g_network_timeout + "ms");
            System.out.println("charset=" + ClientGlobal.g_charset);
    
            long startTime;
            String group_name;
            String remote_filename;
            ServerInfo[] servers;
            TrackerClient tracker = new TrackerClient();
            TrackerServer trackerServer = tracker.getTrackerServer();     //获取tracker服务器
    
            StorageServer storageServer = null;    //存储服务器
    
      		/*
          storageServer = tracker.getStoreStorage(trackerServer);
      		if (storageServer == null)
      		{
      			System.out.println("getStoreStorage fail, error code: " + tracker.getErrorCode());
      			return;
      		}
      		*/
    
            StorageClient client = new StorageClient(trackerServer, storageServer);
            byte[] file_buff;
            NameValuePair[] meta_list;
            String[] results;
            String master_filename;
            String prefix_name;
            String file_ext_name;
            String generated_slave_filename;
            int errno;
    
            meta_list = new NameValuePair[4];
            meta_list[0] = new NameValuePair("width", "800");
            meta_list[1] = new NameValuePair("heigth", "600");
            meta_list[2] = new NameValuePair("bgcolor", "#FFFFFF");
            meta_list[3] = new NameValuePair("author", "zy");
    
            file_buff = "this is a test".getBytes(ClientGlobal.g_charset);
            System.out.println("file length: " + file_buff.length);
    
            group_name = null;
            StorageServer[] storageServers = tracker.getStoreStorages(trackerServer, group_name);
            if (storageServers == null) {
                System.err.println("获取存储服务器失败，代码: " + tracker.getErrorCode());
            } else {
                System.err.println("存储服务器数量: " + storageServers.length + "\n它们的信息如下:");
                for (int k = 0; k < storageServers.length; k++) {
                    System.err.println((k + 1) + ". " + storageServers[k].getInetSocketAddress().getAddress().getHostAddress() + ":" + storageServers[k].getInetSocketAddress().getPort());
                }
                System.err.println("");
            }
    
            startTime = System.currentTimeMillis();
            //上传一个普通的文本文件，返回值 为  String[]
            results = client.upload_file(file_buff, "txt", meta_list);
            System.out.println("上传文件用时:: " + (System.currentTimeMillis() - startTime) + " ms");
    
      		/*
      		group_name = "";
      		results = client.upload_file(group_name, file_buff, "txt", meta_list);
      		*/
            if (results == null) {
                System.err.println("上传文件失败，错误码: " + client.getErrorCode());
                return;
            } else {
                group_name = results[0];   //组编号
                remote_filename = results[1];   //文件名
                System.err.println("组名: " + group_name + ", 文件名: " + remote_filename);
                System.err.println(client.get_file_info(group_name, remote_filename));
    
                servers = tracker.getFetchStorages(trackerServer, group_name, remote_filename);
                if (servers == null) {
                    System.err.println("get storage servers fail, error code: " + tracker.getErrorCode());
                } else {
                    System.err.println("storage servers count: " + servers.length);
                    for (int k = 0; k < servers.length; k++) {
                        System.err.println((k + 1) + ". " + servers[k].getIpAddr() + ":" + servers[k].getPort());
                    }
                    System.err.println("");
                }
                //设置上传的元信息
                meta_list = new NameValuePair[4];
                meta_list[0] = new NameValuePair("width", "1024");
                meta_list[1] = new NameValuePair("heigth", "768");
                meta_list[2] = new NameValuePair("bgcolor", "#000000");
                meta_list[3] = new NameValuePair("title", "Untitle");
    
                startTime = System.currentTimeMillis();
                errno = client.set_metadata(group_name, remote_filename, meta_list, ProtoCommon.STORAGE_SET_METADATA_FLAG_MERGE);
                System.out.println("设置信息用时: " + (System.currentTimeMillis() - startTime) + " ms");
                if (errno == 0) {
                    System.err.println("set_metadata success");
                } else {
                    System.err.println("set_metadata fail, error no: " + errno);
                }
    
                meta_list = client.get_metadata(group_name, remote_filename);
                System.out.println("设置好的元信息如下:");
                if (meta_list != null) {
                    for (int i = 0; i < meta_list.length; i++) {
                        System.out.println(meta_list[i].getName() + " " + meta_list[i].getValue());
                    }
                }
                startTime = System.currentTimeMillis();
                file_buff = client.download_file(group_name, remote_filename);
                System.out.println("下载文件用时: " + (System.currentTimeMillis() - startTime) + " ms");
    
                if (file_buff != null) {
                    System.out.println("文件长度:" + file_buff.length);
                    System.out.println((new String(file_buff)));
                }
    
    
            }

上传的文件内容:  This is a test. 运行结果:

network_timeout=30000ms
    charset=UTF-8
    file length: 14
    存储服务器数量: 1
    它们的信息如下:
    1. 39.99.175.175:23000
    
    上传文件用时:: 416 ms
    组名: group1, 文件名: M00/00/00/J2Ovr1_QbsGABjQnAAAADg0e5-o331.txt
    fetch_from_server = false, file_type = 1, source_ip_addr = 39.99.175.175, file_size = 14, create_timestamp = 2020-12-09 14:29:21, crc32 = 220129258
    storage servers count: 1
    1. 39.99.175.175:23000
    
    设置信息用时: 172 ms
    set_metadata success
    设置好的元信息如下:
    author zy
    bgcolor #000000
    heigth 768
    title Untitle
    width 1024
    下载文件用时: 82 ms
    文件长度:14
    this is a test

[https_gitee.com_fastdfs100_fastdfs-client-java]: https://gitee.com/fastdfs100/fastdfs-client-java
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5neWluZ2NoZW5ncWk_size_16_color_FFFFFF_t_70]: /images/20221120/66b66de5ddf64dbd87a6c0e6d75050ae.png
[fastdfs]: https://forestcat.blog.csdn.net/article/details/110919725
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5neWluZ2NoZW5ncWk_size_16_color_FFFFFF_t_70 1]: /images/20221120/e0de85f7048d4d7c80f576f8084c23d8.png