我将在不久的将来开始一个小型 Java（真的是 GWT）项目，我正处于“信息收集”阶段。
问：有没有用 Java 编写的轻量级消息总线库？
我的要求也是轻量级的 :-)
更新：GWT现在似乎支持集成"event bus"。
【问题讨论】：
【讨论】：
我知道这是一个老问题，但我认为更现代的解决方案是使用 Guava's Event Bus （当然我不确定它是否适用于 GWT，但您的标题和标签都没有不要说 GWT）。
我实际上有一个自定义的RabbitMQ simple message container，它会自动创建队列绑定，然后收到的消息将分派到 Guava EventBus。它令人难以置信的优雅，并且可扩展性极佳。
您可以轻松地使用您的 DI 框架来注册订阅者。对于 Spring，我创建了 BeanPostProcessor，它将自动向 @Subscribe 注册 bean。
下面是 Spring BeanPostProcessor：
package com.snaphop.spring;
import java.lang.reflect.Method;
import org.springframework.beans.BeansException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.config.BeanPostProcessor;
import org.springframework.stereotype.Component;
import com.google.common.eventbus.EventBus;
import com.google.common.eventbus.Subscribe;
@Component
public class EventBusBeanPostProcessor implements BeanPostProcessor {
private EventBus eventBus;
@Override
public Object postProcessBeforeInitialization(Object bean, String beanName) throws BeansException {
if (isApplicable(bean)) {
eventBus.register(bean);
}
return bean;
}
@Override
public Object postProcessAfterInitialization(Object bean, String beanName) throws BeansException {
return bean;
}
protected boolean isApplicable(Object bean) {
for(Method m : bean.getClass().getMethods()) {
if (m.isAnnotationPresent(Subscribe.class))
return true;
}
return false;
}
@Autowired
public void setEventBus(EventBus eventBus) {
this.eventBus = eventBus;
}
}
我确信在 Guice 中做类似的事情是微不足道的。
【讨论】：
如果您碰巧已经在使用 Spring，那么 Spring 的一个方便的隐藏功能是 ApplicationEventMulticaster 接口，这是一个非常简单的 API，用于发布和订阅应用程序生成的事件。这些实现使用TaskExecutor 框架，这意味着它们可以根据需要同步或异步。此外，每个 ApplicationContext 都有一个 publishEvent 方法，因此为 Spring 管理的类设置它非常容易。
所以是的，如果您已经使用 Spring，则无需其他实用程序来执行此操作，它已经内置了。
【讨论】：
不确定它是否真的很轻。但它确实符合您的其余描述：ActiveMQ
【讨论】：
也许您可以尝试一些基于 jabber (XMPP) 的解决方案。开火呢？
【讨论】：