2014-02-19 3 views
0

내 프로젝트의 요구 사항에 따라 사용자 Esper CEP 엔진을 사용하도록 제안되었습니다. 그러나 Esper에 대한 몇 가지 문서를 읽은 후에는 필자의 유스 케이스에 적합하다고 생각하지 않습니다. 아래 요구 사항에 따라 Esper가 어떻게 사용될 수 있는지 설명 할 수 있습니까? - 응용 프로그램 대기열이 있습니다. - 이니시에이터 응용 프로그램이 JMS 메시지를 다음 시스템/응용 프로그램으로 보내고 다음 시스템으로 차례로 보냅니다. 이것은 마지막 시스템이 최종 시스템까지 마침내 반대 방향을 가로 지르는 ack를 보내는 최종 시스템까지 계속됩니다. - 대기열의 다음 시스템으로 메시지를 보내는 동안 각 시스템이 내 응용 프로그램에 메시지 사본을 보냅니다. 마찬가지로 각 시스템의 ack 사본도 내 시스템에서 반품 방식으로받습니다. - 시스템의 각 메시지는 이전 시스템에서 생성 된 메시지와 관련이 있으며 ack도 마찬가지입니다. - 내 시스템의 요구 사항은 메시지의 연결 정보를 사용하여 이러한 모든 메시지와 그 대답을 연결하고 메시지가 누락되거나 수신되지 않았는지 확인하는 것입니다. 은 - 각 메시지 계층 구조 고유 ID 이 - - 내 시스템이 임의의 순서로 메시지를받을 수 있습니다/순서 내 용도는 Esper CEP를 사용하여 구현됩니까

누군가가 나를 도울 수

마찬가지로 시스템 에서받은 원본 메시지와 관련된 수천 개의 메시지가있을 수있다 Esper를 사용하여 메시지를 연결하고 각 메시지 계층 구조에서 누락 된 메시지를 찾는 방법을 이해하십시오.

답변

1

예 패턴 또는 외부 조인 또는 비정상적인 흐름의 존재 여부와 같은 이벤트가없는 것을 Esper에서 쉽게 감지 할 수 있습니다. 샘플은 http://esper.codehaus.org/tutorials/solution_patterns/solution_patterns.html

+0

에 있습니다. 나는 링크를 통해 갔다. 그러나, 내가 뭔가를 놓치고 있는지 확실하지 않으면, 여전히 CEP 접근법이 나의 유스 케이스에 매우 유용하다고 생각하지 않는다. 필자의 요구 사항에서 하나의 주문 메시지 뒤에는 n 개의 채우기 메시지가 올 수 있습니다. 그리고 각각 고유 한 ID를 갖는 수백만 건의 주문이있을 수 있습니다. 또한 각 주문 메시지에는 여러 개의 관련 주문 메시지가 있습니다. 누락 된 주문을 추적하거나 각 주문 계층 구조를 채우는 방법은 무엇입니까? – prasadsh