Описание тега akka
Akka - это набор инструментов и среда выполнения с открытым исходным кодом, упрощающие создание параллельных и распределенных приложений на JVM. Он реализует модель акторов, известную из Erlang.
1
ответ
Остановить обработку сообщений актера по таймауту
Я использую шаблон запроса с тайм-аутом для отправки сообщения моему актеру, что может занять много времени для его обработки. Я хотел бы прекратить обработку сообщения, если время ожидания истекло. Но, похоже, актер продолжает обрабатывать сообщени…
18 июл '13 в 15:26
0
ответов
Установить / изменить свойства списка в application.properties в Akka
Я хочу использовать slf4j для ведения журнала, основываясь на документации doc. Эти настройки должны быть изменены в application.conf: akka { loggers = ["akka.event.slf4j.Slf4jLogger"] logging-filter = "akka.event.slf4j.Slf4jLoggingFilter" } я испол…
24 ноя '18 в 12:03
1
ответ
Монитор Akka DeadLetter не получает сообщения, отправленные необработанными ()
У меня есть следующие настройки актера: public class Master extends AbstractActor { protected Logger log = LoggerFactory.getLogger(this.getClass()); @Override public Receive createReceive() { return receiveBuilder() .match(Init.class, init -> { l…
29 ноя '18 в 14:12
2
ответа
Akka http с помощью Java - получить строку из RequestEntity
Я пытаюсь получить тело запроса http, но кажется, что это не так просто, как может показаться, если, конечно, я что-то упустил. У меня есть экземпляр HttpRequest (от akka.http.javadsl.model) и от этого я могу получить RequestEntity, но я не могу пон…
18 июл '16 в 20:22
2
ответа
Работа с несколькими Scala Futures
У меня больше одного Future, val actor1 : Future[ActorRef] = createActorA() val actor2 : Future[ActorRef] = createActorB() ... ... ... Теперь мне нужно извлечь ActorRefиз всех этих фьючерсов, чтобы я мог использовать их для создания Router, val rout…
17 июл '14 в 21:04
1
ответ
Akka Streams, тайм-аут, если время между завершенной обработкой одного элемента до следующей обработки
Я хочу, чтобы мой поток не работал, если время между завершением обработки одного элемента и началом обработки следующего элемента превышает определенное количество. Похоже, что ни один из существующих методов тайм-аута не имеет отношения к этому сл…
11 апр '18 в 17:41
1
ответ
Как отправлять сообщения в систему akka в соседнем jvm?
Я запустил систему akka с HelloActor в одной JVM и пытался отправить ему сообщения от клиента в другой JVM. И ничего не работает. Как я должен сделать это правильно? Вот код: Простой сервер package akkaSample.severalSystems import akka.actor.{Props,…
03 сен '14 в 10:41
2
ответа
Есть ли способ подождать полной остановки актера?
Как я знаю, все операции в Akka.Net являются асинхронными, и Context.Stop() просто отправляет Stop сообщение актеру. Это означает, что актер будет жив в течение некоторого времени, прежде чем он полностью отключится. И если я позвоню Context.Child()…
06 янв '17 в 10:48
1
ответ
Как регистрировать все входящие сообщения от Akka (Java)
В Scala вы можете заключить функцию приема в LoggingReceive. Как добиться того же от Java API? def receive = { LoggingReceive { case x ⇒ // do something } }
08 янв '14 в 16:12
1
ответ
Обработка операций блокировки в Play 2.1
Я пытаюсь создать способ обработки блокирующих операций определенным образом в Play. Сначала я описал, за какой моей целью следует то, что мне удалось сделать до сих пор. Не могли бы вы сказать мне, если я на правильном пути - если да, не могли бы в…
17 янв '14 в 06:55
1
ответ
Изменить постоянный запрос с устаревшего PersistentView
Я использую Akka Persistence, с LevelDB в качестве плагина для хранения, в приложении, написанном на Scala. На стороне запроса текущая реализация использует PersistentView, который опрашивает сообщения от PersistentActorЖурнал, просто зная идентифик…
15 сен '17 в 12:39
1
ответ
Возможно ли автоматическое масштабирование акки
Мне нужен кластер Akka для запуска нескольких задач с интенсивным использованием процессора. Я не могу предсказать, сколько мощности процессора мне нужно. Иногда нагрузка высокая, в то время как в другое время нагрузки не так много. Я думаю, что авт…
19 авг '18 в 05:37
2
ответа
Akka Actor Memory Leak или управление
Есть ли у вас какой-либо опыт с управлением / утечкой памяти akka actor? Здесь у меня есть модуль, использующий akka actor для взаимодействия с другими модулями, но со временем один из модулей вышел из строя из-за размера кучи памяти. Нужно ли отпра…
12 ноя '15 в 09:59
1
ответ
Scala потоковая передача живого / растущего файла
Мое приложение Scala запускает внешний процесс, который записывает файл на диск. В отдельном потоке я хочу прочитать этот файл и скопировать его содержимое в OutputStream пока процесс не будет завершен и файл больше не будет расти. Есть несколько кр…
21 апр '18 в 23:32
1
ответ
Скачать указанный файл с потоками Акка?
Для следующего кода мне нужно, чтобы клиент отправил имя файла на сервер, чтобы сервер мог ответить клиенту на содержимое указанного файла. Это может сработать, если я не укажу имя файла, просто жесткое кодирование в серверной части, но как клиент с…
02 фев '18 в 08:02
1
ответ
Как ограничить доступ к локальному актеру
Я ищу методы инкапсуляции, такие как private для учеников. Я хотел бы, чтобы актер обеспечил принятие некоторых распространенных безобидных сообщений и привилегий, которые могли бы изменить состояние нежелательным образом. Я также могу создать прокс…
20 авг '15 в 16:21
2
ответа
Можно ли получить кортеж внутри актера без предупреждения "устранено стиранием"
Интересно, возможно ли получить кортеж внутри актера, не получив это предупреждение: non-variable type argument Long in type pattern (Long, Int) is unchecked since it is eliminated by erasure хотя код кажется действительным и работает: override def …
19 июн '16 в 11:03
1
ответ
Тупик в актерах Акка Скала
У меня очень простая структура, основанная на актерах Akka в Scala, но я продолжаю получать предупреждения о недоставленных сообщениях. Это код для основного класса, Collector - это отдельный класс, расширяющий Actor: object Executor extends App { c…
27 апр '14 в 19:03
1
ответ
Управление версиями артефакта API Java Akka?
Мне интересно узнать об соглашениях версий API-интерфейса Akka, и я ничего не могу найти в их документах. Если вы попали в репозиторий Maven и выполните поиск доступных akka-actor версии, вы найдете записи, как: 'com.typesafe.akka:akka-actor_2.10:2.…
29 апр '16 в 14:43
2
ответа
Почему у akka.persistence все еще бета-версия? Это стабильно?
Почему akka.persistence до сих пор выпускается бета-версия для пакетов nuget. Означает ли это, что он все еще нестабилен и не подходит для использования в производственных приложениях?
20 мар '17 в 06:42