FastDFS之java客户端使用

清疚 2022-08-05 01:00 203阅读 0赞

为了方便应用程序的访问FastDFS，官网提供了[fastdfs-client-java][]，以便更好的与应用程序结合使用。

下载[fastdfs-client-java源码][fastdfs-client-java]添加到项目工程里面，添加配置文件：fdfs\_client.conf

connect_timeout=3
    network_timeout = 60
    charset = ISO8859-1
    http.tracker_http_port = 8080
    http.anti_steal_token = no
    http.secret_key = FastDFS1234567890
    tracker_server = 192.168.18.43:22122

测试代码：

package cn.slimsmart.fastdfs;
    
    import java.io.File;
    import java.io.FileInputStream;
    import java.io.FileOutputStream;
    import java.io.IOException;
    import java.io.InputStream;
    import java.util.Arrays;
    
    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;
    
    
    /**
     *  基本操作
     */
    public class FastDFSTest {
    
    	/**
    	 * @param args
    	 * @throws Exception 
    	 */
    	public static void main(String[] args) throws Exception {
    		//加载配置文件的方式
    		String configFileName = "src/main/resources/fdfs_client.conf";  
            try {  
                ClientGlobal.init(configFileName);  
            }catch(Exception e){
            	e.printStackTrace();
            }
            
            /*
             * 也可以使用代码设置配置
             // 连接超时的时限
            ClientGlobal.setG_connect_timeout(2);
            // 网络超时的时限，单位为秒
            ClientGlobal.setG_network_timeout(30);
            ClientGlobal.setG_anti_steal_token(false);
            // 字符集
            ClientGlobal.setG_charset("UTF-8");
            ClientGlobal.setG_secret_key(null);
            // HTTP访问服务的端口号
            ClientGlobal.setG_tracker_http_port(8088);
            // Tracker服务器列表
            InetSocketAddress[] tracker_servers = new InetSocketAddress[1];
            tracker_servers[0] = new InetSocketAddress("192.168.18.43", 22122);
            ClientGlobal.setG_tracker_group(new TrackerGroup(tracker_servers));
             */
           File file = new File("src/main/resources/test.jpg");
           //返回储存路径:group1 M00/00/00/wKhuW1Vmj6KAZ09pAAC9przUxEk788.jpg
           String[] files =  uploadFile(file, "test.jpg", file.length());
           System.out.println(Arrays.asList(files));
          
          //下载文件
          downloadFile(files[0],files[1]);
          //查看文件信息
          getFileInfo(files[0],files[1]);
          getFileMate(files[0],files[1]);
          deleteFile(files[0],files[1]);
    	}
    
    	/**
    	 * 上传文件
    	 */
    	public static String[] uploadFile(File file, String uploadFileName, long fileLength) throws IOException {
    		 System.out.println("上传文件=======================");
    		byte[] fileBuff = getFileBuffer(new FileInputStream(file), fileLength);
    		String[] files = null;
    		String fileExtName = "";
    		if (uploadFileName.contains(".")) {
    			fileExtName = uploadFileName.substring(uploadFileName.lastIndexOf(".") + 1);
    		} else {
    			System.out.println("Fail to upload file, because the format of filename is illegal.");
    			return null;
    		}
    
    		// 建立连接
    		TrackerClient tracker = new TrackerClient();
    		TrackerServer trackerServer = tracker.getConnection();
    		StorageServer storageServer = null;
    		StorageClient client = new StorageClient(trackerServer, storageServer);
    
    		// 设置元信息
    		NameValuePair[] metaList = new NameValuePair[3];
    		metaList[0] = new NameValuePair("fileName", uploadFileName);
    		metaList[1] = new NameValuePair("fileExtName", fileExtName);
    		metaList[2] = new NameValuePair("fileLength", String.valueOf(fileLength));
    
    		// 上传文件
    		try {
    			files = client.upload_file(fileBuff, fileExtName, metaList);
    		} catch (Exception e) {
    			System.out.println("Upload file \"" + uploadFileName + "\"fails");
    		}
    		trackerServer.close();
    		return files;
    	}
    	private static byte[] getFileBuffer(InputStream inStream, long fileLength) throws IOException {
    
    		byte[] buffer = new byte[256 * 1024];
    		byte[] fileBuffer = new byte[(int) fileLength];
    
    		int count = 0;
    		int length = 0;
    
    		while ((length = inStream.read(buffer)) != -1) {
    			for (int i = 0; i < length; ++i) {
    				fileBuffer[count + i] = buffer[i];
    			}
    			count += length;
    		}
    		return fileBuffer;
    	}
    	
    	//下载文件
    	public static void downloadFile(String groupName,String filepath) throws Exception{
    		 System.out.println("下载文件=======================");
    		 TrackerClient tracker = new TrackerClient();
             TrackerServer trackerServer = tracker.getConnection();
             StorageServer storageServer = null;
    
             StorageClient storageClient = new StorageClient(trackerServer, storageServer);
             byte[] b = storageClient.download_file(groupName, filepath);
             System.out.println("文件大小:"+b.length);
             String fileName = "src/main/resources/test1.jpg";  
             FileOutputStream out = new FileOutputStream(fileName);
             out.write(b);
             out.flush();
             out.close();
    	}
    	
    	//查看文件信息
    	public static void getFileInfo(String groupName,String filepath) throws Exception{
    		System.out.println("获取文件信息=======================");
    	    TrackerClient tracker = new TrackerClient();
            TrackerServer trackerServer = tracker.getConnection();
            StorageServer storageServer = null;
    
            StorageClient storageClient = new StorageClient(trackerServer, storageServer);
            FileInfo fi = storageClient.get_file_info(groupName,filepath);
            System.out.println("所在服务器地址:"+fi.getSourceIpAddr());
            System.out.println("文件大小:"+fi.getFileSize());
            System.out.println("文件创建时间:"+fi.getCreateTimestamp());
            System.out.println("文件CRC32 signature:"+fi.getCrc32());
    	}
    	
    	public static void getFileMate(String groupName,String filepath) throws Exception{
    		System.out.println("获取文件Mate=======================");
    		TrackerClient tracker = new TrackerClient();
            TrackerServer trackerServer = tracker.getConnection();
            StorageServer storageServer = null;
    
            StorageClient storageClient = new StorageClient(trackerServer, storageServer);
            NameValuePair nvps[] = storageClient.get_metadata(groupName,filepath);
            for (NameValuePair nvp : nvps) {
                    System.out.println(nvp.getName() + ":" + nvp.getValue());
            }
    	}
    	
    	public static void deleteFile(String groupName,String filepath) throws Exception{
    		System.out.println("删除文件=======================");
            TrackerClient tracker = new TrackerClient();
            TrackerServer trackerServer = tracker.getConnection();
            StorageServer storageServer = null;
            StorageClient storageClient = new StorageClient(trackerServer, storageServer);
            int i = storageClient.delete_file(groupName, filepath);
            System.out.println(i == 0 ? "删除成功" : "删除失败:" + i);
    	}
    }

本实例中我们使用了StorageClient完成文件的基本操作，除此外还有一个实现类 StorageClient1，这里就不演示了。

上面我们是通过字节的方式上传文件，也可以使用流的方式上传文件，请参考：[以流的方式上传文件的客户端代码][Link 1]

另外，还有一客户端[FastdfsClient][]，基于官方[fastdfs-client-java][]客户端基础上，实现了连接池、健康检查等功能。大家可以尝试一下。

[fastdfs-client-java]: https://github.com/happyfish100/fastdfs-client-java
[Link 1]: http://blog.csdn.net/poechant/article/details/6987427
[FastdfsClient]: https://github.com/baoming/FastdfsClient