Akka ist ein Open-Source-Toolkit und eine Laufzeitumgebung, die den Aufbau gleichzeitiger und verteilter Anwendungen auf der JVM vereinfacht. Es implementiert das von Erlang bekannte Akteursmodell.
Ich bin ziemlich Neuling zu Akka Streams und Akka HTTP.
Ich möchte einen einfachen HTTP-Server generieren, der aus dem Inhalt eines Ordners eine ZIP-Datei generieren und an den Client senden kann.
Die org.zeroturnaround.zip.ZipUtil macht d...
Hier ist das Muster, auf das ich gestoßen bin:
Ein Schauspieler A hat mehrere Kinder C1 , ..., Cn . Nach Erhalt einer Nachricht sendet A die Nachricht an jedes ihrer untergeordneten Elemente, die jeweils eine Berechnung für die Nach...
Ich versuche, den Fehler (s), den ich unten sehe, zu verstehen und zu lernen, wie ich es beheben kann.
%Vor%
Hier ist der Testcode, der den Fehler verursacht hat:
%Vor%
Dies ist wahrscheinlich ein extrem einfacher Fehler, aber ich kann nicht richtig funktionieren.
Ich benutze Akka 2.2.3, um eine aktorbasierte Anwendung in scala zu erstellen.
Die vereinfachte Einrichtung ist die folgende:
%Vor%
Und der Ha...
Ich versuche scala -akka von sbt zu benutzen.
Meine sbt-Datei sieht wie folgt aus:
%Vor%
mein Code:
%Vor%
Wenn ich sbt compile mache, bekomme ich
%Vor%
Bitte um Rat.
EDIT2:
basierend auf den folgenden Kommentaren. Hier ist d...
Gibt es einige Codebeispiele für die Verwendung von Bibliotheken org.reactivestreams zur Verarbeitung großer Datenströme mit Java NIO (für hohe Leistung)? ? Ich strebe eine verteilte Verarbeitung an, also wären Beispiele, die Akka verwenden, a...
Ich versuche einen Akteur auszuwählen, der bereits erstellt wurde. Hier ist ein Code:
%Vor%
Das Ergebnis ist:
%Vor%
Ich kann auch eine Nachricht an den Schauspieler weitergeben und es wird gut abgeschlossen.
Was habe ich bei actorSelecti...
Ich fange an Akka zu lernen, indem ich eine bestehende Java SE App dorthin migriere. Ich benutze Akka 2.0.3.
An einem Punkt muss ich eine PoisonPill durch die Nachrichtenwarteschlange senden, um die Akteure zu stoppen. Mein Akteur wird so ins...
Ich möchte etwas so machen.
Schauspieler A:
%Vor%
Darsteller B: (dies remote eingesetzt)
%Vor%
Ich möchte, dass er mir die Zeichenfolge akka zurückgibt: //10.4.20.40: 2555 / slave / user / slaverunner. Aber was ich bekomme ist nur a...
Wie soll ich eine Ausnahme behandeln, die der DbActor hier auslöst? Ich bin mir nicht sicher, wie ich damit umgehen soll, sollte der Fehler Fall pipe?
%Vor%
Würde sich freuen, Ihre Gedanken zu bekommen, danke im Voraus!