使用ConstructR啓動akka集羣

使用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實現的更精細一些。它抽象出一個狀態機用於控制集羣啓動是狀態的流轉。我直接盜圖了：
<image w=800 h=470 describe= name=Notes_1483621897775.png>

在狀態流轉的過程當中，任何一步出現異常都會停掉當前actor system。ConstructR官方給出的底層存儲是etcd，可是也有consul，redis，和zookeeper的實現。

ConstructR的使用也很是簡單：第一步添加依賴，第二步添加ConstructR akka的擴展，第三步配置ConstructR。官方文檔已經提供了很是完整的基於etcd和sbt的配置，下邊我列出我基於redis和gradle的配置：

// dependency
repositories {
    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 conf
redis {
  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