ZStack 技术白皮书 ZStack 可拓展性的秘密武器 1：异步架构

0ZStack可拓展性的秘密武器1：一00ZSTACK--可拓展性的秘密武器1：异步架构对于管理大量硬件和虚拟机的公有云而言，可拓展性是一首先，我们非常不赞同一些文章里面描写的关于“一些基础配套设施，尤其是数据库和00异步操作在计算机科学中是非常常见的操作，异步I/O,AJAX等都是一些众所周知的例AttachNicToVmOnHypervisorMsgAttachNicToVmOnHypervisorMsgamsg=newAttachNicToVmOnHypervisorMsg();amsg.setVmUuid(self.getamsg.setHostUuid(self.getHostUamsg.setNics(msg.gebusbus.makeTargetServiceIdByResourceUuid(amsg,HostConstant.SERVICE_ID,self.getHostUbus.send(amsg,newCloudBusCallBack(msg){@OverrideAttachNicToVmReplyr=newAttachNicToVr.setError(errf.instantiateErrorCode(VmErrors.ATTACH_NETWORK_ERROR,r.getE}}finalfinalImageInventoryinv=ImageInventory.vafinalList<DownloadImageMsgCollectionUtils.transformToList(msg.getBackupStorageUuids(),newFunction<DownloadImageMsg,@OverrideDownloadImageMsgdmsg=newDownloaddmsg.setBackupStorageUubus.makeTargetServiceIdByResourceUuid(dmsg,BackupStorageConstant.SERVICE_I}bus.send(dmsgs,newCloudBusListCallBack(msg){@Override}}finalfinalList<ConnectHostMsg>msgs=newArrayList<ConnectHostMsg>(hostsToLoad.size());ConnectHostMsgconnectMsg=newConnectHconnectMsg.setServiceIconnectMsg.setStartPingTaskOn}busbus.send(msgs,HostGlobalConfig.HOST_LOAD_PARALLELISM_DEGREE.value(Integer.clasCloudBusSteppingCallback(){@Overridepublicvoidrun(NeedReplyMessag}组件、插件使用方法调用的方式来进行交互，这种方式也protectedprotectedvoidstartVm(finalAPIStartVmInstanceMsgmsg,finalSyncTaskChaintaskChain){startVm(msg,newCompletion@OverrideVmInstanceInventoryinv=VmInstanceInventory.valueOf(self);APIStartVmInstanceEventevt=newAPIStartVmInstanceEvent(msg.getId());}@@Overridepublicvoidfail(ErrorCodeerrorCode){APIStartVmInstanceEventevt=newAPIStartVmInstanceEvent(msg.getId());evt.setErrorCode(errf.instantiateErrorCode(VmErrors.START_ERROR,errorCod}}publicpublicvoidcreateApplianceVm(ApplianceVmSpecspeReturnValueCompletion<ApplianceVmInventory>completion){CreateApplianceVmJobjob=newCreateAppljob.run(newReturnValueCompletion<Object>(completion){@Overridecompletion.success((ApplianceVmInventory)}@Override@Overridepublicvoidfail(ErrorCod}jobf.execute(spec.getName(),OWNER,job,completion,ApplianceVmInventory.c}}RefreshFirewallCmdRefreshFirewallCmdcmdList<ApplianceVmFirewallRuleTO>tos=newRuleCombiresf.asyncJsonPost(buildUrl(ApplianceVmConstant.REFRESH_FIREWALL_PATJsonAsyncRESTCallback<RefreshFirewallRsp>(msg,completion){@Overridepublicvoidfail(