关于protocol/rmtp/stream.go下的TransStart()函数的问题

[zhaojiajun193]

s.ws.Range(func(key, val interface{}) bool {
v := val.(*PackWriterCloser)
fmt.Printf(key.(string) + "\n")
if !v.init {
if err = s.cache.Send(v.w); err != nil {
log.Debugf("[%s] send cache packet error: %v, remove", v.w.Info(), err)
s.ws.Delete(key)
return true
}
fmt.Printf("key:%v, value:%v", key, val)
v.init = true
} else {
newPacket := p
if err = v.w.Write(&newPacket); err != nil {
log.Debugf("[%s] write packet error: %v, remove", v.w.Info(), err)
s.ws.Delete(key)
}
}
return true
})
上述代码遍历了某个推流stream下的ws（sync.map），循环向每个想要拉流的tcp连接写入av.Packet，如此一来在连接数很多时是否会导致效率极低，甚至影响推流写入cache的速度，在多人直播间中应该如何优化呢，也可能是本人理解错误了，希望大佬帮忙回答下，感谢

[Justyell]

v.w.Write的逻辑本质上是写入到一个chan里面，如果chan满了会做丢包处理，所以代码层面上这里本身不会引起阻塞从而有性能问题