在Akka Typed中，可以使用Akka Persistence插件来实现持久化。对于集群分片，可以使用Akka Cluster Sharding插件。

以下是一个使用Akka Typed和Akka Persistence的示例代码，演示了如何使用持久化插件：

import akka.actor.typed.scaladsl.Behaviors
import akka.actor.typed.{ActorRef, Behavior}
import akka.persistence.typed.PersistenceId
import akka.persistence.typed.scaladsl.{Effect, EventSourcedBehavior}
import akka.cluster.sharding.typed.scaladsl.{ClusterSharding, Entity, EntityContext, EntityTypeKey}

object MyPersistentActor {
  // 定义实体类型键
  val EntityTypeKey: EntityTypeKey[Command] = EntityTypeKey[Command]("MyPersistentActor")

  // 定义命令和事件
  sealed trait Command
  case class AddItem(item: String, replyTo: ActorRef[Confirmation]) extends Command
  sealed trait Confirmation
  case class ItemAdded(item: String) extends Confirmation

  sealed trait Event
  case class ItemAddedEvent(item: String) extends Event

  // 定义状态
  case class State(items: List[String] = Nil)

  // 定义事件源行为
  def eventSourcedBehavior(persistenceId: PersistenceId): Behavior[Command] = {
    EventSourcedBehavior[Command, Event, State](
      persistenceId,
      State(Nil),
      commandHandler,
      eventHandler
    )
  }

  // 定义命令处理函数
  private val commandHandler: (State, Command) => Effect[Event, State] = { (state, command) =>
    command match {
      case AddItem(item, replyTo) =>
        Effect.persist(ItemAddedEvent(item)).thenRun { _ =>
          replyTo ! ItemAdded(item)
        }
    }
  }

  // 定义事件处理函数
  private val eventHandler: (State, Event) => State = { (state, event) =>
    event match {
      case ItemAddedEvent(item) =>
        state.copy(items = item :: state.items)
    }
  }

  // 创建实体
  def initEntity(entityContext: EntityContext[Command]): Behavior[Command] = {
    eventSourcedBehavior(PersistenceId(entityContext.entityTypeKey.name, entityContext.entityId))
  }

  // 启动集群分片
  def startClusterSharding(): ActorRef[EntityCommand[Command]] = {
    val sharding = ClusterSharding(system) // 假设已经有一个ActorSystem实例
    sharding.init(Entity(EntityTypeKey)(initEntity))
  }
}

在上面的示例中，MyPersistentActor是一个使用Akka Typed和Akka Persistence的持久化Actor。eventSourcedBehavior函数创建了一个事件源行为，其中定义了命令处理函数和事件处理函数。initEntity函数用于初始化实体，在集群分片中使用。startClusterSharding函数用于启动集群分片。

请注意，为了使用Akka Persistence和Akka Cluster Sharding，您需要将相应的依赖添加到项目中的构建文件中。例如，在sbt中，您可以添加以下依赖项：

libraryDependencies ++= Seq(
  "com.typesafe.akka" %% "akka-persistence-typed" % akkaVersion,
  "com.typesafe.akka" %% "akka-cluster-sharding-typed" % akkaVersion
)

其中，akkaVersion是您使用的Akka版本号。

请根据您的实际需求进行修改和调整。希望对您有所帮助！