1. 程式人生 > 程式設計 >詳解兩個Node.js程序是如何通訊

詳解兩個Node.js程序是如何通訊

目錄
  • 前言
  • 不同電腦上的兩個 Node. 程序間通訊
    • 使用 TCP 套接字
    • 使用 HTTP 協議
  • 同一臺電腦上兩個 Node.js 程序間通訊
    • 使用內建 IPC 通道
    • 使用自定義管道
  • 總結

    前言

    兩個 Node.js 程序之間如何進行通訊呢?這裡要分兩種場景:

    1. 不同電腦上的兩個 Node.js 程序間通訊
    2. 同一臺電腦上兩個 Node.js 程序間通訊

    對於第一種場景,通常使用 TCP 或 HTTP 進行通訊,而對於第二種場景,又分為兩種子場景:

    1. Node.js 程序和自己建立的 Node.js 子程序通訊
    2. Node.js 程序和另外不相關的 Node.js 程序通訊

    前者可以使用內建的 IPC 通訊通道,後者可以使用自定義管道,接下來進行詳細介紹:

    不同電腦上的兩個 Node.js 程序間通訊

    要想進行通訊,首先得搞清楚如何標識網路中的程序?網路層的 ip 地址可以唯一標識網路中的主機,而傳輸層的協議和埠可以唯一標識主機中的應用程式(程序),這樣利用三元組(ip 地址,協議,埠)就可以標識網路的程序了。

    使用 TCP 套接字

    TCP 套接字(socket)是一種基於 TCP/IP 協議的通訊方式,可以讓通過網路連線的計算機上的程序進行通訊。一個作為 server 另一個作為 client,server.js 程式碼如下:

    const net = require('net')
    const server = net.createServer(socket => {
      console.log('socket connected')
      socket.on('close',() => console.log('socket disconnected'))
      socket.on('error',err => console.error(err.message))
      socket.on('data',data => {
        console.log(`receive: ${data}`)
        socket.write(data)
        console.log(`send: ${data}`)
      })
    })
    server.listen(8888)
    

    client.fqsdmrThrjs 程式碼:

    const net = require('net')
    const client = net.connect(8888,'192.168.10.105')
    
    client.on('connect',() => console.log('connected.'))
    client.on('data',data => console.log(`receive: ${data}`))
    client.on('end',() => console.log('disconnected.'))
    client.on('error',err => console.error(err.message))
    
    setInterval(() => {
      const msg = 'hello'
      console.log(`send: ${msg}`)
      client.write(msg)
    },3000)
    

    執行效果:

    $ node server.js
    client connected
    receive: hello
    send: hello
    
    $ node client.js
    connect to server
    send: hello
    receive: hello
    

    使用 HTTP 協議

    因為 HTTP 協議也是基於 TCwww.cppcns.comP 的,所以從通訊角度看,這種方式本質上並無區別,只是封裝了上層協議。server.js 程式碼為:

    const http = require('http')
    http.createServer((req,res) => res.end(req.url)).listen(8888)
    

    client.js 程式碼:

    const http = require('http')
    const options = {
      hostname: '192.168.10.105',port: 8888,path: '/hello',method: 'GET',}
    const req = http.request(options,res => {
      console.log(`statusCode: ${res.statusCode}`)
      res.on('data',d => process.stdout.write(d))
    })
    req.on('error',error => console.error(error))
    req.end()
    

    執行效果:

    $ node server.js
    url /hello
    
    $ node client.js
    statusCode: 200
    hello
    

    同一臺電腦上兩個 Node.js 程序間通訊

    雖然網路 socket 也可用於同一臺主機的程序間通訊(通過 loopback 地址 127.0.0.1),但是這種方式需要經過網路協議棧、需要打包拆包、計算校驗和、維護序號和應答等,就是為網路通訊設計的,而同一臺電腦上的兩個程序可以有更高效的通訊方式,即 IPC(Inter-Process Communication),在 unix 上具體的實現方式為 unix domain socket,這是伺服器端和客戶端之間通過本地開啟的套接字檔案進行通訊的一種方法,與 TCP 通訊不同,通訊時指定本地檔案,因此不進行域解析和外部通訊,所以比 TCP 快,在同一臺主機的傳輸速度是 TCP 的兩倍。

    使用內建 IPC 通道

    如果是跟自己建立的子程序通訊,是非常方便的,child_process 模組中的 fork 方法自帶通訊機制,無需關注底層細節,例如父程序 parent.js 程式碼:

    const fork = require("child_process").fork
    const path = require("path")
    const child = fork(path.resolve("child.js"),[],{ stdio: "inherit" });
    child.on("message",(message) => {
      console.log("message from child:",message)
      child.send("hi")
    })
    

    子程序 child.js 程式碼:

    process.on("message",(message) => {
      console.log("message from parent:",message);
    })
    
    if (process.send) {
      setInterval(() => process.send("hello"),3000)
    }
    

    執行效果如下:

    $ node parent.js
    message from child: hello
    message from parent: hi
    message from child: hello
    message from parent: hi
    

    使用自定義管道

    如果是兩個獨立的 Node.js 程序,如何建立通訊通道呢?在 Windows 上可以使用命名管道(Named PIPE),在 unix 上可以使用 unix domain socket,也是一個作為 server,另外一個作為 client,其中 server.js 程式碼如下:

    const net = require('net')
    const fs = require('fs')
    
    const pipeFile = process.platform === 'win32' ? '\\\\.\\pipe\\mypip' : '/tmp/unix.sock'
    
    const server = net.createServer(connection => {
      console.log('socket connected.')
      connection.on('close',() => console.log('disconnected.'))
      connection.on('data',data => {
        console.log(`receive: ${data}`)
        connection.write(data)
        console.log(`send: ${data}`)
      })
      connection.on('error',err => console.error(err.message))
    })
    
    try {
      fs.unlinkSync(pipeFile)
    } catch (error) {}
    
    server.listen(pipeFile)
    
    

    client.js 程式碼如下:

    const net = require('net')
    
    const pipeFile = process.platform === 'win32' ? '\\\\.\\pipe\\mypip' : '/tmp/unix.sock'
    
    const client = net.connect(pipeFile)
    client.on('connect',3000)
    
    

    執行效果:

    $ node server.js 
    socket connected.
    receive: hello
    send: hello
    
    $ node client.js
    connected.
    send: hello
    receive: hello
    

    總結

    到此這篇關於兩個Node.js程序是如何通訊的文章就介紹到這了,更多相關兩個Node.js程序通訊內容請搜尋我們以前的文章或繼續瀏覽下面的相關文章希望大家以後多多支援我們!