Authored by qinchao

恶意ip管理

... ... @@ -72,7 +72,7 @@ public class MaliciousIpJob {
* 敏感接口比例大于等于99%,且敏感接口QPS大于等于100的值,暂时默认放到黑名单
*/
public void init(){
logger.info("-init job!");
/*logger.info("-init job!");
Timer timer = new Timer();
TimerTask timerTask = new TimerTask() {
@Override
... ... @@ -97,7 +97,7 @@ public class MaliciousIpJob {
logger.info(" MaliciousIpJob - init - timerTaskSms yunwei mobile is "+mobile_yunwei);
}
}; //0:代表是延迟0
timerSms.scheduleAtFixedRate(timerTaskSms, 0, 1* 30 * 1000);
timerSms.scheduleAtFixedRate(timerTaskSms, 0, 1* 30 * 1000); */
}
private void uploadMaliciousIp(){
... ...
... ... @@ -93,7 +93,7 @@ public class MaliciousIpServiceImpl implements MaliciousIpService {
* Redis String 类型
*/
//private static final String MALICIOUS_IP = "yh:mip:";
private static final String MALICIOUS_IP_SET = "yhmipset";
private static final String MALICIOUS_IP_SET = "yh:set:malicipset";
/**
* 黑名单失效时间7*24小时
... ... @@ -140,16 +140,14 @@ public class MaliciousIpServiceImpl implements MaliciousIpService {
@Override
public BaseResponse<List<MaliciousIp>> getMipsFromOpsReids(){
logger.info(" bgin get mips ");
logger.info(" mips aws redis "+(awsRedisTemplate==null?false:true));
BaseResponse<List<MaliciousIp>> response = new BaseResponse<>();
Set<String> mipKeys=null;
try{
mipKeys= awsRedisTemplate.opsForSet().members(MALICIOUS_IP_SET);
}catch (Exception e){
logger.info("获取mip member is null" );
logger.info("获取mip member is exception ",e );
}
logger.info(" get mips from redis "+mipKeys);
List<MaliciousIp> listMaliciousIp=new ArrayList<MaliciousIp>();
for(String mipKey:mipKeys){
MaliciousIp mip=new MaliciousIp();
... ...
... ... @@ -16,9 +16,9 @@
<property name="taskScheduler" ref="scheduler" />
</bean>
<bean id="maliciousIpJob" class="com.monitor.other.maliciousip.job.MaliciousIpJob"
<!-- <bean id="maliciousIpJob" class="com.monitor.other.maliciousip.job.MaliciousIpJob"
init-method="init">
</bean>
</bean>-->
<bean id="redisReadUtil" class="com.monitor.other.maliciousip.util.RedisReadUtil" />
... ...