请教关于node异步循环的问题
代码很简单,如下:
var find;
data.some(function(ip) {
client.sismember(url+':ip', ip, function(err, mem) {
!mem && (find = ip);
console.log('redis:' + find);
});
console.log(find);
return find;
});
原理很简单:
- 我先some循环一个IP数组
- 如果数组中的IP不存在redis中,我就将find赋值为当前IP
- 如果循环过程中找到了IP,我就跳出循环,不再一直查询redis
结果,代码中有两个console:
- 先循环数组数据,find一直是undefined,因此不会跳出循环
- 之后执行所有redis查询结果,并重复给find复制,并打印出来
问题:
- 首先结果不是我想要的
- 效率差,我循环100条就查询100次redis
请问如何解决?
11 回复
不知所云
楼主是否需要如下两个函数?:
函数1):检查指定的IP数组是否存在于redis中,返回所有不存在于redis中的IP数组: 函数2):将指定的IP数组存放于redis中
async.js async.parallelLimit(…) 不知是否能解决你的问题
async.mapSeries将执行转成同步,可以试试
@cool-l 谢谢
@cwallow 谢谢
两个办法 要么转同步 . 要么回调函数里加上状态判断 . 建议第二种方式 .
var find;
var howdo = require('howdo');
howdo.each(data, function(index, ip, done){
if(find){
return done(null);
}
client.sismember(url+':ip', ip, function(err, mem) {
if(err){
return done(err);
}
if(!mem){
find = ip;
console.log('redis:' + find);
}
done(null);
});
}).together(function(err){
if(err){
return console.log(err);
}
console.log(find);
});
@cloudcome 谢谢
https://github.com/alsotang/async_demo 来学习一下 async