Method runTrace

ZezeJava/ZezeJava/src/main/java/Zeze/Raft/Test.java:284–455

()

	}

	public void runTrace() throws Exception {
		// 基本测试
		logger.debug("基本测试");
		agent.sendForWait(new AddCount()).await();
		expectCount.incrementAndGet();
		checkCurrentCount("TestAddCount");

		// 基本并发请求
		logger.debug("基本并发请求");
		setLogLevel(Level.INFO);
		testConcurrent("TestConcurrent", 200);
		setLogLevel(Level.TRACE);

		// 普通节点重启网络一。
		logger.debug("普通节点重启网络一");
		var NotLeaders = getNodeNotLeaders();
		if (!NotLeaders.isEmpty())
			NotLeaders.get(0).restartNet();
		testConcurrent("TestNormalNodeRestartNet1", 1);

		// 普通节点重启网络二。
		logger.debug("普通节点重启网络二");
		if (NotLeaders.size() > 1) {
			NotLeaders.get(0).restartNet();
			NotLeaders.get(1).restartNet();
		}
		testConcurrent("TestNormalNodeRestartNet2", 1);

		// Leader节点重启网络。
		logger.debug("Leader节点重启网络");
		getLeader().restartNet();
		testConcurrent("TestLeaderNodeRestartNet", 1);

		// Leader节点重启网络，【选举】。
		logger.debug("Leader节点重启网络，【选举】");
		{
			var leader = getLeader();
			leader.raft.getServer().stop();
			Task.schedule(leader.raft.getRaftConfig().getElectionTimeoutMax(), leader.raft.getServer()::start);
		}
		testConcurrent("TestLeaderNodeRestartNet_NewVote", 1);

		// 普通节点重启一。
		logger.debug("普通节点重启一");
		NotLeaders = getNodeNotLeaders();
		if (!NotLeaders.isEmpty()) {
			NotLeaders.get(0).stopRaft();
			NotLeaders.get(0).startRaft();
		}
		testConcurrent("TestNormalNodeRestartRaft1", 1);

		// 普通节点重启二。
		logger.debug("普通节点重启二");
		if (NotLeaders.size() > 1) {
			NotLeaders.get(0).stopRaft();
			NotLeaders.get(1).stopRaft();
			NotLeaders.get(0).startRaft();
			NotLeaders.get(1).startRaft();