请使用golang beego 解释并优化下面代码func HandelModelDataframes int32 coefl float32 token string commonInfo string seq int var finish bool = true var sig chan int var ok bool driverMutexLock sig ok = token2d
这段代码是一个处理模型数据的函数,使用了beego框架和golang语言。代码的功能是向远程服务器发送数据,并启动和停止表情驱动。
优化建议:
- 可以将一些重复的代码抽取成函数,例如发送HTTP请求的代码可以封装成一个函数,减少重复代码的出现。
- 可以在发送数据时使用缓冲区,减少频繁的网络通信。
- 可以使用goroutine并发发送数据,提高发送数据的速度。
- 可以使用连接池管理UDP连接,避免频繁地创建和关闭连接。
- 可以使用sync.WaitGroup来等待所有goroutine完成后再返回。
下面是对代码的优化示例:
var (
driverMutex sync.Mutex
token2driver = make(map[string]chan<- int)
)
func HandelModelData(frames [][]int32, coefl float32, token string, commonInfo string, seq int) {
var finish bool = true
var sig chan<- int
{
driverMutex.Lock()
defer driverMutex.Unlock()
sig, ok := token2driver[token]
if !ok {
sig = make(chan int, 1)
token2driver[token] = sig
} else {
logs.Info("%s, emmit sig flag, to quit last request", commonInfo)
sig <- 0 // 退出前面的驱动
}
}
defer func() {
if finish {
driverMutex.Lock()
defer driverMutex.Unlock()
_, ok := token2driver[token]
if ok {
close(sig)
delete(token2driver, token)
}
logs.Info("%s, finish", commonInfo)
}
}()
api := appconf.StreamInfoApi + "?token=" + token
status, stream := util.OnGetHttpTimeout(api, 10)
if status != 200 {
logs.Error("%s, api = %v, status = %d, result = %s", commonInfo, api, status, string(stream))
return
}
var streamInfoRes protocol.StreamInfoRes
err := json.Unmarshal(stream, &streamInfoRes)
if err != nil {
logs.Error("%s, err = %v", commonInfo, err)
return
}
if streamInfoRes.Code != 200 {
logs.Error("%s HandelModelData, err = %v", commonInfo, streamInfoRes)
return
}
sip := streamInfoRes.Data.Ip
sport := 11111
if sip == "" {
logs.Error("%s, invalid ip", commonInfo)
return
}
socket, err := getUDPSocket(sip, sport)
if err != nil {
logs.Error("%s, ip = %s, port = %d, err = %v", commonInfo, sip, sport, err)
return
}
defer socket.Close()
err = StartBSDriver(token, seq)
if err != nil {
logs.Error("%s, StartBSDriver failed, err = %v", commonInfo, err)
return
}
logs.Info("%s, sip = %s, sport = %d", commonInfo, sip, sport)
startReq := make(map[string]interface{})
startReq["userIp"] = sip
startData, _ := json.Marshal(&startReq)
var nsent = 0
for nsent < len(startData) {
n, err := socket.Write(startData[nsent:])
if err != nil {
logs.Error("%s, ip = %s, port = %d, err = %v", commonInfo, sip, sport, err)
return
}
nsent += n
}
logs.Info("%s, ip = %s, port = %d, OnAudioDriver", commonInfo, sip, sport)
for i := 0; i < len(frames); i++ {
frame := make([]float32, 61)
for j := 0; j < 51; j++ {
frame[j] = float32(frames[i][j]) / coefl
}
select {
case <-sig:
logs.Info("%s, recv quit sig, quit now", commonInfo)
finish = false
break
default:
data := MakeBSFrame(frame)
err := sendData(socket, data)
if err != nil {
logs.Error("%s, sendData failed, err = %v", commonInfo, err)
return
}
time.Sleep(15 * time.Millisecond)
}
}
err = StopBSDriver(token, seq)
if err != nil {
logs.Error("%s, StopBSDriver failed, err = %v", commonInfo, err)
return
}
return
}
func getUDPSocket(sip string, sport int) (*net.UDPConn, error) {
addr := &net.UDPAddr{
IP: net.ParseIP(sip),
Port: sport,
}
return net.DialUDP("udp", nil, addr)
}
func sendData(socket *net.UDPConn, data []byte) error {
var nsent = 0
for nsent < len(data) {
n, err := socket.Write(data[nsent:])
if err != nil {
return err
}
nsent += n
}
return nil
}
这里对代码进行了一些优化,抽取了发送数据和获取UDP连接的代码,并进行了错误处理。另外,使用了defer语句来释放资源,避免忘记关闭连接。优化后的代码更加简洁和可读性更好
原文地址: http://www.cveoy.top/t/topic/h9ZH 著作权归作者所有。请勿转载和采集!