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

类 BrokerClusterMessageClientProcessor

java.lang.Object
com.alipay.remoting.AbstractLifeCycle
com.alipay.remoting.rpc.protocol.AbstractUserProcessor<BrokerClusterMessage>
com.alipay.remoting.rpc.protocol.AsyncUserProcessor<BrokerClusterMessage>
com.iohao.game.bolt.broker.client.processor.BrokerClusterMessageClientProcessor
所有已实现的接口:
com.alipay.remoting.LifeCycle, com.alipay.remoting.rpc.protocol.UserProcessor<BrokerClusterMessage>, BrokerClientAware
public class BrokerClusterMessageClientProcessor extends com.alipay.remoting.rpc.protocol.AsyncUserProcessor<BrokerClusterMessage> implements BrokerClientAware
集群消息请求处理器 
     如果有新的 broker （游戏网关）加入集群，逻辑服会通过这个请求处理器来接收消息
     逻辑服（对外服和游戏逻辑服）接收到这个消息后，可根据传入的集群消息来建立连接
作者:
渔民小镇
日期:
2022-05-15

  • 嵌套类概要

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

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

  • 字段概要

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

    executorSelector

  • 构造器概要

    构造器
    构造器
    说明
    BrokerClusterMessageClientProcessor()
     

  • 方法概要

    修饰符和类型
    方法
    说明
    Executor
    getExecutor()
     
    void
    handleRequest(com.alipay.remoting.BizContext bizCtx, com.alipay.remoting.AsyncContext asyncCtx, BrokerClusterMessage message)
     
    String
    interest()
     

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

    handleRequest

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

    getBizClassLoader, getExecutorSelector, preHandleRequest, processInIOThread, 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.iohao.game.bolt.broker.core.aware.BrokerClientAware

    setBrokerClient

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

    isStarted, shutdown, startup

  • 构造器详细资料

    • BrokerClusterMessageClientProcessor

      public BrokerClusterMessageClientProcessor()

  • 方法详细资料

    • getExecutor

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

    • handleRequest

      public void handleRequest(com.alipay.remoting.BizContext bizCtx, com.alipay.remoting.AsyncContext asyncCtx, BrokerClusterMessage message)
      指定者:
      handleRequest 在接口中 com.alipay.remoting.rpc.protocol.UserProcessor<BrokerClusterMessage>
      指定者:
      handleRequest 在类中 com.alipay.remoting.rpc.protocol.AsyncUserProcessor<BrokerClusterMessage>

    • interest

      public String interest()
      指定者:
      interest 在接口中 com.alipay.remoting.rpc.protocol.UserProcessor<BrokerClusterMessage>
      指定者:
      interest 在类中 com.alipay.remoting.rpc.protocol.AsyncUserProcessor<BrokerClusterMessage>