程序包 com.iohao.game.bolt.broker.core.common

类 AbstractAsyncUserProcessor<T>

java.lang.Object
com.alipay.remoting.AbstractLifeCycle
com.alipay.remoting.rpc.protocol.AbstractUserProcessor<T>
com.alipay.remoting.rpc.protocol.AsyncUserProcessor<T>
com.iohao.game.bolt.broker.core.common.AbstractAsyncUserProcessor<T>
所有已实现的接口:
com.alipay.remoting.LifeCycle, com.alipay.remoting.rpc.protocol.UserProcessor<T>, UserProcessorExecutorAware, UserProcessorInNettyThreadAware
直接已知子类:
BroadcastMessageBrokerProcessor, BroadcastMessageExternalProcessor, BrokerClientItemConnectMessageBrokerProcessor, BrokerClientOfflineMessageExternalProcessor, BrokerClientOnlineMessageExternalProcessor, EndPointLogicServerMessageBrokerProcessor, EndPointLogicServerMessageExternalProcessor, EventBusMessageBrokerProcessor, EventBusMessageClientProcessor, InnerModuleMessageBrokerProcessor, InnerModuleRequestCollectExternalMessageBrokerProcessor, InnerModuleRequestCollectMessageBrokerProcessor, InnerModuleVoidMessageBrokerProcessor, PulseSignalRequestBrokerProcessor, PulseSignalRequestUserProcessor, PulseSignalResponseBrokerProcessor, PulseSignalResponseUserProcessor, RequestCollectExternalMessageExternalProcessor, RequestMessageBrokerProcessor, RequestMessageClientProcessor, ResponseMessageBrokerProcessor, ResponseMessageExternalProcessor, SettingUserIdMessageBrokerProcessor, SettingUserIdMessageExternalProcessor
public abstract class AbstractAsyncUserProcessor<T> extends com.alipay.remoting.rpc.protocol.AsyncUserProcessor<T> implements UserProcessorExecutorAware
AsyncUserProcessor 父类
作者:
渔民小镇
日期:
2022-11-10

  • 嵌套类概要

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

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

  • 字段概要

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

    executorSelector

  • 构造器概要

    构造器
    构造器
    说明
    AbstractAsyncUserProcessor()
     

  • 方法概要

    修饰符和类型
    方法
    说明
    Executor
    getExecutor()
     
    Executor
    getUserProcessorExecutor()
    get UserProcessor Executor
    boolean
    inNettyThreadExecute()
    是否在执行 netty handler 的线程中执行业务
    boolean
    processInIOThread()
     
    void
    setInNettyThread(boolean inNettyThread)
    消费业务请求的线程
    void
    setUserProcessorExecutor(Executor executor)
    set UserProcessor Executor

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

    handleRequest, handleRequest, interest

    从类继承的方法 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

  • 构造器详细资料

    • AbstractAsyncUserProcessor

      public AbstractAsyncUserProcessor()

  • 方法详细资料

    • getExecutor

      public Executor getExecutor()
      指定者:
      getExecutor 在接口中 com.alipay.remoting.rpc.protocol.UserProcessor<T>
      覆盖:
      getExecutor 在类中 com.alipay.remoting.rpc.protocol.AbstractUserProcessor<T>

    • getUserProcessorExecutor

      public Executor getUserProcessorExecutor()
      从接口复制的说明: UserProcessorExecutorAware
      get UserProcessor Executor
      指定者:
      getUserProcessorExecutor 在接口中 UserProcessorExecutorAware
      返回:
      Executor

    • setUserProcessorExecutor

      public void setUserProcessorExecutor(Executor executor)
      从接口复制的说明: UserProcessorExecutorAware
      set UserProcessor Executor
      指定者:
      setUserProcessorExecutor 在接口中 UserProcessorExecutorAware
      参数:
      executor - Executor

    • setInNettyThread

      public void setInNettyThread(boolean inNettyThread)
      从接口复制的说明: UserProcessorInNettyThreadAware
      消费业务请求的线程 
           默认使用执行 netty handler 的线程中执行业务

     相关源码
     RpcHandler
     RpcRequestProcessor.process(RemotingContext, RpcRequestCommand, ExecutorService)
      指定者:
      setInNettyThread 在接口中 UserProcessorInNettyThreadAware
      参数:
      inNettyThread - true 表示在 netty 中执行业务

    • inNettyThreadExecute

      public boolean inNettyThreadExecute()
      从接口复制的说明: UserProcessorInNettyThreadAware
      是否在执行 netty handler 的线程中执行业务
      指定者:
      inNettyThreadExecute 在接口中 UserProcessorInNettyThreadAware
      返回:
      true 表示在执行 netty handler 的线程中执行业务

    • processInIOThread

      public boolean processInIOThread()
      指定者:
      processInIOThread 在接口中 com.alipay.remoting.rpc.protocol.UserProcessor<T>
      覆盖:
      processInIOThread 在类中 com.alipay.remoting.rpc.protocol.AbstractUserProcessor<T>