程序包 | 说明 |
---|---|
com.fr.cluster.engine.rpc.proxy.components | |
com.fr.cluster.rpc.proxy |
Created by juhaoyu on 2017/12/15.
|
限定符和类型 | 类和说明 |
---|---|
class |
DefaultRemoteResultHandler
Created by juhaoyu on 2017/12/21.
|
限定符和类型 | 类和说明 |
---|---|
class |
AbstractRemoteResultHandler
Created by juhaoyu on 2017/12/22.
|
限定符和类型 | 方法和说明 |
---|---|
static void |
RemoteResultHandlerHelper.finish(RemoteResultHandler remoteHandler,
Invocation invocation,
java.util.Map<ClusterNode,Result> remoteResults) |
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;
}
|
static ClusterInvokeHandler |
RemoteResultHandlerHelper.newAdaptor(RemoteResultHandler handler) |
RPCProxyFactory.Builder<T> |
RPCProxyFactory.Builder.setResultHandler(RemoteResultHandler resultHandler)
结果处理器
|