使用ConstructR启动akka集群

akka集群有两种启动方式。一种是手动加入节点(在akka中节点叫做Node); 另一种是通过在配置中指定seed node。seed node是集群的通信节点，用来进行集群的创建和选举。通常我们会在配置文件中配置一系列的seed node，当新的节点想要加入集群时，只要与其中任何一个取得通信即可。需要注意，当启动第一个节点时，这个节点一定要配置在seed node第一个位置。

在继续下文之前先介绍一下我们目前的服务情况。我们有三台WEB Server，这三台server挂在Amazon的ELB上。这三台server都是无状态的。项目部署使用code deploy，由于三台server都是无状态的，所以部署非常简单。从ELB任意摘下一台server，重启，然后再挂到ELB。

当我们尝试引入akka cluster到项目中时，现有的无状态部署方式便不再适用了。首先我们最初的期望是引入集群但尽量少带来项目启动的复杂性。手动加入节点的方式被淘汰。而使用seed node现有部署脚本就要改。因为seed node决定了一定要有一台服务器优先启动。

纠结了一段时间后，想到一个解决方案。借助redis来启动集群。redis可以做两件事情，分布式锁和存储seed node。分布式锁的意义在于防止多台server同时启动造成cluster分裂。这个方案具体细节是:当节点启动时，首先问redis是否已有启动节点，如果没有则以自己为seed node创建集群;如果已有seed，则加入集群。这看起来是一个可行的方案。在写第一行代码之前，本着不重复造轮子的原则，去Google groups search了一下，找到了constructR这个工具。

当我看了它的介绍之后发现和我们方案的核心思路是一样的，但是constructR实现的更精细一些。它抽象出一个状态机用于控制集群启动是状态的流转。我直接盗图了：

在状态流转的过程中，任何一步出现异常都会停掉当前actor system。ConstructR官方给出的底层存储是etcd，但是也有consul，redis，和zookeeper的实现。

ConstructR的使用也非常简单：第一步添加依赖，第二步添加ConstructR akka的扩展，第三步配置ConstructR。官方文档已经提供了非常完整的基于etcd和sbt的配置，下边我列出我基于redis和gradle的配置：

// dependencyrepositories {    jcenter()    mavenCentral()    maven { url "https://dl.bintray.com/everpeace/maven/" }}dependencies {    compile('de.heikoseeberger:constructr-akka_2.11:0.13.2')    compile('com.github.everpeace:constructr-coordination-redis_2.11:0.0.1')}// add constructr extension for akka akka.extensions = [ "de.heikoseeberger.constructr.akka.ConstructrExtension" ]// constructr confredis {  host = "localhost"  port = 6379  db = 5}constructr {  coordination {    class-name = "com.github.everpeace.constructr.coordination.redis.RedisCoordination"    host = ${redis.host}    port = ${redis.port}    redis {      db = ${redis.db}    }  }  coordination-timeout = 3 seconds  // Maximum response time for coordination service (e.g. etcd)  join-timeout         = 15 seconds // Might depend on cluster size and network properties  max-nr-of-seed-nodes = 0          // Any nonpositive value means Int.MaxValue  nr-of-retries        = 2          // Nr. of tries are nr. of retries + 1  refresh-interval     = 30 seconds // TTL is refresh-interval * ttl-factor  retry-delay          = 3 seconds  // Give coordination service (e.g. etcd) some delay before retrying  ttl-factor           = 2.0        // Must be greater or equal 1 + ((coordination-timeout * (1 + nr-of-retries) + retry-delay * nr-of-retries)/ refresh-interval)!}

write on 2017-1-5