HarmonyOS 鸿蒙Next udp数据收发心跳包问题

HarmonyOS 鸿蒙Next udp数据收发心跳包问题

问题描述

需求：单片机每3秒发送一个“WF=？”
鸿蒙APP每收到一个“WF=？”，就返回一个“WF=OK”

调试结果

一个WF=？，会收到一些列的“WF=OK”
如下图所示:

鸿蒙代码

import { Equipt } from '../Model/Model';
import socket from '@ohos.net.socket';
import util from '@ohos.util';
import { Logger } from '../common/utils/Logger'
import hilog from '@ohos.hilog';
import wifimanager from '@ohos.wifiManager'
import { DialogUtils } from '../common/utils/toastUtlils';

const TAG = '[connSocket]'
export let udp = socket.constructUDPSocketInstance();
let ipNum = wifimanager.getIpInfo().ipAddress
let localIp = (ipNum >>> 24) + '.' + (ipNum >> 16 & 0xFF) + '.' + (ipNum >> 8 & 0xFF) + '.' + (ipNum & 0xFF);

export class udpSkt {
  public static msg: string;

  static async setupWIFI(ssid, pwd): Promise<string> {
    let padAdd: string;
    let deviceConfig: wifimanager.WifiDeviceConfig = {
      ssid: ssid,
      preSharedKey: pwd,
      isHiddenSsid: false,
      securityType: 3
    }
    try {
      wifimanager.addCandidateConfig(deviceConfig).then((value: number) => {
        Logger.debug(TAG, `add config sucess`)
        try {
          wifimanager.connectToCandidateConfig(value);
          Logger.debug(TAG, `connectToDevice success`)
          if (true === wifimanager.isConnected()) {
            Equipt.padIP.set(localIp)
            padAdd = localIp;
            return padAdd;
          }
        } catch (err) {
          Logger.debug(TAG, `connectToDevice fail err is ${JSON.stringify(err)}`)
        }
      })
    } catch (err) {
      Logger.debug(TAG, `addDeviceConfig fail err is ${JSON.stringify(err)}`)
    }
    return padAdd;
  }

  static async creatScoket(): Promise<void> {
    let selfAddress = {
      address: Equipt.padIP.get(),
      port: 10006,
      family: 1
    };

    udp.bind(selfAddress, err => {
      if (err) {
        Equipt.loginfo.addData(Equipt.loginfo.totalCount(), "\r\nbind fail");
        DialogUtils('bind fail' + Equipt.padIP.get(), "Warning", ["OK"]);
        return;
      }
      Equipt.loginfo.addData(Equipt.loginfo.totalCount(), "\r\nbind success");
      DialogUtils('bind sucess' + Equipt.padIP.get(), "Information", ["OK"]);
    })

    udp.on('message', value => {
      let str = "";
      str = this.bufToString(value.message);
      if (str.indexOf("WF=?") != -1) {
        this.sendMsg("WF=OK");
      }
      Equipt.loginfo.addData(Equipt.loginfo.totalCount(), "\r\nRX:" + str);
    });

  }

  static newlocalip(e) {
    Equipt.padIP.set(e.value);
  };
  static newremoteip(e) {
    Equipt.serverIP.set(e.value);
  };
  static newMessage(e) {
    this.msg = e.value;
  };

  static async sendMsg(msg: string) {
    let promise = udp.send({
      data: msg,
      address: {
        address: Equipt.serverIP.get(),
        port: 10006,
        family: 1
      }
    });
    promise.then(() => {
      Equipt.loginfo.addData(Equipt.loginfo.totalCount(), "\r\nTX:" + msg + "\r\nsend success");
      Logger.info('send success');
    }).catch(err => {
      Equipt.loginfo.addData(Equipt.loginfo.totalCount(), "\r\nsend fail");
      Logger.info('send fail');
    });
  }
  static bufToString(buf: ArrayBuffer) {
    let textDecoder = util.TextDecoder.create('utf-8')
    let str = textDecoder.decodeWithStream(new Uint8Array(buf))
    return str;
  }
}