如何修复Akka中的“Futures timed out [5 seconds]”与akkaDeadLetter错误？

核心问题分析 #

• 消息匹配逻辑错误：numbersPrinter Actor的createReceive方法中，仅匹配numbersPrinter类的消息，但主类发送的是String类型消息，导致消息无法被处理，触发死信日志和超时异常。
• 类型转换错误：Actor返回的是Integer类型值（1），但主类中强制将结果转为String，即使消息处理成功也会抛出类型转换异常。

修复步骤 #

1. 修正Actor的消息匹配逻辑 #

修改numbersPrinter类的消息匹配规则，使其能处理String类型消息，同时优化未匹配消息的处理逻辑：

package org.example.actors;

import akka.actor.AbstractActor;
import akka.event.Logging;
import akka.event.LoggingAdapter;

public class numbersPrinter extends AbstractActor {
    LoggingAdapter log = Logging.getLogger(getContext().system(), this);

    public void returnNumber(String message){
        if (message.equals(String.valueOf(1))){
            getSender().tell(1, getSelf());
        } else {
            log.info(message);
        }
    }

    @Override
    public Receive createReceive() {
        return receiveBuilder()
                // 匹配String类型的消息，对应主类发送的内容
                .match(String.class, this::returnNumber)
                // 处理所有未匹配的消息，明确日志信息
                .matchAny(msg -> {
                    log.info("Unhandled message: {}", msg);
                    unhandled(msg);
                })
                .build();
    }
}

2. 修正主类的类型转换逻辑 #

Actor返回的是Integer类型，主类需要对应调整类型转换逻辑，同时添加Actor系统关闭操作避免资源泄漏：

package org.example;

import akka.actor.ActorRef;
import akka.actor.ActorSystem;
import akka.actor.Props;
import akka.pattern.Patterns;
import akka.util.Timeout;
import org.example.actors.numbersPrinter;
import scala.concurrent.Await;
import scala.concurrent.duration.Duration;

import java.util.concurrent.TimeUnit;

public class Main {
    public static void main(String[] args) {
        final ActorSystem system = ActorSystem.create("ActorsSystem");

        ActorRef numbersPrinter = system.actorOf(Props.create(numbersPrinter.class), "numbersPrinter");
        
        System.out.println("numbersPrinter actor test");
        final Timeout timeout = new Timeout(Duration.create(5, TimeUnit.SECONDS));
        scala.concurrent.Future<Object> rt = Patterns.ask(numbersPrinter, String.valueOf(1), timeout);
        
        try {
            // 先转为Integer类型，再转为字符串输出
            Integer result = (Integer) Await.result(rt, timeout.duration());
            System.out.println(result.toString());
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
        
        // 关闭Actor系统，释放资源
        system.terminate();
    }
}

修复后验证 #

运行修改后的代码，会输出以下内容，且无死信日志和超时异常：

numbersPrinter actor test
1

内容的提问来源于stack exchange，提问作者Olga Puzikova