nodejs TCP server和TCP client如何建立連接

尋夢新聞LINE@每日推播熱門推薦文章,趣聞不漏接❤️

加入LINE好友

首先客戶端和服務器端通信得需要一個消息結構,我用如下的構造函數創建一個消息結構,包含消息正文和消息類型(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地址:

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

客戶端的日志:

About 尋夢園
尋夢園是台灣最大的聊天室及交友社群網站。 致力於發展能夠讓會員們彼此互動、盡情分享自我的平台。 擁有數百間不同的聊天室 ,讓您隨時隨地都能找到志同道合的好友!