亚洲av成人无遮挡网站在线观看,少妇性bbb搡bbb爽爽爽,亚洲av日韩精品久久久久久,兔费看少妇性l交大片免费,无码少妇一区二区三区

Chinaunix

標題: 分享個帶連接池的fastdfs Java client [打印本頁]

作者: mineral_cu 時間: 2014-06-30 22:35
標題: 分享個帶連接池的fastdfs Java client

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

-Changelog

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

友情提示，

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

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

作者: ccvcd 時間: 2014-08-20 12:24
支持支持支持，，

作者: yangquanwa 時間: 2014-08-27 08:48
不錯，不錯，我下下來用了哈，穩(wěn)定性多好的，只是感覺樓主好像是socket鏈接是單線，并發(fā)效率不太高，不過任然要感謝樓主提供的資源

作者: lanfen100 時間: 2015-04-27 14:22
回復 1# mineral_cu

你好，在么，關于這個有個問題想請教，不知道怎么聯(lián)系到你~
這邊測試的時候，在
if(dataLength%StorageInfo.BYTE_SIZE!=0){
throw new IOException("recv body length: " + data.length + " is not correct");
}
這個部分會拋出異常， 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 時間: 2015-05-13 15:54
回復 4# lanfen100

確實612，用612沒問題。

作者: guoshenghang 時間: 2015-08-21 10:35
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 后面解析會報數(shù)組越界

作者: poolhe1987 時間: 2015-09-07 10:18
這個連接池能支持多個tracker嗎？

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

作者: zhoujianqian 時間: 2017-08-16 15:23
請問一下，能增加通過字節(jié)流上傳文件的方法嗎，目前只有通過File類型上傳文件的方法，這樣限制比較多

作者: zhoujianqian 時間: 2017-08-16 15:23
這個連接池效率怎么樣呢？相對于FastDFS的Java客戶端來說

作者: ccfish86 時間: 2017-10-26 14:43

zhoujianqian 發(fā)表于 2017-08-16 15:23
請問一下，能增加通過字節(jié)流上傳文件的方法嗎，目前只有通過File類型上傳文件的方法，這樣限制比較多

關于上傳File或字節(jié)流的問題，我改過一版，生產環(huán)境在用，用連接池。唯一問題是功能沒官方的支持的全，當然有能力的可以加（我加過）
https://github.com/ccfish86/FastdfsClient

作者: ccfish86 時間: 2017-10-27 09:55
這論壇要黃了嗎？為什么回的帖子看不到，都兩天多了。

歡迎光臨 Chinaunix (http://72891.cn/)