HarmonyOS 鸿蒙Next 关于udp广播demo

HarmonyOS 鸿蒙Next 关于udp广播demo

//本地IP的数值形式
// let ipNum = wifiManager.getIpInfo().ipAddress;
//本地IP的字符串形式
// let localIp:string = (ipNum >>> 24) + '.' + (ipNum >> 16 & 0xFF) + '.' + (ipNum >> 8 & 0xFF) + '.' + (ipNum & 0xFF);
// console.debug(`localIP: ${ipNum}, ${localIp}`);

await udp.bind({ address: '0.0.0.0', port: 6811 }).then(() => { 
  console.log('bind success');
}).catch((err: Object) => {
  console.error('bind fail: ' + JSON.stringify(err));
});


let udpextraoptions: socket.UDPExtraOptions = {
  receiveBufferSize: 100000,
  sendBufferSize: 100000,
  reuseAddress: false,
  socketTimeout: 6000,
  broadcast: true //一定要设置，不然不允许发送广播
}
await udp.setExtraOptions(udpextraoptions).then(() => {
  console.log('setExtraOptions success');
}).catch((err: BusinessError) => {
  console.log('setExtraOptions fail');
});

udp.on('message', (value: socket.SocketMessageInfo) => {
  console.log('数据长度: ' + value.message.byteLength);
  //自己按照自己的数据过滤处理数据
});

//广播地址和端口
let targetAddr: socket.NetAddress = {
  address: '255.255.255.255',
  port: 8888, //端口填自己设备的
}
//数据发送自己想要发送的数据 arrayBuffer或者string
let date = [0x44,0x43, 0x42, 0x41];
//转换二进制发送直接Uint8Array就行
let arrayBuffer = new Uint8Array(date).buffer;

let sendOptions: socket.UDPSendOptions = {
  data: arrayBuffer,
  address: targetAddr
}


await udp.send(sendOptions).then(() => {
  console.log('send success:', Number(sendOptions.data as ArrayBuffer));
}).catch((err: BusinessError) => {
  console.log('send fail' + JSON.stringify(err));
});
 
}