fastdfs客户端api

/** * Copyright (C) 2008 Happy Fish / YuQing * * FastDFS Java Client may be copied only under the terms of the GNU Lesser * General Public License (LGPL). * Please visit the FastDFS Home Page http://www.csource.org/ for more detail. */ package org.csource.fastdfs; import java.io.*; import java.util.*; import java.net.*; import org.csource.common.*; /** * Storage client for 2 fields file id: group name and filename * @author Happy Fish / YuQing * @version Version 1.9 */ public class StorageClient { protected Socket trackerSocket; protected StorageServer storageServer; protected byte errno; /** * @param trackerSocket Socket of tracker server * @param storageServer Socket of storage server, can be null */ public StorageClient(Socket trackerSocket, StorageServer storageServer) { this.trackerSocket = trackerSocket; this.storageServer = storageServer; } /** * @return the error code of last call */ public byte getErrorCode() { return this.errno; } /** * upload file to storage server (by file name) * @param local_filename local filename to upload * @param file_ext_name file ext name, do not include dot(.), null to extract ext name from the local filename * @param meta_list meta info array * @return 2 elements string array if success:<br> * <ul><li>results[0]: the group name to store the file </li></ul> * <ul><li>results[1]: the new created filename</li></ul> * return null if fail */ public String[] upload_file(String local_filename, String file_ext_name, NameValuePair[] meta_list) throws IOException, Exception { final String group_name = null; return this.upload_file(group_name, local_filename, file_ext_name, meta_list); } /** * upload file to storage server (by file name) * @param group_name the group name to upload file to, can be empty * @param local_filename local filename to upload * @param file_ext_name file ext name, do not include dot(.), null to extract ext name from the local filename * @param meta_list meta info array * @return 2 elements string array if success:<br> * <ul><li>results[0]: the group name to store the file </li></ul> * <ul><li>results[1]: the new created filename</li></ul> * return null if fail */ public String[] upload_file(String group_name, String local_filename, String file_ext_name, NameValuePair[] meta_list) throws IOException, Exception { if (file_ext_name == null) { int nPos = local_filename.lastIndexOf('.'); if (nPos > 0 && local_filename.length() - nPos <= ProtoCommon.FDFS_FILE_EXT_NAME_MAX_LEN + 1) { file_ext_name = local_filename.substring(nPos+1); } } return this.do_upload_file(group_name, local_filename, null, file_ext_name, meta_list); } /** * upload file to storage server (by file buff) * @param file_buff file content/buff * @param file_ext_name file ext name, do not include dot(.) * @param meta_list meta info array * @return 2 elements string array if success:<br> * <ul><li>results[0]: the group name to store the file</li></ul> * <ul><li>results[1]: the new created filename</li></ul> * return null if fail */ public String[] upload_file(byte[] file_buff, String file_ext_name, NameValuePair[] meta_list) throws IOException, Exception { final String group_name = null; return this.do_upload_file(group_name, null, file_buff, file_ext_name, meta_list); } /** * upload file to storage server (by file buff) * @param group_name the group name to upload file to, can be empty * @param file_buff file content/buff * @param file_ext_name file ext name, do not include dot(.) * @param meta_list meta info array * @return 2 elements string array if success:<br> * <ul><li>results[0]: the group name to store the file</li></ul> * <ul><li>results[1]: the new created filename</li></ul> * return null if fail */ public String[] upload_file(String group_name, byte[] file_buff, String file_ext_name, NameValuePair[] meta_list) throws IOException, Exception { return this.do_upload_file(group_name, null, file_buff, file_ext_name, meta_list); } /** * upload file to storage server (by callback) * @param group_name the group name to upload file to, can be empty * @param file_size the file size * @param callback the write data callback object * @param file_ext_name file ext name, do not include dot(.) * @param meta_list meta info array * @return 2 elements string array if success:<br> * <ul><li>results[0]: the group name to store the file</li></ul> * <ul><li>results[1]: the new created filename</li></ul> * return null if fail */ public String[] upload_file(String group_name, long file_size, UploadCallback callback, String file_ext_name, NameValuePair[] meta_list) throws IOException, Exception { byte[] header; byte[] ext_name_bs; String new_group_name; String remote_filename; boolean bNewConnection; bNewConnection = this.newWritableStorageConnection(group_name); try { byte[] meta_buff; byte[] sizeBytes; byte[] hexLenBytes; long fileBytes; FileInputStream fis; if (meta_list == null) { meta_buff = new byte[0]; } else { meta_buff = ProtoCommon.pack_metadata(meta_list).getBytes(ClientGlobal.g_charset); } sizeBytes = new byte[1 + 2 * ProtoCommon.TRACKER_PROTO_PKG_LEN_SIZE]; ext_name_bs = new byte[ProtoCommon.FDFS_FILE_EXT_NAME_MAX_LEN]; Arrays.fill(ext_name_bs, (byte)0); if (file_ext_name != null && file_ext_name.length() > 0) { byte[] bs = file_ext_name.getBytes(); int ext_name_len = bs.length; if (ext_name_len > ProtoCommon.FDFS_FILE_EXT_NAME_MAX_LEN) { ext_name_len = ProtoCommon.FDFS_FILE_EXT_NAME_MAX_LEN; } System.arraycopy(bs, 0, ext_name_bs, 0, ext_name_len); } Arrays.fill(sizeBytes, (byte)0); sizeBytes[0] = (byte)this.storageServer.getStorePathIndex(); hexLenBytes = ProtoCommon.long2buff(meta_buff.length); System.arraycopy(hexLenBytes, 0, sizeBytes, 1, hexLenBytes.length); hexLenBytes = ProtoCommon.long2buff(file_size); System.arraycopy(hexLenBytes, 0, sizeBytes, 1 + ProtoCommon.TRACKER_PROTO_PKG_LEN_SIZE, hexLenBytes.length); header = ProtoCommon.packHeader(ProtoCommon.STORAGE_PROTO_CMD_UPLOAD_FILE, 1 + 2 * ProtoCommon.TRACKER_PROTO_PKG_LEN_SIZE + ProtoCommon.FDFS_FILE_EXT_NAME_MAX_LEN + meta_buff.length + file_size, (byte)0); OutputStream out = this.storageServer.getOutputStream(); byte[] wholePkg = new byte[header.length + sizeBytes.length + ext_name_bs.length + meta_buff.length]; System.arraycopy(header, 0, wholePkg, 0, header.length); System.arraycopy(sizeBytes, 0, wholePkg, header.length, sizeBytes.length); System.arraycopy(ext_name_bs, 0, wholePkg, header.length+sizeBytes.length, ext_name_bs.length); if (meta_buff.length > 0) { System.arraycopy(meta_buff, 0, wholePkg, header.length+sizeBytes.length+ext_name_bs.length, meta_buff.length); } out.write(wholePkg); if ((this.errno=(byte)callback.send(out)) != 0) { return null; } ProtoCommon.RecvPackageInfo pkgInfo = ProtoCommon.recvPackage(this.storageServer.getInputStream(), ProtoCommon.STORAGE_PROTO_CMD_RESP, -1); this.errno = pkgInfo.errno; if (pkgInfo.errno != 0) { return null; } if (pkgInfo.body.length <= ProtoCommon.FDFS_GROUP_NAME_MAX_LEN) { throw new Exception("body length: " + pkgInfo.body.length + " <= " + ProtoCommon.FDFS_GROUP_NAME_MAX_LEN); } new_group_name = new String(pkgInfo.body, 0, ProtoCommon.FDFS_GROUP_NAME_MAX_LEN).trim(); remote_filename = new String(pkgInfo.body, ProtoCommon.FDFS_GROUP_NAME_MAX_LEN, pkgInfo.body.length - ProtoCommon.FDFS_GROUP_NAME_MAX_LEN); String[] results = new String[2]; results[0] = new_group_name; results[1] =