接口 com.fr.cluster.rpc.base.ClusterInvoker
的使用

使用ClusterInvoker的程序包

程序包	说明
com.fr.cluster.engine.rpc.base	Created by juhaoyu on 2017/12/18.
com.fr.cluster.rpc.base	Created by juhaoyu on 2017/12/15.
com.fr.cluster.rpc.proxy	Created by juhaoyu on 2017/12/15.

com.fr.cluster.engine.rpc.base中ClusterInvoker的使用

返回ClusterInvoker的com.fr.cluster.engine.rpc.base中的方法

限定符和类型	方法和说明
ClusterInvoker	ClusterInvokerManager.create(java.lang.Class clazz, CommonSerializer<?>... serializers)
ClusterInvoker	ClusterInvokerManager.create(java.lang.Class clazz, long timeout, CommonSerializer<?>... serializers)
ClusterInvoker	ClusterInvokerManager.create(java.lang.Object singleton, CommonSerializer<?>... serializers)
ClusterInvoker	ClusterInvokerManager.create(java.lang.Object singleton, long timeout, CommonSerializer<?>... serializers)

com.fr.cluster.rpc.base中ClusterInvoker的使用

返回ClusterInvoker的com.fr.cluster.rpc.base中的方法

限定符和类型	方法和说明
ClusterInvoker	ClusterInvokerFactory.create(java.lang.Class clazz, CommonSerializer<?>... serializers) 静态方法调用器，底层不会实例化，无法调用非静态方法 仅适用于无法实例化的场景
ClusterInvoker	ClusterInvokerFactory.create(java.lang.Class clazz, long timeout, CommonSerializer<?>... serializers) 设置调用的超时时间
ClusterInvoker	ClusterInvokerFactory.create(java.lang.Object singleton, CommonSerializer<?>... serializers) 单例方法调用器，也可以调用静态方法
ClusterInvoker	ClusterInvokerFactory.create(java.lang.Object singleton, long timeout, CommonSerializer<?>... serializers) 设置调用的超时时间

参数类型为ClusterInvoker的com.fr.cluster.rpc.base中的方法

限定符和类型	方法和说明
static <T> T	ClusterInvokerHelper.invoke(ClusterInvoker invoker, ClusterNode node, Invocation invocation)

com.fr.cluster.rpc.proxy中ClusterInvoker的使用

参数类型为ClusterInvoker的com.fr.cluster.rpc.proxy中的方法

限定符和类型	方法和说明
java.lang.Object	RPCTargetSwitcher.invoke(ClusterInvoker invoker, java.lang.Object localTarget, Invocation invocation, RemoteResultHandler remoteHandler)
java.lang.Object	RPCInvokeStrategy.invoke(ClusterInvoker invoker, java.lang.Object localTarget, Invocation invocation, RemoteResultHandler remoteHandler) 定义调用策略 例： public Object invoke(ClusterInvoker invoker, Object localTarget, Invocation invocation, RemoteResultHandler remoteHandler) throws Throwable { Object result = invocation.getMethod().invoke(localTarget); invoker.invokeAll(invocation, RemoteResultHandlerHelper.newAdaptor(remoteHandler)); return result; }