node.js - NodeJS TCP socket 经常监听 END 事件

问题描述

我们有一个 Nodejs TCP 连接应用程序。它的作用是接受来自物联网设备的数据（通过 SIM 发送的数据）。该应用程序驻留在 Ubuntu 18 机器中。软件和物联网设备在同一个区域可以完美运行。例如：

服务器在美国，物联网设备在美国

或者

服务器在澳大利亚，物联网设备在澳大利亚

这种情况非常有效。但是，如果服务器或 IOT 设备位于不同的区域，则应用程序通常会监听 Socket 结束事件。例如：

服务器在美国 IOT 设备在西班牙

或者

服务器在美国 IOT 设备在俄罗斯

在上面的例子中，应用程序经常监听套接字END事件，因此设备总是以毫秒的差异重新连接。

然后我在 Google 上冲浪，许多人建议微调 Linux 默认 TCP 值。https://www.cspsprotocol.com/tcp-keep-alive/。然后我更改了默认值，显然它仍然没有任何效果。当前值为

net.ipv4.tcp_keepalive_intvl = 10
net.ipv4.tcp_keepalive_probes = 50
net.ipv4.tcp_keepalive_time = 7200

作为第二步，我在我的 Nodejs 应用程序中添加了以下行，但仍然没有运气。

socket.setKeepAlive(true, 300000);

这是我的 TCP 连接代码：

const Network = require("net");
const Events = require("events");
const { Signale } = require("signale");


const { PORT = 5252, HOST = "localhost" } = process.env;

const emitter = new Events.EventEmitter();

const logger = new Signale({
    scope: "server"
});

const server = Network.createServer(onClientConnected);

server.on("error", error => {
    if (error.code === "EADDRINUSE") {
        logger.warn(`Port is already in use, retrying ..`);
        setTimeout(() => {
            server.close();
            server.listen(PORT, () => {
                logger.success("Retrying listening to port", PORT, "on host", HOST);
            });
        }, 1000);
    }
});

let deviceConnectTimes = {};

function onClientConnected(socket) {
    const clientName = `${socket.remoteAddress}`;
    const networkLogger = logger.scope(clientName);

    socket.deviceMetadata = null;

    const TIMEOUT_IN_SECONDS = 30;
    socket.setTimeout(TIMEOUT_IN_SECONDS * 1000);

    socket.on("timeout", () => {
        networkLogger.warn(`The socket for ${clientName} has timed out.`);
        socket.end();
    });

    socket.on("error", error => {
        networkLogger.error(error);
    });

    socket.on("end", () => {
        networkLogger.warn(`The socket for ${clientName} has closed or timed out.`);
        console.log("socket end", socket.deviceMetadata);
    });

    socket.on("data", async buffer => {
        networkLogger.debug(buffer.toString("hex"));

        **....More code here**

    });
    socket.setKeepAlive(true, 300000); // New code added to solve the disconnetion issue
}

module.exports.events = emitter;

module.exports.listen = () => {
    server.listen(PORT, () => {
        logger.success("Listening on port", PORT, "on host", HOST);
    });
};

任何帮助都将不胜感激，因为如果设备或服务器位于不同的国家，为什么它会延迟延迟。

标签： node.jssocketsubuntutcpkeep-alive

node.js - NodeJS TCP socket 经常监听 END 事件

问题描述

解决方案

推荐阅读