Javascript進程和線程通信

JavaScript 中的進程通信（IPC）和線程通信是實現高性能、高并發應用的核心技術，尤其在處理 CPU 密集型任務或跨環境數據交互時至關重要。以下從底層機制到應用場景的詳解：

🧩 ??一、進程通信（Inter-Process Communication, IPC）??

進程是操作系統資源分配的基本單位，每個進程擁有獨立內存空間，通信需通過特定機制。

??1. 瀏覽器環境（Web Workers）??
  • ??通信機制??：主線程與 Worker 通過 postMessage() 發送消息，onmessage 監聽響應，數據通過??結構化克隆算法??深拷貝（非共享內存）。
  • ??代碼示例??：
    // 主線程
const worker = new Worker('worker.js');
worker.postMessage({ data: 'start' });
worker.onmessage = (e) => console.log(e.data);// worker.js
onmessage = (e) => {const result = heavyCalculation(e.data);postMessage(result);
};
  • ??限制??：無法直接訪問 DOM，不能共享全局變量（通過 SharedArrayBuffer 可部分規避）。
??2. Node.js 環境??
  • ??父子進程通信（內置 IPC）??：
    • 使用 child_process.fork() 創建子進程，通過 send() 和 message 事件通信。
    • 底層基于 ??Unix Domain Socket（本地）?? 或 ??命名管道（Windows）??，高效且無需序列化。
    // 父進程
const { fork } = require('child_process');
const child = fork('child.js');
child.send('ping');
child.on('message', (msg) => console.log(msg));// 子進程 (child.js)
process.on('message', (msg) => {process.send('pong');
});
  • ??跨機器/獨立進程通信??：
    • ??TCP/HTTP??：通過 Socket 或 HTTP 協議傳輸數據，適合網絡分布式系統。
    • ??消息隊列（Redis/Kafka）??：解耦生產者和消費者，支持持久化與高并發，適合復雜業務場景。

🔁 ??二、線程通信（Thread Communication）??

線程共享進程內存空間，通信更高效但需處理同步問題。

??1. 瀏覽器環境（Web Workers + Shared Memory）??
  • ??SharedArrayBuffer 與 Atomics??：
    • 多個 Worker 線程可通過 SharedArrayBuffer 共享內存，配合 Atomics 方法（如 wait(), notify()）實現同步，避免競爭條件。
    // 主線程
const buffer = new SharedArrayBuffer(16);
const arr = new Int32Array(buffer);
const worker = new Worker('worker.js');
worker.postMessage({ buffer });// worker.js
onmessage = (e) => {const arr = new Int32Array(e.buffer);Atomics.add(arr, 0, 1); // 原子操作
};
??2. Node.js 環境（Worker Threads）??
  • ??消息傳遞??：類似 Web Workers，通過 parentPort.postMessage() 通信。
  • ??共享內存??：
    • 使用 worker_threads 模塊的 SharedArrayBuffer，線程可直接修改同一內存區域。
    • ??適用場景??：CPU 密集型計算（如圖像處理、大數據分析）。
    const { Worker, isMainThread, parentPort } = require('worker_threads');
if (isMainThread) {const worker = new Worker(__filename);worker.on('message', (msg) => console.log(msg));
} else {parentPort.postMessage('Hello from thread');
}

?? ??三、進程 vs 線程通信對比??

??特性????進程通信 (IPC)????線程通信??
??資源隔離??? 獨立內存，安全? 共享內存，需同步機制
??通信開銷??較高（需序列化/反序列化）極低（直接內存訪問）
??適用場景??跨應用、分布式系統、任務解耦進程內高性能計算、實時數據處理
??典型 API??postMessage, child_process.fork()SharedArrayBuffer, Atomics
??崩潰影響??單進程崩潰不影響整體線程崩潰可能導致整個進程終止

🚀 ??四、應用場景與最佳實踐??

  1. ??瀏覽器端??：

    • ??進程通信??：用 Web Worker 處理圖像濾鏡、實時數據分析，避免主線程卡頓。
    • ??線程通信??：游戲引擎中共享物理計算數據（如 Three.js + Worker）。

  2. ??Node.js 服務端??：

    • ??多進程??：通過 cluster 模塊創建子進程集群，提升 HTTP 服務并發能力（如負載均衡）。
    • ??多線程??：使用 worker_threads 加速日志分析、視頻轉碼等 CPU 密集型任務。

  3. ??安全與性能優化??：

    • 避免跨進程傳遞大數據（深拷貝開銷大），改用共享內存或流式傳輸。
    • 多線程中優先使用原子操作（Atomics）替代鎖，減少死鎖風險。

💎 ??總結??

JavaScript 通過 ??進程隔離?? 解決安全性問題，通過 ??線程共享內存?? 實現高效計算。實際開發中：

  • 優先用 ??進程通信?? 處理獨立任務（如微服務架構）。
  • 對性能敏感場景（如實時計算）使用 ??線程通信 + 共享內存??。
  • 在 Node.js 中結合 cluster（多進程）和 worker_threads（多線程），充分利用多核 CPU。

提示：瀏覽器中 Web Worker 的 postMessage 適合低頻通信，高頻數據交互應轉向 SharedArrayBuffer；Node.js 的 IPC 通道性能優于網絡通信，優先用于本地進程間調用。

以下是 JavaScript 中進程通信（IPC）和線程通信的深度解析，從底層原理到工程實踐進行系統性梳理：

一、進程通信（IPC）深度機制

??核心原理??
環境通信機制技術細節
??瀏覽器??postMessage + 結構化克隆1. 深拷貝算法支持：支持循環引用/Map/Set等復雜對象
2. 傳輸性能：拷貝開銷隨數據量線性增長
??Node.js??child_process IPC通道1. 本地Socket（Unix域套接字/Windows命名管道）
2. 零序列化：直接傳遞對象引用
??結構化克隆 vs 序列化??
// 結構化克隆特性示例
const obj = { set: new Set([1, 2]), fn: () => {} // 函數會被丟棄!
};
worker.postMessage(obj); // 函數不會傳輸，Set被保留
??高級通信模式??
  1. ??流式傳輸??（大數據場景）
// Node.js 進程間流傳輸
const { spawn } = require('child_process');
const child = spawn('process', []);
fs.createReadStream('bigfile.data').pipe(child.stdin);
child.stdout.pipe(fs.createWriteStream('result.data'));
  1. ??RPC模式??（跨進程調用）
// 使用 electron-ipc 實現遠程調用
// 主進程
ipcMain.handle('getData', () => db.query());// 渲染進程
const data = await ipcRenderer.invoke('getData');

二、線程通信核心技術

??共享內存操作原理??
graph LRA[線程1] -->|寫入| B[SharedArrayBuffer]C[線程2] -->|讀取| BB --> D[原子操作保障]D --> E[內存一致性]
??原子操作深度解析??
// 多線程計數器實現
const buffer = new SharedArrayBuffer(4);
const view = new Int32Array(buffer);// 線程A
Atomics.add(view, 0, 5); // 線程B
Atomics.sub(view, 0, 3);// 安全讀取
const current = Atomics.load(view, 0);
??線程同步原語??
  1. ??互斥鎖模擬??
const lock = new Int32Array(new SharedArrayBuffer(4));// 加鎖
while (Atomics.compareExchange(lock, 0, 0, 1) !== 0) {Atomics.wait(lock, 0, 1);
}// 臨界區操作...// 解鎖
Atomics.store(lock, 0, 0);
Atomics.notify(lock, 0, 1);
  1. ??信號量實現??
class Semaphore {constructor(view, index) {this.view = view;this.index = index;}acquire() {while (Atomics.compareExchange(this.view, this.index, 0, -1) === -1) {Atomics.wait(this.view, this.index, -1);}}release() {Atomics.store(this.view, this.index, 0);Atomics.notify(this.view, this.index, 1);}
}

三、工程實踐指南

??通信模式選擇矩陣??
場景推薦方案性能指標風險控制
高頻小數據交換SharedArrayBuffer + Atomics微秒級延遲需嚴格內存同步
大數據傳輸Stream管道傳輸吞吐量>1GB/s注意背壓控制
跨機器通信gRPC-Web/WebSocket網絡依賴斷線重連機制
復雜任務解耦消息隊列(RabbitMQ/Redis)毫秒級延遲消息持久化配置
??瀏覽器端優化策略??
  1. ??傳輸優化??
// 使用轉移代替拷貝
const uint8Array = new Uint8Array(1024 * 1024);
worker.postMessage(uint8Array, [uint8Array.buffer]); // 轉移所有權
  1. ??線程池模式??
class WorkerPool {constructor(size, workerScript) {this.workers = Array(size).fill().map(() => {const worker = new Worker(workerScript);worker.busy = false;return worker;});}exec(data) {const freeWorker = this.workers.find(w => !w.busy);if (!freeWorker) return Promise.reject('No worker available');freeWorker.busy = true;return new Promise((resolve) => {freeWorker.onmessage = (e) => {freeWorker.busy = false;resolve(e.data);};freeWorker.postMessage(data);});}
}
??Node.js 集群架構??
graph TDMaster[主進程] -->|fork| Worker1[工作進程1]Master -->|fork| Worker2[工作進程2]Master -->|負載均衡| HTTP[HTTP請求]Worker1 -->|IPC| MasterWorker2 -->|IPC| MasterHTTP -->|分發| Worker1HTTP -->|分發| Worker2
// 生產級集群實現
const cluster = require('cluster');
const os = require('os');if (cluster.isMaster) {// 心跳檢測機制const workers = {};for (let i = 0; i < os.cpus().length; i++) {const worker = cluster.fork();workers[worker.id] = worker;// 自動重啟worker.on('exit', () => {delete workers[worker.id];cluster.fork();});}// 零停機重啟process.on('SIGUSR2', () => {const restartWorker = id => {const worker = cluster.fork();worker.on('listening', () => workers[id].kill());};Object.keys(workers).forEach(restartWorker);});
} else {require('./app'); // 業務應用
}

四、安全與調試方案

??共享內存安全機制??
  1. ??Spectre漏洞防護??
# HTTP響應頭要求
Cross-Origin-Opener-Policy: same-origin
Cross-Origin-Embedder-Policy: require-corp
  1. ??內存隔離策略??
// 創建安全沙箱
const sab = new SharedArrayBuffer(1024);
const locker = new Int32Array(sab, 0, 1); // 專用鎖區域
const dataArea = new Uint8Array(sab, 4);  // 數據隔離區
??多進程調試技巧??
  1. ??Chrome DevTools??
# Node.js調試命令
node --inspect=9229 app.js
  • 訪問 chrome://inspect 附加調試器
  1. ??VS Code 配置??
{"type": "node","request": "attach","name": "Worker Thread","port": 9230,"protocol": "inspector"
}

五、演進趨勢與新興方案

  1. ??WebAssembly線程??
const module = new WebAssembly.Module(buffer);
const worker = new Worker('wasm-worker.js');// 共享內存傳遞
worker.postMessage({ module, memory: wasmMemory });
  1. ??Node.js工作線程池??
const { WorkerPool } = require('workerpool');
const pool = WorkerPool();// 自動線程管理
const result = await pool.exec('heavyTask', [params]);
  1. ??并行計算框架??
  • GPU.js：WebGL加速計算
  • TensorFlow.js：自動分布式計算

總結決策樹

graph TDStart[通信需求] --> Isolated{需要內存隔離？}Isolated -->|Yes| IPC[選擇進程通信]Isolated -->|No| HighFreq{高頻數據交換？}HighFreq -->|Yes| SharedMemory[共享內存+原子操作]HighFreq -->|No| SimpleMsg[基礎消息傳遞]IPC --> Browser{瀏覽器環境？}Browser -->|Yes| WebWorker[postMessage]Browser -->|No| NodeIPC[child_process/sockets]SharedMemory --> BrowserEnv{運行環境}BrowserEnv -->|Browser| SAB[SharedArrayBuffer]BrowserEnv -->|Node.js| WorkerThreads

通過分層解析核心機制、工程實踐與未來演進，開發者可根據具體場景選擇最優通信方案，在安全可靠的前提下實現最大化性能提升。

本文來自互聯網用戶投稿，該文觀點僅代表作者本人，不代表本站立場。本站僅提供信息存儲空間服務，不擁有所有權，不承擔相關法律責任。
如若轉載，請注明出處：http://www.pswp.cn/diannao/91916.shtml
繁體地址，請注明出處：http://hk.pswp.cn/diannao/91916.shtml
英文地址，請注明出處：http://en.pswp.cn/diannao/91916.shtml

如若內容造成侵權/違法違規/事實不符，請聯系多彩編程網進行投訴反饋email:809451989@qq.com，一經查實，立即刪除！

相關文章

堆堆堆，咕咕咕

堆堆堆，咕咕咕

1.找TopK問題要找到最前面的k個元素void swap(int *a,int *b) {int temp*a;*a*b;*btemp; } //向下調整最小堆 void minheapify(int arr[],int n,int index) {int left2*index1;int right2*index2;int smallestindex;if(left<n&&arr[left]<arr[smallest]) smalles…
閱讀更多...
n8n教程分享,從Github讀取.md文檔內容

n8n教程分享,從Github讀取.md文檔內容

從上一篇我們了解到了如何安裝 n8n 那么這節課我們嘗試從github的個人倉庫獲取某個文件的內容 目標如下 content/business/1.how-to-use-money.mdx 總流程圖 流程詳解 第1步&#xff1a;申請 GitHub Personal Access Token (Classic) 在gitrhub 個人 設置選項 申請 GitHub P…
閱讀更多...
分布式ID與冪等性面試題整理

分布式ID與冪等性面試題整理

分布式ID與冪等性面試題整理 文章目錄分布式ID與冪等性面試題整理一、分布式ID1. 為什么需要分布式ID&#xff1f;2. 分布式ID的核心要求3. 常見分布式ID方案(1) UUID(2) 數據庫自增(3) Redis自增(4) 雪花算法(Snowflake)(5) 美團Leaf/百度UidGenerator4. 雪花算法詳解二、冪等…
閱讀更多...
node.js學習筆記1

node.js學習筆記1

目錄 Node.js是什么 Node.js下載與安裝 Buffer緩沖區 一些計算機硬件基礎 程序運行的基本流程 Node.js是什么 node.js是一個JavaScript運行環境&#xff0c;或者說&#xff0c;node.js是一個可以運行JavaScript的軟件。 可以用于開發服務端、桌面端、工具類應用。 服務器…
閱讀更多...
游戲開發日志

游戲開發日志

我來為您逐行詳細講解這個 ViewMgr.cs 文件。這是一個Unity游戲中的視野管理系統&#xff0c;用于優化游戲性能。## 文件結構概覽這個文件主要包含以下幾個部分&#xff1a; 1. 數據結構和接口定義 2. 視野管理器 ViewMgr 類 3. 工具類 ViewTools讓我逐行為您講解&#xff1a;#…
閱讀更多...
使用 PlanetScope 衛星圖像繪制水質參數：以莫干湖為例

使用 PlanetScope 衛星圖像繪制水質參數：以莫干湖為例

1.數據采集 我使用ArcGIS Pro 中的Planet Imagery插件下載了 2023 年 6 月 25 日的安卡拉莫干湖衛星圖像。 圖 1&#xff1a;使用 Planet 插件下載衛星圖像 圖 2&#xff1a;下載圖像的日期和傳感器選擇 我查閱的研究中指出&#xff0c;使用無降水時期的衛星圖像對于水質測定…
閱讀更多...
Docker部署前后端分離項目——多項目共享環境部署

Docker部署前后端分離項目——多項目共享環境部署

目錄 一、簡介 二、文件目錄結構 三、前端部署流程&#xff08;多nginx&#xff09; 3.1 前端打包 3.2 編寫部署文件——項目1&#xff08;consult-system&#xff09; 3.3 編寫部署文件——項目2&#xff08;person-system&#xff09; 3.4 前端部署至linux服務器 3.5…
閱讀更多...
學習筆記(39):結合生活案例，介紹 10 種常見模型

學習筆記(39):結合生活案例，介紹 10 種常見模型

學習筆記(39):結合生活案例&#xff0c;介紹 10 種常見模型線性回歸只是機器學習的 “冰山一角”&#xff01;根據不同的任務場景&#xff08;分類、回歸、聚類等&#xff09;&#xff0c;還有許多強大的模型可以選擇。下面我用最通俗易懂的語言&#xff0c;結合生活案例&#…
閱讀更多...
BabyAGI 是一個用于自構建自主代理的實驗框架

BabyAGI 是一個用于自構建自主代理的實驗框架

這個最新的 BabyAGI 是一個用于自構建自主代理的實驗框架 核心是一個新的函數框架 &#xff08;functionz&#xff09;&#xff0c;用于存儲、管理和執行數據庫中的函數。它提供了一個基于圖形的結構&#xff0c;用于跟蹤導入、依賴函數和身份驗證密鑰&#xff0c;并具有自動加…
閱讀更多...
商業秘密視域下計算機軟件的多重保護困境

商業秘密視域下計算機軟件的多重保護困境

作者&#xff1a;邱戈龍、柯堅豪重慶商業秘密律師廣東長昊律師事務所引言&#xff1a;計算機軟件保護的復雜性 在商業秘密保護的宏大版圖中&#xff0c;計算機軟件因其技術密集性和創新性占據著特殊地位。軟件的真正價值不僅在于其代碼本身&#xff0c;更在于其背后的流程、邏…
閱讀更多...
深入理解 Spring Boot 自動配置原理

深入理解 Spring Boot 自動配置原理

Spring Boot 之所以能“開箱即用”&#xff0c;其核心就在于 自動配置機制&#xff08;Auto Configuration&#xff09;。本文將深入剖析 Spring Boot 自動配置的工作原理&#xff0c;從注解入手&#xff0c;再到底層的源碼機制&#xff0c;揭開 Spring Boot 背后的“魔法”。 …
閱讀更多...
Ubuntu18.04開機啟動執行腳本

Ubuntu18.04開機啟動執行腳本

#!/bin/bash # 運行 .NET Core 應用程序 dotnet /home/bruce/atg/SmartConsole.dll &# 打開瀏覽器 firefox 給文件權限sudo chmod 777 start.sh運行gnome-session-properties打開系統自帶的一個啟動程序
閱讀更多...
c語言進階 字符函數和字符串函數

c語言進階 字符函數和字符串函數

字符函數和字符串函數字符函數和字符串函數1. strlenstrlen 函數詳解模擬實現1.計數器方式2.不能創建臨時變量計數器&#xff08;遞歸&#xff09;3.指針-指針的方式2. strcpystrcpy 函數詳解模擬實現3. strcatstrcat 函數詳解模擬實現4. strcmpstrcmp 函數詳解模擬實現5. strn…
閱讀更多...
(LeetCode 每日一題) 1233. 刪除子文件夾 (排序)

(LeetCode 每日一題) 1233. 刪除子文件夾 (排序)

題目&#xff1a;1233. 刪除子文件夾 思路&#xff1a;排序&#xff0c;時間復雜度0(L*nlogn)。 文件夾a的子文件b&#xff0c;b字符串字典序列一定是大于a的&#xff0c;所以直接將字符串數組folder升序排序。每次只需判斷當前字符串&#xff0c;是否是父文件夾數組v最后一個…
閱讀更多...
集成算法學習bagging,boosting,stacking

集成算法學習bagging,boosting,stacking

baggibg(rf隨機森林) adaboostibg 用來展示 Project Jupyter | Home 展示源碼 Eclipse IDE | The Eclipse Foundation Eclipse 下載 |Eclipse 基金會 教程8-Adaboost決策邊界效果_嗶哩嗶哩_bilibili (23 封私信) 圖解機器學習神器&#xff1a;Scikit-Learn - 知乎 Baggi…
閱讀更多...
HOOPS SDK賦能PLM：打造全生命周期3D數據管理與協作能力

HOOPS SDK賦能PLM：打造全生命周期3D數據管理與協作能力

在制造業和工業領域&#xff0c;產品全生命周期管理&#xff08;PLM&#xff09; 已成為驅動企業數字化轉型、提升創新力與運營效率的核心引擎。一個高效的PLM平臺不僅需要管理海量的設計數據&#xff0c;還必須在設計、制造、供應鏈、銷售和服務等多個環節之間無縫流轉信息&am…
閱讀更多...
解決 Selenium 頁面跳轉過快導致的內容獲取問題：從原理到實踐

解決 Selenium 頁面跳轉過快導致的內容獲取問題：從原理到實踐

在使用 Selenium 進行網頁自動化操作時&#xff0c;很多開發者都會遇到一個頭疼的問題&#xff1a;頁面還沒加載完&#xff0c;代碼就已經執行到下一句了。結果要么是元素找不到&#xff0c;要么是獲取的內容不完整&#xff0c;甚至直接拋出異常。今天我們就來聊聊如何優雅地解…
閱讀更多...
【Python練習】051. 編寫一個函數，實現簡單的定時器功能

【Python練習】051. 編寫一個函數，實現簡單的定時器功能

051. 編寫一個函數，實現簡單的定時器功能 051. 編寫一個函數，實現簡單的定時器功能 代碼說明： 示例運行： 擴展功能 代碼說明： 實現Python定時器的幾種方法 051. 編寫一個函數，實現簡單的定時器功能 以下是一個簡單的Python函數，用于實現定時器功能。這個定時器可以設置…
閱讀更多...
springboot基礎-demo

springboot基礎-demo

1.創建學生信息表 create table stu(id int unsigned primary key auto_increment comment ID,name varchar(100) comment 姓名,age tinyint unsigned comment 年齡,gender tinyint unsigned comment 性別, 1:男, 2:女,score double(5,2) comment 成績,phone varchar(11) comme…
閱讀更多...
關于transformer的一些疑點總結

關于transformer的一些疑點總結

殘差連接的作用 Transformer中的殘差連接&#xff08;Residual Connection&#xff09;是其深層架構能穩定訓練的核心設計之一&#xff0c;主要通過以下機制發揮作用&#xff1a; 1. 緩解梯度消失&#xff0c;支持深層訓練 梯度保護機制&#xff1a;在反向傳播時&#xff0c;…
閱讀更多...
最新文章

Copyright @ 2022~2023