Блог

Я работаю с шаблоном akka distributed worker, доступным в typesafe. Я использую его для написания серверного задания, которое берет данные из siebel с помощью вызовов soap и вставляет в mongo. Предполагается, что это задание выполняется один раз в неделю в течение нескольких часов.

Основываясь на использовании кластера и другой документации на веб-сайте AKKA, я импортировал akka-cluster.jar и настроил файл конфигурации приложения с НАЧАЛЬНЫМИ узлами (akka.cluster.seed-nodes). Но когда я запускаю первый узел (ГЛАВНЫЙ УЗЕЛ) с упомянутой мной конфигурацией (исходные узлы и т.д.), Я начинаю получать ошибки на консоли сервера, в которых говорится, что не удалось присоединиться к исходному узлу, что очевидно (поскольку это первый узел, и присоединяться не к чему).). Теперь я запускаю второй узел с akka.cluster.seed-узлами, настроенными с ip-адресом и портом процесса, в котором запущен главный узел. Я снова получаю ошибки на консоли сервера.

Теперь то, что я делаю дальше, — это взять первый адрес соединения главного участника с ГЛАВНОГО УЗЛА и динамически установить его в подчиненном узле в коде (создать объект Address и передать его участникам на подчиненном узле). ЭТО РАБОТАЕТ!!! Если я беру тот же адрес соединения и настраиваю его в конфигурации приложения akka.cluster.seed-nodes, он выдает ошибку, и подчиненный узел не присоединяется к кластеру.

Итак, у меня есть следующие вопросы: — 1. Как настроить конфигурацию akka.cluster.seed-узла в приложении. Я никогда не мог заставить его работать / подсчитывать в конфигурации. 2. Есть ли какой-либо способ предварительно настроить исходные узлы в конфигурации. По моим наблюдениям, похоже, что конфигурация является динамической, т.Е. Для получения адреса соединения субъекта на главном узле из журналов и настройки конфигурации начального узла подчиненного устройства с этим адресом?

У меня были похожие проблемы, которые были результатом несоответствия между системным именем субъекта в конфигурации начальных узлов и фактическим системным именем субъекта, созданным в моем коде.