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

使用Invocation的程序包

程序包	说明
org.apache.dubbo.rpc
org.apache.dubbo.rpc.filter
org.apache.dubbo.rpc.filter.tps
org.apache.dubbo.rpc.listener
org.apache.dubbo.rpc.protocol
org.apache.dubbo.rpc.proxy
org.apache.dubbo.rpc.support

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

实现Invocation的org.apache.dubbo.rpc中的类

修饰符和类型	类	说明
class	RpcInvocation	RPC Invocation.

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

修饰符和类型	方法	说明
Invocation	RpcContext.getInvocation()	已过时。 Replace to getMethodName(), getParameterTypes(), getArguments()

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

修饰符和类型	方法	说明
void	ListenableFilter.addListener(Invocation invocation, Filter.Listener listener)
String	ZoneDetector.getZoneOfCurrentRequest(Invocation invocation)
Result	Filter.invoke(Invoker<?> invoker, Invocation invocation)	Make sure call invoker.invoke() in your implementation.
Result	Invoker.invoke(Invocation invocation)	invoke.
String	ZoneDetector.isZoneForcingEnabled(Invocation invocation, String zone)
Filter.Listener	ListenableFilter.listener(Invocation invocation)
static AsyncRpcResult	AsyncRpcResult.newDefaultAsyncResult(Object value, Throwable t, Invocation invocation)
static AsyncRpcResult	AsyncRpcResult.newDefaultAsyncResult(Object value, Invocation invocation)
static AsyncRpcResult	AsyncRpcResult.newDefaultAsyncResult(Throwable t, Invocation invocation)
static AsyncRpcResult	AsyncRpcResult.newDefaultAsyncResult(AppResponse appResponse, Invocation invocation)	Some utility methods used to quickly generate default AsyncRpcResult instance.
static AsyncRpcResult	AsyncRpcResult.newDefaultAsyncResult(Invocation invocation)
void	Filter.Listener.onError(Throwable t, Invoker<?> invoker, Invocation invocation)
void	Filter.Listener.onResponse(Result appResponse, Invoker<?> invoker, Invocation invocation)
void	ListenableFilter.removeListener(Invocation invocation)
RpcContext	RpcContext.setInvocation(Invocation invocation)

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

构造器	说明
AppResponse(Invocation invocation)
AsyncRpcResult(CompletableFuture<AppResponse> future, Invocation invocation)
RpcInvocation(Invocation invocation)
RpcInvocation(Invocation invocation, Invoker<?> invoker)

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

参数类型为Invocation的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	ClassLoaderFilter.invoke(Invoker<?> invoker, Invocation invocation)
Result	CompatibleFilter.invoke(Invoker<?> invoker, Invocation invocation)
Result	ConsumerContextFilter.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	TimeoutFilter.invoke(Invoker<?> invoker, Invocation invocation)
Result	TokenFilter.invoke(Invoker<?> invoker, Invocation inv)
Result	TpsLimitFilter.invoke(Invoker<?> invoker, Invocation invocation)
void	ActiveLimitFilter.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	TimeoutFilter.onError(Throwable t, Invoker<?> invoker, Invocation invocation)
void	ActiveLimitFilter.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	TimeoutFilter.onResponse(Result appResponse, Invoker<?> invoker, Invocation invocation)

org.apache.dubbo.rpc.filter.tps中Invocation的使用

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

修饰符和类型	方法	说明
boolean	DefaultTPSLimiter.isAllowable(URL url, Invocation invocation)
boolean	TPSLimiter.isAllowable(URL url, Invocation invocation)	judge if the current invocation is allowed by TPS rule

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

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

修饰符和类型	方法	说明
Result	ListenerInvokerWrapper.invoke(Invocation invocation)

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

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

修饰符和类型	方法	说明
Result	AbstractInvoker.invoke(Invocation inv)
Result	AsyncToSyncInvoker.invoke(Invocation invocation)
Result	InvokerWrapper.invoke(Invocation invocation)

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

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

修饰符和类型	方法	说明
Result	AbstractProxyInvoker.invoke(Invocation invocation)

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

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

修饰符和类型	方法	说明
static void	RpcUtils.attachInvocationIdIfAsync(URL url, Invocation inv)	Idempotent operation: invocation id will be added in async operation by default
void	AccessLogData.buildAccessLogData(Invoker<?> invoker, Invocation inv)
static Object[]	RpcUtils.getArguments(Invocation invocation)
static Long	RpcUtils.getInvocationId(Invocation inv)
static InvokeMode	RpcUtils.getInvokeMode(URL url, Invocation inv)
static String	RpcUtils.getMethodName(Invocation invocation)
static Class<?>[]	RpcUtils.getParameterTypes(Invocation invocation)
static Class<?>	RpcUtils.getReturnType(Invocation invocation)
static Type[]	RpcUtils.getReturnTypes(Invocation invocation)
static long	RpcUtils.getTimeout(Invocation invocation, long defaultTimeout)
Result	MockInvoker.invoke(Invocation invocation)
static boolean	RpcUtils.isAsync(URL url, Invocation inv)
static boolean	RpcUtils.isGenericAsync(Invocation inv)
static boolean	RpcUtils.isOneway(URL url, Invocation inv)
static boolean	RpcUtils.isReturnTypeFuture(Invocation inv)