WeBASE-Node-Manager-master.zip

/** * Copyright 2014-2021 the original author or authors. * * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except * in compliance with the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software distributed under the License * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express * or implied. See the License for the specific language governing permissions and limitations under * the License. */ package com.webank.webase.node.mgr.front; import com.webank.webase.node.mgr.base.code.ConstantCode; import com.webank.webase.node.mgr.base.enums.DataStatus; import com.webank.webase.node.mgr.base.enums.FrontStatusEnum; import com.webank.webase.node.mgr.base.enums.GroupStatus; import com.webank.webase.node.mgr.base.enums.GroupType; import com.webank.webase.node.mgr.base.enums.HostStatusEnum; import com.webank.webase.node.mgr.base.enums.OptionType; import com.webank.webase.node.mgr.base.enums.RunTypeEnum; import com.webank.webase.node.mgr.base.enums.ScpTypeEnum; import com.webank.webase.node.mgr.base.exception.NodeMgrException; import com.webank.webase.node.mgr.config.properties.ConstantProperties; import com.webank.webase.node.mgr.config.properties.VersionProperties; import com.webank.webase.node.mgr.tools.CertTools; import com.webank.webase.node.mgr.tools.JsonTools; import com.webank.webase.node.mgr.tools.NodeMgrTools; import com.webank.webase.node.mgr.tools.NumberUtil; import com.webank.webase.node.mgr.tools.ProgressTools; import com.webank.webase.node.mgr.tools.ThymeleafUtil; import com.webank.webase.node.mgr.tools.cmd.ExecuteResult; import com.webank.webase.node.mgr.deploy.chain.ChainService; import com.webank.webase.node.mgr.deploy.entity.DeployNodeInfo; import com.webank.webase.node.mgr.deploy.entity.NodeConfig; import com.webank.webase.node.mgr.deploy.entity.TbAgency; import com.webank.webase.node.mgr.deploy.entity.TbChain; import com.webank.webase.node.mgr.deploy.entity.TbHost; import com.webank.webase.node.mgr.deploy.mapper.TbChainMapper; import com.webank.webase.node.mgr.deploy.mapper.TbHostMapper; import com.webank.webase.node.mgr.deploy.service.AgencyService; import com.webank.webase.node.mgr.deploy.service.AnsibleService; import com.webank.webase.node.mgr.deploy.service.DeployShellService; import com.webank.webase.node.mgr.deploy.service.DockerCommandService; import com.webank.webase.node.mgr.deploy.service.HostService; import com.webank.webase.node.mgr.deploy.service.PathService; import com.webank.webase.node.mgr.front.entity.FrontInfo; import com.webank.webase.node.mgr.front.entity.FrontNodeConfig; import com.webank.webase.node.mgr.front.entity.FrontParam; import com.webank.webase.node.mgr.front.entity.TbFront; import com.webank.webase.node.mgr.frontgroupmap.FrontGroupMapCache; import com.webank.webase.node.mgr.frontgroupmap.FrontGroupMapMapper; import com.webank.webase.node.mgr.frontgroupmap.FrontGroupMapService; import com.webank.webase.node.mgr.frontgroupmap.entity.TbFrontGroupMap; import com.webank.webase.node.mgr.front.frontinterface.FrontInterfaceService; import com.webank.webase.node.mgr.group.GroupService; import com.webank.webase.node.mgr.group.entity.TbGroup; import com.webank.webase.node.mgr.node.NodeMapper; import com.webank.webase.node.mgr.node.NodeService; import com.webank.webase.node.mgr.node.entity.NodeParam; import com.webank.webase.node.mgr.node.entity.PeerInfo; import com.webank.webase.node.mgr.node.entity.TbNode; import com.webank.webase.node.mgr.scheduler.ResetGroupListTask; import java.io.IOException; import java.nio.file.Files; import java.nio.file.Path; import java.time.Duration; import java.time.Instant; import java.time.LocalDateTime; import java.util.ArrayList; import java.util.Arrays; import java.util.HashMap; import java.util.HashSet; import java.util.List; import java.util.Map; import java.util.Objects; import java.util.Optional; import java.util.Set; import java.util.concurrent.CountDownLatch; import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicInteger; import java.util.stream.Collectors; import lombok.extern.log4j.Log4j2; import org.apache.commons.collections4.CollectionUtils; import org.apache.commons.collections4.map.HashedMap; import org.apache.commons.io.FileUtils; import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.tuple.Pair; import org.apache.logging.log4j.Level; import org.fisco.bcos.sdk.client.protocol.response.NodeInfo.NodeInformation; import org.fisco.bcos.sdk.client.protocol.response.SyncStatus.SyncStatusInfo; import org.fisco.bcos.sdk.crypto.CryptoSuite; import org.fisco.bcos.sdk.model.CryptoType; import org.fisco.bcos.sdk.model.NodeVersion.ClientVersion; import org.springframework.aop.framework.AopContext; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Propagation; import org.springframework.transaction.annotation.Transactional; /** * service of web3. */ @Log4j2 @Service public class FrontService { @Autowired private FrontMapper frontMapper; @Autowired private TbHostMapper tbHostMapper; @Autowired private NodeMapper nodeMapper; @Autowired private FrontGroupMapMapper frontGroupMapMapper; @Autowired private TbChainMapper tbChainMapper; @Autowired private NodeService nodeService; @Autowired private GroupService groupService; @Autowired private FrontGroupMapService frontGroupMapService; @Autowired private FrontInterfaceService frontInterface; @Autowired private FrontGroupMapCache frontGroupMapCache; @Autowired private ResetGroupListTask resetGroupListTask; @Autowired private ConstantProperties constants; @Autowired private AgencyService agencyService; @Autowired private PathService pathService; @Autowired private DeployShellService deployShellService; @Autowired private ConstantProperties constant; @Autowired private DockerCommandService dockerOptions; @Autowired private AnsibleService ansibleService; @Autowired private HostService hostService; @Autowired private ChainService chainService; @Qualifier(value = "deployAsyncScheduler") @Autowired private ThreadPoolTaskScheduler threadPoolTaskScheduler; @Autowired private CryptoSuite cryptoSuite; // version to check @Autowired private VersionProperties versionProperties; // interval of check front status private static final Long CHECK_FRONT_STATUS_WAIT_MIN_MILLIS = 3000L; /** * refresh front, group, frontGroupMap, nodeList */ @Transactional public void refreshFront() { //get all front List<TbFront> frontList = frontMapper.getAllList(); if (frontList == null || frontList.size() == 0) { log.info("refreshFront. not find any front."); return; } for (TbFront tbFront : frontList) { try { String frontIp = tbFront.getFrontIp(); Integer frontPort = tbFront.getFrontPort(); // query group list from chain List<String> groupIdList; groupIdList = frontInterface.getGroupListFromSpecificFront(frontIp, frontPort); // get syncStatus SyncStatusInfo syncStatus = frontInterface.getSyncStatusFromSpecificFront(frontIp, frontPort, Integer.valueOf(groupIdList.get(0))); // get version info ClientVersion versionResponse = frontInterface.getClientVe