Guava EventBus：如何从事件处理程序返回结果

Question

我有一个web服务，它从另一个系统接收xml事件，使用特定的工作流处理它们，并将潜在错误列表作为HTTP响应发送回。

事件处理工作流由几个使用Guava的EventBus实现的处理程序（例如：预处理器、持久器和验证器）组成。处理程序相互发送事件。类似这样：

public class RequestHandler {

    @RequestMapping
    public Errors handleRequest(String xmlData) {
        eventBus.post(new XmlReceivedEvent(xmlData));
        ...
        return errors; // how to get errors object from the last handler in chain ? 
    }
}

public class Preprocessor {

    @Subscribe
    public void onXmlReceived(XmlReceivedEvent event) {
       // do some pre-processing
       ...  
       eventBus.post(new PreprocessingCompleteEvent(preprocessingResult)); 
    }
}

public class Persister {

    @Subscribe
    public void onPreprocessingComplete(PreprocessingCompleteEvent event) {
       // do some persistence stuff
       ...    
       eventBus.post(new PersistenceCompleteEvent(persistenceResult)); 
    }
}

public class Validator {

    @Subscribe
    public void onPersistenceComplete(PersistenceCompleteEvent event) {
       // do validation
       ...    
       eventBus.post(new ValidationCompleteEvent(errors)); // errors object created, should be returned back to the RequestHandler 
    }
}

问题是：如何将处理结果从Validator处理程序深度返回到起点（Request estHandler），以便用户接收HTTP响应？

我考虑两种选择：

>

public class RequestHandler {

    @RequestMapping
    public Errors handleRequest(String xmlData) {
        XmlReceivedEvent event = new XmlReceivedEvent(xmlData);
        eventBus.post(event);
        ...
        return event.getErrors(); 
    }
}

但是，在这种情况下，我必须将错误对象传递给链中的每个事件，以使Validator可以使用真实数据填充它。

>

从Validator订阅Request estHandler到ValidationCompleteEvent，其中包含填充的错误对象。

public class RequestHandler {

    private Errors errors;

    @RequestMapping
    public Errors handleRequest(String xmlData) {
        XmlReceivedEvent event = new XmlReceivedEvent(xmlData);
        eventBus.post(event);
        ...
        return this.errors; // ??? 
    }

    @Subscribe
    public void onValidationComplete(ValidationCompleteEvent event) {
        this.errors = event.getErrors();
    }
}

但不幸的是，RequestHandler是一个Spring无状态服务（singleton），所以我希望避免在类字段中保存任何数据。

欣赏任何想法。

Answer 1

如果您想要这样的工作流，您不应该为此使用GuavaEventBus。EventBus专门用于允许将事件发布给订阅者，而事件发帖人不知道或关心这些订阅者是什么...因此，您不能将订阅者的结果返回给事件发帖人。

在我看来，您应该在这里做一些更简单的事情，比如注入预处理器、持久器和验证器，并直接调用它们的方法。