2011-09-26 3 views
2

이 질문은 일반적인 해결책을 찾을 수 없었던 매우 일반적인 문제와 관련이 있습니다. 여기 데이터 팬 아웃 Java 라이브러리

는 설정이다 :
  • 당신은 생산자의 수에게 이러한 기호의 분리 된 부분 집합에 대한 각 생산 데이터를 가지고 당신은 소비자의 수, 각 기호의 집합에 가입이

    1. 소비자는 기호에 대한 모든 변경 사항을 소비하기에는 너무 느려서 을 예약 했으므로 조절할 필요가 있습니다.
    2. 소비자는 각 기호에 대한 최신 데이터에만 관심이 있습니다. 소비자가 심볼에 대한 업데이트를 놓친 경우 최신 데이 터를 사용할 수있는 경우 가장 최근의 것만 보내야합니다.

    필자는이 문제를 아주 자주 겪었으며 매번 사용하지 않은 데이터를 새로운 데이터로 교체 할 수있는 큐를 구현할 때마다 휠을 다시 만들어야했습니다. 효율적인 방법으로 이것에 대한 해결책을 구현하는 라이브러리가 있는지 궁금합니다.

  • +0

    '가입 하시겠습니까?'라는 말은이 문맥에서 무엇을 의미합니까? 새로운 기호가 도착했을 때 소비자에게 통보해야합니까, la pub/sub입니까? 심볼의 각 하위 집합이 다른 데이터 구조에 할당되었거나 모두 혼합되어 있습니까? – vemv

    답변

    0

    게시자가 시장 데이터 피드를 게시하는 것과 같고 고객이 특정 피드를 구독하도록하려는 경우 모든 데이터 메시지를 처리 ​​할 필요가 없으므로 대기열이 필요하지 않습니다. UDP는 전송 프로토콜로 UDP를 사용하여 시장 데이터를 게시합니다. UDP는 패킷이 다음 패킷을 보내기 전에 수신중인 것으로 확인 될 필요가 없기 때문에 시장 데이터를 게시합니다. 클라이언트는 수신 한 마지막 값을 캐시해야하며 큐를 유지할 필요가 없습니다. 그런 다음이 마지막 값에 대한 관찰자를 가지며 변경 될 때 나머지 응용 프로그램에 게시 할 수 있습니다.