Method start

ZezeJava/ZezeJava/src/main/java/Zeze/Dbh2/Dbh2Manager.java:152–195

()

	}

	public void start() throws Exception {
		ShutdownHook.add(this, this::stop);
		var raftXmlFiles = new ArrayList<File>();
		listRaftXmlFiles(new File(home), raftXmlFiles);
		logger.info("loading {} raftXmlFiles from '{}'", raftXmlFiles.size(), home);
		raftXmlFiles.parallelStream().forEach((raftXml) -> {
			try {
				var bytes = java.nio.file.Files.readAllBytes(raftXml.toPath());
				var raftStr = new String(bytes, StandardCharsets.UTF_8);
				var raftConfig = RaftConfig.loadFromString(raftStr);
				raftConfig.setDbHome(raftXml.getParent());
				dbh2s.computeIfAbsent(raftConfig.getSortedNames(), __ -> {
					var dbh2 = new Dbh2(this, raftConfig.getName(),
							database, raftConfig,
							null, false, taskOneByOne);
					proxyServer.addRaft(dbh2.getRaft());
					logger.info("start: add raftName = '{}'", dbh2.getRaft().getName());
					return dbh2;
				});
			} catch (IOException ex) {
				throw new RuntimeException(ex);
			}
		});
		masterAgent.startAndWaitConnectionReady();
		var acceptorAddress = masterService.getAcceptorAddress();
		var dbh2sAtMaster = masterAgent.register(acceptorAddress.getKey(), acceptorAddress.getValue(), dbh2s.size());
		logger.info("{}, {} - rafts=\n{}\n{}", acceptorAddress.getKey(), acceptorAddress.getValue(), dbh2sAtMaster, dbh2s.keySet());
		// build map
		var dbh2sAtMasterMiss = new HashMap<String, BDbh2Config.Data>();
		for (var dbh2 : dbh2sAtMaster.getDbh2Configs()) {
			if (!dbh2s.containsKey(dbh2.getRaftConfig()))
				dbh2sAtMasterMiss.put(dbh2.getRaftConfig(), dbh2);
		}
		// 保存并启动丢失的dbh2（一般是系统完全毁坏，重新找的新机器） ...
		logger.info("miss rafts={}", dbh2sAtMasterMiss.values());
		for (var dbh2 : dbh2sAtMasterMiss.values()) {
			createBucket(dbh2.getDatabase(), dbh2.getTable(), dbh2.getRaftConfig());
		}
		// set ready
		masterAgent.setDbh2Ready();
		proxyServer.start();

		loadMonitorTimer = Task.scheduleUnsafe(120_000, 120_000, this::loadMonitor);
	}

	private void loadMonitor() throws Exception {
		var loadManager = 0.0;