send package to storage server @param cmd which command to send @param group_name the group name of storage server @param remote_fil

set metadata items to storage server @param group_name the group name of storage server @param remote_filename filename on storage server @param

debug display array

同步发送 http://localhost:9071/sync_send

truncate appender file to size 0 from storage server @param group_name the group name of storage server @param appender_filename the appender

释放锁 <p> true：成功释放 false：释放锁失败，也有可能是自动过期

信任所有证书

send quit command to server and close socket @param sock the Socket object

设置连接池 1.最大等待连接数 2.连接时间

HTTPS证书验证套接字工厂

decode a well-formed complete Base64 string back into an array of bytes. It must have an even multiple of 4 data characters (not counting \n), padded

下载文件

注意这里的数据只能下载很小的文件 几百k， 如果有需要下载大文件到内存中，麻烦找louxiu重新写接口 @param groupName @param filename @return

Encode an arbitrary array of bytes as Base64 printable ASCII. It will be broken into lines of 72 chars each. The last line is not terminated with a l

get boolean value from config file @param name item name in config file @param default_value the default value @return boolean value

前置判断是分块存储的，获取对应的chunkMeta @param remoteId @return @throws IOException

return connected tracker server @return connected tracker server, null for fail

根据remoteId获取数据 @param remoteId @return

get storage servers to download file @param trackerServer the tracker server @param groupName the group name of storage server @param filename

get fields total size @return fields total size

get fields total size @return fields total size

根据remoteId 获取group path @param remoteId @return

buff convert to ip address @param bs the buffer (big-endian) @param offset the start position based 0 @return ip address

get the connected socket @return the socket

@return the store path index on the storage server

query storage server to upload file @param trackerServer the tracker server @return storage server Socket object, return null if fail

query storage server to update file (delete file or set meta data) @param trackerServer the tracker server @param groupName the group name of sto

get all values from config file @param name item name in config file @return string values (array)

get file info decoded from the filename, fetch from the storage if necessary @param group_name the group name @param remote_filename the filenam

get all metadata items from storage server @param group_name the group name of storage server @param remote_filename filename on storage server

消息处理逻辑

load from properties file @param trackerServers 例如："10.0.11.245:22122,10.0.11.246:22122" server的IP和端口用冒号':'分隔

判断是否是分块 @param remoteId @return @throws IOException

判定页面边界

判定页面边界

判定页面边界

判定页面边界

判定页面边界

query storage server stat info of the group @param trackerServer the tracker server @param groupName the group name of storage server @return sto

md5 function @param source the input buffer @return md5 string

check storage socket, if null create a new connection @param group_name the group name to upload file to, can be empty @return true if create a new c

pack metadata array to string @param meta_list metadata array @return packed metadata

发送post请求 @param url @param postData @return

打印canal server解析binlog获得的实体类信息

recv file content callback function, may be called more than once when the file downloaded @param file_size file size @param data data buff @par

regenerate filename for appender file @param group_name the group name of appender file @param appender_filename the appender filename @return

延时发送消息

set fields @param bs byte array @param offset start offset

set the file type @param file_type the file type

split metadata to name value pair array @param meta_buff metadata @return name value pair array