Method send

ZezeJava/ZezeJava/src/main/java/Zeze/Raft/ProxyAgent.java:119–165

如果启用了代理，则把rpc包装成代理协议，发送出去； 否则按原始raft请求发送出去。 @param proxyAgent 启用代理的实例 @param rpc 发送的rpc @param leader leader连接器，可能是原始的，也可能是伪造的。可能为null。 @param leaderSocket leader.Socket。可能为null。 @return 发送结果，可能失败。 @see ProxyServer send

(Service localService,
							   ProxyAgent proxyAgent,
							   RaftRpc<?, ?> rpc,
							   Agent.ConnectorProxy leader,
							   AsyncSocket leaderSocket)

	 * @see ProxyServer send
	 */
	@SuppressWarnings("unchecked")
	public static boolean send(Service localService,
							   ProxyAgent proxyAgent,
							   RaftRpc<?, ?> rpc,
							   Agent.ConnectorProxy leader,
							   AsyncSocket leaderSocket) {

		if (null != proxyAgent) {
			if (null != leader) {
				var proxyArgument = new ProxyArgument(leader.getName(), rpc);
				var proxyRpc = new ProxyRequest(proxyArgument);
				// leaderSocket 就是从leader中获取的，这里是为了在循环中发送的时候不用每次获取，优化！
				//logger.info("send to {}", leaderSocket.getRemoteAddress());
				return proxyRpc.Send(leaderSocket, (proxyRpcThis) -> {
					if (proxyRpc.getResultCode() == 0) {
						var outFh = new OutObject<Service.ProtocolFactoryHandle<?>>();
						var resultRpc = (Rpc<?, ?>)Protocol.decode(
								localService::findProtocolFactoryHandle,
								ByteBuffer.Wrap(proxyRpc.Result.getData()),
								outFh);
						if (null != resultRpc) {
							if (null != rpc.getResponseHandle()) {
								@SuppressWarnings("rawtypes")
								var originHandle = (ProtocolHandle)rpc.getResponseHandle();
								localService.dispatchRpcResponse(resultRpc, originHandle, outFh.value);
							} else if (rpc.getFuture() != null){
								rpc.getFuture().setRawResult(resultRpc.Result);
							}
						} else {
							logger.error("Agent ProxyRequest({}) resultRpc not found.", proxyArgument.getRaftName());
						}
					} else {
						if (Procedure.Timeout != proxyRpc.getResultCode())
							logger.error("Agent ProxyRequest({}) error={}",
									proxyArgument.getRaftName(), IModule.getErrorCode(proxyRpc.getResultCode()));
						else
							logger.info("Agent ProxyRequest({}) timeout.", proxyArgument.getRaftName());
					}
					return 0;
				}, proxyAgent.rpcTimeout);
			}
			// leader 还没有选出。
			return false;
		}
		// 旧的独立的直接的raft访问发送方式。
		return rpc.Send(leaderSocket);
	}
}