尋夢新聞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地址：
觀察一下服務器端的日志：
客戶端的日志：
