Não é possível enviar uma mensagem para um akka remoto ator

Question 1

Eu sou novo para akka remoting e eu estou tentando basta enviar uma mensagem para um remoto ator e obter uma resposta em retorno. Eu tenho 2 ator sistemas em localhost - portas diferentes: MasterSystem e WorkerSystem. Eu criei um ator em WorkerSystem e tentei enviar uma mensagem para o seu endereço remoto. Mas continuo recebendo um 'letra morta encontrado" mensagem! Gostaria de receber qualquer tipo de ajuda. Obrigado!

MainMaster.java

package pi_swarm_approx;

import akka.actor.ActorRef;
import akka.actor.ActorSelection;
import akka.actor.ActorSystem;
import akka.actor.UntypedActor;
import com.typesafe.config.ConfigFactory;

public class MainMaster extends UntypedActor{
    ActorSystem system;
    ActorRef actor;
    ActorSelection remoteActor;
    
    public MainMaster() {
        system = ActorSystem.create("MasterSystem", ConfigFactory.load("master"));
        System.out.println("MasterSystem created");
        MainWorker mw = new MainWorker();
        System.out.println("MainWorker obj created");
        remoteActor = mw.system.actorSelection("akka://WorkerSystem@localhost:2552/user/workerActor");
        
        System.out.println("Remote actor created");    
        remoteActor.tell("hello", getSelf());
        System.out.println("Message sent to remote actor");
    }
    
    public void onReceive(Object msg) {
        if (msg != null) {
            System.out.println("Got it back");
        }
         else {
            unhandled(msg);
            getContext().stop(getSelf());
         }
    }
}

MainWorker.java

package pi_swarm_approx;

import akka.actor.ActorSystem;
import akka.actor.ActorRef;
import com.typesafe.config.ConfigFactory;
import akka.actor.Props;

public class MainWorker {
    ActorSystem system;
    ActorRef actor;
    public MainWorker() {
        this.system = ActorSystem.create("WorkerSystem", ConfigFactory.load("worker"));
        actor = system.actorOf(Props.create(Worker.class), "workerActor");
    }
}

Worker.java

package pi_swarm_approx;

import akka.actor.UntypedActor;

public class Worker extends UntypedActor {  
    public void onReceive(Object msg) {
        System.out.println("Worker actor got message");
        if (msg != null) {
            getSender().tell("Request processed", getSelf());
        }
         else {
            unhandled(msg);
         }
        getContext().stop(getSelf());
    }
}

o mestre.conf

akka {
  actor {
    provider = "cluster"
  }
  remote {
  transport = ["akka.remote.netty.tcp"]
    netty.tcp {
      hostname = "localhost"
      port = 2551
    }
  }
  
  clustering {
    cluster.name = "MasterSystem"
    role = "master"
  }
 }

trabalhador.conf

akka {
  actor {
    provider = "cluster"
    deployment {
        /workerActor {
          remote = "akka.tcp://WorkerSystem@localhost:2552"
        }
  }
}

Saída

In main
MasterSystem created
MainWorker obj created
Remote actor created
Message sent to remote actor
[INFO] [11/22/2021 16:01:34.531] [WorkerSystem-akka.actor.default-dispatcher-5] [akka://WorkerSystem/deadLetters] Message [java.lang.String] from Actor[akka://Main/user/app#402333018] to Actor[akka://WorkerSystem/deadLetters] was not delivered. [1] dead letters encountered. If this is not an expected behavior, then [Actor[akka://WorkerSystem/deadLetters]] may have terminated unexpectedly, This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
<=========----> 75% EXECUTING [18s]

Question 2

Há vários problemas com o código que você postou. Estou postando um mínimo de código de trabalho.

Primeiro, você está usando uma versão versão do akka.actor.UntypedActor. Este foi preterido no 2.4.0. Se você estiver usando o maven mudanças de dependências de acordo. O código foi compilado e executado em java 11.

construir.sbt

libraryDependencies ++=
  Seq(
    "com.typesafe.akka" %% "akka-actor" % "2.6.17",
    "com.typesafe.akka" %% "akka-remote" % "2.6.17",
  )

Para provider Eu tenho usado remote em vez de cluster. Você pode usar cluster, mas certifique-se de adicionar as dependências necessárias. A configuração pode ser ainda mais simplificada, removendo as repetições, mas você pode fazer como você explorar.

o mestre.conf

akka {
  actor {
    provider = "remote"
  }
  remote {
    artery {
      enabled = on
      transport = tcp
      canonical {
        hostname = "127.0.0.1"
        port = 2552
      }
    }
  }
}

trabalhador.conf

akka {
  actor {
    provider = "remote"
  }
  remote {
    artery {
      enabled = on
      transport = tcp
      canonical {
        hostname = "127.0.0.1"
        port = 2551
      }
    }
  }
}

MainMaster.java

import akka.actor.AbstractActor;

public class MainMaster extends AbstractActor {
    @Override
    public Receive createReceive() {
        return receiveBuilder()
            .match(
                    String.class,
                    System.out::println)
            .matchAny(o -> System.out.println("received unknown message"))
            .build();
    }
}

Worker.java

public class Worker extends AbstractActor {

    @Override
    public Receive createReceive() {
        return receiveBuilder()
            .match(
                    String.class,
                    msg -> {
                        System.out.println(msg);
                        getSender().tell("Request processed", getSelf());
                    })
            .matchAny(o -> System.out.println("received unknown message"))
            .build();
    }
}

MainWorker.java

public class MainWorker {

    public static void main(String[] args) {
        ActorSystem system = ActorSystem.create("WorkerSystem", ConfigFactory.load("worker.conf"));
        ActorRef actor = system.actorOf(Props.create(Worker.class), "workerActor");
        System.out.println("worker started");
    }
}

Main.java

public class Main {
    public static void main(String[] args) {
        System.out.println("In main");
        ActorSystem system = ActorSystem.create("MasterSystem", ConfigFactory.load("master.conf"));
        ActorRef master = system.actorOf(Props.create(MainMaster.class), "master");

        ActorSelection remoteActor = system.actorSelection("akka://[email protected]:2551/user/workerActor");
        remoteActor.tell("Hello Worker", master);
    }
}

Johny T Koshy · Answer 1 · 2021-11-22T17:59:51

Há vários problemas com o código que você postou. Estou postando um mínimo de código de trabalho.

Primeiro, você está usando uma versão versão do akka.actor.UntypedActor. Este foi preterido no 2.4.0. Se você estiver usando o maven mudanças de dependências de acordo. O código foi compilado e executado em java 11.

construir.sbt

libraryDependencies ++=
  Seq(
    "com.typesafe.akka" %% "akka-actor" % "2.6.17",
    "com.typesafe.akka" %% "akka-remote" % "2.6.17",
  )

Para provider Eu tenho usado remote em vez de cluster. Você pode usar cluster, mas certifique-se de adicionar as dependências necessárias. A configuração pode ser ainda mais simplificada, removendo as repetições, mas você pode fazer como você explorar.

o mestre.conf

akka {
  actor {
    provider = "remote"
  }
  remote {
    artery {
      enabled = on
      transport = tcp
      canonical {
        hostname = "127.0.0.1"
        port = 2552
      }
    }
  }
}

trabalhador.conf

akka {
  actor {
    provider = "remote"
  }
  remote {
    artery {
      enabled = on
      transport = tcp
      canonical {
        hostname = "127.0.0.1"
        port = 2551
      }
    }
  }
}

MainMaster.java

import akka.actor.AbstractActor;

public class MainMaster extends AbstractActor {
    @Override
    public Receive createReceive() {
        return receiveBuilder()
            .match(
                    String.class,
                    System.out::println)
            .matchAny(o -> System.out.println("received unknown message"))
            .build();
    }
}

Worker.java

public class Worker extends AbstractActor {

    @Override
    public Receive createReceive() {
        return receiveBuilder()
            .match(
                    String.class,
                    msg -> {
                        System.out.println(msg);
                        getSender().tell("Request processed", getSelf());
                    })
            .matchAny(o -> System.out.println("received unknown message"))
            .build();
    }
}

MainWorker.java

public class MainWorker {

    public static void main(String[] args) {
        ActorSystem system = ActorSystem.create("WorkerSystem", ConfigFactory.load("worker.conf"));
        ActorRef actor = system.actorOf(Props.create(Worker.class), "workerActor");
        System.out.println("worker started");
    }
}

Main.java

public class Main {
    public static void main(String[] args) {
        System.out.println("In main");
        ActorSystem system = ActorSystem.create("MasterSystem", ConfigFactory.load("master.conf"));
        ActorRef master = system.actorOf(Props.create(MainMaster.class), "master");

        ActorSelection remoteActor = system.actorSelection("akka://[email protected]:2551/user/workerActor");
        remoteActor.tell("Hello Worker", master);
    }
}

Obrigado pela resposta. Uma pergunta, porém; quando é o WorkerSystem criado? Eu não vejo um MainWorker objeto a ser criados em qualquer lugar.
Sendo sistemas remotos, você deve considerar MainWorker e Main como aplicativos separados e executar como tal. Neste caso em particular, executar MainWorker primeiro, seguido por Main para que uma instância de Worker é inicializado e está disponível para pesquisa de Main.
Infelizmente, eu ainda estou começando a 'letra morta encontrado" mensagem. Eu tentei criar o workerActor em Main.java e ActorSelection remoteActor = system1.actorSelection("akka://WorkerSystem/user/workerActor"); de obras. Mas, ActorSelection remoteActor = system.actorSelection("akka://[email protected]:2551/user/workerActor"); não.
Se MainWorker já não está sendo executado quando você iniciar Main, você vai entender a mensagem. Verifique se for o caso.
Além disso, este ActorRef actor = system1.actorOf(Props.create(Worker.class), "workerActor"); System.out.println(actor.path().address().host()); retorna Nenhum.
Você pode exibir o arquivo atualizado a estrutura de arquivos e no github?
worker.conf e master.conf são colocados sob resources/configs. Eles são acessados por ActorSystem criação usando ActorSystem.create("MasterSystem", ConfigFactory.load("master.conf"));. Colocar o conf arquivos em resources pasta, ele deve funcionar

Não é possível enviar uma mensagem para um akka remoto ator

Pergunta

Melhor resposta

Em outros idiomas

Esta página está em outros idiomas

Popular nesta categoria

Perguntas populares nesta categoria