程序包 | 说明 |
---|---|
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.rpc | |
com.fr.rpc.serialization |
限定符和类型 | 方法和说明 |
---|---|
Result |
ClusterInvoker.invoke(ClusterNode node,
Invocation invocation)
调用指定机器
|
限定符和类型 | 方法和说明 |
---|---|
java.util.Map<ClusterNode,Result> |
ClusterInvoker.invokeAll(Invocation invocation)
调用所有机器
|
限定符和类型 | 方法和说明 |
---|---|
void |
ClusterInvokeHandler.done(ClusterNode marker,
Invocation invocation,
Result result)
结果处理器,用于异步rpc
|
限定符和类型 | 方法和说明 |
---|---|
static void |
RemoteResultHandlerHelper.finish(RemoteResultHandler remoteHandler,
Invocation invocation,
java.util.Map<ClusterNode,Result> remoteResults) |
限定符和类型 | 类和说明 |
---|---|
class |
FineResult
Created by juhaoyu on 2017/12/18.
|
限定符和类型 | 方法和说明 |
---|---|
Result |
ResultSerializer.deserialize(java.io.InputStream in) |
限定符和类型 | 方法和说明 |
---|---|
void |
ResultSerializer.serialize(Result obj,
java.io.OutputStream out) |