Нужно ли мне повторно использовать ту же систему Akka ActorSystem или я могу просто создать ее каждый раз, когда она мне нужна?

Акка 2.X требует много команд для ссылки ActorSystem. Итак, чтобы создать экземпляр актера MyActor вы можете сказать: val system = ActorSystem() val myActor = system.actorOf(Props[MyActor]) из-за частой необходимости ActorSystem: многие примеры к ...

Akka-сколько экземпляров актера вы должны создать?

Я новичок в рамках Akka, и я создаю приложение HTTP-сервера поверх Netty + Akka. моя идея до сих пор заключается в создании актера для каждого типа запроса. Например, у меня был бы актер для сообщения в /my-resource и другой актер для получения /my- ...

В чем разница актера акки с моделью актера скалы

Я обнаружил, что есть также модель акка-актера, поэтому мне интересно, в чем разница между актером акки и моделью актера скалы? ...

Как это узел.JS evented system отличается от модели актера Акка?

Я работал с Node.js на некоторое время и считаю себя довольно хорошо с Java. Но я только что обнаружил Akka и сразу же заинтересовался его картины актер (насколько я понимаю). это было мое понимание, что узел отлично справляется со многими одновр ...

Как акка сравнивается с Эрлангом? [закрытый]

Я недавно смотрел на Акку, и это довольно впечатляет. Похоже, что у него есть большинство убийственных функций erlang - прозрачность местоположения, иерархия надзора и многое другое. Есть ли у Эрланга какие-то особенности, которых нет у акки? ...

Параллелизм Java: OpenCL / GPU против актеров / потоков

Проект APARAPI описывает себя следующим образом: Aparapi позволяет разработчикам Java использовать преимущества вычислительной мощности GPU и устройств APU, выполняя фрагменты параллельного кода данных на GPU, а не ограничиваясь локальным процес ...

Как создать источник, на который не влияет противодавление

Я хочу протестировать некоторые функции Akka streams, такие как conflate. Для этого мне нужно построить источник, на который не влияет противодавление в рамках простого юнит-теста. Наивные попытки вроде Source.tick(1.milli, 1.milli, "tick").map(_ = ...

Это Акка задать блокируя текущий поток

У меня есть сценарий, в котором я должен получить сведения о пользователе по его id. Это HTTP-запрос, который приходит в мой уровень обработчика HTTP, я использую идентификатор, который я получаю из запроса, посылаю сообщение актору, который затем об ...

Запуск SBT (Scala) на нескольких (кластерных) машинах одновременно

Поэтому я уже некоторое время играю с актерами Akka и написал некоторый код, который может распределять вычисления между несколькими машинами в кластере. Перед запуском "основного" кода мне нужно иметь ActorSystem, ожидающий на каждой машине, которую ...

Обрабатывать первый элемент Акка трансляция специально

Существует ли идиоматический способ обработки первого элемента потока Akka Source особым образом? То, что у меня сейчас есть: var firstHandled = false source.map { elem => if(!firstHandled) { //handle specially firs ...

Akka.net динамическое добавление ребенка

Есть сконфигурированный ActorSystem с акторами, организованными иерархически следующим образом: /user /processes /process1 /process2 /process3 Для генерации этой схемы я использую следующий код C#: // in entry point IActorRef proc ...

Akka-Http: как вернуть ответ от актера?

Я использую актора внутри запроса с шаблоном "ask": val route = pathPrefix("myapp") { path("search") { get { (mainActorRef ? DoSomething("foo")).mapTo[ReturningType].map { result => complete(HttpEntity(ContentTypes. ...

Лучшие практики для проверки Акка упорство команды

Допустим, у нас есть команда AddUser: case class AddUser(username: String, password: String) Как лучше всего проверить эту команду перед сохранением события? Делать это таким образом, например, кажется довольно грязным. override def receiveComma ...

Почему lagom использует асинхронный аппендер в производстве

Следующий ресурс утверждает, что Lagom использует асинхронный регистратор в рабочей среде. https://www.lagomframework.com/documentation/1.3.x/java/SettingsLogger.html Однако lagom также использует akka, и akka советует вам использовать akka-способ ...

Почему Scala не выводит параметры типа при сопоставлении с шаблоном @

Я использую Scala 2.10.4 с akka 2.3.4. Я столкнулся с проблемой, когда вывод типа ведет себя не так, как я ожидал. Приведенный ниже код иллюстрирует пример того, что я испытываю. У меня есть класс case, который обертывает сообщения с именем id M ...

Регистрируйте все сообщения в Akka без изменения всех методов получения

Я хочу регистрировать все полученные сообщения для всех участников в моем приложении Akka. Существует конфигурация akka.actor.debug.receive, которая будет регистрировать все сообщения, отправленные актору, если этот метод получения акторов является L ...

Альтернативы JGroups

Я хочу создать распределенное приложение на JVM, которое имеет несколько узлов, и мне нужна библиотека, которая позволит мне: Управление членством в кластере / сетке, т. е. я хочу получать уведомления об отпуске / присоединении управление сообщения ...

Что плохого в том, как я использую akka unbecome

Есть класс scala (из курса Coursera reactive) class Counter extends Actor { def counter(n: Int): Receive = { case "inc" => context.become(counter(n + 1)) case "get" => sender ! n } def receive = counter(0) } Все, что ...

Бассейн рабочих с ручьями Акка

Как описано в документации Akka streams я попытался создать пул рабочих (потоков): def balancer[In, Out](worker: Flow[In, Out, NotUsed], workerCount: Int): Flow[In, Out, NotUsed] = { import GraphDSL.Implicits._ Flow.fromGraph(GraphDSL.cre ...

Akka-Http Websockets: как отправлять потребителям один и тот же поток данных

У меня есть WebSocket, к которому клиенты могут подключиться, у меня также есть поток данных с помощью akka-streams. Как я могу сделать так, чтобы все клиенты получали одни и те же данные? В данный момент они, похоже, гонятся за данными. Спасибо ...