Authored by qinchao

恶意ip拦截原因

... ... @@ -84,7 +84,6 @@ public class MaliciousIpMapperImpl extends InfluxDBQuery implements MaliciousIpM
ips = StringUtils.stripEnd(ips, " or ");
//取出每个ip最新的一条数据
query_cmd = query_cmd.concat("where (").concat(ips).concat(")").concat("group by ip order by time desc limit 1;");
System.out.println("查询语句:" + query_cmd );
log.info("getMaliousIpInfo query_cmd is :" + query_cmd);
QueryResult result = query(influxDBStr, query_cmd, InfluxDBContants.YOMO_MONITOR);
for (QueryResult.Result queryResult : result.getResults()) {
... ...
... ... @@ -193,13 +193,16 @@ public class MaliciousIpServiceImpl implements MaliciousIpService {
Map<String,String> awsInfo = awsIpInfo.get(mipKey);
String reasonDur = "";
if(awsInfo != null){
reasonDur = reasonDur + "aws :" + awsInfo.get("reason") + "--" + awsInfo.get("dur") +"</br>";
reasonDur += "aws: " + awsInfo.get("dur") + " -- " + awsInfo.get("reason");
}
Map<String,String> qcloudInfo = qcloudIpInfo.get(mipKey);
if(qcloudInfo != null){
reasonDur = reasonDur + "qcloud :" + qcloudInfo.get("reason") + "--" + qcloudInfo.get("dur") +"</br>";
if(reasonDur.length()>0){
reasonDur += "</br>";
}
reasonDur += "qcloud: " + qcloudInfo.get("dur")+ " -- "+ qcloudInfo.get("reason") ;
}
mip.setReasonDur(reasonDur);
mip.setReasonDur(reasonDur);
listMaliciousIp.add(mip);
}
response.setData(listMaliciousIp);
... ... @@ -311,8 +314,8 @@ public class MaliciousIpServiceImpl implements MaliciousIpService {
public BaseResponse<UpLoadError> upLoad(String[] ips) {
BaseResponse<UpLoadError> response = new BaseResponse<>();
UpLoadError error = new UpLoadError();
try{
redisWrite.setIps(ips);
try {
redisWrite.setIps(ips);
error.setStatus("0");
}catch(Exception e){
error.setStatus("1");
... ... @@ -596,7 +599,7 @@ public class MaliciousIpServiceImpl implements MaliciousIpService {
@Override
public BaseResponse<Integer> delIpRule(int id) {
try{
try {
logger.info("delIpRule id : " + id);
int result = 0;
result = malIpRuleMapper.deleteById(id);
... ...