...
|
...
|
@@ -27,6 +27,7 @@ module.exports = (req, res, next) => { |
|
|
|
|
|
if (remoteIp.indexOf(',') > 0) {
|
|
|
let arr = remoteIp.split(',');
|
|
|
|
|
|
remoteIp = arr[0];
|
|
|
}
|
|
|
|
...
|
...
|
@@ -59,18 +60,18 @@ module.exports = (req, res, next) => { |
|
|
res.status(403).end();
|
|
|
} else {
|
|
|
cache.incrAsync(key, 1); // qps + 1
|
|
|
next();
|
|
|
return next();
|
|
|
}
|
|
|
} else {
|
|
|
cache.setAsync(key, 1, 60); // 设置key,1s失效
|
|
|
next();
|
|
|
return next();
|
|
|
}
|
|
|
}).catch(e => {
|
|
|
logger.error(`request limiter get key[${key}] from cache error.`, e);
|
|
|
next();
|
|
|
return next();
|
|
|
});
|
|
|
} else {
|
|
|
next();
|
|
|
return next();
|
|
|
}
|
|
|
|
|
|
|
...
|
...
|
|