上一篇博客我们介绍了remote模式下Actor的创建，其实与local的创建并没有太大区别，一般情况下还是使用LocalActorRef创建了Actor。那么发消息是否意味着也是相同的呢？ 既然actorOf还是委托给了LocalActorRef，那么在本地创建的Actor发消息还是跟以前一样的，那么如果如何给远程的Actor发消息呢？我们一般是通过act...
前言........... 上一篇文章我们讲了Akka Remote，理解了Akka中的远程通信，其实Akka Cluster可以看成Akka Remote的扩展，由原来的两点变成由多点组成的通信网络，这种模式相信大家都很了解，就是集群，它的优势主要有两点：系统伸缩性高，容错性更好。 集群概念 很多人很容易把分布式和集群的概念搞错，包括我也是，我一开始也以...
Akka入门实例 Akka 是一个用 Scala 编写的库，用于简化编写容错的、高可伸缩性的 Java 和 Scala 的 Actor 模型应用。 Actor模型并非什么新鲜事物，它由Carl Hewitt于上世纪70年代早期提出，目的是为了解决分布式编程中一系列的编程问题。其特点如下： 系统中的所有事物都可以扮演一个Actor Actor之间完全独...
一致性和可扩展性 一致性是系统内比较复杂的属性，它会随着系统的变化而变化。简单来说，一致性就是数据保持一致，在分布式系统中，可以理解为多个节点中数据的值是一致的。一旦系统具有并行性（分布式只是并行的一种表现），保持一致性就变得困难了，毕竟需要协调全局状态。 事务和一致性 一致性意义上的事务是指单一的原子操作。也就意味着一系列操作要么全成功，要么全不成功，不...
Akka是一个构建在JVM上，基于Actor模型的的并发框架，为构建伸缩性强，有弹性的响应式并发应用提高更好的平台。本文主要是个人对Akka的学习和应用中的一些理解。 Actor模型 Akka的核心就是Actor，所以不得不说Actor，Actor模型我通俗的举个例子，假定现实中的两个人，他们只知道对方的地址，他们想要交流，给对方传递信息，但是又没有手机，...
上一节我们深入讨论了ActorRef等相关的概念及其关系，但ActorRef和ActorPath的关系还需要再加以分析说明。其实还是官网说的比较清楚。 “A path in an actor system represents a “place” which might be occupied by a living actor. Initially (a...
在之前的博客中，我们分析过local模式下Actor的创建过程，最终还是调用了provider的actorOf的函数创建了Actor，在remote模式下provider就是RemoteActorRefProvider，所以这样就知道在哪里最终创建了Actor。 def actorOf(system: ActorSystemImpl, props: Pro...
上一遍博客中，我们分析了网络链接建立的过程，一旦建立就可以正常的收发消息了。发送消息的细节不再分析，因为对于本地的actor来说这个过程相对简单，它只是创立链接然后给指定的netty网路服务发送消息就好了。接收消息就比较麻烦了，因为这对于actor来说是透明的，netty收到消息后如何把消息分发给指定的actor呢？这个分发的过程值得研究研究。 之前分析过...
前言.... Akka作为一个天生用于构建分布式应用的工具，当然提供了用于分布式组件即Akka Remote，那么我们就来看看如何用Akka Remote以及Akka Serialization来构建分布式应用。 背景 很多同学在程序的开发中都会遇到一个问题，当业务需求变得越来越复杂，单机服务器已经不足以承载相应的请求的时候，我们都会考虑将服务部署到不同的...
快速上手 Flower框架的主要元素包括：Flower Service（服务）、Flower 流程和Flow容器。Service实现一个细粒度的服务功能，Service之间通过Message关联，前一个Service的返回值（Message），必须是后一个Service的输入参数（Message），Service按照业务逻辑编辑成一个Flow（流程），Fl...