本文介绍了基于事件溯源的Akka应用程序的底层数据库迁移案例研究，推荐使用Akka Persistence的r2dbc模式，AlloyDB在大量写入操作方面性能高，CockroachDB在垂直扩展后性能瓶颈，建议迁移到AlloyDB以获得更好的性能和可靠性。

Play框架发布了2.9和3.0版本，3.0版本采用了Apache Pekko替代Akka，增强了模块化组件，更新了重要库，但放弃了对Java 8的支持。Pekko团队发布了迁移指南。

Akka的新许可证给Apache Flink带来了许多问题，因为它在内部使用Akka 进行集群协调。 但是，Apache Flink的许可证不会改变。将不会再使用 Akka 2.7+，这将确保用户不受影响。 Flink 没有任何直接的危险，我们将确保用户不受此更改的影响。 Flink 的许可不会改变；它将保持 Apache 许可，并且仅包含与其兼容的依赖项。 我们不会使用带有新许可证的...

Akka 的新许可证是 Business Source License (BSL) v1.1，附加使用授权以涵盖 Akka 的一些开源使用，例如 Play Framework 的一部分。BSL 由 David Axmark 和 Michael Widenius 创建，并已被 MariaDB、Cockroach Labs、Sentry、Materialized 等采用。 BSL...

Akka是一个用于构建分布式高并发系统的工具包，支持Java和Scala。它实现了Actor模式，Actor是基本执行单元。Akka分为Classic和Typed两种实现，Typed引入了强制消息类型，增强了系统的安全性和可控性。Actor之间通过消息交互，遵循“协议优先”原则，生命周期需要显式管理，支持创建和停止。与Spring集成时，可以通过Spring管理Actor实例。

1 2 3 4 5 6 7 8 9 10 11 12 13 14 object Main1 extends App { val system = ActorSystem("HelloSystem") val jazzListener = system.actorOf(Props[Listener]) val musicListener =...

2014 Java中使用akka手记四 用法速查 posted in java,akka Java中使用akka手记三 Cluster详例 posted in java,akka Java中使用akka手记二 Cluster posted in java,akka Java中使用akka手记一 posted in java,akka

Actor UntypedActor actor的基类，继承并实现onReceive方法就可以得到一个Actor。 Props 配置类，用Props.create可以创建一个按指定配置生成的Actor。 Props的推荐实践，创建Actor时，搞一个static的Props.create方法。可以少写不少重复代码。 system.actorOf 会创建顶级的actor，将被系统监控。...

一个例子 同样是typesafe的经典例子。 例子提供的服务是传输文本。当文本发给frontend节点，它会委派backend节点，backend执行转化任务，把结果返回给原来的客户端。 新的backend节点和frontend节点，都可以动态地在cluster上增减。 message 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20...

基础知识 2.3.2的cluster还有些想实现的东西没有实现，包括：actor分区（负载均衡） actor handoff（临时故障时的actor处理） actor重新平衡（增减节点时有用） actor状态复制机制（类似做M/S作用） 2.3.2的cluster已经有的能力有：节点－集群－leader节点; membership; gossip协议同步状态; VECTOR...

什么是actor? Actor模型在并发编程中是比较常见的一种模型。很多开发语言都提供了原生的Actor模型。例如erlang,scala等。 它由Carl Hewitt于上世纪70年代早期提出，目的是为了解决分布式编程中一系列的编程问题。 Actor模型的本质已经被强调了无数遍：万物皆Actor。Actor之间只有发送消息这一种通信方式。...