Nodejs串口到tcp
是否可以使用nodejs建立主机以流式传输tcp上的串行连接-我希望将传感器数据从我计算机上的iot设备流式传输到连接到web服务器的计算机。原始数据的流式传输是很好的-远程计算机将处理它。我正在研究net和serialport npm包--但我不确定如何将这两个包结合起来……
谢谢!
回答 1
Stack Overflow用户
发布于 2021-07-30 13:58:53
准备工作
几乎每个供应商或设备都有自己的串行通信协议。通常，这些设备也使用带有报头、校验和的数据包，但每个设备使用不同的方式。
第一个问题实际上是，您希望将数据包报头和校验和信息转发到何种程度。您可能希望将传入的数据包转换为事件，或者已经转换为某种JSON消息。
假设您只想以原始格式转发数据，而不进行任何预处理，那么确定数据包的开始和结束位置仍然很有价值。当您通过TCP/IP刷新数据时，最好不要中途刷新这些串行数据包。
例如，您的设备可能是条形码扫描仪。大多数条形码扫描仪在每次扫描结束时都会发送CR (回车)。主动读取传入字节以查找CR字符将是有意义的。然后，每次注意到CR字符时，都会刷新字节的缓冲区。
但是，它并不总是CR。某些器件将其数据打包在STX (0x02)和ETX (0x03)字符之间。还有一些发送固定长度的包(例如，每条消息12个字节)。
为了清楚起见，你可以每100个字节发送一次数据，而消息实际上是12个字节。这会破坏一些数据包。有时，您的TCP接收器会收到不完整的数据包。说了这么多。您还可以在TCP接收端添加所有这些逻辑。当接收到不完整的数据包时，您可以假设下一个传入的数据包将包含丢失的字节，将其保存在缓冲区中。
考虑一下它是否值得
请注意，有一些商用的RS232转以太网设备，您可以从货架上购买并配置(约100欧元)，它们完全可以做您想要的事情。并且通常在这类设备的设置中，您可以选择配置转储清除字符。(例如，该CR)。艾条可能是你能得到的最好的了。亚当还制造了一些不错的设备。这些供应商制造这种设备已经有大约30年的历史了。
让你入门
但为了锻炼，我们开始吧。首先，你需要一些东西来与你的串行设备通信。我用的是这个：
npm install serialport@^9.1.0您几乎可以盲目地复制以下代码。但显然你需要设置你自己的RS232或USB端口设置。查看设备手册以确定波特率、数据位、停止位、奇偶校验以及可选的RTS/DTR
import SerialPort from "serialport";
export class RS232Port {
private port: SerialPort;
constructor(private listener: (buffer: Buffer) => any, private protocol) {
this.port = new SerialPort("/dev/ttyS0", {
baudRate: 38400,
dataBits: 8,
stopBits: 1,
parity: "none",
});
// check your RTS/DTR settings.
// this.port.on('open', () => {
// this.port.set({rts: true, dtr: false}, () => {
// });
//});
const parser = this.port.pipe(this.protocol);
parser.on('data', (data) => {
console.log(`received packet:[${toHexString(data)}]`);
if (this.listener) {
this.listener(data);
}
});
}
sendBytes(buffer: Buffer) {
console.log(`write packet:[${toHexString(buffer)}]`);
this.port.write(buffer);
}
}上面的代码连续地从串行设备读取数据，并使用“协议”来确定消息的开始/结束位置。它有一个"listener"，这是一个回调。它还可以使用其sendBytes函数发送字节。
这就把我们带到了协议，正如前面解释的那样，它应该在找到分隔符之前读取。
因为我不知道你的分隔符是什么。我会给你另一种选择，那就是静静地等待。它假设在一段时间内没有传入数据时，消息将是完整的。
export class TimeoutProtocol extends Transform {
maxBufferSize: number;
currentPacket: [];
interval: number;
intervalID: any;
constructor(options: { interval: number, maxBufferSize: number }) {
super()
const _options = { maxBufferSize: 65536, ...options }
if (!_options.interval) {
throw new TypeError('"interval" is required')
}
if (typeof _options.interval !== 'number' || Number.isNaN(_options.interval)) {
throw new TypeError('"interval" is not a number')
}
if (_options.interval < 1) {
throw new TypeError('"interval" is not greater than 0')
}
if (typeof _options.maxBufferSize !== 'number' || Number.isNaN(_options.maxBufferSize)) {
throw new TypeError('"maxBufferSize" is not a number')
}
if (_options.maxBufferSize < 1) {
throw new TypeError('"maxBufferSize" is not greater than 0')
}
this.maxBufferSize = _options.maxBufferSize
this.currentPacket = []
this.interval = _options.interval
this.intervalID = -1
}
_transform(chunk: [], encoding, cb) {
clearTimeout(this.intervalID)
for (let offset = 0; offset < chunk.length; offset++) {
this.currentPacket.push(chunk[offset])
if (this.currentPacket.length >= this.maxBufferSize) {
this.emitPacket()
}
}
this.intervalID = setTimeout(this.emitPacket.bind(this), this.interval)
cb()
}
emitPacket() {
clearTimeout(this.intervalID)
if (this.currentPacket.length > 0) {
this.push(Buffer.from(this.currentPacket))
}
this.currentPacket = []
}
_flush(cb) {
this.emitPacket()
cb()
}
}最后一块拼图是TCP/IP连接。在这里，您必须确定哪一端是客户端，哪一端是服务器。我暂时跳过了这个部分，因为有大量的教程和代码示例向您展示如何设置TCP/IP客户机-服务器连接。
在上面的一些代码中，我使用函数toHexString(Buffer)将缓冲区的内容转换为十六进制格式，这样可以更容易地将其打印到控制台日志中。
export function toHexString(byteArray: Buffer) {
let s = '0x';
byteArray.forEach(function (byte) {
s += ('0' + (byte & 0xFF).toString(16)).slice(-2);
});
return s;
}https://stackoverflow.com/questions/64545042
复制相似问题
腾讯云开发者
