xyz.noark.network.rpc

类 DefaultRpcClient

java.lang.Object

xyz.noark.network.rpc.DefaultRpcClient

所有已实现的接口:

RpcClient

public class DefaultRpcClient
extends java.lang.Object
implements RpcClient

默认的RPC实现.

从以下版本开始:

3.4.7

作者:

小流氓[176543888@qq.com]

构造器概要

构造器

构造器和说明
DefaultRpcClient(java.util.List<java.net.SocketAddress> addressList)
DefaultRpcClient(RpcConnectorFactory connectorFactory, java.util.List<java.net.SocketAddress> addressList)
DefaultRpcClient(RpcLoadBalanced loadBalanced)

方法概要

限定符和类型	方法和说明
void	setLoadBalanced(RpcLoadBalanced loadBalanced) 重置RPC负载均衡算法.
<T> T	syncCall(java.io.Serializable opcode, java.lang.Object req, java.lang.Class<T> ackClass) 同步调用一个协议并返回结果.

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

DefaultRpcClient

public DefaultRpcClient(java.util.List<java.net.SocketAddress> addressList)

DefaultRpcClient

public DefaultRpcClient(RpcConnectorFactory connectorFactory,
                        java.util.List<java.net.SocketAddress> addressList)

DefaultRpcClient

public DefaultRpcClient(RpcLoadBalanced loadBalanced)

方法详细资料

setLoadBalanced

public void setLoadBalanced(RpcLoadBalanced loadBalanced)

重置RPC负载均衡算法.

参数:

loadBalanced - 负载均衡算法

syncCall

public <T> T syncCall(java.io.Serializable opcode,
                      java.lang.Object req,
                      java.lang.Class<T> ackClass)

从接口复制的说明: RpcClient

同步调用一个协议并返回结果.

指定者:

syncCall 在接口中 RpcClient

类型参数:

T - RPC响应返回对象的Class

参数:

opcode - RPC的唯一标识，类似于协议编号

req - RPC请求对象

ackClass - RPC响应结构

返回:

RPC响应对象