From cee0dec313bdcb56bfd14a21b84890d36fb65a0e Mon Sep 17 00:00:00 2001 From: yangduo Date: Thu, 12 Sep 2024 16:54:23 +0800 Subject: [PATCH] 1 --- server/mqproxy/listener/udplistener.go | 35 +------------------------- 1 file changed, 1 insertion(+), 34 deletions(-) diff --git a/server/mqproxy/listener/udplistener.go b/server/mqproxy/listener/udplistener.go index f9394289..43191f81 100644 --- a/server/mqproxy/listener/udplistener.go +++ b/server/mqproxy/listener/udplistener.go @@ -14,7 +14,6 @@ import ( ) type UDPListener struct { - // ss.MsgHandlerImpl udpconn *net.UDPConn ch chan bool } @@ -28,8 +27,7 @@ func (this *UDPListener) Init() { panic(err) } else { this.udpconn = conn - // go this.serverRead() - go this.serverRead2() + go this.serverRead() } } @@ -41,38 +39,7 @@ func (this *UDPListener) UnInit() { close(this.ch) } -var UDPPACKHEAD = 2 - func (this *UDPListener) serverRead() { - for { - this.ch <- true - go func(conn *net.UDPConn, ch chan bool) { - buf := make([]byte, jccommon.MAX_PACKET_LEN+UDPPACKHEAD) - bufLen, _, err := this.udpconn.ReadFrom(buf) - if err == nil && bufLen > UDPPACKHEAD { - dataLen := q5.MkUInt16(buf[0], buf[1]) - if bufLen >= int(UDPPACKHEAD)+int(dataLen) { - obj := struct { - Topic string `json:"topic"` - Expire int32 `json:"expire"` - Msg string `json:"msg"` - }{} - data := buf[UDPPACKHEAD : UDPPACKHEAD+int(dataLen)] - if json.Unmarshal(data, &obj) == nil { - expire := obj.Expire - if expire > 86400*7 { - expire = 86400 * 7 - } - service.MqManager.PublishTopic(obj.Topic, obj.Msg, expire) - } - } - } - <-ch - }(this.udpconn, this.ch) - } -} - -func (this *UDPListener) serverRead2() { for { buf := make([]byte, jccommon.MAX_PACKET_LEN) bufLen, peer, err := this.udpconn.ReadFromUDP(buf)