国产xxxx99真实实拍_久久不雅视频_高清韩国a级特黄毛片_嗯老师别我我受不了了小说

資訊專欄INFORMATION COLUMN

使用Akka Cluster Singleton實現集群單例

TZLLOG / 1460人閱讀

摘要：接下來會選擇一個最老的實例并在上面創建單例。可以確保整個集群中至多有一個的實例，言下之意，存在沒有實例的時刻。訪問需要借助于，會把所有的消息給當前被代理的實例。

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

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

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

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

統一外部系統出口

一主多從

統一命名服務或路由邏輯

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

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

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

創建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

文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。

轉載請注明本文地址：http://specialneedsforspecialkids.com/yun/66464.html

相關文章

  • 使用Akka Cluster Singleton實現集群單例

    摘要：接下來會選擇一個最老的實例并在上面創建單例。可以確保整個集群中至多有一個的實例，言下之意，存在沒有實例的時刻。訪問需要借助于，會把所有的消息給當前被代理的實例。 上篇文章主要講了如何使用Akka作異步任務處理。最后還拋出一個問題。 具體問題的描述就不在這篇文章贅述了，我們僅簡單回顧一下第一種解決方案：覆寫persistenceId()時，加一個UUID，這樣三臺服務器上的Actor就不...

    xiangzhihong 評論0 收藏0

  • 使用akka作異步任務處理

    摘要：創建訂單時同步操作有查詢庫存，扣款，刷新庫存可異步的操作有通知風控系統，給買家發送扣款郵件和短信，通知賣家，創建一些定時任務。 同步轉異步是一種常見的優化手段，最近一次在做調優時便大量使用了這種方式。通常在一個業務場景中會包含多個操作，有些操作的結果需要讓用戶立馬知道，但有些操作則不需要。這些用戶不需要等待結果的操作，我們在編程的時候便可以異步處理。這么做最直接的效果就是縮短接口響應速...

    shiweifu 評論0 收藏0

  • EasySwoole 服務啟動過程以及主體設計流程源碼解析

    摘要：以上是服務啟動過程中的主體設計，其中包括了各種組件的實例化，如對象池等。 EasySwoole 服務啟動過程以及主體設計流程源碼解析 本文主要講解EasySwoole 服務的啟動過程，會通過源碼片段講解主體的設計流程 命令啟動 當我們通過php easyswoole start啟動EasySwoole 服務時，命令真正到達的文件是 easyswoole項目vendoreasyswool...

    huayeluoliuhen 評論0 收藏0

發表評論

0條評論

最新活動
閱讀需要支付1元查看
<