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

首先客户端和服务器端通信得需要一个消息结构，我用如下的构造函数创建一个消息结构，包含消息正文和消息类型(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地址：

观察一下服务器端的日志：

客户端的日志：