akka

0熱度

2回答

假設你有一個返回餐廳收視率在四個歐洲首都服務：阿姆斯特丹都柏林倫敦巴黎使用阿卡，想象你將每個城市分配給一個演員，然後將這些演員分配到兩個節點（認爲Akka集羣）。如果我們天真地分片我們按字母順序排列的演員，所產生的分工是：節點1：阿姆斯特丹+都柏林的演員（總人口400萬美元）節點2：倫敦+巴黎參與者（總人口1100萬）很明顯，交通將是非常不平衡的。如果你事先不知道城市的人口，Akk

0熱度

1回答

如何在scala中爲https請求創建akka-http cachedHostConnectionPool？

我不知道如何使用scala在akka-http中創建cachedHostConnectionPool以發送https請求。 queueRequest(HttpRequest(uri = "https://example.com")向http發送請求，cachedHostConnectionPool[Promise[HttpResponse]]("https://example.com")拋出錯誤，

1熱度

1回答

在阿卡

1熱度

2回答

Scala編碼風格

我一直無法確定下面的代碼代表什麼，因爲這些語法沒有完全列在Scala文檔中。有人可以在下面的每一行上說明一些情況嗎？如果上述標題需要更改爲可以使他人受益的內容，請告訴我。 val route = path("hello") { get { complete(HttpEntity(ContentTypes.`text/html(UTF-8)`, "<h1>Say he

0熱度

1回答

更改爲持續查詢從棄用PersistentView

我用阿卡持久性，與性LevelDB作爲存儲插件，在用Scala編寫的應用程序。在查詢方面，目前執行的只知道演員的標識符采用PersistentView，其調查的消息從PersistentActor的日記。現在我已經瞭解到，PersistentView已被棄用，一個是鼓勵使用持久查詢代替。但是，我還沒有找到關於如何修改使用PersistentView來支持首選持久性查詢實現的詳細說明。任何幫助，

1熱度

3回答

斯卡拉案例類「明確暴露狀態」

在閱讀akka docs正確的消息和不變性部分，它提到了「明確暴露狀態」內的案例類。所以我的問題是; 什麼意思是說「明確暴露狀態」案例類？爲了實現不可變性，是不是足夠寫一個類的「案例」？或者我應該小心使用它？

0熱度

1回答

Java Akka Scheduling API拋出MissingMethodException

Java 8（以及Groovy）在這裏使用Akka com.typesafe.akka:akka-actor_2.11:2.5.4。我試圖創建一個用於創建/擁有/管理的另一位演員（StateChecker），預計發送每4秒這StateChecker一個CheckState消息的演員（AppMaster）： class CheckState {} class StateChecker exten

1熱度

1回答

如何在我目前的設計延長了阿卡接收方法

我有一個這樣的演員： class MyActor[T] extends Actor { def receive = { case Option1(t: T) => doWork(t) onComplete ..... case Option2 => } def doWork(T): Future[T]{ } }

0熱度

1回答

如何將akka sharded actor狀態外部化爲redis或ignite？

我對Akka聚類和研究概念證明非常陌生。在我的情況下，我有一個在羣集上運行的演員，演員的狀態爲Map [String，Any]。因此，對於任何請求，actor根據傳入的消息接收它，它會創建一個新的實體actor和數據映射。這裏的問題是地圖現在在內存中。是否有可能在Redis或點燃某個地方存儲Sharded actor狀態？

1熱度

1回答

在Android（java版本1.6編譯 - 不是1.8）AKKA（2.4優先）的JAR文件

我一直在尋找一個很長的時間現在的AKKA的jar文件（最好2.4）編譯爲Java 1.6或1.7和NOT 1.8！如果互聯網有彎道，我相信我現在已經看到他們了！順便說一句，我用Java編程，而不是Scala。我在我的項目中經常使用AKKA，但我真的很想將它用於我正在開發的多平臺項目，它也應該在Android上運行。不是作爲客戶，而是作爲本地應用程序。我已經使用Linux測試了Raspberry