Описание тега akka-cluster

Вопросы с тегом
Кластер Akka - это новая функциональность (2.1+), которая позволяет создавать возможности кластера поверх промежуточного программного обеспечения Akka.
1 ответ

Как я могу проверить метод получения подписчика в кластере Akka?

У меня есть следующее Subscriber абстрактный базовый класс: abstract class Subscriber(topics: Seq[String]) extends Actor with ActorLogging { import DistributedPubSubMediator.{ Subscribe, SubscribeAck } val mediator = DistributedPubSub(context.system…
01 янв '17 в 14:41
1 ответ

Привязка удаленного порта Netty кластера: адрес уже используется

Поэтому я пытаюсь запустить 2 экземпляра приложения Akka на моей локальной машине (в отдельных виртуальных машинах). Когда запускается экземпляр №1, isSeedNode = true (поэтому порт связан с 2552) Когда запускается экземпляр #2 isSeedNode = false (по…
15 дек '15 в 22:17
2 ответа

SBT неразрешенная зависимость с Akka

Я довольно новичок в Scala, Akka и SBT, поэтому эта проблема вызывает у меня головную боль! Я работаю с книгой " Акка в действии", где автор приводит примеры на Github: https://github.com/RayRoestenburg/akka-in-action На чистом клоне репозитория я п…
29 май '17 в 08:48
0 ответов

Аккалар не видит друг друга

В Akka я добавляю две разные машины в кластер. Но есть некоторые проблемы. Если 2 машины встают одновременно, 2 стороны уходят как лидер и не видят друг друга. Или из-за схожих проблем они не видят друг друга. Вы знаете, есть ли у него решение?
27 фев '19 в 18:45
0 ответов

Акка: Простой кластер Акка не работает.

Мы создаем простой образец кластера akka и следуем Akka In Action книга. мы создаем 3 начальных узла, как указано в следующем коде: akka { loglevel = INFO stdout-loglevel = INFO event-handlers = ["akka.event.Logging$DefaultLogger"] log-dead-letters …
10 мар '17 в 10:31
0 ответов

Акка КластерКлиент на самом деле не отправляет GetContacts

Я сталкиваюсь с проблемой реализации клиента кластера Akka, поскольку кажется, что ClusterClient фактически никогда не отправляет сообщение GetContacts, даже если оно указывает, что оно отправляет его (в журналах отладки). Я уверен, что сообщение не…
30 авг '17 в 12:20
1 ответ

Как я могу определить seed-узлы во время выполнения

У меня есть кластер akka с application.conf, как показано ниже: remote { // Remote configuration for this seed node enabled-transports = ["akka.remote.netty.tcp"] netty.tcp { hostname = "" port = 2555 } } cluster { seed-nodes = [ "akka.tcp://automat…
19 июн '17 в 07:45
1 ответ

Акка: подписчик, работающий с несколькими темами

Подписчик открытого класса расширяет UntypedActor { public Subscriber() { ActorRef mediator = DistributedPubSub.get(getContext().system()).mediator(); // subscribe to the topic named "content" mediator.tell(new DistributedPubSubMediator.Subscribe("c…
11 апр '17 в 11:53
1 ответ

Маршрутизаторы с поддержкой Akka Cluster - делитесь экземпляром redis со всеми маршрутизаторами

В контексте кластерного приложения Akka я столкнулся с проблемой, касающейся одного свойства, ожидаемого Akka: каждый (cas) класс и каждое используемое сообщение должны быть сериализуемыми. У меня есть следующий контекст: я хочу использовать данные …
23 фев '17 в 23:22
1 ответ

Вызов актера Акка из контроллера Play

Я играл с распределенным рабочим шаблоном, и я столкнулся с проблемой, выдвигающей работу из веб-запроса. У примера проекта есть интерфейс: val mediator = DistributedPubSubExtension(context.system).mediator def receive = { case work => log.info("…
27 июн '14 в 10:55
1 ответ

Поиск узлов в сети с помощью Акки.

Есть ли способ искать узлы в сети, чтобы, если какой-либо узел был отключен, мы могли бы снова подключить его, когда он станет работающим. В настоящее время я использую mdns, но я хочу добиться этого с помощью akka. Я использую Акку с Java.
28 июл '16 в 12:30
1 ответ

Акка Упорство Query и актерский осколок

Я делаю запрос стороны приложения актеров CQRS Akka. Актеры запросов настроены как кластерный осколок и заполнены событиями из одного потока постоянных запросов. Мои вопросы: Если один из актеров в кластере перезапускается, как его восстановить? Вык…
04 июл '16 в 18:02
1 ответ

Akka Удаленный выбор актера с настройкой

Есть ли способ настройки конфигурации для удаленного выбора актера, аналогичного удаленному созданию актора, как указано в документации Akka: akka { actor { deployment { /sampleActor { remote = "akka.tcp://sampleActorSystem@127.0.0.1:2553" } } } } Я…
13 ноя '15 в 12:56
1 ответ

Профили пользователей как актеры с akka.cluster. Маршрутизация и создание

Я хочу использовать Akka.Cluster для простого обслуживания профиля пользователя. Будет несколько экземпляров служб http-api, которые будут отправлять сообщения для некоторых серверных экземпляров с постоянными субъектами userprofile (Profile Actor).…
24 авг '15 в 19:11
3 ответа

Система нескольких акка в одном ПК

Как мы можем запустить несколько узлов akka на одном компьютере? В настоящее время я следую за application.conf файл. Для каждой системы я добавил разные номера портов, но я не могу запустить более одного экземпляра. Ошибка говорит, Address already …
11 июл '13 в 08:02
1 ответ

Есть ли способ для одного узла Akka узнать, был ли перезапущен другой узел Akka?

У меня есть узел akka (скажем, A), который выполняет начальную загрузку и после этого отправляет сообщение другому узлу akka (скажем, B), только тогда узел B начнет выполнять свою работу. Теперь проблема, скажем, в том, что Узел A отправил сообщение…
05 июл '18 в 05:33
2 ответа

Java Akka одновременное ограничение в использовании маршрутизатора?

Код является: public class TestAkka { public static void main(String[] args) throws InterruptedException { ActorSystem system = ActorSystem.create("ExampleRouter", ConfigFactory.load().getConfig("MyRouter")); ActorRef router = system.actorOf(Props.c…
04 июн '16 в 16:04
2 ответа

Есть ли атомная трансляция в акке?

Мне нужна атомная трансляция, и я хочу использовать кластер Акка. Я не уверен, есть ли в akka атомная трансляция, поэтому я просто хочу спросить, чтобы быть уверенным. Я знаю, что есть такие вещи, как DistributedPubSubMediator.SendToAll так же как C…
14 янв '15 в 00:10
1 ответ

Я хочу создать простой одноэлементный кластер и отправить сообщение с удаленного узла

Здесь я создал синглтон актера. Мастер и начальный узел одинаковы. Из другого проекта я пытаюсь добавить в кластер и хочу отправить сообщение. Я могу присоединиться к кластеру, но не могу отправить сообщение. Мой мастер и начальный узел: package Dem…
06 авг '17 в 04:46
1 ответ

Акка Сообщения в подпроектах?

У меня есть сообщение, которое я отправляю через кластер в Акке. У меня есть два базовых узла и один интерфейсный узел. Внутренние узлы работают нормально, но внешний интерфейс не запускается (ассоциация не удалась). Я чувствую, что у меня есть подс…
08 окт '14 в 22:16