| 程序包 | 说明 |
|---|---|
| com.alipay.remoting | |
| com.alipay.remoting.rpc | |
| com.alipay.remoting.rpc.protocol |
| 限定符和类型 | 方法和说明 |
|---|---|
UserProcessor<?> |
RemotingContext.getUserProcessor(String className)
Get user processor for class name.
|
| 限定符和类型 | 方法和说明 |
|---|---|
void |
ConnectionFactory.registerUserProcessor(UserProcessor<?> processor)
Register User processor
|
abstract void |
RemotingServer.registerUserProcessor(UserProcessor<?> processor)
Register user processor.
|
| 构造器和说明 |
|---|
RemotingContext(io.netty.channel.ChannelHandlerContext ctx,
boolean serverSide,
ConcurrentHashMap<String,UserProcessor<?>> userProcessors)
Constructor.
|
RemotingContext(io.netty.channel.ChannelHandlerContext ctx,
InvokeContext invokeContext,
boolean serverSide,
ConcurrentHashMap<String,UserProcessor<?>> userProcessors)
Constructor.
|
| 限定符和类型 | 方法和说明 |
|---|---|
void |
RpcConnectionFactory.registerUserProcessor(UserProcessor<?> processor) |
void |
RpcServer.registerUserProcessor(UserProcessor<?> processor) |
void |
RpcClient.registerUserProcessor(UserProcessor<?> processor)
Register user processor for client side.
|
| 构造器和说明 |
|---|
RpcHandler(boolean serverSide,
ConcurrentHashMap<String,UserProcessor<?>> userProcessors) |
RpcHandler(ConcurrentHashMap<String,UserProcessor<?>> userProcessors) |
| 限定符和类型 | 类和说明 |
|---|---|
class |
AbstractUserProcessor<T>
Implements common function and provide default value.
|
class |
AsyncUserProcessor<T>
Extends this to process user defined request in ASYNC way.
|
class |
SyncUserProcessor<T>
Extends this to process user defined request in SYNC way.
|
Copyright © 2018. All rights reserved.