Authored by qinchao

切换lb改为异步

... ... @@ -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;
}
... ...