fastdfs文件上传java简单例子

墨蓝 2022-10-13 01:46 172阅读 0赞

#### 1 maven配置如下 ####

<dependency>
    	<groupId>org.csource.fastdfs</groupId>
    	<artifactId>fastdfs</artifactId>
    	<version>1.2</version>
    </dependency>

代码结构如下  
![在这里插入图片描述][20210708105527788.png]

#### 2 main方法如下 ####

import org.csource.fastdfs.*;
    
    import java.io.*;
    
    public class FastDFSDemo { 
        public static void main(String[] args) { 
            // 上传文件
            testUpload();
            // 下载文件
    // testDownload();
        }
    
        private static void testUpload() { 
            try{ 
                // 1、加载配置文件，配置文件中的内容就是 tracker 服务的地址。TODO 改成自己的路径
                ClientGlobal.init("E:\\EDish2\\xionganxinqu\\pig\\fastdfs\\src\\main\\resources\\fdfs_client.conf");
                // 2、创建一个 TrackerClient 对象。直接 new 一个。
                TrackerClient trackerClient = new TrackerClient();
                // 3、使用 TrackerClient 对象创建连接，获得一个 TrackerServer 对象。
                TrackerServer trackerServer = trackerClient.getConnection();
                // 4、创建一个 StorageServer 的引用，值为 null
                StorageServer storageServer = null;
                // 5、创建一个 StorageClient 对象，需要两个参数 TrackerServer 对象、StorageServer 的引用
                StorageClient storageClient = new StorageClient(trackerServer, storageServer);
                // 6、使用 StorageClient 对象上传图片。
                //扩展名不带“.” TODO 改成自己的路径
                String[] strings = storageClient.upload_file("C:\\Users\\hasee\\Desktop\\photo\\cat.jpg", "jpg",
                        null);
                // 7、返回数组。包含组名和图片的路径。
                for (String string : strings) { 
                    System.out.println(string);
                }
                // http://192.168.25.133/group1/M00/00/00/wKgZhVwJCTKAQUPoAABIga2I1P4060.jpg
            } catch (Exception e){ 
                e.printStackTrace();
            }
    
        }
    
        /** * 下载文件 */
        public static void testDownload() { 
            try { 
                // 配置文件 TODO 改成自己的路径
                ClientGlobal.init("E:\\EDish2\\xionganxinqu\\pig\\fastdfs\\src\\main\\resources\\fdfs_client.conf");
                TrackerClient tracker = new TrackerClient();
                TrackerServer trackerServer = tracker.getConnection();
                StorageServer storageServer = null;
                StorageClient storageClient = new StorageClient(trackerServer, storageServer);
                //http://192.168.25.133/group1/M00/00/05/wKgZhV1wtJWADRS1AAAADrnj5qQ812.txt
                byte[] b = storageClient.download_file("group1", "M00/00/00/ajeSWGDidpeAMrh2AAZjGSgHyGM675.jpg");
    
                // 下載文件
                download(b);
            } catch (Exception e) { 
                e.printStackTrace();
            }
        }
    
        public static void download(byte[] bytesArray) { 
            FileOutputStream fos = null;
            File file;
            try { 
                // TODO 改成自己的路径
                file = new File("E:\\myFile.jpg");
                fos = new FileOutputStream(file);
                fos.write(bytesArray);
                fos.flush();
                System.out.println("成功");
            } catch (FileNotFoundException e) { 
                e.printStackTrace();
            } catch (IOException e) { 
                e.printStackTrace();
            } finally { 
                try { 
                    if (fos != null) { 
                        fos.close();
                    }
                } catch (IOException ioe) { 
                    System.out.println("出錯了");
                }
            }
        }
    }

#### 3 配置文件如下 ####

配置文件的名字：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=/app/fastdfs_document/data
    
    # 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 访问nginx的端口 改这里
    http.tracker_server_port=80
    
    #use "#include" directive to include HTTP other settiongs
    ##include http.conf

#### 4 测试 ####

![在这里插入图片描述][20210708104804499.png]  
浏览器访问，域名已模糊处理，用ip也可访问  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xoMTU1MTM2_size_16_color_FFFFFF_t_70]

[20210708105527788.png]: /images/20221005/f736a0f0826d4f2199e98fd3a442bee9.png
[20210708104804499.png]: /images/20221005/a62499c4ac7540faadeeb26ef962fbe1.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xoMTU1MTM2_size_16_color_FFFFFF_t_70]: /images/20221005/574ad924ac9e4ffa89967ac8586d682b.png