如何管理 NodeJs TCP 客户端



我正在研究一台带有Arduino电机的机器,用于在偏航和俯仰轴上旋转。我还有一个nodejs服务器实现来将数据发送到机器(坐标列表(。为此,我在TCP_Client.js中实现了一个TCPClient类,如下所示:

var net = require('net');
/***********************************************************************************************************************
---------------------------------------------------Client TCP socket----------------------------------------------------
* *********************************************************************************************************************/
const port = 5303;
const host = 'localhost';
// creating a custom socket client and connecting it....
var client;
class TCPClient {
constructor(host, port) {
this.host = host;
this.port = port;
client = new net.Socket();
client.connect({
port: this.port,
host: this.host
});
this.onConnect();
}
onConnect() {
client.on('connect',function(){
console.log('Client: connection established with server');
console.log('---------client details -----------------');
var address = client.address();
var port = address.port;
var family = address.family;
var ipaddr = address.address;
console.log('Client is listening at port' + port);
console.log('Client ip :' + ipaddr);
console.log('Client is IP4/IP6 : ' + family);
});
client.on('drain', function(){
console.log("DRAIN");
});
this.setEncoding();
client.on('data', function(data) {
console.log("RECEIVED");
client.end();
});
client.on('end', function(){
console.log("END");
});
}
setEncoding() {
console.log("setEncoding");
client.setEncoding('utf8');
}
onData(data) {
console.log("DATA= ", data);
client.write(data);
}
end() {
client.end();
}
close() {
client.close();
}
}
//CREATE A TCP CLIENT OBJECT
exports.newTCPclient = function (host, port) {
console.log("CONSTRUCT TCP CLIENT");
var tc = new TCPClient(host, port);
return tc;
}

在服务器中.js我初始化一个全局TCPClient,如下所示:

const port = 5033;
const host = '192.168.100.20';
var tcp_client = tcpclient.newTCPclient(host, port);

我将合并到名为 coords 的文本变量中的坐标发送如下:

tcp_client.onData(coords);

每次我移动 arduino 电机时,我都会重复此操作,但过了一会儿,我遇到了此错误:

events.js:174
throw er; //Unhandled 'error' event
Error: read ECONNRESET
at TCP.onStreamRead(internal/stream_base_commons.js:111:27)
Emitted 'error' event at:
at emitErrorNT (internal/streams/destroy.js:91:8)
at emitErrorAndCloseNT (internal/streams/destroy.js:59:3)
at process. tckCallback (internal/process/next_tick.js:63:19)

我对人脉不是很流利。它与 TCP 客户端类有关吗?如果是这样,我该如何解决?

谢谢你的帮助。

>ECONNRESET表示TCP会话的另一端突然关闭了其连接结束。确保它在接收端正确关闭连接。 运行代码时使用--abort-on-uncaught-exception节点选项,它将显示详细的报告

最新更新