diff --git a/monitor-service-switch/src/main/java/com/monitor/switchs/NginxSwitchCtrl.java b/monitor-service-switch/src/main/java/com/monitor/switchs/NginxSwitchCtrl.java index 5090703..a2ac686 100644 --- a/monitor-service-switch/src/main/java/com/monitor/switchs/NginxSwitchCtrl.java +++ b/monitor-service-switch/src/main/java/com/monitor/switchs/NginxSwitchCtrl.java @@ -60,9 +60,9 @@ public class NginxSwitchCtrl { Set<String> nowIDset=switchLbResponseMap.keySet(); List<String> ids=Lists.newArrayList(rtnID.split(",")); if(nowIDset.containsAll(ids)){ - for(String id:ids){ + /*for(String id:ids){ switchLbResponseMap.remove(id); - } + }*/ return new BaseResponse(); } return new BaseResponse(201,"not finished"); @@ -95,17 +95,18 @@ public class NginxSwitchCtrl { Map<String,List<String>> innerListenerMap=getLbListerner(true); Map<String,List<String>> outerListenerMap=getLbListerner(false); String ts=String.valueOf(new Date().getTime()); - String rtnID=""; + StringBuilder rtnIDsb=new StringBuilder(); for(LbModel lb:lbList){ - if(rtnID.length()>0){ - rtnID += ","; + String rtnID=ts+"-"+valueCount.getAndIncrement(); + if(rtnIDsb.length()>0){ + rtnIDsb.append(","); } - rtnID += (ts+"-"+valueCount.getAndIncrement()); + rtnIDsb.append(rtnID); //beginSwitchLb(rtnID,targetMap,lb,innerListenerMap,outerListenerMap); startRunAsySwitchLb(rtnID,targetMap,lb,innerListenerMap,outerListenerMap); } BaseResponse response= new BaseResponse(); - response.setData(rtnID); + response.setData(rtnIDsb.toString()); return response; }