首先客戶端和服務器端通信得需要一個消息結構，我用如下的構造函數創建一個消息結構，包含消息正文和消息類型(method):

function message(_data,_method = '') {_message = {}if(_method != "" || _method != '') {_message.method = _method}if(_data != "" || _data != '') {_message.data = _data}return _message}module.exports = {message }

首先創建服務器：借用nodejs的net module：

const net = require('net');server = net.createServer(function (socket) {// 此處編寫客戶端成功連接后的回調邏輯 });

使用init方法啟動這個服務器實例：

function startServer(serverIP, serverPort) {server.listen(serverPort, serverIP);return eventEmitter; };function init(_ip,_port,_logName) {server = startServer(_ip, _port);log.info('init TCP Server at '+_ip+':'+_port)return server }

把init方法暴露出去：

module.exports = {init }

服務器端監聽在8081端口：

let server = TCPServer.init("127.0.0.1","8081",'Orchestra');

再編寫客戶端：

const net = require('net');async function startClient(ip = configJson.TCP.client.ip, port = configJson.TCP.client.port) {client = new net.Socket(); // 調用net.Socket()返回的實例的connect方法進行連接await client.connect(port, ip, () => {});client.on('connect', (data) => {// 連接成功，發connect事件通知應用eventEmitter.emit('connect',data);});}

應用程序捕捉到這個connect事件后，可以做相應處理：

async function connectToOrchestra () {log.info('connecting statemachine in an asynchronous way');var client = await TCPClient.startClient("127.0.0.1", "8081");client.on('connect', (dataTmp) => {log.info('Congratulations! Statemachine is connected')；// 這里可以開始執行應用邏輯了})

而剛才服務器端創建server實例之后，createServer的回調函數在客戶端成功連接到服務器端后，會自動觸發，這里根據輸入的socket參數就能解析出客戶端的IP地址：

觀察一下服務器端的日志：

客戶端的日志：

要獲取更多Jerry的原創文章，請關注公眾號"汪子熙":

總結

以上是生活随笔為你收集整理的nodejs TCP server和TCP client如何建立连接的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。