akka 클러스터 인식 라우터 및 akka 클러스터 샤딩의 사용 사례가 다릅니 까?

Question

1. 클러스터 인식 라우터 : 여기

   val router = system.actorOf(ClusterRouterPool(
       RoundRobinPool(0), 
       ClusterRouterPoolSettings(
       totalInstances = 20, 
       maxInstancesPerNode = 1, 
       allowLocalRoutees = false, 
       useRole = None 
   ) 
   ).props(Props[Worker]), name = "router") 
   

   , 우리는 router에 메시지를 보낼 수는 메시지가 원격 routee 배우의 일련 보내드립니다.

2. 클러스터 샤딩 (지속성을 고려하지 않음)

   class NewShoppers extends Actor { 
       ClusterSharding(context.system).start(
       "shardshoppers", 
       Props(new Shopper), 
       ClusterShardingSettings(context.system), 
       Shopper.extractEntityId, 
       Shopper.extractShardId 
   ) 
   
       def proxy = { 
       ClusterSharding(context.system).shardRegion("shardshoppers") 
       } 
   
       override def receive: Receive = { 
       case msg => proxy forward msg 
       } 
   } 
   

   여기, 우리가 proxy 메시지를 보낼 수있는 메시지가 분산됩니다 행위자 (일명, 단체)의 일련 보내드립니다.

그래서, 내 질문은 : 당신은 그냥 어떤 노드에 몇 가지 작업을 보내고 일부 처리 일이하고 싶을 때 it seems both 2 methods can make the tasks distribute to a lot of actors. What's the design choice of above two? Which situation need which choice?

Answer 1

풀 라우터가 될 것이라고 순서로 전송이 메시지는 가능성이 끝날하지 않습니다 처리를 위해 동일한 액터에서

클러스터 샤딩은 특정 액터마다 고유 한 ID가 있고 한 노드에 너무 많은 수의 ID가있는 경우 해당 ID를 가진 모든 메시지가 항상 배우로 끝나기를 원할 때 사용됩니다. 그 이드. 예를 들어 User을 엔티티로 모델링하는 경우 해당 사용자에 대한 모든 명령이 사용자로 끝나기를 원하지만 클러스터 토폴로지가 변경되거나 (노드를 제거 또는 추가) 기존 액티비티간에 합리적으로 균형을 유지하려는 경우 액터가 이동되기를 원합니다 노드.