|
|
package com.monitor.other.maliciousip.job;
|
|
|
|
|
|
import com.monitor.common.service.AlarmMsgService;
|
|
|
import com.monitor.other.maliciousip.util.RedisDataByApiUtil;
|
|
|
import com.util.GetUsersInfoUtil;
|
|
|
import com.yoho.core.config.ConfigReader;
|
|
|
import org.slf4j.Logger;
|
|
|
import org.slf4j.LoggerFactory;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.beans.factory.annotation.Qualifier;
|
|
|
|
|
|
import java.util.concurrent.atomic.AtomicInteger;
|
|
|
|
|
|
public class MaliciousIpJob {
|
|
|
|
|
|
/**
|
|
|
* 日志接口
|
|
|
*/
|
|
|
private Logger logger = LoggerFactory.getLogger("banIPLogger");
|
|
|
//private Logger logger = LoggerFactory.getLogger("banIPLogger");
|
|
|
|
|
|
/*@Autowired
|
|
|
private RedisReadUtil redisRead;*/
|
...
|
...
|
@@ -30,27 +25,27 @@ public class MaliciousIpJob { |
|
|
/**
|
|
|
* 如果从redis中读取数据,默认取2s的数据
|
|
|
*/
|
|
|
private static final String TIME_DIMENSION_SECONDS_KEY = "2";
|
|
|
//private static final String TIME_DIMENSION_SECONDS_KEY = "2";
|
|
|
|
|
|
@Autowired
|
|
|
public AlarmMsgService alarmMsgService;
|
|
|
/* @Autowired
|
|
|
public AlarmMsgService alarmMsgService;*/
|
|
|
|
|
|
@Autowired
|
|
|
/*@Autowired
|
|
|
@Qualifier("core-config-reader")
|
|
|
private ConfigReader configReader;
|
|
|
private ConfigReader configReader;*/
|
|
|
|
|
|
private AtomicInteger errorCount = new AtomicInteger();
|
|
|
//private AtomicInteger errorCount = new AtomicInteger();
|
|
|
|
|
|
/**
|
|
|
* 根据报警组名称取成员的手机号码
|
|
|
*/
|
|
|
@Autowired
|
|
|
private GetUsersInfoUtil getUsersInfoUtil;
|
|
|
/*@Autowired
|
|
|
private GetUsersInfoUtil getUsersInfoUtil;*/
|
|
|
|
|
|
/**
|
|
|
* 成员手机号码集合
|
|
|
*/
|
|
|
private String mobile_yunwei;
|
|
|
//private String mobile_yunwei;
|
|
|
|
|
|
/**
|
|
|
* 敏感接口比例大于等于99%,且敏感接口QPS大于等于100的值,暂时默认放到黑名单
|
...
|
...
|
|