Публикации по теме 'akka'
[Akka Stream] Принципы механизмов задержки и варианты использования по сравнению с регулированием
Механизмы задержки
При использовании Akka Stream и столкновении с проблемой задержки сообщений; очевидный ответ — использовать метод Source.delay или Flow.delay.
Однако важно понять некоторые основные принципы, чтобы полностью освоить использование задержки.
Задерживать
Задержка не блокирует сообщения от восходящего потока. Вместо этого он принимает сообщения внутри своего внутреннего буфера, и задержка начинается, как только сообщение попадает внутрь этого внутреннего буфера...
Сохранение состояния актора с использованием Akka Persistence
Актер Akka может иметь состояние, но он теряется при завершении работы или сбое актора. К счастью, мы можем сохранить состояние актора, используя Akka Persistence , которое является одним из расширений Akka.
Сначала добавьте в build.sbt следующие зависимости:
libraryDependencies ++= Seq(
"com.typesafe.akka" %% "akka-actor" % "2.4.2",
"com.typesafe.akka" %% "akka-persistence" % "2.4.2",..
Воспроизведение шаблона обработчика событий Erlang в Akka
Мне нравится создавать системы. Системы в кибернетическом смысле слова: компоненты и связи между ними. Вот почему я пытаюсь найти языки программирования, поддерживающие этот тип программирования. Моя текущая одержимость — Erlang. Сначала небольшое отступление…
Эрланг
На мой взгляд, Эрланг не очень прост в изучении из-за нескольких вещей:
Синтаксис Парадигма
С первым особых проблем нет. Его можно преодолеть, если много разглядывать код до тех пор, пока он не обретет смысл...
Что они не говорят о «спросить»
Создание хорошей системы актеров начинается с малого. Если мы сначала не поймем должным образом меньшие строительные блоки, из которых строится большая система, мы рискуем распространить все эти маленькие ошибки таким образом, что это может превратиться в кошмар.
Вы, должно быть, сталкивались с двумя способами общения с Актером : Рассказать (!) и Спросить (?)
Tell (!) означает асинхронную отправку сообщения актору без ожидания ответа. Это обязательно. Вы говорите актеру что-то..
Вопросы по теме 'akka'
Каковы недостатки использования модели Immutability + Actor для программирования с параллелизмом?
При создании большого многопоточного приложения для индустрии финансовых услуг я везде, где мог, использовал неизменяемые классы и модель Actor для рабочего процесса. Я очень доволен результатом. Он использует изрядное количество кучи (его в Java,...
952 просмотров
schedule
27.09.2021
имена регистраторов для настройки регистратора akka с помощью обработчика событий
Итак, я использую Slf4jEventHandler и logback-classic. Как настроить уровни ведения журнала для разных субъектов отдельно? [Я использую Akka 2.0_M2]
Я пробовал делать что-то вроде
<configuration debug="true" scan="true">...
2655 просмотров
schedule
18.11.2021
Синтаксис Scala / Akka Socket Server IterateeRef
Может кто-нибудь объяснить мне значение этой строки кода?
val state = IO.IterateeRef.Map.async[IO.Handle]()(context.dispatcher)
(из http://doc.akka.io/docs/akka/2.0/scala/io.html )
Я предполагаю, что это частичное применение асинхронной...
402 просмотров
schedule
02.12.2021
application.conf для Scala SBT Akka Actors
Мне было интересно .. куда вы кладете application.conf файл, который настраивает актеров в файле? Я пытаюсь сделать то, что делается здесь , но SBT не улавливает файл - у меня создалось впечатление, что SBT найдет application.conf и...
10564 просмотров
schedule
06.11.2021
Эквивалент сообщения зависимых типов методов
Благодаря этому сообщению я получаю моя голова вокруг зависимых типов методов. У меня есть структура, подобная следующей
trait Environment{
type Population <: PopulationBase
protected trait PopulationBase
def...
180 просмотров
schedule
01.11.2021
Неявное преобразование Scala в Akka ActorRef блокирует доступ к оператору отправки Akka !, почему?
Я использую Akka для программирования модели акторов с помощью Scala, и для того, чтобы полностью и в достаточной мере использовать некоторые функции моей структуры, я решил использовать неявное преобразование из абстрактного класса Scala в Akka...
672 просмотров
schedule
17.09.2021
Кластеризация Akka - заставляет акторов оставаться на определенных машинах
У меня есть приложение akka, которое я буду развертывать на многих машинах. Я хочу, чтобы каждое из этих приложений взаимодействовало друг с другом с помощью функций распределенной шины событий публикации / подписки.
Однако, если я настраиваю...
1034 просмотров
schedule
23.11.2021
какой смысл в Akka Microkernel с использованием Java и Maven?
Я разработал сервер на основе Akka, и мне понравилась идея Microkernel . . Однако, когда я смотрю на детали реализации с использованием Java и Maven Я торгую простым основным классом запуска Java для решения, специфичного для фреймворка, которое...
921 просмотров
schedule
09.10.2021
Простые сеансы баз данных, эффективность и многопоточность в Akka
В настоящее время я работаю с очень большой базой данных (> 50 ГБ) и пытаюсь понять наиболее эффективный и удобный подход, который хорошо сочетается с присущей Akka потоковой передачей.
Что касается подхода «обертывание всего внутри withSession...
2599 просмотров
schedule
28.10.2021
Как я могу разобрать Spray API HTTPResponse?
Я использую Spray API (спрей-клиент), чтобы попасть по внутреннему URL-адресу Solr, я хочу иметь возможность анализировать ответ в классе случая Scala.
Если я просто ожидаю и HTTPResponse, я получаю значение обратно, но когда я пытаюсь...
4485 просмотров
schedule
13.09.2021
Как начать актер Scala akka
Класс ниже вызывает ошибку в строке new HelloWorld:
Exception in thread "main" akka.actor.ActorInitializationException: You cannot create an instance of [HelloWorld] explicitly using the constructor (new). You have to use one of the 'actorOf'...
11441 просмотров
schedule
22.09.2021
Akka Pattern - дерево актеров, ответ на первоисточник
Это вопрос дизайна;
Скажем, у меня есть дерево актеров, которые выполняют кучу обработки. Обработка запускается клиентом / субъектом соединения (т. Е. Дерево является сервером). В конце концов клиентский актер хочет получить ответ. Т.е. У меня...
2954 просмотров
schedule
26.09.2021
scala- как подписаться на событие Akka Leader Up
Я использую акку с игрой. И я хочу, чтобы что-то было сделано только один раз, когда появится новый лидер.
Я собираюсь найти что-то вроде этого, другими словами, я ищу что-то подобное.
class LeaderUpHook {
def onLeaderUp {...
940 просмотров
schedule
22.09.2021
Вложенные фьючерсы в Akka
У меня есть два актера, A и B. Мой псевдокод будет выглядеть так:
if A has a given state
return "ok"
else
send a message to B and return "ok" when B is done handling the message
Это моя реализация с использованием Await:
val f1 =...
447 просмотров
schedule
07.09.2021
можно ли побороть стирание типа в акка получать?
У меня есть особенность и реализация актора akka, который не может должным образом различать типы входящих сообщений из-за стирания типа, поэтому первый случай соответствует всем сообщениям.
Я использую scala 2.10.x, и, прочитав множество других...
1113 просмотров
schedule
17.09.2021
Как отключить сообщения об ошибках Akka, когда клиентский субъект отключается от удаленного субъекта?
Я попытался отключить, следуя тому, что мне было сказано в консольном сообщении: я установил akka.log-dead-letter-during-shutdown = off и log-dead-letter = off. Я даже установил log-remote-lifecycle-events = off. Но вроде не работает:
Мой...
417 просмотров
schedule
02.10.2021
Как масштабировать akka-jetty на несколько машин? (обратный прокси)
У меня есть пристань (apache camel). Потребительский актор акка, который получает запрос, направляет запрос вместе с дескрипторомactorRef в клиентский сокет соответствующему «рабочему актору» для генерации запрошенного контента, затем я отправляю...
402 просмотров
schedule
13.09.2021
Правильный способ создания ActorSystem внутри Actor
Я использую стороннюю библиотеку ( rediscala ) для доступа к базе данных Redis в моем собственном Актере. Ниже приведен пример того, как я сейчас это делаю. Это верно ? Есть ли какие-либо потенциальные проблемы со следующим кодом, потому что я...
640 просмотров
schedule
29.10.2021
Последствия родства родитель-ребенок в акка
import akka.actor._
case object ChildMessage
implicit val as = ActorSystem()
class Child extends Actor {
def receive = {
case ChildMessage => println("I'm a child")
}
}
class ParentWithExplicitChildren extends Actor {
val children =...
506 просмотров
schedule
08.10.2021
Почему возникает ошибка "Конфликт межверсионных суффиксов"?
Я получаю эту ошибку, когда пытаюсь скомпилировать проект Scala в sbt.
Modules were resolved with conflicting cross-version suffixes in {file:/home/seven3n/caja/Flujo_de_caja/}flujo_de_caja:
[error] com.typesafe.akka:akka-actor _2.11, _2.10...
23197 просмотров
schedule
27.10.2021
