分享個(gè)帶連接池的fastdfs Java client

mineral_cu

地址 https://github.com/baoming/FastdfsClient


-Changelog

修改和增加了連接池健康檢查的feature.
增加了上傳slave文件的api.

友情提示，

-沒有嚴(yán)格在生產(chǎn)環(huán)境使用，請(qǐng)多做測(cè)試，有問題可以在github給我發(fā)issue.
-沒有官方fishman的api那么全，只提供upload和delete,set/get meta的幾個(gè)常用方法.


并不是我的原創(chuàng)，我也是fork github上別人的項(xiàng)目改的。因不知道原作者怎么聯(lián)系，所以在這里先感謝他 mikesu （https://github.com/mikesu/FastdfsClient），
要是他在這論壇里，或者有人告訴他一聲，加個(gè)開源License就更好了。

ccvcd

支持支持支持，，

yangquanwa

不錯(cuò)，不錯(cuò)，我下下來用了哈，穩(wěn)定性多好的，只是感覺樓主好像是socket鏈接是單線，并發(fā)效率不太高，不過任然要感謝樓主提供的資源

lanfen100

回復(fù) 1# mineral_cu


    你好 ， 在么 ， 關(guān)于這個(gè)有個(gè)問題想請(qǐng)教，不知道怎么聯(lián)系到你~
    這邊測(cè)試的時(shí)候， 在
if(dataLength%StorageInfo.BYTE_SIZE!=0){
                                throw new IOException("recv body length: " + data.length + " is not correct");
                        }
  這個(gè)部分會(huì)拋出異常， BYTE_SIZE 您這邊定義的600  得到的是612 �。。�


    public class StorageInfoCmd extends AbstractCmd<List<StorageInfo>> {

        @Override
        public Result<List<StorageInfo>> exec(Socket socket) throws IOException {
                request(socket.getOutputStream());
                Response response = response(socket.getInputStream());
                if(response.isSuccess()){
                        byte[] data = response.getData();
                        int dataLength = data.length;
                        if(dataLength%StorageInfo.BYTE_SIZE!=0){
                                throw new IOException("recv body length: " + data.length + " is not correct");
                        }
                        List<StorageInfo> storageInfos = new ArrayList<StorageInfo>();
                        int offset = 0;
                        while(offset<dataLength){
                                StorageInfo storageInfo = new StorageInfo(data,offset);
                                storageInfos.add(storageInfo);
                                offset += StorageInfo.BYTE_SIZE;
                        }
                        return new Result<List<StorageInfo>>(response.getCode(), storageInfos);
                }else{
                        return new Result<List<StorageInfo>>(response.getCode(), "Error");
                }
        }

fennykk

回復(fù) 4# lanfen100


    確實(shí)612，用612沒問題。

guoshenghang

public class StorageInfoCmd extends AbstractCmd<List<StorageInfo>> {

        @Override
        public Result<List<StorageInfo>> exec(Socket socket) throws IOException {
                request(socket.getOutputStream());
                Response response = response(socket.getInputStream());
                if(response.isSuccess()){
                        byte[] data = response.getData();
                        int dataLength = data.length;  --我這邊取得是97
                        if(dataLength%StorageInfo.BYTE_SIZE!=0){  --BYTE_SIZE定義的是105
                                throw new IOException("recv body length: " + data.length + " is not correct");
                        }
                        List<StorageInfo> storageInfos = new ArrayList<StorageInfo>();
                        int offset = 0;
                        while(offset<dataLength){
                                StorageInfo storageInfo = new StorageInfo(data,offset);
                                storageInfos.add(storageInfo);
                                offset += StorageInfo.BYTE_SIZE;
                        }
                        return new Result<List<StorageInfo>>(response.getCode(), storageInfos);
                }else{
                        return new Result<List<StorageInfo>>(response.getCode(), "Error");
                }
        }

另外我把SIZE改成97 后面解析會(huì)報(bào)數(shù)組越界

poolhe1987

這個(gè)連接池能支持多個(gè)tracker嗎？

wxdh1987

我覺得這樣不太好，相當(dāng)于廢棄了官方的底層的tcp協(xié)議，而是copy了它的源碼（將各種tcp協(xié)議抽象了cmd）。假設(shè)協(xié)議修改或者fastdfs做了修改以后（當(dāng)然不太可能），自己的東西就全部都要修改了。我的建議是，底層通信還是使用它的jar包提供的api來完成，因?yàn)閖ar和fastdfs畢竟是同步的。我們只要在jar上在封裝一層，比如建立自己的tracker連接池，storage連接池。維護(hù)好這些就可以了，真正的上傳下載還是交給底層來做、

zhoujianqian

請(qǐng)問一下，能增加通過字節(jié)流上傳文件的方法嗎，目前只有通過File類型上傳文件的方法，這樣限制比較多

zhoujianqian

這個(gè)連接池效率怎么樣呢？相對(duì)于FastDFS的Java客戶端來說