1. 程式人生 > >FastDFS簡單入門小demo

FastDFS簡單入門小demo

cti gen class serve HA AR jar包 pre bigdata

圖片上傳

需要引入 FastDFS 相關的jar包,但是這個jar沒有在中央倉庫,所以還得需要找到這個jar手動安裝到自己的本地倉庫才能使用。

需要一個配置文件 fdfs_client.conf

需要一個 FastDFS 服務器

看代碼:

fdfs_client.conf

技術分享圖片
# connect timeout in seconds
# default value is 30s
connect_timeout=30

# network timeout in seconds
# default value is 30s
network_timeout=60

# the base path to store log files
base_path
=/home/fastdfs # tracker_server can ocur more than once, and tracker_server format is # "host:port", host can be hostname or ip address tracker_server=192.168.25.133:22122 #服務器地址 #standard log level as syslog, case insensitive, value list: ### emerg for emergency ### alert ### crit for critical ### error ### warn
for warning ### notice ### info ### debug log_level=info # if use connection pool # default value is false # since V4.05 use_connection_pool = false # connections whose the idle time exceeds this time will be closed # unit: second # default value is 3600 # since V4.05 connection_pool_max_idle_time
= 3600 # if load FastDFS parameters from tracker server # since V4.05 # default value is false load_fdfs_parameters_from_tracker=false # if use storage ID instead of IP address # same as tracker.conf # valid only when load_fdfs_parameters_from_tracker is false # default value is false # since V4.05 use_storage_id = false # specify storage ids filename, can use relative or absolute path # same as tracker.conf # valid only when load_fdfs_parameters_from_tracker is false # since V4.05 storage_ids_filename = storage_ids.conf #HTTP settings http.tracker_server_port=80 #use "#include" directive to include HTTP other settiongs ##include http.conf
View Code

Test.java

package cn.itcast.demo;

import java.io.FileNotFoundException;
import java.io.IOException;

import org.csource.fastdfs.ClientGlobal;
import org.csource.fastdfs.StorageClient;
import org.csource.fastdfs.StorageServer;
import org.csource.fastdfs.TrackerClient;
import org.csource.fastdfs.TrackerServer;

public class Test {

    public static void main(String[] args) throws FileNotFoundException, IOException, Exception {
        // 1.加載配置文件
        ClientGlobal.init("D:\\pinyougou_bigdata1\\fastDFSdemo\\src\\main\\resources\\fdfs_client.conf");
        // 2.構建一個管理者客戶端
        TrackerClient client=new TrackerClient();
        // 3.連接管理者服務端
        TrackerServer trackerServer = client.getConnection();
        //4. 聲明存儲服務端
        StorageServer storageServer=null;
        //5. 獲取存儲服務器的客戶端對象
        StorageClient storageClient=new StorageClient(trackerServer, storageServer);
        //6.上傳文件
        String[] strings = storageClient.upload_file("e:\\image\\b.jpg", "jpg", null);
        //7.顯示上傳結果 file_id
        for(String str:strings){
            System.out.println(str);
        }        
        
    }

}

FastDFS簡單入門小demo