gx

chenyc

5 天以前 747a86bb94006aaca721cfc0c0ce7061643a9ea6

 tcp-service.js

@@ -47,7 +47,7 @@

      map.set(normalizeIp(device.ip), {
        ...device,
        name: device.name || device['备注'] || device.deviceId,
        name: device.name || device.备注 || device['澶囨敞'] || device.deviceId,
      });
    }

@@ -66,7 +66,7 @@
    this.server.maxConnections = this.tcpConfig.maxConnections || 100;

    this.server.on('error', (error) => {
      this.logger.error(`[TCP] 服务错误: ${error.message}`);
      this.logger.error(`[TCP] 服务异常: ${error.message}`);
    });

    await new Promise((resolve, reject) => {
@@ -79,7 +79,7 @@
      });
    });

    this.logger.info(`[TCP] 已监听 ${this.tcpConfig.host}:${this.tcpConfig.port} devices=${this.deviceMap.size} maxConnections=${this.server.maxConnections}`);
    this.logger.info(`[TCP] 已开始监听 ${this.tcpConfig.host}:${this.tcpConfig.port} devices=${this.deviceMap.size} maxConnections=${this.server.maxConnections}`);
  }

  handleConnection(socket) {
@@ -143,7 +143,7 @@
    const results = session.decoder.push(chunk);

    if (results.length === 0) {
      this.logger.warn(`[TCP] 当前数据片段未形成完整报文 deviceId=${session.device.deviceId} bytes=${chunk.length}`);
      this.logger.warn(`[TCP] 当前数据片段尚未组成完整报文 deviceId=${session.device.deviceId} bytes=${chunk.length}`);
    }

    for (const result of results) {