akka 如何扩大或缩小持久性参与者以获得更高的吞吐量?

yzuktlbb  于 2022-11-06  发布在  其他
关注(0)|答案(1)|浏览(208)

是否可以将持久性执行元与路由器(如)一起使用以进行横向扩展?如果持久性执行元具有弹性,则表示事件来源存在问题。
因此,我想知道如何扩大或缩小持久参与者以获得更好的吞吐量?

z6psavjg

z6psavjg1#

这个问题有点过于开放,无法直接回答,不过一般来说,你可以先做两件事:
为了提高Persistent Actor的吞吐量,您已经可以在它内部使用一些技术,例如使用persistAsync,它将更新分批发送到一个批处理中,并发送到日志。
PersistentActors可以通过与ClusterSharding一起使用来轻松地扩展,ClusterSharding允许在独立节点上启动给定id(和分片id)的参与者-这将负载出售给这些参与者。
当然,为了调整消息持久化的原始吞吐量,您必须选择一种快速的序列化格式,并按照schema evolution文档中的说明进行配置。
最后,也是非常重要的一点,你应该选择一个能够根据你的需求进行扩展的Journal implementation。Cassandra是一个很受欢迎的选择,但是你至少需要运行3个节点才能让它有意义。
希望这对你有帮助,hakking快乐!

相关问题