|
|
@@ -4,6 +4,7 @@ import cn.hutool.core.bean.BeanUtil;
|
|
|
import cn.hutool.core.collection.CollUtil;
|
|
|
import cn.hutool.core.io.FileUtil;
|
|
|
import cn.hutool.core.io.file.FileNameUtil;
|
|
|
+import cn.hutool.core.thread.ThreadUtil;
|
|
|
import cn.hutool.core.util.StrUtil;
|
|
|
import cn.hutool.core.util.ZipUtil;
|
|
|
import cn.hutool.extra.qrcode.QrCodeUtil;
|
|
|
@@ -212,8 +213,11 @@ public class BuildSceneServiceImpl implements IBuildSceneService {
|
|
|
if(env.equals("gn") && Objects.nonNull(maxRate) && maxRate > 50){
|
|
|
//发送mq，就进行计算
|
|
|
mqProducer.sendByWorkQueue(queueModelingCall.concat("-128G"), message);
|
|
|
+ ThreadUtil.sleep(2000L);
|
|
|
int mqNum = rabbitMqProducer.getMessageCount(queueModelingCall.concat("-128G"));
|
|
|
+ log.info("128G队列排队数:{}", mqNum);
|
|
|
if(mqNum > 0){
|
|
|
+ log.info("启动128G弹性伸缩");
|
|
|
String result = scalingService.createEcs(scalingExtendAri);
|
|
|
log.info("createEcs-result:{}", result);
|
|
|
}
|
dengsixing