actor

11Ciepło

2Odpowiedz

Nieprzenikniony błąd spowodowany przez wyłączenie wątku maszyny JVM, ponieważ w systemie ActorSystem

jest włączony plik "akka.jvm-exit-on-fatal-error". W wierszu polecenia uruchomiono plik JAR i uzyskałem wyjątek poniżej. I w wyniku zakończenia. błąd Uncaught z nici [ccp-akka.persistence.dispatchers.

5Ciepło

1Odpowiedz

nie można znaleźć niejawnej wartości dla systemu parametrów: akka.actor.ActorSystem

Tworzę przypadek testowy dla aktora Akka, używając TestActorRef. def actorRefFactory = context implicit def executionContext = actorRefFactory.dispatcher implicit val OutputActor = actorRe

9Ciepło

1Odpowiedz

Jak ciężcy są aktorzy akka?

Jestem świadomy, że jest to bardzo nieprecyzyjne pytanie i może zostać uznane za nieodpowiednie dla stosu. Niestety, mniejsze aplikacje (pod względem liczby aktorów) i "podobne do tutorialu" nie pomag

7Ciepło

1Odpowiedz

Jak miksować aktorów i aktorów bez typu?

Jak miksować aktorów i aktorów bez typu? Jak zrozumiałem, muszę określić głównego aktora, gdy tworzę instancję ActorSystem jak ten val system: akka.typed.ActorSystem[Start] = akka.typed.ActorSystem("m

6Ciepło

1Odpowiedz

Jaka jest różnica między przepływem danych TPL a Akka.net?

Pracowałem z przepływem danych TPL. Naprawdę się podobało. Wiele razy słyszałem termin Akka od moich znajomych java/scala, więc próbowałem przeczytać o tym i dowiedziałem się, że akka również ma port

6Ciepło

2Odpowiedz

Ponów/ponów komunikaty o błędach w AKKA

Używam AKKA.NET w moim bieżącym projekcie .NET. Moje pytanie brzmi następująco: W jaki sposób doświadczeni programiści AKKA wdrażają wzorzec powtórnej transmisji po awarii przy użyciu najnowszych bibl

5Ciepło

2Odpowiedz

Wzorzec aktora z Akka i długimi procesami

Ostatnio badałem wspaniały układ Akka, aby spróbować go poczuć i zdecydować, czy będzie on odpowiedni dla mojego projektu. Obecnie ta aplikacja jest zwykłą starą aplikacją java, która wykonuje bardzo

10Ciepło

2Odpowiedz

Poczekaj na asynchroniczne Przyszłe połączenie przed przetworzeniem następnej wiadomości w Akka

Podczas odbierania zdarzeń, Aktorzy Akka będą przetwarzać jedną wiadomość na raz, blokując, aż żądanie zostanie zakończone przed przejściem do następnej wiadomości. Działa to dobrze dla zadań synchron

12Ciepło

1Odpowiedz

Jak radzić sobie z limitami czasu w poolboyu?

Mam problem z długotrwałą migracją, którą chciałem uruchomić równolegle (można ją uruchomić równolegle). W rzeczywistości migracja polega na zabraniu wszystkich rekordów do bazy danych i zaimplementow

9Ciepło

1Odpowiedz

Iskrzenie strumieniowe z aktora

Chciałbym, aby aktor konsumencki zasubskrybował temat Kafki i przesyłał dane do dalszego przetwarzania za pomocą Spark Streaming poza konsumentem. Dlaczego aktor? Ponieważ przeczytałem, że jego strate