Class ProxyAgent

ZezeJava/ZezeJava/src/main/java/Zeze/Raft/ProxyAgent.java:22–166

当raft节点运行在一个进程内时，可以通过代理方式复用同一个连接。 这个类在一个进程内只有一个实例，然后传入启用代理的Raft.Agent使用。 另外，ProxyDispatch 的代码也写在这里，只是一个静态函数。

 * 另外，ProxyDispatch 的代码也写在这里，只是一个静态函数。
 */
public class ProxyAgent extends Service {
	public static final String eProxyAgentName = "Zeze.Raft.ProxyAgent";
	private final int rpcTimeout;

	public ProxyAgent(int rpcTimeout) {
		super(eProxyAgentName, (Config)null);
		this.rpcTimeout = rpcTimeout;
		getSocketOptions().setOutputBufferMaxSize(100 * 1024 * 1024);
		getSocketOptions().setInputBufferMaxProtocolSize(100 * 1024 * 1024);

		AddFactoryHandle(ProxyRequest.TypeId_, new Service.ProtocolFactoryHandle<>(
				ProxyRequest::new,
				this::ProcessProxyRequest,
				TransactionLevel.None
		));
	}

	/**
	 * 把代理请求派发到指定的raft中执行。
	 *
	 * @param r ProxyRequest
	 */
	private long ProcessProxyRequest(ProxyRequest r) throws Exception {
		var agent = agents.get(r.Argument.getRaftName());
		if (null == agent)
			return Procedure.ProviderNotExist;
		var client = agent.getClient();
		var outFactoryHandle = new OutObject<Service.ProtocolFactoryHandle<?>>();
		var p = Protocol.decode(client::findProtocolFactoryHandle, ByteBuffer.Wrap(r.Argument.getRpcBinary()), outFactoryHandle);
		if (null == p)
			return Procedure.NotImplement;

		if (!(p instanceof ProxyableRpc<?, ?>))
			throw new RuntimeException("not a proxyable rpc.");

		var proxyable = (ProxyableRpc<?, ?>)p;
		proxyable.setProxyRequest(r);
		// 重新派发一次，有点浪费线程切换，以后再考虑优化。
		client.dispatchProtocol(p, outFactoryHandle.value);
		return 0;
	}

	public static class ConnectorEx extends Connector {
		private final ConcurrentHashMap<String, Agent.ConnectorProxy> proxys = new ConcurrentHashMap<>();

		public ConnectorEx(String host, int port) {
			super(host, port, true);
		}

		public ConnectorEx(String host, int port, boolean autoConnect) {
			super(host, port, autoConnect);
		}

		public Agent.ConnectorProxy getConnectorProxy(String name) {
			return proxys.computeIfAbsent(name, __ -> new Agent.ConnectorProxy(name, this));
		}
	}
	/**