Akka在Flink中的使用剖析

Akka与Actor 模型 Akka是一个用来开发支持并发、容错、扩展性的应用程序框架。它是actor model的实现，所以跟Erlang的并发模型很像。在actor模型的上下文中，全部的活动实体都被认为是互不依赖的actor。actor之间的互相通讯是经过彼此之间发送异步消息来实现的。每一个actor都有一个邮箱来存储接收到的消息。所以每一个actor都维护着本身独立的状态。java 每一个a

>>阅读原文<<