Method install

ZezeJava/ZezeJava/src/main/java/Zeze/Hot/HotManager.java:340–510

(List<String> namespaces, boolean atomicAll)

	}

	private ArrayList<HotModule> install(List<String> namespaces, boolean atomicAll) throws Exception {
		logger.info("________________ install ________________ {}", namespaces);
		try {
			upgrading = true;
			// 首先查询得到现有的模块，不存在也加入null。
			var exists = new ArrayList<HotModule>(namespaces.size());
			for (var namespace : namespaces)
				exists.add(modules.get(namespace));
			// 锁外执行stopBefore
			for (var exist : exists) {
				if (null != exist)
					exist.stopBefore();
			}
			var result = new ArrayList<HotModule>();
			try (var ignored = enterWriteLock()) {
				var app = zeze.getAppBase();
				// 先保存现有的数据
				app.getZeze().checkpointRun();
				// remove
				for (var namespace : namespaces) {
					modules.remove(namespace);
				}
				// reverse stop
				var reverseIndex = exists.size() - 1;
				try {
					for (; reverseIndex >= 0; --reverseIndex) {
						var exist = exists.get(reverseIndex);
						if (exist != null)
							exist.stop();
					}
				} catch (Throwable ex) {
					logger.error("stop modules {}", exists, ex);
					recoverModules(exists, reverseIndex); // 此时的恢复，schemas没有变化，不需要重新alter。
					return null;
				}

				var txn = new HotTransaction("HotManager.install");
				app.getZeze().__install_prepare__();
				var old = app.getZeze().__upgrade_schemas__(loadSchemas());

				var mainRollbackAction = new MainRollbackAction(zeze, exists, old);
				txn.whileRollback(mainRollbackAction);

				ArrayList<JarFile> hotJarFiles;
				ArrayList<HotModule> newModules;
				try {
					// install
					for (var namespace : namespaces) {
						result.add(_install(namespace, txn));
					}
					// batch load redirect
					var iModules = createModuleInstance(result);
					txn.whileRollback(() -> {
						for (var iModule : iModules)
							iModule.UnRegister();
					});
					app.getZeze().__install_alter__();
					mainRollbackAction.setHasAlter();