Method send

ZezeJava/ZezeJava/src/main/java/Zeze/Raft/ProxyServer.java:103–134

如果启用了代理，则把rpc包装成代理协议，发送出去； 否则按原始raft请求发送出去。 @param proxyServer 启用代理的服务器 @param rpc 待发送rpc @param sender 连接 @see ProxyAgent send

(Service localService, ProxyServer proxyServer, Rpc<?, ?> rpc, String raftName, AsyncSocket sender)

	 * @see ProxyAgent send
	 */
	@SuppressWarnings("unchecked")
	public static boolean send(Service localService, ProxyServer proxyServer, Rpc<?, ?> rpc, String raftName, AsyncSocket sender) {
		if (null == sender)
			return false; // 没有连接，直接失败。

		if (null != proxyServer) {
			var proxyArgument = new ProxyArgument(raftName, rpc);
			var proxyRpc = new ProxyRequest(proxyArgument);
			return proxyRpc.Send(sender, (proxyRpcThis) -> {
				if (proxyRpc.getResultCode() == 0) {
					var outFh = new OutObject<ProtocolFactoryHandle<?>>();
					var resultRpc = Protocol.decode(
							localService::findProtocolFactoryHandle,
							ByteBuffer.Wrap(proxyRpc.Result.getData()),
							outFh);
					if (null != resultRpc && null != rpc.getResponseHandle()) {
						@SuppressWarnings("rawtypes")
						var originHandle = (ProtocolHandle)rpc.getResponseHandle();
						localService.dispatchRpcResponse(resultRpc, originHandle, outFh.value);
					}
					// todo error handle
				} else {
					// todo error handle
					logger.error("Server ProxyRequest error={}", IModule.getErrorCode(proxyRpc.getResultCode()));
				}
				return 0;
			}, proxyServer.rpcTimeout);
		}

		// 旧的独立的直接的raft访问发送方式。
		return rpc.Send(sender); // ignore response
	}
}