专栏首页Jerry的SAP技术分享nodejs TCP server和TCP client如何建立连接

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地址:

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

客户端的日志:

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • 使用脚手架应用做单元测试

    版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。 ...

    Jerry Wang
  • 使用脚手架应用做单元测试

    因为后台service比较复杂,需要三个不同的实例协同工作,所以之前Oliver开发了Scaffolding App这个Angular前端,目的是方便我们随时测...

    Jerry Wang
  • ABAP和Java里关于DEFAULT(默认)机制的一些语言特性

    由此可见新语法比较简洁,能少写3行代码。但是这样有一个缺陷,在新语法下如果it_data内表内不存在object_ext的值为cl_crm_prodil_bo_...

    Jerry Wang
  • 50行代码的MVVM,感受闭包的艺术

    name 和 age 被响应式的渲染出来,在 2s 后我们修改了 name 的值,同样能在页面正确更新。

    Nealyang
  • 【综述】最新7篇数据科学/深度学习/CNN/知识图谱/文本匹配等中英文综述论文推介(附下载)

    【导读】专知内容组整理了最近人工智能领域相关期刊的7篇最新综述文章,为大家进行介绍,欢迎查看! 1 ▌深度文本匹配综述 ---- 作者:庞亮 兰艳艳 徐...

    WZEARW
  • CTPN论文翻译——中文版

    文章作者:Tyan 博客:noahsnail.com | CSDN | 简书

    Tyan
  • 指南:使用Keras和TensorFlow探索数据增强

    数据扩充使模型对较小的变化更鲁棒,因此可以防止模型过度拟合。将扩充后的数据存储在内存中既不实际也不高效,这就是Keras的Image Data Generato...

    用户6543014
  • 人工智能|利用keras和tensorflow探索数据增强

    将扩充后的数据存储在内存中既不实用也不高效,这就是keras中的imagedatagenerator类(也包括在tensorflow的高级api:tensorf...

    算法与编程之美
  • 实现了个shell下U盘热插拔识别

    用户3765803
  • R+python︱XGBoost极端梯度上升以及forecastxgb(预测)+xgboost(回归)双案例解读

    ——————————————————————————————————————————————————

    素质

扫码关注云+社区

领取腾讯云代金券