如何复用Akka ActorRef并保持状态，实现Akka Actors间balance共享？

核心问题拆解 #

你当前的代码在循环里每次创建新的BankAccount Actor，每个实例都有独立的balance状态，自然无法共享。死信问题大概率是因为你复用的ActorRef指向的实例已经被终止（比如提前调用了system.terminate()），或者Actor创建失败导致Ref无效。

Akka Actor的设计原则是每个Actor实例对应唯一的身份（路径），要共享状态，你只需要维护一个Actor实例，所有操作都发给它即可。

修正步骤与代码 #

1. 定义消息类 #

首先补全你用到的消息类型（Akka通过消息传递交互，必须明确消息结构）：

public class DepositMessage {
    public final int amount;
    public DepositMessage(int amount) {
        this.amount = amount;
    }
}

public class WithdrawMessage {
    public final int amount;
    public WithdrawMessage(int amount) {
        this.amount = amount;
    }
}

2. 完善BankAccount Actor的消息处理逻辑 #

给BankAccount添加receive方法，处理存款、取款请求并更新状态：

public class BankAccount extends AbstractActor {
    private int balance;

    public BankAccount(int balance) {
        this.balance = balance;
        System.out.printf("Bank account initialised with £%d%n", balance);
    }

    public static Props props(int balance) {
        return Props.create(BankAccount.class, () -> new BankAccount(balance));
    }

    @Override
    public Receive createReceive() {
        return receiveBuilder()
                .match(DepositMessage.class, msg -> {
                    balance += msg.amount;
                    System.out.printf("Deposited £%d, current balance: £%d%n", msg.amount, balance);
                })
                .match(WithdrawMessage.class, msg -> {
                    // 简单处理取款，不考虑余额不足的情况
                    balance += msg.amount; // 因为msg.amount是负数
                    System.out.printf("Withdrew £%d, current balance: £%d%n", -msg.amount, balance);
                })
                .build();
    }
}

3. 修改main方法：复用单一Actor实例 #

把Actor创建移到循环外，只初始化一次，循环内重复给这个Actor发消息：

public static void main(String[] args) throws InterruptedException {
    ActorSystem system = ActorSystem.create("bank-system");
    // 只创建一个BankAccount Actor，初始余额100
    ActorRef bankAccount = system.actorOf(BankAccount.props(100), "bankAccount");

    Random rnd = new Random();
    for (int i = 0; i < 10; i++) {
        int num = rnd.ints(-1000, 1000).findFirst().orElse(i);
        
        if (num > 0) {
            bankAccount.tell(new DepositMessage(num), ActorRef.noSender());
        } else {
            bankAccount.tell(new WithdrawMessage(num), ActorRef.noSender());
        }
        // 加个短延迟，方便看日志顺序，生产环境可去掉
        Thread.sleep(100);
    }

    // 等待所有消息处理完成再终止系统
    Thread.sleep(1000);
    system.terminate();
}

关键说明 #

• 复用同一ActorRef：所有操作都发给这个唯一的Actor实例，状态会持续更新，不会重置
• 避免提前终止：原代码循环结束立刻调用system.terminate()，Actor可能还没处理完消息就被销毁，这也是死信的常见原因之一，所以加了延迟等待
• 如果需要多Actor共享状态（比如分布式场景），可以用Akka的Distributed Data或者Cluster Sharding，但单系统场景下单一Actor是最简单高效的方案

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