資訊專欄INFORMATION COLUMN
摘要：接下來會選擇一個最老的實例并在上面創(chuàng)建單例?？梢源_保整個集群中至多有一個的實例，言下之意，存在沒有實例的時刻。訪問需要借助于，會把所有的消息給當前被代理的實例。
上篇文章主要講了如何使用Akka作異步任務處理。最后還拋出一個問題。
具體問題的描述就不在這篇文章贅述了，我們僅簡單回顧一下第一種解決方案：覆寫persistenceId()時，加一個UUID，這樣三臺服務器上的Actor就不會再共享journal。雖然這個方案已經(jīng)可以解決問題了，但并不是最理想的。首先，現(xiàn)在的項目中只是用akka處理一些無狀態(tài)的任務異步處理，但是將來肯定要用akka作更多的事情。比如，緩存，DAO這些可以設計成有狀態(tài)的，而現(xiàn)在actor重啟時是不能replay消息消息歷史的，所以這樣不能最大限度發(fā)揮actor的優(yōu)勢。還有，我的目標是把所有的后端server構建為一個邏輯上的server，現(xiàn)在他們仍然是三個各自為營的獨立server。因此我又繼續(xù)作了一些調研，最終發(fā)現(xiàn)了Cluster Singleton。
文檔上給出了Cluster Singleton的適用場景：
集群中的單點決策，或者協(xié)調
統(tǒng)一外部系統(tǒng)出口
一主多從
統(tǒng)一命名服務或路由邏輯
第二點正好就是我們的場景。下邊看一下如何使用Cluster Singleton。
添加依賴（我用的構建工具是Gradle）
compile("com.typesafe.akka:akka-cluster_2.11:${akkaVersion}")
compile("com.typesafe.akka:akka-cluster-tools_2.11:${akkaVersion}")
創(chuàng)建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");
創(chuàng)建actor比原來復雜了。首先要創(chuàng)建一個ClusterSingletomManager。ClusterSingletonManager也是一個Actor，它會在Cluster的每個節(jié)點上都啟動起來（或者集群擁有某些角色的節(jié)點）。ClusterSingletomManager.props要傳入三個參數(shù)，第一個是需要創(chuàng)建Singleton實例的Actor配置；第二個是當Manager關閉時要給它管理的Actor發(fā)送什么消息；第三個，集群部署配置，即指定ClusterSingletomManager在哪些集群Node上啟動。
接下來ClusterSingletonManager會選擇一個最老的實例并在上面創(chuàng)建Actor單例。ClusterSingletonManager可以確保整個集群中至多有一個singleton的實例，言下之意，存在沒有singleton實例的時刻。比如cluster node crash，原有的singleton實例丟失，這時需要重新選舉新最老的ClusterSingletonManager，然后創(chuàng)建新的singleton實例。
訪問Singleton Actor需要借助于ClusterSingletonProxy，ClusterSingletonProxy會把所有的消息forward給當前被代理的Actor實例。因為有可能某些時刻是沒有singleton actor實例的，所以遇到這種情況ClusterSingletonProxy會先把消息緩存，當新的Actor單例創(chuàng)建之后，再把緩存的消息轉發(fā)過去。
當然，Cluster Singleton也有它的問題，比如單點潛在的性能問題，而且singleton actor并不是100%可用。但相比于第一種方案，顯然這個要更接近我的期望。
write on 2017-1-10
文章版權歸作者所有，未經(jīng)允許請勿轉載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。
轉載請注明本文地址：http://systransis.cn/yun/66464.html
摘要：接下來會選擇一個最老的實例并在上面創(chuàng)建單例?？梢源_保整個集群中至多有一個的實例，言下之意，存在沒有實例的時刻。訪問需要借助于，會把所有的消息給當前被代理的實例。 上篇文章主要講了如何使用Akka作異步任務處理。最后還拋出一個問題。 具體問題的描述就不在這篇文章贅述了，我們僅簡單回顧一下第一種解決方案：覆寫persistenceId()時，加一個UUID，這樣三臺服務器上的Actor就不...
摘要：創(chuàng)建訂單時同步操作有查詢庫存，扣款，刷新庫存可異步的操作有通知風控系統(tǒng)，給買家發(fā)送扣款郵件和短信，通知賣家，創(chuàng)建一些定時任務。 同步轉異步是一種常見的優(yōu)化手段，最近一次在做調優(yōu)時便大量使用了這種方式。通常在一個業(yè)務場景中會包含多個操作，有些操作的結果需要讓用戶立馬知道，但有些操作則不需要。這些用戶不需要等待結果的操作，我們在編程的時候便可以異步處理。這么做最直接的效果就是縮短接口響應速...
摘要：以上是服務啟動過程中的主體設計，其中包括了各種組件的實例化，如對象池等。 EasySwoole 服務啟動過程以及主體設計流程源碼解析 本文主要講解EasySwoole 服務的啟動過程，會通過源碼片段講解主體的設計流程 命令啟動 當我們通過php easyswoole start啟動EasySwoole 服務時，命令真正到達的文件是 easyswoole項目vendoreasyswool...
閱讀 2926·2021-11-19 09:40
閱讀 3610·2021-10-09 09:43
閱讀 2688·2021-09-22 15:31
閱讀 1741·2021-07-30 15:31
閱讀 798·2019-08-30 15:55
閱讀 3274·2019-08-30 15:54
閱讀 1175·2019-08-30 11:26
閱讀 1923·2019-08-29 13:00
