akka

1熱度

1回答

我正在用akka框架（特別是版本2.3）開發一個java應用程序。我需要在運行時監視我的工作演員。更確切地說，我需要獲得演員的郵箱大小/工作演員的數量等。我選擇了Kamon framework，並試圖將它連接到我的應用程序，但面臨問題。我根據文檔做了一切。正如他們說在他們的網站添加卡蒙，JMX的依賴到項目，並確保它在你的classpath在運行時，僅此而已。 Kamon的模塊加載器將檢

1熱度

2回答

兒童演員，期貨和例外

我目前正在使用註冊過程處理應用程序。此註冊過程在某些時候將以異步方式與外部系統進行通信。爲了使這個問題簡潔明瞭，我顯示你，我已經寫了兩個重要角色： SignupActor.scala class SignupActor extends PersistentFSM[SignupActor.State, Data, DomainEvt] { private val apiActor = co

1熱度

1回答

在Akka中，如何管理阻塞方法調用，如從StdIn中讀取數據？

我開始使用Scala和AKKA模式，並且我寫了這段代碼，但它不起作用，我不知道爲什麼... 我創建了一個讀取用戶的小項目從控制檯輸入。當這個用戶寫了一個'關鍵字'時，keyWord Actor（Child）會解釋它並且將與控制檯Actor（Grand父母）進行通信。動作演員將用於播放和做更多的東西。當我在控制檯Actor中輸入命令'rename'時，我進入動作Actor，然後在keyWord

1熱度

2回答

我在哪裏可以下載Akka 2.5.6的庫.jar文件？

我想從Akka 2.4.10更新到現在的Akka 2.5.6。由於任何原因，我無法在https://akka.io上找到下載鏈接。在Github上，我找到了源文件，但是我正在尋找的是以.jar文件捆綁的編譯後的.class文件，以便我可以直接將它們作爲庫集成到IntelliJ IDEA中。（在2.4.10版本中，有一個文件「akka_2.11-2.4.10.zip」可在https://akka.

0熱度

1回答

在Akka流-kafka中阻塞Kafka協調器的線程

使用VisualVM來配置使用akka-streams-kafka的應用程序。它顯示了很多卡夫卡協調阻塞線程誰是這些協調員？我也有三個卡夫卡消費者，也阻塞線程我需要爲他們創造一個獨立的執行上下文？

0熱度

1回答

如何從模塊中訪問Play 2.5中使用的actor系統

我需要訪問Play Framework 2.5在我的Module類中使用的默認actor系統。我看到有上ActorSystemProvider一個方法來獲得這樣的： @Singleton class ActorSystemProvider @Inject()(environment: Environment, configuration: Configuration, applicationL

0熱度

2回答

ExecutionContext導致Akka死信

出於某種原因，我必須同時使用gRPC和Akka。當這個演員成爲頂級演員時，沒有任何問題（在這個小演示中）。但是，當它成爲一個兒童演員，也沒有收到任何消息，並且以下記錄： [default-akka.actor.default-dispatcher-6] [akka://default/user/Grpc] Message [AkkaMessage.package$GlobalStart] from

2熱度

2回答

如何在集羣中運行一次Akka Scheduler？

我想在羣集中運行Akka調度程序的單個實例。目前我的調度程序在我的本地工作正常，但不像預期的那樣。調度程序從數據庫中選擇訂單並推送到Kafka主題。我正在使用akka 2.5.6（Java）。我已經通過了official Doc，但沒有提供太多的幫助。任何幫助將不勝感激。 public class OrderReprocessActor extends UntypedActor {

0熱度

1回答

Akka集羣 - 來自死信的消息？

我正在使用Akka集羣，我有一個有趣的問題。我在節點A上有一個演員Actor1（akka.tcp：//[email protected]：2554）。此演員發現使用 val actor2sel = context.actorSelection(RootActorPath(m.address)/"user"/"actor2") m哪裏是集羣的成員的另一節點上的另一行動者。 actor2sel是

1熱度

1回答

卡夫卡作爲阿卡的持久性雜誌

在寫日記的不同選項來實現事件採購，卡夫卡似乎從「外部」一個非常合理的選擇：它有一個很大的生態系統它是有據可查的它自然地支持流媒體和聽衆然而，尋找到阿卡持久性，似乎只有通過社會貢獻packag卡夫卡日記支持e，這在過去的2年裏沒有被修改過。卡夫卡不是一個好的選擇，是否有更好的選擇，如果這是最好的選擇，那麼人們是如何使用它的akka-persistance？