接口的使用
org.apache.dubbo.rpc.Invoker

使用Invoker的程序包

程序包	说明
org.apache.dubbo.rpc
org.apache.dubbo.rpc.filter
org.apache.dubbo.rpc.listener
org.apache.dubbo.rpc.protocol
org.apache.dubbo.rpc.proxy
org.apache.dubbo.rpc.proxy.javassist
org.apache.dubbo.rpc.proxy.jdk
org.apache.dubbo.rpc.proxy.wrapper
org.apache.dubbo.rpc.stub
org.apache.dubbo.rpc.support

org.apache.dubbo.rpc中Invoker的使用

返回Invoker的org.apache.dubbo.rpc中的方法

修饰符和类型	方法	说明
Invoker<T>	Exporter.getInvoker()	get invoker.
Invoker<?>	Invocation.getInvoker()	get the invoker in current context.
<T> Invoker<T>	ProxyFactory.getInvoker(T proxy, Class<T> type, URL url)	create invoker.
Invoker<?>	RpcContext.getInvoker()	已过时。 Replace to getUrl()
Invoker<?>	RpcInvocation.getInvoker()
Invoker<?>	RpcServiceContext.getInvoker()	已过时。 Replace to getUrl()
Invoker<T>	ServerService.getInvoker(URL url)
<T> Invoker<T>	Protocol.refer(Class<T> type, URL url)	Refer a remote service: 1.
Invoker<?>	PathResolver.resolve(String path)

返回变量类型为Invoker的类型的org.apache.dubbo.rpc中的方法

修饰符和类型	方法	说明
List<Invoker<?>>	RpcContext.getInvokers()	已过时。 Replace to getUrls()
List<Invoker<?>>	RpcServiceContext.getInvokers()	已过时。 Replace to getUrls()

参数类型为Invoker的org.apache.dubbo.rpc中的方法

修饰符和类型	方法	说明
void	PathResolver.add(String path, Invoker<?> invoker)
void	InvokerListener.destroyed(Invoker<?> invoker)	The invoker destroyed.
<T> Exporter<T>	Protocol.export(Invoker<T> invoker)	Export service for remote invocation: 1.
<T> T	ProxyFactory.getProxy(Invoker<T> invoker)	create proxy.
<T> T	ProxyFactory.getProxy(Invoker<T> invoker, boolean generic)	create proxy.
Result	BaseFilter.invoke(Invoker<?> invoker, Invocation invocation)	Always call invoker.invoke() in the implementation to hand over the request to the next filter node.
RpcInvocation	HeaderFilter.invoke(Invoker<?> invoker, RpcInvocation invocation)
void	BaseFilter.Listener.onError(Throwable t, Invoker<?> invoker, Invocation invocation)	This method will be called on detection of framework exceptions, for example, TimeoutException, NetworkException Exception raised in Filters, etc.
void	BaseFilter.Listener.onResponse(Result appResponse, Invoker<?> invoker, Invocation invocation)	This method will only be called on successful remote rpc execution, that means, the service in on remote received the request and the result (normal or exceptional) returned successfully.
void	InvokerListener.referred(Invoker<?> invoker)	The invoker referred
RpcContext	RpcContext.setInvoker(Invoker<?> invoker)
void	RpcInvocation.setInvoker(Invoker<?> invoker)
RpcServiceContext	RpcServiceContext.setInvoker(Invoker<?> invoker)

类型变量类型为Invoker的org.apache.dubbo.rpc中的方法参数

修饰符和类型	方法	说明
RpcContext	RpcContext.setInvokers(List<Invoker<?>> invokers)
RpcServiceContext	RpcServiceContext.setInvokers(List<Invoker<?>> invokers)

参数类型为Invoker的org.apache.dubbo.rpc中的构造器

构造器	说明
RpcInvocation(String methodName, String interfaceName, String protocolServiceKey, Class<?>[] parameterTypes, Object[] arguments, Map<String,Object> attachments, Invoker<?> invoker, Map<Object,Object> attributes)	已过时。 deprecated, will be removed in 3.1.x
RpcInvocation(String targetServiceUniqueName, ServiceModel serviceModel, String methodName, String interfaceName, String protocolServiceKey, Class<?>[] parameterTypes, Object[] arguments, Map<String,Object> attachments, Invoker<?> invoker, Map<Object,Object> attributes, InvokeMode invokeMode)	To create a brand-new invocation
RpcInvocation(Invocation invocation, Invoker<?> invoker)	Deep clone of an invocation & put some service params into attachment from invoker (will not change the invoker in invocation)
RpcInvocation(ServiceModel serviceModel, String methodName, String interfaceName, String protocolServiceKey, Class<?>[] parameterTypes, Object[] arguments, Map<String,Object> attachments, Invoker<?> invoker, Map<Object,Object> attributes)	已过时。 deprecated, will be removed in 3.1.x
RpcInvocation(ServiceModel serviceModel, String methodName, String interfaceName, String protocolServiceKey, Class<?>[] parameterTypes, Object[] arguments, Map<String,Object> attachments, Invoker<?> invoker, Map<Object,Object> attributes, InvokeMode invokeMode)	已过时。 deprecated, will be removed in 3.1.x

org.apache.dubbo.rpc.filter中Invoker的使用

参数类型为Invoker的org.apache.dubbo.rpc.filter中的方法

修饰符和类型	方法	说明
Result	AccessLogFilter.invoke(Invoker<?> invoker, Invocation inv)	This method logs the access log for service method invocation call.
Result	ActiveLimitFilter.invoke(Invoker<?> invoker, Invocation invocation)
Result	ClassLoaderCallbackFilter.invoke(Invoker<?> invoker, Invocation invocation)
Result	ClassLoaderFilter.invoke(Invoker<?> invoker, Invocation invocation)
Result	CompatibleFilter.invoke(Invoker<?> invoker, Invocation invocation)
Result	ContextFilter.invoke(Invoker<?> invoker, Invocation invocation)
Result	DeprecatedFilter.invoke(Invoker<?> invoker, Invocation invocation)
Result	EchoFilter.invoke(Invoker<?> invoker, Invocation inv)
Result	ExceptionFilter.invoke(Invoker<?> invoker, Invocation invocation)
Result	ExecuteLimitFilter.invoke(Invoker<?> invoker, Invocation invocation)
Result	GenericFilter.invoke(Invoker<?> invoker, Invocation inv)
Result	GenericImplFilter.invoke(Invoker<?> invoker, Invocation invocation)
Result	ProfilerServerFilter.invoke(Invoker<?> invoker, Invocation invocation)
Result	TimeoutFilter.invoke(Invoker<?> invoker, Invocation invocation)
Result	TokenFilter.invoke(Invoker<?> invoker, Invocation inv)
RpcInvocation	TokenHeaderFilter.invoke(Invoker<?> invoker, RpcInvocation invocation)
Result	TpsLimitFilter.invoke(Invoker<?> invoker, Invocation invocation)
void	ActiveLimitFilter.onError(Throwable t, Invoker<?> invoker, Invocation invocation)
void	ClassLoaderCallbackFilter.onError(Throwable t, Invoker<?> invoker, Invocation invocation)
void	ClassLoaderFilter.onError(Throwable t, Invoker<?> invoker, Invocation invocation)
void	CompatibleFilter.onError(Throwable t, Invoker<?> invoker, Invocation invocation)
void	ContextFilter.onError(Throwable t, Invoker<?> invoker, Invocation invocation)
void	ExceptionFilter.onError(Throwable e, Invoker<?> invoker, Invocation invocation)
void	ExecuteLimitFilter.onError(Throwable t, Invoker<?> invoker, Invocation invocation)
void	GenericFilter.onError(Throwable t, Invoker<?> invoker, Invocation invocation)
void	GenericImplFilter.onError(Throwable t, Invoker<?> invoker, Invocation invocation)
void	ProfilerServerFilter.onError(Throwable t, Invoker<?> invoker, Invocation invocation)
void	TimeoutFilter.onError(Throwable t, Invoker<?> invoker, Invocation invocation)
void	ActiveLimitFilter.onResponse(Result appResponse, Invoker<?> invoker, Invocation invocation)
void	ClassLoaderCallbackFilter.onResponse(Result appResponse, Invoker<?> invoker, Invocation invocation)
void	ClassLoaderFilter.onResponse(Result appResponse, Invoker<?> invoker, Invocation invocation)
void	CompatibleFilter.onResponse(Result appResponse, Invoker<?> invoker, Invocation invocation)
void	ContextFilter.onResponse(Result appResponse, Invoker<?> invoker, Invocation invocation)
void	ExceptionFilter.onResponse(Result appResponse, Invoker<?> invoker, Invocation invocation)
void	ExecuteLimitFilter.onResponse(Result appResponse, Invoker<?> invoker, Invocation invocation)
void	GenericFilter.onResponse(Result appResponse, Invoker<?> invoker, Invocation inv)
void	GenericImplFilter.onResponse(Result appResponse, Invoker<?> invoker, Invocation invocation)
void	ProfilerServerFilter.onResponse(Result appResponse, Invoker<?> invoker, Invocation invocation)
void	TimeoutFilter.onResponse(Result appResponse, Invoker<?> invoker, Invocation invocation)

org.apache.dubbo.rpc.listener中Invoker的使用

实现Invoker的org.apache.dubbo.rpc.listener中的类

修饰符和类型	类	说明
class	ListenerInvokerWrapper<T>	ListenerInvoker

返回Invoker的org.apache.dubbo.rpc.listener中的方法

修饰符和类型	方法	说明
Invoker<T>	ListenerExporterWrapper.getInvoker()
Invoker<T>	ListenerInvokerWrapper.getInvoker()

参数类型为Invoker的org.apache.dubbo.rpc.listener中的方法

修饰符和类型	方法	说明
void	InvokerListenerAdapter.destroyed(Invoker<?> invoker)
void	DeprecatedInvokerListener.referred(Invoker<?> invoker)
void	InvokerListenerAdapter.referred(Invoker<?> invoker)

参数类型为Invoker的org.apache.dubbo.rpc.listener中的构造器

构造器	说明
ListenerInvokerWrapper(Invoker<T> invoker, List<InvokerListener> listeners)

org.apache.dubbo.rpc.protocol中Invoker的使用

实现Invoker的org.apache.dubbo.rpc.protocol中的类

修饰符和类型	类	说明
class	AbstractInvoker<T>	This Invoker works on Consumer side.
class	InvokerWrapper<T>	InvokerWrapper

返回Invoker的org.apache.dubbo.rpc.protocol中的方法

修饰符和类型	方法	说明
Invoker<T>	AbstractExporter.getInvoker()
<T> Invoker<T>	AbstractProtocol.refer(Class<T> type, URL url)
<T> Invoker<T>	ProtocolListenerWrapper.refer(Class<T> type, URL url)
<T> Invoker<T>	ProtocolSerializationWrapper.refer(Class<T> type, URL url)

参数类型为Invoker的org.apache.dubbo.rpc.protocol中的方法

修饰符和类型	方法	说明
<T> Exporter<T>	AbstractProxyProtocol.export(Invoker<T> invoker)
<T> Exporter<T>	ProtocolListenerWrapper.export(Invoker<T> invoker)
<T> Exporter<T>	ProtocolSerializationWrapper.export(Invoker<T> invoker)

参数类型为Invoker的org.apache.dubbo.rpc.protocol中的构造器

构造器	说明
AbstractExporter(Invoker<T> invoker)
InvokerWrapper(Invoker<T> invoker, URL url)

org.apache.dubbo.rpc.proxy中Invoker的使用

实现Invoker的org.apache.dubbo.rpc.proxy中的类

修饰符和类型	类	说明
class	AbstractProxyInvoker<T>	This Invoker works on provider side, delegates RPC to interface implementation.

参数类型为Invoker的org.apache.dubbo.rpc.proxy中的方法

修饰符和类型	方法	说明
<T> T	AbstractProxyFactory.getProxy(Invoker<T> invoker)
<T> T	AbstractProxyFactory.getProxy(Invoker<T> invoker, boolean generic)
abstract <T> T	AbstractProxyFactory.getProxy(Invoker<T> invoker, Class<?>[] types)
static Object	InvocationUtil.invoke(Invoker<?> invoker, RpcInvocation rpcInvocation)

参数类型为Invoker的org.apache.dubbo.rpc.proxy中的构造器

构造器	说明
InvokerInvocationHandler(Invoker<?> handler)

org.apache.dubbo.rpc.proxy.javassist中Invoker的使用

返回Invoker的org.apache.dubbo.rpc.proxy.javassist中的方法

修饰符和类型	方法	说明
<T> Invoker<T>	JavassistProxyFactory.getInvoker(T proxy, Class<T> type, URL url)

参数类型为Invoker的org.apache.dubbo.rpc.proxy.javassist中的方法

修饰符和类型	方法	说明
<T> T	JavassistProxyFactory.getProxy(Invoker<T> invoker, Class<?>[] interfaces)

org.apache.dubbo.rpc.proxy.jdk中Invoker的使用

返回Invoker的org.apache.dubbo.rpc.proxy.jdk中的方法

修饰符和类型	方法	说明
<T> Invoker<T>	JdkProxyFactory.getInvoker(T proxy, Class<T> type, URL url)

参数类型为Invoker的org.apache.dubbo.rpc.proxy.jdk中的方法

修饰符和类型	方法	说明
<T> T	JdkProxyFactory.getProxy(Invoker<T> invoker, Class<?>[] interfaces)

org.apache.dubbo.rpc.proxy.wrapper中Invoker的使用

返回Invoker的org.apache.dubbo.rpc.proxy.wrapper中的方法

修饰符和类型	方法	说明
<T> Invoker<T>	StubProxyFactoryWrapper.getInvoker(T proxy, Class<T> type, URL url)

参数类型为Invoker的org.apache.dubbo.rpc.proxy.wrapper中的方法

修饰符和类型	方法	说明
<T> T	StubProxyFactoryWrapper.getProxy(Invoker<T> invoker)
<T> T	StubProxyFactoryWrapper.getProxy(Invoker<T> invoker, boolean generic)

org.apache.dubbo.rpc.stub中Invoker的使用

实现Invoker的org.apache.dubbo.rpc.stub中的类

修饰符和类型	类	说明
class	StubInvoker<T>

返回Invoker的org.apache.dubbo.rpc.stub中的方法

修饰符和类型	方法	说明
<T> Invoker<T>	StubProxyFactory.getInvoker(T proxy, Class<T> type, URL url)

参数类型为Invoker的org.apache.dubbo.rpc.stub中的方法

修饰符和类型	方法	说明
static <T,R> StreamObserver<T>	StubInvocationUtil.biOrClientStreamCall(Invoker<?> invoker, MethodDescriptor method, StreamObserver<R> responseObserver)
static <T> T	StubSuppliers.createStub(String interfaceName, Invoker<T> invoker)
<T> T	StubProxyFactory.getProxy(Invoker<T> invoker)
<T> T	StubProxyFactory.getProxy(Invoker<T> invoker, boolean generic)
static <T,R> void	StubInvocationUtil.serverStreamCall(Invoker<?> invoker, MethodDescriptor method, T request, StreamObserver<R> responseObserver)
static <T,R> R	StubInvocationUtil.unaryCall(Invoker<?> invoker, MethodDescriptor methodDescriptor, T request)
static <T,R> void	StubInvocationUtil.unaryCall(Invoker<?> invoker, MethodDescriptor method, T request, StreamObserver<R> responseObserver)

类型变量类型为Invoker的org.apache.dubbo.rpc.stub中的方法参数

修饰符和类型	方法	说明
static void	StubSuppliers.addSupplier(String interfaceName, Function<Invoker<?>,Object> supplier)

org.apache.dubbo.rpc.support中Invoker的使用

实现Invoker的org.apache.dubbo.rpc.support中的类

修饰符和类型	类	说明
class	MockInvoker<T>

返回Invoker的org.apache.dubbo.rpc.support中的方法

修饰符和类型	方法	说明
<T> Invoker<T>	MockProtocol.protocolBindingRefer(Class<T> type, URL url)

参数类型为Invoker的org.apache.dubbo.rpc.support中的方法

修饰符和类型	方法	说明
void	AccessLogData.buildAccessLogData(Invoker<?> invoker, Invocation inv)
<T> Exporter<T>	MockProtocol.export(Invoker<T> invoker)