Guava EventBus : 이벤트 처리기에서 결과를 반환하는 방법

Question

다른 시스템에서 XML 이벤트를 수신하고 특정 워크 플로를 사용하여 처리 한 웹 서비스가 있으며 HTTPS 응답으로 잠재적 오류 목록을 다시 보냅니다. Guava's EventBus를 사용하여 구현 :

이벤트 처리 워크 플로우는 여러 핸들러 (처리기,Persister 및 검사기의 말을하자)로 구성되어 있습니다. 핸들러는 서로 이벤트를 보냅니다. 이런 식으로 뭔가 :

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

문제는 다음과 같습니다 방법 시작점 (RequestHandler를)로 다시 검사기 핸들러에서 깊이 처리 결과을 반환하므로 사용자는 HTTP 응답을받을 수 있습니까?

나는 두 가지 옵션을 고려하십시오

1. 설정 오류가 초기 XmlReceivedEvent에 반대하고 완전한 처리 한 후이를 검색 :

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

그러나,이 경우에 내가 통과해야합니다 errors는 Validator에서 실제 데이터로 채울 수 있도록 체인의 각 이벤트에 반대합니다.

1. 는 RequestHandler를로 채워진 에러 검사기로부터 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를은 봄 비 저장 서비스 (싱글), 그래서 클래스 필드에 데이터를 저장하지 않도록하고 싶습니다.

아이디어가 있으면 감사하겠습니다.

Answer 1

이와 같은 워크 플로를 원한다면 Guava EventBus을 사용하지 않아야합니다. EventBus은 이벤트 포스터가 알지 못하거나 구독자가 무엇인지 신경 쓰지 않고 구독자에게 이벤트를 게시 할 수 있도록 특별히 고안되었습니다. 따라서 구독자의 이벤트 포스터에 결과를 반환 할 수 없습니다.

전처리 기, persister 및 유효성 검사기를 주입하고 직접 메소드를 호출하는 것과 같이 훨씬 간단한 작업을 수행해야하는 것처럼 들립니다.