Method init

ZezeJava/ZezeJava/src/main/java/Zeze/Raft/Agent.java:347–381

(NetClient client, RaftConfig raftConf)

	}

	private void init(NetClient client, RaftConfig raftConf) throws Exception {
		if (raftConf == null)
			raftConf = RaftConfig.load();

		raftConfig = raftConf;
		this.client = client;

		if (this.client.getConfig().acceptorCount() != 0)
			throw new IllegalStateException("Acceptor Found!");
		if (this.client.getConfig().connectorCount() != 0)
			throw new IllegalStateException("Connector Found!");

		if (proxyAgent == null) {
			// 没有启用代理，按原始raft方式建立连接器。
			for (var node : raftConfig.getNodes().values())
				this.client.getConfig().addConnector(new Connector(node.getHost(), node.getPort()));
		} else {
			proxyAgent.addAgent(this);
			leader = proxyAgent.getLeader(raftConfig.getNodes().values().iterator().next());
			logger.info("proxy first leader {} {}_{}",
					leader.getName(), leader.getConnector().getHostNameOrAddress(), leader.getConnector().getPort());
		}

		this.client.AddFactoryHandle(LeaderIs.TypeId_, new Service.ProtocolFactoryHandle<>(
				LeaderIs::new, this::processLeaderIs, TransactionLevel.Serializable, DispatchMode.Critical));

		this.client.AddFactoryHandle(GetLeader.TypeId_, new Service.ProtocolFactoryHandle<>(
				GetLeader::new, null, TransactionLevel.None, DispatchMode.Normal));
		this.client.AddFactoryHandle(StartServerConnector.TypeId_, new Service.ProtocolFactoryHandle<>(
				StartServerConnector::new, null, TransactionLevel.None, DispatchMode.Normal));
		this.client.AddFactoryHandle(StopServerConnector.TypeId_, new Service.ProtocolFactoryHandle<>(
				StopServerConnector::new, null, TransactionLevel.None, DispatchMode.Normal));
		// ugly
		resendTask = Task.scheduleUnsafe(1000, 1000, this::resend);
	}

	private Connector getRandomConnector(Connector except) {
		var notMe = new ArrayList<Connector>(client.getConfig().connectorCount());