harmony_car/subject-two
harmony_car/subject-two
4
0
Fork 3
Code Issues Pull Requests Packages Projects 1 Releases 45 Wiki Activity

tcp重连

Browse Source
This commit is contained in:
lvyuankang 2024-07-19 13:27:51 +08:00
parent 1be1d806f7
commit 60a55f585d
2 changed files with 28 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
entry/src/main/ets/common/utils/GlobalTcp.ts
View File

@ -14,7 +14,16 @@ export async function getTCP() {
await globalThis.TcpClient.rebindTcp(result[0].tcplocalIp, result[0].tcplocalIpPort,result[0].tcpOppositeIp,result[0].tcpOppositePort) await globalThis.TcpClient.rebindTcp(result[0].tcplocalIp, result[0].tcplocalIpPort,result[0].tcpOppositeIp,result[0].tcpOppositePort)
await globalThis.TcpClient.connectTcp() await globalThis.TcpClient.connectTcp()
await globalThis.TcpClient.sendMsg('1002')//1002 await globalThis.TcpClient.sendMsg('1002')//1002
globalThis.TcpClient.onError() globalThis.TcpClient.onError((val)=>{
setTimeout(()=>{
globalThis.TcpClient.sendMsg('1002')//1002
if(val){
// const msg=val.substring(5,val.length-1)
console.log('socketTag[PLC.UdpClient] status:',globalThis.udpClient.getStatus())
globalThis.udpClient?.sendMsg(val)
}
},1000)
})
await globalThis.TcpClient.onMessage((val)=>{ await globalThis.TcpClient.onMessage((val)=>{
setTimeout(()=>{ setTimeout(()=>{
globalThis.TcpClient.sendMsg('1002')//1002 globalThis.TcpClient.sendMsg('1002')//1002
@ -35,14 +44,20 @@ export async function getTCP() {
await globalThis.TcpClient.bindTcp() await globalThis.TcpClient.bindTcp()
await globalThis.TcpClient.connectTcp() await globalThis.TcpClient.connectTcp()
await globalThis.TcpClient.sendMsg('1002')//1002 await globalThis.TcpClient.sendMsg('1002')//1002
globalThis.TcpClient.onError() globalThis.TcpClient.onError((val)=>{
hilog.info(0x0000, 'testTag', "valvalval2" + JSON.stringify(val));
setTimeout(()=>{
globalThis.TcpClient.sendMsg('1002')//1002
if(val&& globalThis.udpClient?.sendMsg){
globalThis.udpClient?.sendMsg(val)
}
},1000)
})
await globalThis.TcpClient.onMessage((val)=>{ await globalThis.TcpClient.onMessage((val)=>{
hilog.info(0x0000, 'testTag', "valvalval2" + JSON.stringify(val)); hilog.info(0x0000, 'testTag', "valvalval2" + JSON.stringify(val));
setTimeout(()=>{ setTimeout(()=>{
globalThis.TcpClient.sendMsg('1002')//1002 globalThis.TcpClient.sendMsg('1002')//1002
if(val&& globalThis.udpClient?.sendMsg){ if(val&& globalThis.udpClient?.sendMsg){
// const msg=val.substring(5,val.length-1)
globalThis.udpClient?.sendMsg(val) globalThis.udpClient?.sendMsg(val)
} }
},1000) },1000)

13
entry/src/main/ets/common/utils/TcpClient.ts
View File

@ -24,7 +24,11 @@ export default class TcpClient {
onError(callback?){ onError(callback?){
this.tcp.on('error', err => { this.tcp.on('error', err => {
console.log(TAG,'tcpOnerror', JSON.stringify(err)) console.log(TAG,'tcpOnerror', JSON.stringify(err))
callback&&callback() setTimeout(async ()=>{
await this.bindTcp()
await this.connectTcp()
this.onMessage(callback)
},2000)
// this.closeUdp(()=>{ // this.closeUdp(()=>{
// this.bindUdp() // this.bindUdp()
// }) // })
@ -107,12 +111,13 @@ export default class TcpClient {
resolve(true) resolve(true)
}).catch(err => { }).catch(err => {
globalThis.getCloseTcp=true globalThis.getCloseTcp=true
setTimeout(()=>{
this.connectTcp()
},2000)
console.log('testTagconnect,error') console.log('testTagconnect,error')
resolve(false)
}); });
}) })
} }
sendMsg(msg: string) { sendMsg(msg: string) {