akka

    0熱度

    2回答

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

    0熱度

    1回答

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

    1熱度

    1回答

    傳播例外,我有一個簡單的演員的層次結構,看起來如下: root | -- parent1 | | | -- child1_1 | | | -- child1_2 | -- parent2 | -- child2_1 | -- child2_2 root實現superv

    1熱度

    2回答

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

    0熱度

    1回答

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

    1熱度

    3回答

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

    0熱度

    1回答

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

    1熱度

    1回答

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