番石榴事件总线内存限制

Question

我用一个订阅者实现了一个单例EventBus。我的应用程序有很多生产者（任何请求都可以是生产者）。

@Bean
public EventBus eventBus() {
    EventBus eventBus = new EventBus();
    eventBus.register(new MyEventHandler());
    return eventBus;
}

我找不到如何为EventBus设置事件数限制（如何为EventBus设置内存限制），以及如果生成的事件数大于EventBus容量会发生什么。

我想抛出一个异常来记录失败。

Answer 1

无需设置内存限制。它是安全的，因为EventBus是无状态工作的。

在单个线程中，每次EventBus.post（）完成后，EventBus都会清理事件队列，因此在单个线程中是安全的。

在多线程中，EventBus为每个线程使用独立的事件队列。