일부 속성

Question

에 의해 버전/Akka 메시지를 고유하게 나는 다음과 같은 사용 사례가 있습니다

배우가 key:value 쌍으로 구성 외부 소스에서 데이터를 소비합니다. 그런 다음 그들은 이전의 것들을 건너 뛰고 key과 최신 value에서 몇 가지 작업을 수행해야하는 배우에게 전달됩니다. 기본적으로 사서함을 1의 용량을 가진 "하위 주제"로 분할하려고합니다. Akka에서는 이러한 일이 가능합니까? 그렇지 않다면 어떤 대안을 고려해야합니까?

Answer 1

당신이 필요로하는 것은 가장 우선 순위가 높은 메시지입니다. PriorityMailbox의 기본 구현을 살펴보십시오.

그것은 (워드 프로세서의 예에 따라) 같은 것을 볼 수 있습니다

여기 versionToInt

import akka.dispatch.PriorityGenerator 
import akka.dispatch.UnboundedStablePriorityMailbox 
import com.typesafe.config.Config 

type Version = // Long, Date, Timestamp, smth else - must be ordered 
case class MyMessage(key: String, value: String, version: Version) 

class MyPrioMailbox(settings: ActorSystem.Settings, config: Config) 
    extends UnboundedStablePriorityMailbox(
    // Create a new PriorityGenerator, lower prio means more important 
    PriorityGenerator { 
     case MyMessage(_, _, version) => versionToInt(version) 

     // PoisonPill when no other left 
     case PoisonPill => 1 // or Int.MaxValue - 2 

     // We default to 1, which is in between high and low 
     case otherwise  => 0 // or Int.MaxValue - 1 
    }) 

메시지 (높은 우선 순위)의 새 버전 낮은 일부 Int 값을 반환해야합니다을 2 - Inf에 말 범위.

이후에 배우에서 처리 된 가장 높은 버전을 추적하고 해당 버전 이전의 다른 모든 메시지를 삭제할 수 있습니다. 배우를 위해 become 또는 var을 사용하십시오.

보낸 메시지의 순서는 Akka에서 보장되지만 결국 메시지를 보내는 순서와 중간에있는 지연에 따라 달라 지므로 메시지 처리에 영향을 미칩니다.