Вопросы по теме 'akka-cluster'
Широковещательное сообщение для маршрутов в ClusterRouter в Akka
Я пытаюсь передать сообщение всем маршрутам в конфигурации ClusterRouter . Я уже пробовал два варианта. Вот этот:
val workerRouter = context.actorOf(Props[ClusterRouter].withRouter(
ClusterRouterConfig(AdaptiveLoadBalancingRouter(metrics),...
2055 просмотров
schedule
20.10.2022
Проверить, был ли отправитель-субъект локальным или удаленным
Мне нужно определить, был ли отправитель сообщения одним из локальных или удаленных субъектов в кластере Akka. В настоящее время я нашел единственный способ сделать это:
def isLocal(sndr: ActorRef) = sndr.path.address.toString ==...
932 просмотров
schedule
25.03.2022
Создать актера на любом неуказанном/случайном узле в кластере
Можно программно создать актера на удаленном узле, если вы укажете точный узел .
Однако я хотел бы просто попросить акторную систему создать актор на случайном или, возможно, наименее используемом узле.
Можно ли создать актера на любом...
1154 просмотров
schedule
29.07.2023
Выбрать Akka или Spark для параллельной обработки?
При выборе распараллеливания задач я обычно использую Spark. Чтение статей о параллельной обработке в Akka, таких как http://blog.knoldus.com/2011/09/19/power-of-parallel-processing-in-akka/ кажется, что использование Akka для распараллеливания...
3396 просмотров
schedule
04.04.2023
ClusterSingletonManager не переходит на другой ресурс
Я тестировал кластер Master/Worker со следующей настройкой:
2 виртуальных сервера, на каждом сервере есть Master и Worker (отдельные jvms)
Мастер создается с помощью ClusterSingletonManager
Мастера также являются семенными узлами.
Я...
242 просмотров
schedule
17.09.2022
Akka cluster-sharding: могут ли участники Entry иметь динамические свойства
Похоже, что Akka Cluster-Sharding хорошо сочетается с вариантом использования, в котором я должен создавать отдельные экземпляры постоянных субъектов с отслеживанием состояния на узлах Akka.
Я не понимаю, возможно ли иметь тип субъекта Entry,...
2789 просмотров
schedule
14.09.2023
Запуск приложения с помощью sbt и Akka Microkernel
Могу ли я использовать оба в своем проекте?
Раньше у меня был только объект, расширяющий черту App , но поскольку я начал использовать Microkernel , мне нужно иметь класс, расширяющий черту Bootable .
Допустим, у меня есть что-то вроде этого:...
593 просмотров
schedule
26.08.2023
акка-потоки с акка-кластером
Мой акка-стрим продолжается. Я хочу интегрировать свое приложение akka-streams с akka -cluster и DistributedPubSubMediator .
Добавить поддержку публикации довольно просто, но с частью подписки у меня проблемы.
Для справки: подписчик указан в...
4182 просмотров
schedule
27.05.2024
Как правильно развернуть с помощью Akka Cluster
Сценарий
Сейчас у нас есть только один узел, на котором работает вся система. Мы хотим провести различие между «интерфейсными» узлами и одним «внутренним» узлом.
Узлы "Frontend" (N узлов): поддерживает постоянное соединение с клиентами через...
881 просмотров
schedule
12.02.2022
Есть ли пример отправки сообщений между акторами с помощью Akkling.Cluster.Sharding?
Это может быть дублировать .
Таким образом, я добился определенного прогресса. Однако мне сложно интерпретировать справочную документацию по C# API к нужному API Akka.FSharp .
Есть ли пример отправки сообщений между акторами с помощью...
434 просмотров
schedule
05.09.2023
Akka не выбирает существующий рабочий узел в качестве начального узла, как только начальный узел убит
Я новичок в акке. Имея очень простую конфигурацию с одним начальным узлом и одним не начальным узлом.
Пожалуйста, найдите ниже, последовательность операций: -
Начальный узел запущен: -
val pConfig =...
355 просмотров
schedule
26.10.2022
Как я могу определить начальные узлы во время выполнения
У меня есть кластер akka с application.conf, как показано ниже:
remote { // Remote configuration for this seed node
enabled-transports = ["akka.remote.netty.tcp"]
netty.tcp {
hostname = ""
port = 2555
}
}
cluster {
seed-nodes = [...
511 просмотров
schedule
01.01.2024
В документе Akka неясно, как заставить ExtendedActorSystem десериализовать ActorRef.
Я пытаюсь сериализовать/десериализовать ActorRef через protobuf. Согласно документу Akka, единственный способ сделать это — преобразовать ActorRef в String и преобразовать его обратно в систему удаленного актера.
В документе упоминается...
486 просмотров
schedule
22.11.2023
Потоки Akka - можно ли масштабировать как обычных актеров или как-то иначе?
У меня есть код, выполняющий конвейер с использованием потоков Akka.
Мой вопрос в том, как лучше масштабировать его? Можно ли это сделать и с помощью потоков Akka?
Или его нужно преобразовать в акторов/другим способом?
Фрагмент кода:
val...
364 просмотров
schedule
17.07.2023
Проверить, существует ли актер в кластере akka
Я столкнулся со сценарием, в котором мне нужно проверить, существует ли конкретный субъект или нет, что можно сделать с помощью метода ActorSystem.actorSelection, указав путь к субъекту. Однако этот метод работает правильно, когда такой субъект...
718 просмотров
schedule
23.05.2024
Akka Cluster - Восстановление данных с разбившегося актера
Предположим, у меня есть мастер с n подчиненными, где подчиненные расположены на других компьютерах.
Мастер-актер выглядит так
class MasterActor extends Actor {
val router: ActorRef = // ... initialized router to contact the slaves...
174 просмотров
schedule
07.05.2024
Отключить ведение журнала akka для akka.actor.LocalActorRefProvider?
Я получаю кучу таких сообщений:
2018-09-25 14:22:42.606 [DEBUG] akka.actor.LocalActorRefProvider(akka://cluster) - Resolve (deserialization) of path [system/ddataReplicator/$b#1795511840] doesn't match an active actor. It has probably been...
266 просмотров
schedule
25.05.2024
Как исправить частичные результаты, появляющиеся в Cinnamon (телеметрия Lightbend)
Я запускаю кластер akka в трех контейнерах докеров. Я запускаю корицу для сбора некоторой телеметрии, и у меня есть такая ситуация, когда это только карта размера пула, активных потоков, запущенных потоков и параллелизма на панели управления Akka...
64 просмотров
schedule
10.05.2024
Какие плагины сохраняемости поддерживаются акка-типизированным и кластерным сегментированием
Я играю с Akka Typed (версия 2.6.0) и источником событий, и мне удалось заставить его работать с плагином LevelDB.
Поскольку я намерен использовать кластерную среду, LevelDB не будет работать с такой настройкой, поскольку он хранит данные в...
54 просмотров
schedule
06.01.2024
Alpakka AMQP: как обнаружить исключение объявления?
У меня есть источник AMQP и приемник AMQP с объявлениями:
List<Declaration> declarations = new ArrayList<Declaration>() {{
add(QueueDeclaration.create(sourceExchangeName));
add(BindingDeclaration.create(sourceExchangeName,...
52 просмотров
schedule
27.03.2023
