集群分片钝化中按实体类型设置活跃实体限制

Akka集群分片支持通过自定义PassivationStrategy实现按实体类型区分的活跃实体数量限制，具体实现步骤如下：

• 实现自定义PassivationStrategy
  编写类实现akka.cluster.sharding.PassivationStrategy接口，重写shouldPassivate方法，根据实体类型判断是否触发钝化。你可以从EntityContext中提取实体类型标识（比如实体ID的前缀、消息中的类型字段等），匹配预先定义的不同类型的活跃数量上限。

  示例代码（Scala）：

  import akka.cluster.sharding.{EntityContext, PassivationStrategy}
  import scala.concurrent.duration.FiniteDuration
  
  class TypedPassivationStrategy(
    typeToLimit: Map[String, Int],
    defaultIdleTimeout: FiniteDuration
  ) extends PassivationStrategy {
  
    override def shouldPassivate(ctx: EntityContext[_], currentActiveEntities: Int): Boolean = {
      // 假设实体ID格式为「类型-唯一ID」，拆分前缀获取实体类型
      val entityType = ctx.entityId.split("-").head
      // 获取对应类型的活跃上限，无匹配则使用默认值
      val typeLimit = typeToLimit.getOrElse(entityType, 500)
      
      // 满足活跃数超限 或 实体空闲超时任一条件则触发钝化
      currentActiveEntities > typeLimit || ctx.idleTime > defaultIdleTimeout
    }
  }
  

• 在ShardRegion中配置自定义策略
  创建ShardRegionSettings时，通过withPassivationStrategy方法注入自定义策略实例，再将该配置传入ClusterSharding.start方法：

  示例代码（Scala）：

  import akka.cluster.sharding.ShardRegionSettings
  import scala.concurrent.duration._
  import akka.actor.Props
  
  // 定义不同实体类型的活跃数量上限
  val entityTypeLimits = Map(
    "user" -> 2000,
    "order" -> 300,
    "product" -> 1000
  )
  val customPassivation = new TypedPassivationStrategy(entityTypeLimits, 10.minutes)
  val shardSettings = ShardRegionSettings(system).withPassivationStrategy(customPassivation)
  
  // 启动分片区域时传入自定义配置
  ClusterSharding(system).start(
    typeName = "MultiTypeEntity",
    entityProps = Props[YourEntityActor](),
    settings = shardSettings,
    extractEntityId = yourExtractEntityIdFn,
    extractShardId = yourExtractShardIdFn
  )
  

• 进阶优化提示
  如果需要更精准的按类型统计活跃实体数（而非依赖分片内总活跃数），可以在自定义策略类中维护线程安全的计数器，结合实体的启动/钝化事件更新计数（比如通过监听分片区域的实体生命周期消息）。

内容的提问来源于stack exchange，提问作者Arne Claassen