sharedarraybuffer + atomics 是 node.js 多 worker 间低延迟共享数据的内建方案,因各 worker 内存隔离,模块变量无法共享;主进程创建 sharedarraybuffer 并分发,worker 用相同视图映射并借助 atomics 原子操作协同访问。

在 Node.js 的多进程架构中,尤其是使用 cluster 模块启动多个 Worker 时,每个 Worker 都运行在独立的 V8 实例中,内存彼此隔离。这意味着模块级变量(如 let count = 0)在各 Worker 中是完全独立的副本,无法直接共享或同步。若需跨 Worker 协同访问同一份数据(例如请求计数、缓存状态、限流令牌池),必须借助外部机制——而 共享内存(SharedArrayBuffer + Atomics) 是一种零依赖、低延迟、内建于 JavaScript 的高效方案。
为什么不能直接用模块变量同步?
Node.js 的每个 Worker 是一个独立进程(非线程),即使通过 require() 加载同一模块,该模块的顶层变量也会被重复执行并各自初始化。例如:
let counter = 0;<br>module.exports = {<br> inc() { return ++counter; },<br> get() { return counter; }<br>};
两个 Worker 分别调用 inc(),结果都是从 0 开始自增,互不影响。这不是“不同步”,而是根本没共享——它们压根不在一块内存里。
SharedArrayBuffer + Atomics:轻量级跨 Worker 共享方案
Node.js 12+ 支持 SharedArrayBuffer(需启用 --experimental-shared-array-buffer 标志),配合 Atomics 可实现原子读写。关键在于:所有 Worker 必须基于同一个共享内存实例操作——这需要主进程(Master)创建并分发。
操作要点:
- 主进程创建
SharedArrayBuffer(如 1024 字节),并封装为 TypedArray(如Int32Array) - 通过
worker.postMessage()将buffer(非数组!)传递给 Worker - Worker 收到后,用相同视图(如
new Int32Array(buffer))映射同一块内存 - 读写必须用
Atomics(如Atomics.add(arr, index, 1)),避免竞态
完整可运行示例:跨 Worker 计数器
server.js(主进程)
const cluster = require('cluster');<br>const { SharedArrayBuffer } = require('buffer');<br><br>if (cluster.isMaster) {<br> const sab = new SharedArrayBuffer(1024); // 1KB 共享内存<br> const counter = new Int32Array(sab); // 视图:32位整数数组<br> counter[0] = 0; // 初始化计数器<br><br> for (let i = 0; i const worker = cluster.fork();<br> worker.postMessage({ type: 'INIT_SHARED', buffer: sab });<br> }<br><br msg> {<br> if (msg.type === 'COUNTER_VALUE') {<br> console.log('当前总请求数:', msg.value);<br> }<br> });<br>} else {<br> // Worker 进程逻辑见下方<br>}
worker.js(Worker 内)
const http = require('http');<br>let sharedCounter;<br><br>process.on('message', (msg) => {<br> if (msg.type === 'INIT_SHARED') {<br> sharedCounter = new Int32Array(msg.buffer); // 映射同一块内存<br> }<br>});<br><br>const server = http.createServer((req, res) => {<br> if (sharedCounter) {<br> // 原子递增索引 0 处的值<br> const newValue = Atomics.add(sharedCounter, 0, 1);<br> res.end(`Worker ${process.pid} handled request #${newValue}`);<br> // 同步上报当前值(可选)<br> process.send({ type: 'COUNTER_VALUE', value: newValue });<br> } else {<br> res.statusCode = 503;<br> res.end('Shared memory not ready');<br> }<br>});<br><br>server.listen(3000);
注意事项与边界场景
共享内存不是万能的,实际使用需注意:
-
必须显式传递 buffer:仅传
Int32Array不行,V8 会复制数据;必须传原始SharedArrayBuffer对象 -
Atomics 是必须的:直接
arr[0]++在多 Worker 下仍可能丢失更新,因 JS 引擎不保证原子性 -
内存布局需手动管理:比如想存多个字段(count、timestamp、flag),需约定偏移量:
arr[0]是计数器,arr[1]是时间戳(秒级) -
无自动序列化:只能存数字(
Int32Array、Float64Array等),字符串/对象需自行编码(如 UTF-8 写入Uint8Array) - 不适用于大量数据:适合高频小数据同步(计数、开关、简单状态);大结构建议用 Redis 或消息队列










