用LOL获得BUFF场景来看待Guava之事件总线

栗子

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);
    }
}
           

结果：

应用场景

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());
}
           

与Spring结合使用

@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);