当前位置：首页 > JavaScript

js实现actor模型

2026-02-02 14:00:12JavaScript

Actor模型简介

Actor模型是一种并发计算模型，通过独立的“Actor”实体进行通信，每个Actor封装状态和行为，仅通过异步消息传递交互。JavaScript可通过库或手动实现Actor模型，适用于分布式系统或高并发场景。

实现Actor模型的核心要素

消息队列
每个Actor维护一个私有消息队列，按顺序处理接收到的消息，避免竞态条件。

隔离状态
Actor内部状态不被外部直接访问，所有交互通过消息传递完成。

异步通信
Actor之间通过发送不可变消息异步通信，发送方不阻塞等待响应。

手动实现基础Actor模型

class Actor {
  constructor() {
    this.queue = [];
    this.isProcessing = false;
  }

  // 发送消息到队列
  send(message) {
    this.queue.push(message);
    if (!this.isProcessing) {
      this.processQueue();
    }
  }

  // 处理队列消息
  async processQueue() {
    this.isProcessing = true;
    while (this.queue.length > 0) {
      const message = this.queue.shift();
      await this.handle(message); // 用户自定义处理逻辑
    }
    this.isProcessing = false;
  }

  // 需由子类实现
  handle(message) {
    throw new Error("Not implemented");
  }
}

使用示例

class PrinterActor extends Actor {
  handle(message) {
    console.log(`Received: ${message}`);
  }
}

const printer = new PrinterActor();
printer.send("Hello"); // 输出: Received: Hello

使用现有库

1. Akka.js
基于JVM Akka的移植版，适合复杂分布式系统。

2. XActor
轻量级库，支持TypeScript，示例：

import { ActorSystem, Actor } from 'xactor';

class CounterActor extends Actor {
  state = { count: 0 };
  onMessage(message) {
    this.state.count += message.value;
  }
}

const system = new ActorSystem();
const counter = system.spawn(CounterActor);
counter.send({ value: 1 });