akka

0熱度

1回答

我目前正在建立一個系統中有相當多的地方，其中有多種方法可以聯繫到同一個演員。例如，如果你有一個持久的汽車演員，你可以使用VIN或車牌。由於我們在重新創建actor時需要一個「真實名稱」作爲actor名稱/持久性ID，因此這些「lookups/references」本身就是actors，它們以鍵名命名，只保留actor的ID參考。這似乎是正確的方法嗎？好像很多演員不是真正的演員，只是代理人。

1熱度

2回答

阿卡unstashAll（）

我有這個不是重播的消息： val receive = beforeLoadReceive // my default receive override def preStart(): Unit = { doSomeLoadFromDB() unstashAll() context.become(connectedReceive) println("I a

0熱度

1回答

Akka STM似乎並未在最新版本中支持

查看沒有STM的最新akka文檔。爲什麼Akka STM似乎不支持最新版本？哪個模塊代替它？謝謝！

1熱度

1回答

Akka流mapConcat不能與循環運行RunnableGraph

我有RunnableGraph像下面。當broadcast和merge階段之間有簡單的map時，一切都很好。但是，當涉及到mapConcat時，此代碼在使用第一個元素後不起作用。我想知道爲什麼它不起作用。 RunnableGraph.fromGraph(GraphDSL.create() { implicit b => import GraphDSL.Implicits._ val M =

-1熱度

1回答

發送回答或轉發給其他演員

我正在做Akka和Scala的第一步。對於這個問題，scala並不重要，也可以是java。我的小程序：收集一些數據（A）做一些計算（B）並將結果保存在一個表（C）我見兩種或更好的三種不同的方法來設計我的演員。（A）發送消息爲（B）的演員，但那麼我們就可以不同的方式之間進行選擇：（B）發送答案回（A）（B）發送給第三演員的持久性（C）（（B）將數據存儲在自己的DB）哪一個是最好的

0熱度

2回答

Kafka - scala - 處理多個郵件

是否可以通過Kafka Producer對象發送字符串數組。我想從'topic1'中接收一些消息 - 文本行然後將其分割爲單個單詞並將其發送到另一個主題。 object KafkaConsumer extends App { implicit val actorSystem = ActorSystem("test-actor-system") implicit val s

0熱度

1回答

停止Akka演員在WebSocket斷開連接或空閒時間後

我目前正在使用Akka actors，streaming和http的組合來處理客戶端告訴服務器想要接收事件的速度有多快，並且服務器發送客戶端事件的速度。這裏的客戶端消息到服務器： { "uuid": "d30711c6-6bbf-4f11-9471-638ef7e19dfd", "startTime": "1501254050", "rate": "1.5" } 這是由看起來像這樣一

0熱度

1回答

阿卡http客戶端跟隨重定向

的阿卡-HTTP文檔提供了一個例子來查詢http服務： http://doc.akka.io/docs/akka-http/current/scala/http/client-side/request-level.html 我怎麼能告訴阿卡-HTTP來自動執行重定向，而不是接收的HttpResponse與代碼== 302？阿卡2.5.3，阿卡-HTTP 10.0.9 import akka.ac

1熱度

1回答

Scala Akka HTTP轉換參數爲java.time.ZonedDateTime

我正在使用Akka HTTP（在Scala中）處理REST服務。我希望傳入一個http請求的參數被轉換爲ZonedDateTime類型。代碼工作正常，如果我嘗試使用String或Int但失敗與ZonedDateTime類型。該代碼看起來像這樣： parameters('testparam.as[ZonedDateTime]) 這裏是我看到的錯誤： Error:(23, 35) type mis

1熱度

1回答

斯卡拉IntelliJ警告「動態調用可以用構造函數調用替換」

爲什麼Intellij給出這個警告，這是什麼意思，我怎麼能讓它變得更好？ import akka.actor.Props object Router { def props(config: Config, addresses: Set[Address]): Props = Props(classOf[Router], config, addresses) // "