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