java - 如何在 Akka 中确定消息何时发送

Question

我想知道是否有可能知道消息何时已送达。因为我想在之后立即关闭 actorsystem。下面的代码连接到远程参与者，然后发送消息。但在某些情况下，本地 actor 系统似乎关闭得太早。

ActorSystem system = ActorSystem.create("Test", config.getConfig("webbackend"));
ActorSelection communicator = system.actorSelection("akka.tcp://Midas@127.0.0.1:2555/user/Communicator");
communicator.tell(new TimerTransmissionCmd(channel.getId()), ActorRef.noSender());
//system.shutdown();

Answer 1

尝试在发送消息后添加此代码:

Boolean wasProcessed = (Integer)Await.result(Patterns.ask(communicator, new ResultClass(), 5000), 
            Duration.create(5000, TimeUnit.MILLISECONDS));

if(wasProcessed){
    actorSystem.shutdown();
}

您还必须将其添加到您的 Actor 类中:

private boolean wasProcessed = false;

@Override
public void onReceive(Object messageReceived) throws Exception {
    if (messageReceived instanceof ResultClass) {
        this.workerActor1.tell(wasProcessed, getSender());
    } else {
        //Put your process code here
        wasProcessed = true;
    }
}

但我建议您配置一个谨慎的超时，然后始终关闭系统。