KubeIaaS 是基于 Kubernetes 的易于部署和运维、功能完备且易用的私有 IaaS 云解决方案，

package kubeiaas.iaascore.service; import kubeiaas.common.bean.*; import kubeiaas.common.constants.LogInjectionConstants; import kubeiaas.common.constants.ResponseMsgConstants; import kubeiaas.common.constants.bean.HostConstants; import kubeiaas.common.constants.bean.VmConstants; import kubeiaas.common.enums.config.SpecTypeEnum; import kubeiaas.common.enums.network.IpTypeEnum; import kubeiaas.common.enums.vm.VmBootEnum; import kubeiaas.common.enums.vm.VmInstallationMethodEnum; import kubeiaas.common.enums.vm.VmOperateEnum; import kubeiaas.common.enums.vm.VmStatusEnum; import kubeiaas.iaascore.config.AgentConfig; import kubeiaas.iaascore.dao.TableStorage; import kubeiaas.iaascore.exception.BaseException; import kubeiaas.iaascore.exception.VmException; import kubeiaas.iaascore.process.*; import kubeiaas.iaascore.response.PageResponse; import kubeiaas.iaascore.response.ResponseEnum; import kubeiaas.iaascore.scheduler.DeviceScheduler; import kubeiaas.iaascore.utils.LogUtils; import lombok.extern.slf4j.Slf4j; import org.slf4j.MDC; import org.springframework.stereotype.Service; import org.springframework.util.CollectionUtils; import org.springframework.util.StringUtils; import javax.annotation.Resource; import java.util.*; @Slf4j @Service public class VmService { @Resource private TableStorage tableStorage; @Resource private NetworkProcess networkProcess; @Resource private VmProcess vmProcess; @Resource private ResourceProcess resourceProcess; @Resource private VolumeProcess volumeProcess; @Resource private VncProcess vncProcess; @Resource private DeviceScheduler deviceScheduler; /** * 创建虚拟机 */ public Vm createVm( String name, int cpus, int memory, String imageUuid, int ipSegmentId, Integer publicIpSegId, Integer diskSize, String description, String hostUUid) throws VmException { log.info(String.format("createVm info -- name: %s, cpus: %d, memory: %d, imageUuid: %s, ipSegmentId: %d, publicIpSegId: %d, diskSize: %d, description: %s, hostUUid: %s", name, cpus, memory, imageUuid, ipSegmentId, publicIpSegId, diskSize, description, hostUUid)); /* ---- 1. pre create VM ---- Generate and Set basic info of vm. （预处理：设置基础参数，保存虚拟机信息） */ log.info("STEP 1: create VM in database"); Vm newVm = vmProcess.preCreateVm(name, cpus, memory, imageUuid, diskSize, description, hostUUid); MDC.put(LogInjectionConstants.UUID_INJECTION, LogUtils.appendUuidInjection(MDC.get(LogInjectionConstants.UUID_INJECTION), newVm.getUuid())); /* ---- 2. Image Check ---- Check image available and set diskSize */ log.info("STEP 2: Image Check"); newVm = resourceProcess.updateVmImage(newVm); /* ---- 3. Resource Operator ---- Use Resource Operator to allocate Host and check Resource available （资源调度：分配宿主机，检查资源合法性） */ log.info("STEP 3: Resource Operator"); if (publicIpSegId == null || publicIpSegId <= 0) { newVm = resourceProcess.createVmOperate(newVm, ipSegmentId, false, -1); } else { newVm = resourceProcess.createVmOperate(newVm, ipSegmentId, true, publicIpSegId); } /* ---- 4. Network ---- Get mac-info ip-info and bind in DHCP-Controller （网络信息：分配 mac 与 ip，存储入库，dhcp 绑定） */ log.info("STEP 4: Get mac-info ip-info and bind in DHCP-Controller"); List<IpUsed> newIpUsedList = allocateIPs(newVm, ipSegmentId, publicIpSegId); newVm.setIps(newIpUsedList); /* ---- 5. Volume ---- Create system volume. （系统盘：使用 image 创建 system volume） */ log.info("STEP 5: Create system volume"); volumeProcess.createVmVolume(newVm); return newVm; } /** * 删除虚拟机 */ public String deleteVM(String vmUuid, boolean isForce) throws BaseException, VmException { log.info(String.format("deleteVM info -- vmUuid: %s, isForce: %s", vmUuid, isForce)); // ----- check if exist ----- log.info(String.format("-> invoke DB -- vmQueryByUuid, vmUuid: %s", vmUuid)); Vm vm = tableStorage.vmQueryByUuid(vmUuid); log.info("<- invoke DB -- done"); if (vm == null) { log.error(String.format("ERROR: vm not found! (uuid: %s)", vmUuid)); throw new BaseException("ERR: vm not found! (uuid: " + vmUuid + ")", ResponseEnum.VM_DELETE_ERROR); } /* ----- judge status ---- Check the VM status */ if (!isForce) { if (vm.getStatus().equals(VmStatusEnum.ACTIVE)) { return ResponseMsgConstants.FAILED; } } try { // -- 0. set status -- Set deleting status log.info("STEP 0: Set deleting status"); vmProcess.setVmStatus(vmUuid, VmStatusEnum.DELETING); // -- 1. choose host -- Select the host where the VM to be deleted resides log.info("STEP 1: Select the host where the VM to be deleted resides"); resourceProcess.selectHostByVmUuid(vmUuid); // ┌- 2. delete VM -- Delete the VM and then delete other information -┐ log.info("STEP 2: Delete the VM and then delete other information"); vmProcess.deleteVM(vmUuid); // ├- 3. Delete Volume -- Delete disks, including Linux files and database information log.info("STEP 3: Delete disks, including Linux files and database information"); volumeProcess.deleteSystemVolume(vmUuid); // ├- 4. Delete Ip -- Delete Ip information log.info("STEP 4: Delete Ip information"); networkProcess.deleteIps(vmUuid); // ├- 5. Delete Device -- Delete Device information (while Step.2 already detached) log.info("STEP 5: Delete Device information"); log.info(String.format("-> invoke DB -- deviceQueryByVm, vmUuid: %s", vmUuid)); deviceScheduler.deleteDevice(vmUuid); log.info("<- invoke DB -- done"); // └- 6. delete in database -- Delete VM records from the database -┘ log.info("STEP 6: Delete VM records from the database"); vmProcess.deleteVmInDataBase(vmUuid); // -- 7. delete vnc -- delete vnc in token.config log.info("STEP 7: delete vnc in token.config"); vncProcess.deleteVncToken(vmUuid); } catch (Exception e) { log.error(String.format("ERROR: delete failed (uuid: %s)!", vmUuid), e); String log = (e instanceof BaseException) ? ((BaseException) e).getMsg() : ""; throw new VmException(vm, String.format("err: delete failed (uuid: %s)! %s", vmUuid, log), ResponseEnum.VM_DELETE_ERROR); } return ResponseMsgConstants.SUCCESS; } /** * ====== 修改系列 ====== * 支持：CPU、内存 */ public String modifyVm(String vmUuid, Integer cpus, Integer memory, boolean isReduce) throws BaseException { log.info(String.format("modifyVm info -- vmUuid: %s, cpus: %d, memory: %d, isReduce: %s", vmUuid, cpus, memory, isReduce)); /* -----1. choose host ---- Select the host where the VM to be modified */ log.info("STEP 1: Select the host where the VM to be modified"); resourceProcess.selectHostByVmUuid(vmUuid); /* -----2. modify VM ---- Modify cpu and memory */ log.info("STEP 2: Modify cpu and memory"); if (isReduce) { vmProcess.reduceVM(vmUuid, cpus, memory); } else { v