Method Dbh2

ZezeJava/ZezeJava/src/main/java/Zeze/Dbh2/Dbh2.java:151–186

(Dbh2Manager manager, String raftName, RocksDatabase database,
				RaftConfig raftConf, Config config, boolean writeOptionSync,
				TaskOneByOneByKey taskOneByOne)

	}

	public Dbh2(Dbh2Manager manager, String raftName, RocksDatabase database,
				RaftConfig raftConf, Config config, boolean writeOptionSync,
				TaskOneByOneByKey taskOneByOne) {
		this.manager = manager;

		var selfNode = raftConf.getNodes().get(raftName);
		if (!selfNode.isSuggestMajority()) {
			// 根据配置，发现自己不是推荐的多数派，先去检测(等待)建议的多数派产生Leader。
			// 如果检测失败，继续启动过程，此后即时不是推荐的，也可能成为Leader。
			Agent.waitForLeader(raftConf);
		}
		if (config == null)
			config = Config.load();
		config.parseCustomize(this.dbh2Config);

		try {
			stateMachine = new Dbh2StateMachine(this);
			raft = new Raft(stateMachine, raftName, database, raftConf, config,
					"Zeze.Dbh2.Server", Dbh2RaftServer::new, taskOneByOne);
			raft.getServer().getSocketOptions().setInputBufferMaxProtocolSize(100 * 1024 * 1024);
			raft.getServer().getSocketOptions().setOutputBufferMaxSize(100 * 1024 * 1024);
			raftConf.setSnapshotCommitDelayed(true);
			logger.info("newRaft: {}", raft.getName());
			stateMachine.openBucket();
			var writeOptions = writeOptionSync ? RocksDatabase.getSyncWriteOptions() : RocksDatabase.getDefaultWriteOptions();
			raft.getLogSequence().setWriteOptions(writeOptions);
			stateMachine.getBucket().setWriteOptions(writeOptions);

			RegisterProtocols(raft.getServer());
			raft.setOnLeaderReady(this::recoverSplitting);
			raft.setOnFollowerReceiveKeepAlive(this::onFollowerReceiveKeepAlive);
			raft.getServer().start();
		} catch (Exception ex) {
			throw new RuntimeException(ex);
		}
	}

	@Override
	public void close() throws IOException {