类的使用
com.iohao.game.action.skeleton.eventbus.EventBusMessage
程序包
说明
分布式事件总线相关文档,分布式事件总线与 Guava EventBus、Redis 发布订阅、MQ 等产品类似。
逻辑服 - processor 用于接收 Broker(游戏网关)的消息处理器。
-
com.iohao.game.action.skeleton.eventbus中EventBusMessage的使用
修饰符和类型方法说明void
EventBusListener.emptySubscribe
(EventBusMessage eventBusMessage, EventBus eventBus) 事件消息没有对应的订阅者时,触发的监听回调void
EventBus.fire
(EventBusMessage eventBusMessage) [异步] 发送事件给所有订阅者void
EventBus.fireAny
(EventBusMessage eventBusMessage) [异步] 给当前进程的订阅者和远程进程的订阅者送事件消息,如果同类型逻辑服存在多个,只会给其中一个实例发送。void
EventBus.fireAnySync
(EventBusMessage eventBusMessage) [同步] 给当前进程的订阅者和远程进程的订阅者送事件消息,如果同类型逻辑服存在多个,只会给其中一个实例发送。void
EventBus.fireLocal
(EventBusMessage eventBusMessage) [异步] 给当前进程所有逻辑服的订阅者发送事件消息void
EventBus.fireLocalNeighbor
(EventBusMessage eventBusMessage) [异步] 给当前进程其他逻辑服的订阅者发送事件消息,不包括当前 EventBus。void
EventBus.fireLocalNeighborSync
(EventBusMessage eventBusMessage) [同步] 给当前进程其他逻辑服的订阅者发送事件消息,不包括当前 EventBus。void
EventBus.fireLocalSync
(EventBusMessage eventBusMessage) [同步] 给当前进程所有逻辑服的订阅者发送事件消息void
EventBus.fireMe
(EventBusMessage eventBusMessage) [异步] 仅给当前 EventBus 的订阅者发送事件消息void
EventBus.fireMeSync
(EventBusMessage eventBusMessage) [同步] 仅给当前 EventBus 的订阅者发送事件消息void
EventBus.fireSync
(EventBusMessage eventBusMessage) [同步] 发送事件给所有订阅者void
SubscriberInvoke.invoke
(EventBusMessage eventBusMessage) 执行订阅者方法void
EventBusListener.invokeException
(Throwable e, Object eventSource, EventBusMessage eventBusMessage) 订阅者异常处理EventBus.listSubscriber
(EventBusMessage eventBusMessage) 事件消息所对应的订阅者SubscribeExecutorStrategy.select
(Subscriber subscriber, EventBusMessage eventBusMessage, ExecutorRegion executorRegion) 得到对应的线程执行器 -
com.iohao.game.bolt.broker.client.processor中EventBusMessage的使用
修饰符和类型方法说明void
EventBusMessageClientProcessor.handleRequest
(com.alipay.remoting.BizContext bizCtx, com.alipay.remoting.AsyncContext asyncCtx, EventBusMessage eventBusMessage) -
com.iohao.game.bolt.broker.server.processor中EventBusMessage的使用
修饰符和类型方法说明void
EventBusMessageBrokerProcessor.handleRequest
(com.alipay.remoting.BizContext bizCtx, com.alipay.remoting.AsyncContext asyncCtx, EventBusMessage eventBusMessage)