程序包 com.iohao.game.bolt.broker.client.processor

类 RequestMessageClientProcessor

java.lang.Object

com.alipay.remoting.AbstractLifeCycle

com.alipay.remoting.rpc.protocol.AbstractUserProcessor<RequestMessage>

com.alipay.remoting.rpc.protocol.AsyncUserProcessor<RequestMessage>

com.iohao.game.bolt.broker.core.common.AbstractAsyncUserProcessor<RequestMessage>

com.iohao.game.bolt.broker.client.processor.RequestMessageClientProcessor

所有已实现的接口:

com.alipay.remoting.LifeCycle, com.alipay.remoting.rpc.protocol.UserProcessor<RequestMessage>, BrokerClientAware, UserProcessorExecutorAware, UserProcessorExecutorSelectorAware, UserProcessorInNettyThreadAware

public class RequestMessageClientProcessor
extends AbstractAsyncUserProcessor<RequestMessage>
implements BrokerClientAware, UserProcessorExecutorSelectorAware

客户端请求处理器

     通过业务框架把请求派发给指定的业务类来处理
 

作者:

渔民小镇

日期:

2022-05-14

嵌套类概要

从接口继承的嵌套类/接口 com.alipay.remoting.rpc.protocol.UserProcessor

com.alipay.remoting.rpc.protocol.UserProcessor.ExecutorSelector

字段概要

从类继承的字段 com.alipay.remoting.rpc.protocol.AbstractUserProcessor

executorSelector

构造器概要

构造器

构造器	说明
RequestMessageClientProcessor()

方法概要

修饰符和类型	方法	说明
void	handleRequest(com.alipay.remoting.BizContext bizCtx, com.alipay.remoting.AsyncContext asyncCtx, RequestMessage request)
String	interest()
void	setBrokerClient(BrokerClient brokerClient)	set BoltBrokerClient
void	setUserProcessorExecutorSelector(UserProcessorExecutorSelectorStrategy executorSelector)

从类继承的方法 com.iohao.game.bolt.broker.core.common.AbstractAsyncUserProcessor

getExecutor, getUserProcessorExecutor, inNettyThreadExecute, processInIOThread, setInNettyThread, setUserProcessorExecutor

从类继承的方法 com.alipay.remoting.rpc.protocol.AsyncUserProcessor

handleRequest

从类继承的方法 com.alipay.remoting.rpc.protocol.AbstractUserProcessor

getBizClassLoader, getExecutorSelector, preHandleRequest, setExecutorSelector, timeoutDiscard

从类继承的方法 com.alipay.remoting.AbstractLifeCycle

ensureStarted, isStarted, shutdown, startup

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 com.alipay.remoting.LifeCycle

isStarted, shutdown, startup

构造器详细资料

RequestMessageClientProcessor

public RequestMessageClientProcessor()

方法详细资料

handleRequest

public void handleRequest(com.alipay.remoting.BizContext bizCtx,
 com.alipay.remoting.AsyncContext asyncCtx,
 RequestMessage request)

指定者:

handleRequest 在接口中 com.alipay.remoting.rpc.protocol.UserProcessor<RequestMessage>

指定者:

handleRequest 在类中 com.alipay.remoting.rpc.protocol.AsyncUserProcessor<RequestMessage>

setBrokerClient

public void setBrokerClient(BrokerClient brokerClient)

从接口复制的说明: BrokerClientAware

set BoltBrokerClient

指定者:

setBrokerClient 在接口中 BrokerClientAware

参数:

brokerClient - BoltBrokerClient

interest

public String interest()

指定者:

interest 在接口中 com.alipay.remoting.rpc.protocol.UserProcessor<RequestMessage>

指定者:

interest 在类中 com.alipay.remoting.rpc.protocol.AsyncUserProcessor<RequestMessage>

setUserProcessorExecutorSelector

public void setUserProcessorExecutorSelector(UserProcessorExecutorSelectorStrategy executorSelector)

指定者:

setUserProcessorExecutorSelector 在接口中 UserProcessorExecutorSelectorAware