리스너가있는 세계의 HazelCast지도

Question

Hazelcast를 사용하면 소비자가 세계의 현재 상태 (현재 현재지도에있는 것)에 대해 알고 싶어하며 그 사이에 아무 것도 잃지 않는 일반적인 시나리오가 있다고 상상해 봅니다.

는 Hazelcast 맵이 리스너에서 소비자가 (아마도 수신을 통해) 스트리밍하고자하는 데이터의 일부 다양한 현재 상태 및 다음의 최신 소식을 들고 시나리오를 상상해보십시오.

이 API

우리가 업데이트에 대한 리스너를 추가하고 보통 인 ConcurrentMap로지도를 치료하는 것이 좋습니다. 그러나 Map을 열거하는 동안 청취자를 통해 업데이트가 들어올 수 있으므로 올바른 항목 순서를 보장하는 것은 어렵습니다.

우리는지도 열거와 청취자 사이에 잠금 장치를 공유 할 수 있지만 그 코드 냄새가 조금 보인다. 우리가 SoTW 다음 업데이트를 스트리밍하려면

그래서 일반적으로 내 질문에 우리가이 작업을 수행 할 수있는 방법이다? 우리를 도울 수있는 Hazelcast에 내장 된 것이 있습니까?

도움 모든

Answer 1

먼저 주셔서 감사합니다, 나는 그냥 불행하게도 설명 추측,지도에는 순서가 없습니다!

제 물건은 Hazelcast지도 비 스냅 숏, 비 지속 데이터 구조이다. ConcurrentHashMap와 마찬가지로 데이터 구조의 변경 사항은 반복자에 반영되며 그 반대의 경우도 마찬가지입니다.

이벤트는, 다른 측면에서, 이벤트가 비동기 적으로 전달 특히 이후, 완전히 독립적 인 시스템이다. 따라서 iterator를 같은 요소 나 다른 라운드로 향상시키기 전에 이벤트가 실제로 도착할 수도 있습니다.

더 나은 보증이 필요한 경우 먼저 반복하고 수신기를 추가하고 처음 실행 시작과 놓친 이벤트 사이에 변경 사항을 적용합니다 (두 번째 반복에서 델타를 수행해야합니다). 실제로 그것을 처리하는 좋은 방법은 아니지만 다른 방법이 있다고 생각하지 않습니다.