Nodejs Client for FastDFS

FastDFS 是分布式文件存儲系統。這個項目是FastDFS的NodeJS客戶端，用來與FastDFS Server進行交互，進行文件的相關操作。我測試過的server版本是4.0.6。

github

https://github.com/ymyang/fdfs

安裝

npm install fdfs 

使用

1.  
   var fdfs = require('fdfs');
2.  
    
3.  
   var fdfs = new FdfsClient({
4.  
   // tracker servers
5.  
   trackers: [
6.  
   {
7.  
   host: 'tracker.fastdfs.com',
8.  
   port: 22122
9.  
   }
10.  
    ],
11.  
    // 默認超時時間10s
12.  
    timeout: 10000,
13.  
    // 默認后綴
14.  
    // 當獲取不到文件后綴時使用
15.  
    defaultExt: 'txt',
16.  
    // charset默認utf8
17.  
    charset: 'utf8'
18.  
    });
19.  
     

以上是一些基本配置，你還可以自定義你的日志輸出工具，默認是使用console 例如你要使用debug作為你的日志輸出工具，你可以這么做：

1.  
   var debug = require('debug')('fdfs');
2.  
   var fdfs = new FdfsClient({
3.  
   // tracker servers
4.  
   trackers: [
5.  
   {
6.  
   host: 'tracker.fastdfs.com',
7.  
   port: 22122
8.  
   }
9.  
   ],
10.  
    logger: {
11.  
    log: debug
12.  
    }
13.  
    });
14.  
     

上傳文件

注：以下fileId為group + '/' + filename，以下的所有操作使用的fileId都是一樣

通過本地文件名上傳

1.  
   fdfs.upload( 'e:/shou.jpg').then(function(fileId) {
2.  
   // fileId 為 group + '/' + filename
3.  
   console.log(fileId);
4.  
   }). catch(function(err) {
5.  
   console.error(err);
6.  
   );

上傳Buffer

1.  
   var fs = require('fs');
2.  
    
3.  
   // 注意此處的buffer獲取方式只為演示功能，實際不會這么去構建buffer
4.  
   var buffer = fs.readFileSync('test.gif');
5.  
   fdfs.upload(buffer).then(function(fileId) {
6.  
   // fileId 為 group + '/' + filename
7.  
   console.log(fileId);
8.  
   }).catch(function(err) {
9.  
   console.error(err);
10.  
    );
11.  
     

ReadableStream

1.  
   var fs = require('fs');
2.  
    
3.  
   var rs = fs.createReadStream('test.gif');
4.  
   fdfs.upload(rs).then(function(fileId) {
5.  
   // fileId 為 group + '/' + filename
6.  
   console.log(fileId);
7.  
   }).catch(function(err) {
8.  
   console.error(err);
9.  
   );
10.  
     

其他一些options，作為第2個參數傳入

1.  
   fdfs.upload( 'test.gif', {
2.  
   // 上傳方法 [upload, uploadAppender, append, modify], 默認為upload
3.  
   method: 'upload',
4.  
   // 指定文件存儲的group，不指定則由tracker server分配
5.  
   group: 'group1',
6.  
   // method為append或modify指定追加的源文件
7.  
   fileId: 'group1/M00/00/0F/wKgBeFXlZJuAdsBZAAPm5H9JxDA153.jpg',
8.  
   // file bytes, file參數為ReadableStream時必須指定
9.  
   size: 1024,
10.  
    // method為modify指定追加的源文件的起始點
11.  
    offset: 10240,
12.  
    // 上傳文件的后綴，不指定則獲取file參數的后綴，不含(.)
13.  
    ext: 'jpg'
14.  
    }). then(function(fileId) {
15.  
    // fileId 為 group + '/' + filename
16.  
    console.log(fileId);
17.  
    }). catch(function(err) {
18.  
    console.error(err);
19.  
    );

下載文件

下載到本地

1.  
   fdfs.download(fileId, 'test_download.gif').then(function() {
2.  
   // 下載完成
3.  
    
4.  
   }). catch(function(err) {
5.  
   console.error(err);
6.  
   );

下載到WritableStream

1.  
   var fs = require('fs');
2.  
   var ws = fs.createWritableStream('test_download.gif');
3.  
   fdfs.download(fileId, ws).then(function() {
4.  
   // 下載完成
5.  
    
6.  
   }).catch(function(err) {
7.  
   console.error(err);
8.  
   );
9.  
    

下載文件片段

1.  
   fdfs.download(fileId, {
2.  
   target: 'test_download.part',
3.  
   offset: 5,
4.  
   bytes: 5
5.  
   }). then(function() {
6.  
   // 下載完成
7.  
    
8.  
   }). catch(function(err) {
9.  
   console.error(err);
10.  
    );

刪除文件

1.  
   fdfs.del(fileId). then(function() {
2.  
   // 刪除成功
3.  
    
4.  
   }). catch(function(err) {
5.  
   console.error(err);
6.  
   );

獲取文件信息

1.  
   fdfs.getFileInfo(fileId). then(function(fileInfo) {
2.  
   // fileInfo有4個屬性
3.  
   // {
4.  
   // // 文件大小
5.  
   // size:
6.  
   // // 文件創建的時間戳，單位為秒
7.  
   // timestamp:
8.  
   // // 校驗和
9.  
   // crc32:
10.  
    // // 最初上傳到的storage server的ip
11.  
    // addr:
12.  
    // }
13.  
    console.log(fileInfo);
14.  
    }). catch(function(err) {
15.  
    console.error(err);
16.  
    );

文件的Meta Data

設置Meta Data

flag字段如果不傳則默認是O

1.  
   // flag 'O' for overwrite all old metadata (default) 'M' for merge, insert when the meta item not exist, otherwise update it
2.  
   fdfs.setMetaData(fileId, metaData, flag). then(function() {
3.  
   // 設置成功
4.  
    
5.  
   }). catch(function(err) {
6.  
   console.error(err);
7.  
   );

獲取Meta Data

1.  
   fdfs.getMetaData(fileId). then(function(metaData) {
2.  
   console.log(metaData);
3.  
   }). catch(function(err) {
4.  
   console.error(err);
5.  
   );

group信息

1.  
   fdfs.listGroups(). then(function(groups) {
2.  
   console.log(groups);
3.  
   }). catch(function(err) {
4.  
   console.error(err);
5.  
   );

storage信息

 

1.  
   fdfs.listStorages(‘group1’). then(function(storages) {
2.  
   console.log(storages);
3.  
   }). catch(function(err) {
4.  
   console.error(err);
5.