目錄

* 一. net模塊簡(jiǎn)介 <https://www.cnblogs.com/dashnowords/p/10976552.html#一.-net模塊簡(jiǎn)介>
* 二. Client-Server的通訊
<https://www.cnblogs.com/dashnowords/p/10976552.html#二.-client-server的通訊>
* 2.1 server的建立
<https://www.cnblogs.com/dashnowords/p/10976552.html#server的建立>
* 2.2 Socket的建立
<https://www.cnblogs.com/dashnowords/p/10976552.html#socket的建立>
* 三. IPC通訊 <https://www.cnblogs.com/dashnowords/p/10976552.html#三.-ipc通訊>
* 四. 擼一個(gè)簡(jiǎn)易的cluster通訊模型
<https://www.cnblogs.com/dashnowords/p/10976552.html#四.-擼一個(gè)簡(jiǎn)易的cluster通訊模型>


示例代碼托管在：http://www.github.com/dashnowords/blogs
<https://github.com/dashnowords/blogs/tree/master/Demo/nodejs/net_demo/net_demo>

博客園地址：《大史住在大前端》原創(chuàng)博文目錄 <https://www.cnblogs.com/dashnowords/p/10127926.html>

華為云社區(qū)地址：【你要的前端打怪升級(jí)指南】
<https://bbs.huaweicloud.com/blogs/8ae7e6420a4611e9bd5a7ca23e93a891>

一. net模塊簡(jiǎn)介

net模塊是nodejs通訊功能實(shí)現(xiàn)的基礎(chǔ)，nodejs中最常用的功能就是作為WebServer使用，建立服務(wù)器時(shí)使用的http.createServer
就是在net.createServer方法的基礎(chǔ)上建立的。前端最熟悉的http協(xié)議屬于應(yīng)用層協(xié)議，應(yīng)用層的內(nèi)容想要發(fā)送出去，還需要將消息逐層下發(fā)，通過(guò)傳輸層（
tcp,udp），網(wǎng)際層(ip)和更底層的網(wǎng)絡(luò)接口后才能被傳輸出去。net模塊就是對(duì)分層通訊模型的實(shí)現(xiàn)。

net模塊中有兩大主要抽象概念——net.Server和net.Socket。《deep-into-node》一書(shū)中對(duì)Socket概念進(jìn)行了解釋?zhuān)?br>
Socket 是對(duì) TCP/IP
協(xié)議族的一種封裝，是應(yīng)用層與TCP/IP協(xié)議族通信的中間軟件抽象層。它把復(fù)雜的TCP/IP協(xié)議族隱藏在Socket接口后面，對(duì)用戶(hù)來(lái)說(shuō)，一組簡(jiǎn)單的接口就是全部，讓Socket去組織數(shù)據(jù)，以符合指定的協(xié)議。

Socket
還可以認(rèn)為是一種網(wǎng)絡(luò)間不同計(jì)算機(jī)上的進(jìn)程通信的一種方法，利用三元組（ip地址，協(xié)議，端口）就可以唯一標(biāo)識(shí)網(wǎng)絡(luò)中的進(jìn)程，網(wǎng)絡(luò)中的進(jìn)程通信可以利用這個(gè)標(biāo)志與其它進(jìn)程進(jìn)行交互。

簡(jiǎn)單地說(shuō)，net.Server實(shí)例可以監(jiān)聽(tīng)一個(gè)端口（用于實(shí)現(xiàn)客戶(hù)端TCP連接通訊）或者地址（用于實(shí)現(xiàn)IPC跨進(jìn)程通訊），net.Socket
實(shí)例可以建立一個(gè)套接字實(shí)例，它可以用來(lái)和server建立連接，連接建立后，就可以實(shí)現(xiàn)通訊了。你可以將socket想象成手機(jī)，把server想象成基站
，雖然不是很貼切，但可以降低理解難度。net相關(guān)API可以直接查看中文文檔【net模塊文檔】 <http://nodejs.cn/api/net.html>。

二. Client-Server的通訊

2.1 server的建立

Server類(lèi)的定義非常精簡(jiǎn)，也很容易看懂：



可以看到構(gòu)造函數(shù)基本上只是初始化了一些屬性，然后添加了對(duì)connection事件的響應(yīng)。服務(wù)器是net.Server類(lèi)的實(shí)例，通過(guò)
net.createServer([options][,onConnection] )方法建立，如果傳入一個(gè)函數(shù)，則這個(gè)函數(shù)會(huì)作為connection
事件的回調(diào)函數(shù)，當(dāng)一個(gè)socket實(shí)例連接到server時(shí)，connection事件就會(huì)觸發(fā)，回調(diào)函數(shù)中的形參就指向了發(fā)起連接的socket實(shí)例。server
實(shí)例并不能獨(dú)立工作，作為網(wǎng)絡(luò)服務(wù)器使用時(shí)需要需要調(diào)用listen方法來(lái)監(jiān)聽(tīng)一個(gè)地址，示例如下：
const net = require('net'); const { StringDecoder } =
require('string_decoder'); let decoder = new StringDecoder('utf8'); let server
= net.createServer(socket=>{ console.log('接收連接'); socket.on('data',data=>{
console.log('收到來(lái)自客戶(hù)端的消息:',decoder.write(data)); }); socket.on('end',function(){
console.log('socket從客戶(hù)端被關(guān)閉了'); }); }); server.listen(12315);
socket上以流的形式發(fā)送數(shù)據(jù)，所以需要調(diào)用string_decoder
模塊進(jìn)行解碼才能夠看到內(nèi)容，否則看到的就是原始的字節(jié)信息。上面的實(shí)例監(jiān)聽(tīng)了12315端口。

2.2 Socket的建立

前文已經(jīng)提及Socket是對(duì)TCP/IP協(xié)議族的一種封裝?？蛻?hù)端通訊套接字是net.Socket的實(shí)例，通過(guò)調(diào)用實(shí)例方法
socket.connect(args)來(lái)和服務(wù)器建立連接，作為客戶(hù)端通訊套接字時(shí)需要監(jiān)聽(tīng)端口號(hào)，建立連接后，客戶(hù)端server通過(guò)connection
事件的回調(diào)函數(shù)就可以拿到發(fā)起連接的socket實(shí)例，這樣客戶(hù)端和服務(wù)器就可以通訊了，其中一方通過(guò)socket.write（）方法寫(xiě)入數(shù)據(jù)，另一方注冊(cè)的監(jiān)聽(tīng)器
socket.on('data',onData)回調(diào)函數(shù)就會(huì)收到信息。socket實(shí)例化示例如下:
const net = require('net'); let socket = new net.Socket();
socket.connect(12315); //連接服務(wù)器 socket.on('connect',c=>{
console.log('成功建立和12315的連接') setTimeout(()=>{ console.log('建立連接1s后發(fā)送消息');
socket.write('SN:1231512315','utf8',function(){ console.log('消息已發(fā)送'); });
},1000); }); socket.on('data',function(resp){ console.log('收到服務(wù)器返回消息：',resp);
}); socket.on('end',function(){ console.log('socket從客戶(hù)端被關(guān)閉了'); })
客戶(hù)端connect連接服務(wù)器的動(dòng)作，就好比打電話前要先撥號(hào)一樣，等接通以后，你說(shuō)的話（也就是socket.write( )寫(xiě)入的data）才能被發(fā)送過(guò)去。
【代碼倉(cāng)的示例DEMO】中提供了相對(duì)完整的示例,分別放在server.js和client.js
中，你可以通過(guò)控制臺(tái)打印的信息來(lái)觀察每條語(yǔ)句執(zhí)行的先后順序，熟悉從通信建立到消息收到再到服務(wù)器關(guān)閉的整個(gè)過(guò)程，記得要先起服務(wù)器，后起客戶(hù)端。



Tips：你可以使用postman向這個(gè)server發(fā)一個(gè)GET請(qǐng)求，看看是什么樣子，對(duì)理解http和tcp/ip
的關(guān)系有很大幫助，它非常直觀，反正我是第一次見(jiàn)。

三. IPC通訊

IPC通訊是指Inter Process Communication，也就是跨進(jìn)程通訊，上一節(jié)在提到cluster
時(shí)已經(jīng)介紹過(guò)進(jìn)程之間是資源隔離的，所以跨進(jìn)程通訊也需要通過(guò)net模塊來(lái)建立消息管道。它的用法比較簡(jiǎn)單，只需要將server.listen( )和
socket.connect( )的參數(shù)從端口號(hào)換成地址字符串就可以了。示例代碼如下：
const net = require('net'); const cluster = require('cluster'); const path =
require('path'); const { StringDecoder } = require('string_decoder'); let
serverForIPC;//作為子進(jìn)程的server if (cluster.isMaster) { //主進(jìn)程執(zhí)行邏輯 setupMaster();
cluster.fork();//生成子進(jìn)程 cluster.fork();//生成另一個(gè)子進(jìn)程 } else { //子進(jìn)程執(zhí)行邏輯
setupWorker(); } //主進(jìn)程邏輯 function setupMaster() { //作為Server監(jiān)聽(tīng)子進(jìn)程消息 let decoder
= new StringDecoder('utf8'); //windows系統(tǒng)中要求的IPC通訊命名規(guī)則 let ipcPath =
path.join('\\\\?\\pipe', process.cwd(), 'dashipc'); serverForIPC =
net.createServer(socket=>{ console.log(`[master]:子進(jìn)程通過(guò)ipcServer連接到主進(jìn)程`);
socket.on('data',data=>{
console.log('[master]:收到來(lái)自子進(jìn)程的消息:',decoder.write(data)); }); });
//IPC-server端監(jiān)聽(tīng)指定地址 serverForIPC.listen(ipcPath); } //子進(jìn)程邏輯 function
setupWorker() { let ipcPath = path.join('\\\\?\\pipe', process.cwd(),
'dashipc'); let socket = new net.Socket(); //子進(jìn)程的socket連接主進(jìn)程中監(jiān)聽(tīng)的地址
socket.connect(ipcPath,c=>{
console.log(`[child-${process.pid}]:pid為${process.pid}的子進(jìn)程已經(jīng)連接到主進(jìn)程`);
//過(guò)一秒后發(fā)個(gè)消息測(cè)試一下 setTimeout(()=>{
socket.write(`${process.pid}的消息:SN1231512315`,'utf8',function(){
console.log(`[child-${process.pid}]:消息已發(fā)送`); }); },1000); }); }
需要注意盡管主進(jìn)程和子進(jìn)程運(yùn)行的是同樣的腳本，但執(zhí)行的具體邏輯由cluster.isMaster進(jìn)行了區(qū)分。當(dāng)主進(jìn)程的腳本運(yùn)行時(shí)會(huì)建立一個(gè)IPC通訊管道的
server端并監(jiān)聽(tīng)指定地址，然后通過(guò)cluster.fork生成子進(jìn)程，子進(jìn)程會(huì)執(zhí)行setupWorker( )方法的邏輯，新建一個(gè)socket
實(shí)例并連接主進(jìn)程監(jiān)聽(tīng)的地址，這樣跨進(jìn)程通訊就建立了。示例代碼放置在代碼倉(cāng)中的ipc.js中,運(yùn)行結(jié)果如下：



四. 擼一個(gè)簡(jiǎn)易的cluster通訊模型

既然客戶(hù)端通訊和跨進(jìn)程通訊都實(shí)現(xiàn)了，那么把它們連起來(lái)協(xié)調(diào)好，其實(shí)就可以復(fù)現(xiàn)cluster集群模塊的功能了，雖然它不能等同于cluster
的源碼，cluster中跨進(jìn)程通訊是直接可以使用的，不需要自己手動(dòng)建立，但“造輪子”對(duì)于理解集群通訊機(jī)制非常有幫助。簡(jiǎn)易模型的基本方案如下，邏輯的順序已經(jīng)標(biāo)記出來(lái)了，在前文的基礎(chǔ)上實(shí)際上增加的只是調(diào)度相關(guān)的功能（也就是橙色背景的部分）：




首先主線程和子線程之間建立IPC通訊，連接建立后，由子進(jìn)程將自己的pid通過(guò)socket發(fā)給主進(jìn)程，這樣主進(jìn)程就知道連接到IPCserver的socket是哪個(gè)子進(jìn)程連過(guò)來(lái)的了，demo在內(nèi)部構(gòu)建了一個(gè)
type屬性為internal_init
的消息來(lái)完成這個(gè)登記動(dòng)作，然后啟動(dòng)一個(gè)接收客戶(hù)端連接的Server，監(jiān)聽(tīng)指定的端口。接下來(lái)到了第6步，客戶(hù)端新建了socket連接到了主線程Client
Server監(jiān)聽(tīng)的端口，clientServer把它發(fā)過(guò)來(lái)的socket
傳給調(diào)度中心，調(diào)度中心根據(jù)一定規(guī)則（demo中直接就簡(jiǎn)單粗暴地輪換使用各個(gè)線程）決定將這個(gè)socket與哪個(gè)worker
socket相匹配（所謂匹配就是指client socket發(fā)來(lái)的消息應(yīng)該調(diào)用哪個(gè)worker socket的write
方法來(lái)分發(fā)給對(duì)應(yīng)的子進(jìn)程），然后將這個(gè)客戶(hù)端socket登記到匹配記錄表中某條記錄的client socket上，這樣通訊通道就建立好了。

當(dāng)客戶(hù)端調(diào)用socket.write
來(lái)寫(xiě)入數(shù)據(jù)時(shí)，主線程就會(huì)收到這個(gè)數(shù)據(jù)，然后根據(jù)已經(jīng)建立好的socket關(guān)系把這條消息write到子進(jìn)程，子進(jìn)程處理完后在消息體中增加一個(gè)pid
屬性標(biāo)明這個(gè)消息是哪個(gè)進(jìn)程處理的(這個(gè)標(biāo)記也可以在主進(jìn)程中添加，因?yàn)橹鬟M(jìn)程中維護(hù)的有pid,client socket和worker socket
的對(duì)應(yīng)關(guān)系)，然后調(diào)用socket.write發(fā)回給主進(jìn)程，主進(jìn)程根據(jù)消息的pid屬性在記錄表中找到這個(gè)消息應(yīng)該由哪個(gè)client
socket來(lái)返回，找到后調(diào)用它的end方法將數(shù)據(jù)返回給客戶(hù)端，這樣就完成了一次請(qǐng)求分發(fā)。

demo中提供了示例，ipc_http.js是簡(jiǎn)易集群模型的服務(wù)端，ipc_http_client.js是客戶(hù)端，前后一共發(fā)送了3次請(qǐng)求，結(jié)果如下：

服務(wù)端的日志：



客戶(hù)端的請(qǐng)求：



上面的示例僅僅是為了幫助理解網(wǎng)絡(luò)通信和跨進(jìn)程通信協(xié)作的原理，并不代表cluster
的源碼，但通信層面的原理是類(lèi)似的，實(shí)際開(kāi)發(fā)中跨進(jìn)程通訊時(shí)不需要自己再構(gòu)建IPC消息通道，因?yàn)樽舆M(jìn)程返回的process
上就已經(jīng)集成了跨進(jìn)程通訊能力，理解這個(gè)簡(jiǎn)化的模型對(duì)閱讀cluster模塊的通訊原理能夠提供很好的過(guò)渡。

• ? 上一篇：Spring淺入淺出——不吹牛逼不裝逼
• ? 下一篇：.net持續(xù)集成sonarqube篇之 sonarqube與jenkins集成(命令模式)