Scala Akka TCP Актеры

Question

У меня есть вопрос о Akka 2.4 TCP API.

Я запускаю сервер и имею 2 сервера TCP в Akka TCP, один для входящих клиентов и один для рабочих узлов моего сервера (которые находятся на других компьютерах/IP-адресах). У меня есть одно текущее соединение с клиентом и одно подключение к рабочему узлу.

Если вы получаете сообщение от клиента, я хочу передать часть этой информации рабочему узлу, но мой TCP Akka Actor, представляющий соединение рабочего узла, кажется, не нравится, когда я, из потока, выполняющего клиент Акка Актер, отправьте сообщения в рабочий узел Акка Актора.

Так, например, если клиент отправляет сообщение для удаления файла и что разделы этого файла находятся на рабочем узле, я хочу отправить TCP-сообщение этому рабочему узлу, чтобы он удалял разделы ,

Как я могу от клиента Актер отправить сообщение рабочему узлу Актер, чтобы он передавался серверу рабочих узлов через TCP? Когда вы делаете обычный workerActorRef ! msg, он не получает его вообще и не отображается журнал.

Я надеюсь, что этот вопрос не был неясен, но в основном я хочу workerActorRef, чтобы каким-то образом быть в состоянии иметь некоторую функциональность, подобную «отправить это через TCP сокет».

Приветствия,

Йохан

Answer 1

Вы смотрели на Akka Remoting вообще? При правильном использовании он должен иметь возможность добиться того, чего вы хотите. Возможно, вы захотите заглянуть в Clustering, так как он построен поверх Remoting.