关于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满了会做丢包处理，所以代码层面上这里本身不会引起阻塞从而有性能问题