首先客戶端和服務(wù)器端通信得需要一個消息結(jié)構(gòu)，我用如下的構(gòu)造函數(shù)創(chuàng)建一個消息結(jié)構(gòu)，包含消息正文和消息類型(method):

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

首先創(chuàng)建服務(wù)器：借用nodejs的net module：

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

使用init方法啟動這個服務(wù)器實例：

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 }

服務(wù)器端監(jiān)聽在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(); // 調(diào)用net.Socket()返回的實例的connect方法進行連接await client.connect(port, ip, () => {});client.on('connect', (data) => {// 連接成功，發(fā)connect事件通知應(yīng)用eventEmitter.emit('connect',data);});}

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

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')；// 這里可以開始執(zhí)行應(yīng)用邏輯了})

而剛才服務(wù)器端創(chuàng)建server實例之后，createServer的回調(diào)函數(shù)在客戶端成功連接到服務(wù)器端后，會自動觸發(fā)，這里根據(jù)輸入的socket參數(shù)就能解析出客戶端的IP地址：

觀察一下服務(wù)器端的日志：

客戶端的日志：

要獲取更多Jerry的原創(chuàng)文章，請關(guān)注公眾號"汪子熙":

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。