使用Spring IoC在Guava EventBus中自动注册beans

Question

假设我的应用程序中有一个语言更改事件接口（它基于Vaadin）：

public interface ILanguageChangeListener{
    @Subscribe onLanguageChange(LanguageChangeEvent event);
}

我有很多bean实现了这个用@Component注释的接口，因此它们在Spring IoC中可用。我还有一个活动巴士豆：

<bean id="languageSwitcher" class="com.google.common.eventbus" scope="session" />

现在，在从IoC获取任何bean的实例后，我还必须获取语言Switcher的实例并在其中注册新创建的bean：

languageSwitcher.register(myNewBean);

以便接收该事件。是否有可能以某种方式告诉IoC，我想在实现ILanguageChangeListener的每个新bean上调用languageSwitcher bean的register方法？

Answer 1

为事件总线使用工厂bean，并在上下文中注入所有ILanguageChangeListener bean的列表。

public class EventBusFactoryBean implements FactoryBean<EventBus> {

    @Autowired
    private List<ILanguageChangeListener> languageChangeListeners;

    private EventBus instance;

    @PostConstruct
    public void init() {

        this.instance = new EventBus();

        for (ILanguageChangeListener listener : this.languageChangeListeners) {
            this.instance.register(listener);
        }
    }

    public EventBusFactoryBean() {

    }

    public EventBus getObject() throws Exception {
        return this.instance;
    }

    public Class<?> getObjectType() {
        return EventBus.class;
    }

    public boolean isSingleton() {
        return true;
    }

    public List<ILanguageChangeListener> getLanguageChangeListeners() {
        return languageChangeListeners;
    }

    public void setLanguageChangeListeners(
            List<ILanguageChangeListener> languageChangeListeners) {
        this.languageChangeListeners = languageChangeListeners;
    }

}

然后在Spring Bean定义文件中定义您的bean或使用@Component对其进行注释

Answer 2

IMO，它甚至更好（耦合更少），而不是实现标记接口，使用类级注释来标记应该注册的bean。这是修改后的bean后处理器代码：

public class EventBusListenersRegistererBeanPostProcessor implements BeanPostProcessor{

    Logger log = LoggerFactory.getLogger(this.getClass());

    @Inject
    private EventBus bus;

    @Override
    public Object postProcessBeforeInitialization(Object bean, String beanName) throws BeansException {
        return bean;
    }

    @Override
    public Object postProcessAfterInitialization(Object bean, String beanName) throws BeansException {
        if(bean.getClass().isAnnotationPresent(RegisterWithEventBus.class)){
            log.info("Event Bus is registering bean named \"{}\" of class {}.", beanName, bean.getClass().getCanonicalName());
            bus.register(bean);
        }

        return bean;
    }
}

还有注解:

@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.TYPE)
@Inherited // important when working with dynamically generated proxies i.e. CGLib
public @interface RegisterWithEventBus {}

请注意，注释接口具有@Inherited元注释。这在使用CGLIB代理的Spring应用程序中是必要的，因为注释不是在对象的实际(动态)类上，而是在父类上。

Answer 3

好，使用一个BeanPostProcessor，注册接口的每个bean:

public class EventBusRegisterBeanPostProcessor implements BeanPostProcessor,
        ApplicationContextAware {

    private ApplicationContext context;

    @Autowired
    private EventBus eventBus; // The only event bus i assume...

    public Object postProcessBeforeInitialization(Object bean, String beanName)
            throws BeansException {

        return bean;
    }

    public Object postProcessAfterInitialization(Object bean, String beanName)
            throws BeansException {

        if (bean instanceof ILanguageChangeListener) {
            registerToEventBus(bean);
        }

        return bean;
    }

    private void registerToEventBus(Object bean) {
        this.eventBus.register(bean);
    }

    public void setApplicationContext(ApplicationContext applicationContext)
            throws BeansException {
        this.context = applicationContext;
    }

}

请注意，如果您有许多事件总线字节，则应使用应用程序上下文.getBean（字符串）来获取所需的事件总线。

我引用javadoc：

对于FactoryBean，将为FactoryBean实例和由FactoryBean创建的对象调用此回调(从Spring 2.0开始)。后处理器可以通过FactoryBean检查的相应Bean实例来决定是应用于FactoryBean还是创建的对象，或者同时应用于两者。