遍历 redis

nodejs遍历redis里所有数据进行

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'; //遍历游标
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') {
          //游标回到原点 则遍历结束
          return console.log('Iteration complete');
        }
        return scan();
      })
    })
}

scan();