| 限定符和类型 | 方法和说明 |
|---|---|
Result |
CacheFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
| 构造器和说明 |
|---|
DubboMonitor(Invoker<MonitorService> monitorInvoker,
MonitorService monitorService) |
| 限定符和类型 | 方法和说明 |
|---|---|
Result |
MonitorFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
| 构造器和说明 |
|---|
DubboRegistry(Invoker<RegistryService> registryInvoker,
RegistryService registryService) |
| 限定符和类型 | 类和说明 |
|---|---|
static class |
RegistryProtocol.InvokerDelegete<T> |
| 限定符和类型 | 方法和说明 |
|---|---|
Invoker<T> |
RegistryProtocol.InvokerDelegete.getInvoker() |
<T> Invoker<T> |
RegistryProtocol.refer(Class<T> type,
URL url) |
| 限定符和类型 | 方法和说明 |
|---|---|
List<Invoker<T>> |
RegistryDirectory.doList(Invocation invocation) |
Map<String,List<Invoker<T>>> |
RegistryDirectory.getMethodInvokerMap()
Haomin: added for test purpose
|
Map<String,Invoker<T>> |
RegistryDirectory.getUrlInvokerMap()
Haomin: added for test purpose
|
| 限定符和类型 | 方法和说明 |
|---|---|
<T> Exporter<T> |
RegistryProtocol.export(Invoker<T> originInvoker) |
| 构造器和说明 |
|---|
InvokerDelegete(Invoker<T> invoker,
URL url) |
| 限定符和类型 | 方法和说明 |
|---|---|
Invoker<?> |
RpcInvocation.getInvoker() |
Invoker<?> |
RpcContext.getInvoker()
已过时。
Replace to getUrl()
|
Invoker<?> |
Invocation.getInvoker()
get the invoker in current context.
|
Invoker<T> |
Exporter.getInvoker()
get invoker.
|
<T> Invoker<T> |
ProxyFactory.getInvoker(T proxy,
Class<T> type,
URL url)
create invoker.
|
<T> Invoker<T> |
Protocol.refer(Class<T> type,
URL url)
引用远程服务:
1. |
| 限定符和类型 | 方法和说明 |
|---|---|
List<Invoker<?>> |
RpcContext.getInvokers()
已过时。
Replace to getUrls()
|
| 限定符和类型 | 方法和说明 |
|---|---|
void |
InvokerListener.destroyed(Invoker<?> invoker)
The invoker destroyed.
|
<T> Exporter<T> |
Protocol.export(Invoker<T> invoker)
暴露远程服务:
1. |
<T> T |
ProxyFactory.getProxy(Invoker<T> invoker)
create proxy.
|
Result |
Filter.invoke(Invoker<?> invoker,
Invocation invocation)
do invoke filter.
|
void |
InvokerListener.referred(Invoker<?> invoker)
The invoker referred
|
void |
RpcInvocation.setInvoker(Invoker<?> invoker) |
RpcContext |
RpcContext.setInvoker(Invoker<?> invoker) |
| 限定符和类型 | 方法和说明 |
|---|---|
RpcContext |
RpcContext.setInvokers(List<Invoker<?>> invokers) |
| 构造器和说明 |
|---|
RpcInvocation(Invocation invocation,
Invoker<?> invoker) |
RpcInvocation(String methodName,
Class<?>[] parameterTypes,
Object[] arguments,
Map<String,String> attachments,
Invoker<?> invoker) |
| 限定符和类型 | 方法和说明 |
|---|---|
<T> Invoker<T> |
Cluster.join(Directory<T> directory)
Merge the directory invokers to a virtual invoker.
|
<T> Invoker<T> |
LoadBalance.select(List<Invoker<T>> invokers,
URL url,
Invocation invocation)
select one invoker in list.
|
| 限定符和类型 | 方法和说明 |
|---|---|
List<Invoker<T>> |
Directory.list(Invocation invocation)
list invokers.
|
<T> List<Invoker<T>> |
Router.route(List<Invoker<T>> invokers,
URL url,
Invocation invocation)
route.
|
| 限定符和类型 | 方法和说明 |
|---|---|
<T> List<Invoker<T>> |
Router.route(List<Invoker<T>> invokers,
URL url,
Invocation invocation)
route.
|
<T> Invoker<T> |
LoadBalance.select(List<Invoker<T>> invokers,
URL url,
Invocation invocation)
select one invoker in list.
|
| 限定符和类型 | 方法和说明 |
|---|---|
List<Invoker<T>> |
AbstractDirectory.list(Invocation invocation) |
| 构造器和说明 |
|---|
StaticDirectory(List<Invoker<T>> invokers) |
StaticDirectory(List<Invoker<T>> invokers,
List<Router> routers) |
StaticDirectory(URL url,
List<Invoker<T>> invokers) |
StaticDirectory(URL url,
List<Invoker<T>> invokers,
List<Router> routers) |
| 限定符和类型 | 方法和说明 |
|---|---|
<T> Invoker<T> |
AbstractLoadBalance.select(List<Invoker<T>> invokers,
URL url,
Invocation invocation) |
| 限定符和类型 | 方法和说明 |
|---|---|
<T> Invoker<T> |
AbstractLoadBalance.select(List<Invoker<T>> invokers,
URL url,
Invocation invocation) |
| 限定符和类型 | 方法和说明 |
|---|---|
<T> List<Invoker<T>> |
MockInvokersSelector.route(List<Invoker<T>> invokers,
URL url,
Invocation invocation) |
| 限定符和类型 | 方法和说明 |
|---|---|
<T> List<Invoker<T>> |
MockInvokersSelector.route(List<Invoker<T>> invokers,
URL url,
Invocation invocation) |
| 限定符和类型 | 方法和说明 |
|---|---|
<T> List<Invoker<T>> |
ConditionRouter.route(List<Invoker<T>> invokers,
URL url,
Invocation invocation) |
| 限定符和类型 | 方法和说明 |
|---|---|
<T> List<Invoker<T>> |
ConditionRouter.route(List<Invoker<T>> invokers,
URL url,
Invocation invocation) |
| 限定符和类型 | 方法和说明 |
|---|---|
<T> List<Invoker<T>> |
ScriptRouter.route(List<Invoker<T>> invokers,
URL url,
Invocation invocation) |
| 限定符和类型 | 方法和说明 |
|---|---|
<T> List<Invoker<T>> |
ScriptRouter.route(List<Invoker<T>> invokers,
URL url,
Invocation invocation) |
| 限定符和类型 | 类和说明 |
|---|---|
class |
AbstractClusterInvoker<T>
AbstractClusterInvoker
|
class |
AvailableClusterInvoker<T>
AvailableCluster
|
class |
BroadcastClusterInvoker<T>
BroadcastClusterInvoker
|
class |
FailbackClusterInvoker<T>
失败自动恢复,后台记录失败请求,定时重发,通常用于消息通知操作。
|
class |
FailfastClusterInvoker<T>
快速失败,只发起一次调用,失败立即报错,通常用于非幂等性的写操作。
|
class |
FailoverClusterInvoker<T>
失败转移,当出现失败,重试其它服务器,通常用于读操作,但重试会带来更长延迟。
|
class |
FailsafeClusterInvoker<T>
失败安全,出现异常时,直接忽略,通常用于写入审计日志等操作。
|
class |
ForkingClusterInvoker<T>
并行调用,只要一个成功即返回,通常用于实时性要求较高的操作,但需要浪费更多服务资源。
|
class |
MergeableClusterInvoker<T> |
| 限定符和类型 | 方法和说明 |
|---|---|
<T> Invoker<T> |
MergeableCluster.join(Directory<T> directory) |
<T> Invoker<T> |
ForkingCluster.join(Directory<T> directory) |
<T> Invoker<T> |
FailsafeCluster.join(Directory<T> directory) |
<T> Invoker<T> |
FailoverCluster.join(Directory<T> directory) |
<T> Invoker<T> |
FailfastCluster.join(Directory<T> directory) |
<T> Invoker<T> |
FailbackCluster.join(Directory<T> directory) |
<T> Invoker<T> |
BroadcastCluster.join(Directory<T> directory) |
<T> Invoker<T> |
AvailableCluster.join(Directory<T> directory) |
| 限定符和类型 | 方法和说明 |
|---|---|
Result |
ForkingClusterInvoker.doInvoke(Invocation invocation,
List<Invoker<T>> invokers,
LoadBalance loadbalance) |
Result |
FailsafeClusterInvoker.doInvoke(Invocation invocation,
List<Invoker<T>> invokers,
LoadBalance loadbalance) |
Result |
FailoverClusterInvoker.doInvoke(Invocation invocation,
List<Invoker<T>> invokers,
LoadBalance loadbalance) |
Result |
FailfastClusterInvoker.doInvoke(Invocation invocation,
List<Invoker<T>> invokers,
LoadBalance loadbalance) |
Result |
BroadcastClusterInvoker.doInvoke(Invocation invocation,
List<Invoker<T>> invokers,
LoadBalance loadbalance) |
Result |
AvailableClusterInvoker.doInvoke(Invocation invocation,
List<Invoker<T>> invokers,
LoadBalance loadbalance) |
| 限定符和类型 | 类和说明 |
|---|---|
class |
MockClusterInvoker<T> |
| 限定符和类型 | 方法和说明 |
|---|---|
<T> Invoker<T> |
MockClusterWrapper.join(Directory<T> directory) |
| 构造器和说明 |
|---|
MockClusterInvoker(Directory<T> directory,
Invoker<T> invoker) |
| 限定符和类型 | 方法和说明 |
|---|---|
Result |
TpsLimitFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
TokenFilter.invoke(Invoker<?> invoker,
Invocation inv) |
Result |
TimeoutFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
GenericImplFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
GenericFilter.invoke(Invoker<?> invoker,
Invocation inv) |
Result |
ExecuteLimitFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
ExceptionFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
EchoFilter.invoke(Invoker<?> invoker,
Invocation inv) |
Result |
DeprecatedFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
ContextFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
ConsumerContextFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
CompatibleFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
ClassLoaderFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
ActiveLimitFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
AccessLogFilter.invoke(Invoker<?> invoker,
Invocation inv) |
| 限定符和类型 | 类和说明 |
|---|---|
class |
ListenerInvokerWrapper<T>
ListenerInvoker
|
| 限定符和类型 | 方法和说明 |
|---|---|
Invoker<T> |
ListenerExporterWrapper.getInvoker() |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
InvokerListenerAdapter.destroyed(Invoker<?> invoker) |
void |
InvokerListenerAdapter.referred(Invoker<?> invoker) |
void |
DeprecatedInvokerListener.referred(Invoker<?> invoker) |
| 构造器和说明 |
|---|
ListenerInvokerWrapper(Invoker<T> invoker,
List<InvokerListener> listeners) |
| 限定符和类型 | 类和说明 |
|---|---|
class |
AbstractInvoker<T>
AbstractInvoker.
|
class |
InvokerWrapper<T>
InvokerWrapper
|
| 限定符和类型 | 方法和说明 |
|---|---|
Invoker<T> |
AbstractExporter.getInvoker() |
<T> Invoker<T> |
ProtocolListenerWrapper.refer(Class<T> type,
URL url) |
<T> Invoker<T> |
ProtocolFilterWrapper.refer(Class<T> type,
URL url) |
<T> Invoker<T> |
AbstractProxyProtocol.refer(Class<T> type,
URL url) |
| 限定符和类型 | 方法和说明 |
|---|---|
<T> Exporter<T> |
ProtocolListenerWrapper.export(Invoker<T> invoker) |
<T> Exporter<T> |
ProtocolFilterWrapper.export(Invoker<T> invoker) |
<T> Exporter<T> |
AbstractProxyProtocol.export(Invoker<T> invoker) |
| 构造器和说明 |
|---|
AbstractExporter(Invoker<T> invoker) |
InvokerWrapper(Invoker<T> invoker,
URL url) |
| 限定符和类型 | 类和说明 |
|---|---|
class |
DubboInvoker<T>
DubboInvoker
|
| 限定符和类型 | 方法和说明 |
|---|---|
<T> Invoker<T> |
DubboProtocol.refer(Class<T> serviceType,
URL url) |
| 限定符和类型 | 方法和说明 |
|---|---|
Collection<Invoker<?>> |
DubboProtocol.getInvokers() |
| 限定符和类型 | 方法和说明 |
|---|---|
<T> Exporter<T> |
DubboProtocol.export(Invoker<T> invoker) |
| 构造器和说明 |
|---|
DubboExporter(Invoker<T> invoker,
String key,
Map<String,Exporter<?>> exporterMap) |
| 构造器和说明 |
|---|
DubboInvoker(Class<T> serviceType,
URL url,
ExchangeClient[] clients,
Set<Invoker<?>> invokers) |
| 限定符和类型 | 方法和说明 |
|---|---|
Result |
TraceFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Result |
FutureFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
| 限定符和类型 | 方法和说明 |
|---|---|
<T> Invoker<T> |
InjvmProtocol.refer(Class<T> serviceType,
URL url) |
| 限定符和类型 | 方法和说明 |
|---|---|
<T> Exporter<T> |
InjvmProtocol.export(Invoker<T> invoker) |
| 限定符和类型 | 方法和说明 |
|---|---|
<T> Invoker<T> |
MemcachedProtocol.refer(Class<T> type,
URL url) |
| 限定符和类型 | 方法和说明 |
|---|---|
<T> Exporter<T> |
MemcachedProtocol.export(Invoker<T> invoker) |
| 限定符和类型 | 方法和说明 |
|---|---|
<T> Invoker<T> |
RedisProtocol.refer(Class<T> type,
URL url) |
| 限定符和类型 | 方法和说明 |
|---|---|
<T> Exporter<T> |
RedisProtocol.export(Invoker<T> invoker) |
| 限定符和类型 | 类和说明 |
|---|---|
class |
ThriftInvoker<T> |
| 限定符和类型 | 方法和说明 |
|---|---|
<T> Invoker<T> |
ThriftProtocol.refer(Class<T> type,
URL url) |
| 限定符和类型 | 方法和说明 |
|---|---|
<T> Exporter<T> |
ThriftProtocol.export(Invoker<T> invoker) |
| 构造器和说明 |
|---|
ThriftInvoker(Class<T> type,
URL url,
ExchangeClient[] clients,
Set<Invoker<?>> invokers) |
| 限定符和类型 | 类和说明 |
|---|---|
class |
AbstractProxyInvoker<T>
InvokerWrapper
|
| 限定符和类型 | 方法和说明 |
|---|---|
<T> T |
AbstractProxyFactory.getProxy(Invoker<T> invoker) |
abstract <T> T |
AbstractProxyFactory.getProxy(Invoker<T> invoker,
Class<?>[] types) |
| 构造器和说明 |
|---|
InvokerInvocationHandler(Invoker<?> handler) |
| 限定符和类型 | 方法和说明 |
|---|---|
<T> Invoker<T> |
JavassistProxyFactory.getInvoker(T proxy,
Class<T> type,
URL url) |
| 限定符和类型 | 方法和说明 |
|---|---|
<T> T |
JavassistProxyFactory.getProxy(Invoker<T> invoker,
Class<?>[] interfaces) |
| 限定符和类型 | 方法和说明 |
|---|---|
<T> Invoker<T> |
JdkProxyFactory.getInvoker(T proxy,
Class<T> type,
URL url) |
| 限定符和类型 | 方法和说明 |
|---|---|
<T> T |
JdkProxyFactory.getProxy(Invoker<T> invoker,
Class<?>[] interfaces) |
| 限定符和类型 | 方法和说明 |
|---|---|
<T> Invoker<T> |
StubProxyFactoryWrapper.getInvoker(T proxy,
Class<T> type,
URL url) |
| 限定符和类型 | 方法和说明 |
|---|---|
<T> T |
StubProxyFactoryWrapper.getProxy(Invoker<T> invoker) |
| 限定符和类型 | 类和说明 |
|---|---|
class |
DelegateInvoker<T>
DelegateInvoker
|
class |
MockInvoker<T> |
| 限定符和类型 | 方法和说明 |
|---|---|
Invoker<T> |
DelegateExporter.getInvoker() |
<T> Invoker<T> |
MockProtocol.refer(Class<T> type,
URL url) |
| 限定符和类型 | 方法和说明 |
|---|---|
<T> Exporter<T> |
MockProtocol.export(Invoker<T> invoker) |
| 构造器和说明 |
|---|
DelegateInvoker(Invoker<T> invoker) |
| 限定符和类型 | 方法和说明 |
|---|---|
Result |
ValidationFilter.invoke(Invoker<?> invoker,
Invocation invocation) |
Copyright © 2012–2017 Alibaba. All rights reserved.