nodejs遍歷redis里所有數(shù)據(jù)進(jìn)行

var redis = require('redis');
var async = require('async')
var client = redis.createClient({
  "host": "127.0.0.1",
  "port": "6379",
  "db": 0,
  "password": ""
});
var cursor = '0'; //遍歷游標(biāo)
function scan() {
  client.scan(
    cursor,
    'MATCH', 'string:url_info:short_id:*',
    'COUNT', '1000',  
    function (err, res) {
      if (err) throw err;
      cursor = res[0];
      var keys = res[1];
      async.mapLimit(keys,50,function(key,done){
        client.get(key, function (error, result) {
              //xxxx 此處添加邏輯
              done()
         })
      },function(err,result){
        if (cursor === '0') {
          //游標(biāo)回到原點(diǎn) 則遍歷結(jié)束
          return console.log('Iteration complete');
        }
        return scan();
      })
    })
}

scan();