public class TestPreconditions {
static class Listener {
@Subscribe
public void listen(String eventData) {
System.out.println("接收到事件数据:" + eventData);
}
@Subscribe
public void listen(Integer eventData) {
System.out.println("接收到事件int数据:" + eventData);
}
}
public static void main(String[] args) {
EventBus bus = new EventBus();
bus.register(new Listener());
bus.post("这是事件数据!");
bus.post(123456);
}
}
结果:
我们假设你需要设计一个lol里面各种英雄获得buff的处理,你就可以采用如下代码
public class TestLolBuff {
//蓝buff
static class BlueBuff {
}
//红buff
static class RedBuff {
}
//小龙buff
static class DragonetBuff {
}
//大龙buff
static class BaronBuff {
}
static class Listener {
@Subscribe
public void listen(BlueBuff eventData) {
System.out.println("我得到了蓝buff:");
}
@Subscribe
public void listen(RedBuff eventData) {
System.out.println("我得到了红buff:");
}
@Subscribe
public void listen(DragonetBuff eventData) {
System.out.println("我得到了小龙buff:");
}
@Subscribe
public void listen(BaronBuff eventData) {
System.out.println("我得到了大龙buff:");
}
}
public static void main(String[] args) {
EventBus bus = new EventBus();
bus.register(new Listener());
bus.post(new DragonetBuff());
}
}
输出:
public static void main(String[] args) {
AsyncEventBus bus = new AsyncEventBus();
bus.register(new Listener());
bus.post(new DragonetBuff());
}
每次都new AsyncEventBus();这种方式为免有点太low,可以使用@Bean
注解构建一个Bean对象
@Component
public class AsyncEventBusBean {
@Bean
public AsyncEventBus asyncEventBus() {
AsyncEventBus eventBus = new AsyncEventBus(Executors.newFixedThreadPool(10));
eventBus.register(new xxx());
return eventBus;
}
}
@Autowired
private AsyncEventBus asyncEventBus;
asyncEventBus.post(xxx);
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。