在重新平衡或集群重启后以不同的行为启动实体actor

问题描述

我有一个简单的集群分片示例，其中实体持有订阅。

  val numberOfShards = 6

  val extractEntityId: ShardRegion.ExtractEntityId = {
    case msg: NewSubscribe => (msg.id.toString,msg)
    case msg: Unsubscribe => (msg.id.toString,msg)
  }

  val extractShardId: ShardRegion.ExtractShardId = {
    case msg: NewSubscribe => (msg.id % numberOfShards).toString
    case msg: Unsubscribe => (msg.id % numberOfShards).toString
    case ShardRegion.StartEntity(id) =>
      logger.info(s"Starting old subscription with id $id")
      (id.toInt % numberOfShards).toString
  }

  val settings = ClusterShardingSettings(system)
  val cluster: ClusterSharding = ClusterSharding(system)
  val strategy: ShardAllocationStrategy = cluster.defaultShardAllocationStrategy(settings)

  val counterRegion: ActorRef = cluster.start(
    typeName = SubscribeActor.name,entityProps = Props(new SubscribeActor()),settings = settings,extractEntityId = extractEntityId,extractShardId = extractShardId,allocationStrategy = strategy,handOffStopMessage = SubscribeActor.FinishSubscribe()
  )

当我使用命令 NewSubscribe 或 Unsubscribe 打开新订阅或关闭已经运行的订阅时，一切正常。但是在重新平衡之后，我想用不同的命令启动旧的实体 actor，例如 RestoreSubscription。到目前为止，我发现了这样的东西

    case ShardRegion.StartEntity(id) =>
      logger.info(s"Starting old subscription with id $id")
      (id.toInt % numberOfShards).toString

但是没有办法发送任何命令。我知道我可以使用 PersistentActor 来保存订阅的状态，然后我可以从中确定它是旧订阅还是新订阅，但是有没有更简单的方法来做到这一点？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）