使用Akka Cluster Singleton實現集羣單例

上篇文章主要講了如何使用Akka做異步任務處理。最後還拋出一個問題。

具體問題的描述就不在這篇文章贅述了，咱們僅簡單回顧一下第一種解決方案：覆寫persistenceId()時，加一個UUID，這樣三臺服務器上的Actor就不會再共享journal。雖然這個方案已經能夠解決問題了，但並非最理想的。首先，如今的項目中只是用akka處理一些無狀態的任務異步處理，可是未來確定要用akka做更多的事情。好比，緩存，DAO這些能夠設計成有狀態的，而如今actor重啓時是不能replay消息消息歷史的，因此這樣不能最大限度發揮actor的優點。還有，個人目標是把全部的後端server構建爲一個邏輯上的server，如今他們仍然是三個各自爲營的獨立server。所以我又繼續做了一些調研，最終發現了Cluster Singleton。

文檔上給出了Cluster Singleton的適用場景：

• 集羣中的單點決策，或者協調

• 統一外部系統出口

• 一主多從

• 統一命名服務或路由邏輯

第二點正好就是咱們的場景。下邊看一下如何使用Cluster Singleton。

1. 添加依賴（我用的構建工具是Gradle）

compile("com.typesafe.akka:akka-cluster_2.11:${akkaVersion}")
compile("com.typesafe.akka:akka-cluster-tools_2.11:${akkaVersion}")

1. 建立actor

actorSystem.actorOf(ClusterSingletonManager.props(
    SpringExtProvider.get(actorSystem).props("NotificationActor"),
    PoisonPill.getInstance(),
    ClusterSingletonManagerSettings.create(actorSystem).withRole("master")
), "notification-master");

notificationActor = actorSystem.actorOf(
    ClusterSingletonProxy.props(
        "/user/notification-master",
        ClusterSingletonProxySettings.create(actorSystem).withRole("master")),
    "notification-proxy");

建立actor比原來複雜了。首先要建立一個ClusterSingletomManager。ClusterSingletonManager也是一個Actor，它會在Cluster的每一個節點上都啓動起來（或者集羣擁有某些角色的節點）。ClusterSingletomManager.props要傳入三個參數，第一個是須要建立Singleton實例的Actor配置；第二個是當Manager關閉時要給它管理的Actor發送什麼消息；第三個，集羣部署配置，即指定ClusterSingletomManager在哪些集羣Node上啓動。

接下來ClusterSingletonManager會選擇一個最老的實例並在上面建立Actor單例。ClusterSingletonManager能夠確保整個集羣中至多有一個singleton的實例，言下之意，存在沒有singleton實例的時刻。好比cluster node crash，原有的singleton實例丟失，這時須要從新選舉新最老的ClusterSingletonManager，而後建立新的singleton實例。

訪問Singleton Actor須要藉助於ClusterSingletonProxy，ClusterSingletonProxy會把全部的消息forward給當前被代理的Actor實例。由於有可能某些時刻是沒有singleton actor實例的，因此遇到這種狀況ClusterSingletonProxy會先把消息緩存，當新的Actor單例建立以後，再把緩存的消息轉發過去。

固然，Cluster Singleton也有它的問題，好比單點潛在的性能問題，並且singleton actor並非100%可用。但相比於第一種方案，顯然這個要更接近個人指望。

---

write on 2017-1-10