MAVEN

<!-- https://mvnrepository.com/artifact/net.oschina.zcx7878/fastdfs-client-java -->

<dependency>

    <groupId>net.oschina.zcx7878</groupId>

    <artifactId>fastdfs-client-java</artifactId>

    <version>1.27.0.0</version>

</dependency>

示例代码

新建fdfs_client.conf

connect_timeout = 2    （可以没有）

network_timeout = 30（可以没有）

charset = UTF-8（可以没有）

http.tracker_http_port = 80

http.anti_steal_token = no（可以没有）

http.secret_key = FastDFS1234567890（可以没有）

tracker_server = 192.168.17.112:22122      

示例代码

package com.example.demo.test;

import java.io.FileNotFoundException;

import java.io.FileOutputStream;

import java.io.IOException;

import java.util.UUID;

import org.apache.commons.io.IOUtils;

import org.csource.common.MyException;

import org.csource.common.NameValuePair;

import org.csource.fastdfs.ClientGlobal;

import org.csource.fastdfs.FileInfo;

import org.csource.fastdfs.StorageClient;

import org.csource.fastdfs.StorageServer;

import org.csource.fastdfs.TrackerClient;

import org.csource.fastdfs.TrackerServer;

import org.junit.After;

import org.junit.Before;

import org.junit.Test;

public class TestFastDfs {

public Stringconf_filename ="D:\\stsworkspace\\fastdfs-demo\\src\\main\\resources\\fdfs_client.conf";

    public Stringlocal_filename ="D:\\stsworkspace\\fastdfs-demo\\src\\main\\resources\\sprites.png";

    @Before

public void setUp()throws Exception {

}

@After

public void tearDown()throws Exception {

}

@Test

public void testUpload() {

try {

ClientGlobal.init(conf_filename);

            TrackerClient tracker =new TrackerClient();

            TrackerServer trackerServer = tracker.getConnection();

            StorageServer storageServer =null;

            StorageClient storageClient =new StorageClient(trackerServer, storageServer);

            NameValuePair nvp [] =new NameValuePair[]{

new NameValuePair("age", "18"),

                    new NameValuePair("sex", "male")

};

            String fileIds[] = storageClient.upload_file(local_filename, "png", nvp);

            System.out.println(fileIds.length);

            System.out.println("组名：" + fileIds[0]);

            System.out.println("路径: " + fileIds[1]);

        }catch (FileNotFoundException e) {

e.printStackTrace();

        }catch (IOException e) {

e.printStackTrace();

        }catch (MyException e) {

e.printStackTrace();

        }

}

@Test

public void testDownload() {

try {

ClientGlobal.init(conf_filename);

            TrackerClient tracker =new TrackerClient();

            TrackerServer trackerServer = tracker.getConnection();

            StorageServer storageServer =null;

            StorageClient storageClient =new StorageClient(trackerServer, storageServer);

            byte[] b = storageClient.download_file("group1", "M00/00/00/wKgRcFV_08OAK_KCAAAA5fm_sy874.conf");

            System.out.println(b);

            IOUtils.write(b, new FileOutputStream("D:/"+UUID.randomUUID().toString()+".conf"));

        }catch (Exception e) {

e.printStackTrace();

        }

}

@Test

public void testGetFileInfo(){

try {

ClientGlobal.init(conf_filename);

            TrackerClient tracker =new TrackerClient();

            TrackerServer trackerServer = tracker.getConnection();

            StorageServer storageServer =null;

            StorageClient storageClient =new StorageClient(trackerServer, storageServer);

            FileInfo fi = storageClient.get_file_info("group1", "M00/00/00/wKgRcFV_08OAK_KCAAAA5fm_sy874.conf");

            System.out.println(fi.getSourceIpAddr());

            System.out.println(fi.getFileSize());

            System.out.println(fi.getCreateTimestamp());

            System.out.println(fi.getCrc32());

        }catch (Exception e) {

e.printStackTrace();

        }

}

@Test

public void testGetFileMate(){

try {

ClientGlobal.init(conf_filename);

            TrackerClient tracker =new TrackerClient();

            TrackerServer trackerServer = tracker.getConnection();

            StorageServer storageServer =null;

            StorageClient storageClient =new StorageClient(trackerServer,

                    storageServer);

            NameValuePair nvps [] = storageClient.get_metadata("group1", "M00/00/00/wKgRcFV_08OAK_KCAAAA5fm_sy874.conf");

            for(NameValuePair nvp : nvps){

System.out.println(nvp.getName() +":" + nvp.getValue());

            }

}catch (Exception e) {

e.printStackTrace();

        }

}

@Test

public void testDelete(){

try {

ClientGlobal.init(conf_filename);

            TrackerClient tracker =new TrackerClient();

            TrackerServer trackerServer = tracker.getConnection();

            StorageServer storageServer =null;

            StorageClient storageClient =new StorageClient(trackerServer,

                    storageServer);

            int i = storageClient.delete_file("group1", "M00/00/00/wKgRcFV_08OAK_KCAAAA5fm_sy874.conf");

            System.out.println( i==0 ?"删除成功" :"删除失败:"+i);

        }catch (Exception e) {

e.printStackTrace();

        }

}

}