Вопросы по теме 'akka-cluster'

Akka Cluster удаляет сообщение о подключении пульса
Что означает информационное сообщение FailureDetector(akka://MyCluster) - Remove heartbeat connection [akka://[email protected]:35250] в кластере Акка имеете в виду? Кажется, я ничего не могу найти в документации. Я часто вижу это при...
801 просмотров
schedule 08.08.2022

Несколько систем akka на одном ПК
Как мы можем запустить несколько узлов akka на одном компьютере? В настоящее время я следую в своем файле application.conf . Для каждой системы я добавил разные номера портов, но не могу запустить более одного экземпляра. Ошибка говорит, Address...
4707 просмотров
schedule 02.10.2022

максимальное количество актеров на хост в akka
Сколько максимальных актеров мы можем иметь на одной коробке в akka? public void MyActor extends AkkaActor{ receive(Objet obj){ // so something } } 1)Is there some limit on max number of actors instances?I am planning to created around...
3253 просмотров
schedule 05.10.2022

узлы кластера akka за NAT (с использованием докера)
Можно ли запускать узлы akka за NAT (каждый узел находится за отдельным nat, публичный порт привязан к частному)? В настоящее время я пытаюсь развернуть узлы akka в контейнере докеров. Docker использует открытый порт Nating для частного порта...
2356 просмотров
schedule 05.03.2024

Примеры использования Akka Cluster, Cluster Sharding и Cluster singleton
Я пишу приложение Akka и хочу использовать функцию кластера Akka, которую предоставляет Typsafe. Я пытаюсь понять основное различие между Akka Cluster, Akka Cluster Singleton и Akka Cluster Sharding. Мне кажется, что они предоставляют похожие вещи....
2686 просмотров
schedule 26.04.2022

Как подписаться на событие становления ЛИДЕРОМ в Akka Cluster Singleton Pattern
В качестве члена экземпляра кластера Akka Singleton, как подписаться на событие становления LEADER в шаблоне Akka Cluster Singleton. application.conf следующим образом: akka { actor { provider = "akka.cluster.ClusterActorRefProvider"...
362 просмотров
schedule 06.06.2023

akka простой кластер с двумя начальными узлами
Пользуюсь akka cluster 2.3.6 Я скомпилировал две отдельные банки, и внутри у меня есть основной класс val configuration = ConfigFactory.load() val bucket = configuration.getString("bucket") val system =...
5039 просмотров
schedule 21.11.2022

Запрос члена кластера Akka
Можно ли с кластером akka запросить, какие члены в данный момент находятся в кластере? Если начальный узел выходит из строя и в конечном итоге снова поднимается, может ли он узнать, какие другие члены используют его в качестве начального узла?
282 просмотров
schedule 11.11.2022

Сочетание маршрутизации спрея и сопоставления шаблонов актеров
Следуя документации Akka Cluster, у меня запущен пример Worker Dial-in. http://doc.akka.io/docs/akka/snapshot/java/cluster-usage.html Поэтому я пытаюсь интегрировать это с маршрутизацией распыления. Моя идея состоит в том, чтобы иметь...
277 просмотров
schedule 14.06.2022

Система мониторинга для кластера Akka
Очень сложно отслеживать состояния всех участников кластера Akka. Я искал в Интернете хорошую систему для мониторинга кластерной системы Akka. Однако результаты, скорее всего, были системами для мониторинга статистики JVM. Мне любопытно, есть ли...
1052 просмотров
schedule 02.08.2023

Акка за HAProxy
У меня есть 2 системы: система 1 запускает akka и HAProxy, система 2 запускает компоненты REST, которые делают запрос к akka. Akka работает на порту 4241 в системе 1. Система 2 может подключаться к системе 1 при отсутствии HAProxy. После того, как...
508 просмотров
schedule 30.12.2021

имитировать сетевой раздел с помощью набора тестов akka cluster multi-jvm
Я пытаюсь создать преобразователь разделения мозга для кластера akka. Но довольно сложно смоделировать сценарий, в котором определенные узлы недоступны для остальной части исходного кластера и формируют свой собственный кластер. Это невозможно...
223 просмотров
schedule 23.12.2022

Выбор актера Akka Remote с конфигурацией
Есть ли способ настроить конфигурацию для выбора удаленного субъекта, аналогичного созданию удаленного субъекта, как указано в документы Akka : akka { actor { deployment { /sampleActor { remote =...
878 просмотров
schedule 09.05.2023

Где я должен хранить экземпляр соединения с БД и пул соединений с БД?
Должен ли я реализовать пул субъектов службы, каждый из которых имеет одно соединение с БД? Я очень новичок в Akka и не знаю, как реализовать работу, связанную с БД. Мой контекст: я создаю распределенный игровой сервер, используя akka-cluster.
197 просмотров
schedule 14.03.2024

Может ли клиент кластера Akka отправлять сообщения узлам кластера, не входящим в начальные контакты?
Используя Akka 2.3.14, пытаюсь создать Akka-кластер из различных сервисов. До сих пор у меня были все мои «службы» в одном артефакте, который был кластеризован на нескольких узлах, но теперь я пытаюсь разбить этот артефакт на несколько служб, которые...
1232 просмотров
schedule 26.10.2022

Кластер Кафка и Акка
Ниже приведен мой вариант использования Куча приложений ставят сообщения в Kafka в очередь по разным темам. Попросите потребителя каждой темы передать работу работнику в кластере. Работу можно разделить на длительную, интенсивную по памяти,...
1011 просмотров
schedule 25.12.2021

Что произойдет с почтовым ящиком, прикрепленным к удаленному субъекту, если субъект выйдет из строя
Если удаленный актер умирает, родительский актер получает уведомление, но что происходит с почтовым ящиком, прикрепленным к удаленному актеру? Если нет способа получить его, то как мы можем сказать, что akka отказоустойчива?
177 просмотров
schedule 04.10.2022

Поиск узлов в сети с помощью akka.
Есть ли способ поиска узлов в сети, чтобы, если какой-либо узел не работает, мы могли снова подключить его, когда он встанет. В настоящее время я использую mdns, но я хочу добиться этого с помощью akka. Я использую akka с java.
145 просмотров
schedule 31.12.2022

Pubsub с использованием тематических групп с Akka Cluster
Я пытаюсь создать приложение в стиле pubsub с помощью Akka Cluster. Я читаю документы о pubsub, и сейчас я пытаюсь запустить их пример. Мой основной рабочий процесс таков: Запускаем подписчика (который становится мастером / лидером)....
1771 просмотров

AKKA- как заблокировать создание актора если его имя не уникально в кластере
Я пытаюсь заблокировать возможность наличия в системе актеров с одинаковым именем (они находятся на разных путях, поэтому InvalidActorNameException не будет выброшено) приложение.conf: someactor { akka.remote.netty.tcp.port = 6405...
301 просмотров
schedule 25.05.2022