答案：Go通过组合channel和goroutine实现广播。1. 使用带缓冲channel和中心广播器，遍历订阅者channel发送消息；2. 利用close(channel)通知所有协程退出；3. 可借助第三方库实现复杂场景的发布-订阅。需避免阻塞、及时清理订阅者。
在Golang中，可以通过channel实现广播机制，让一个发送者的消息被多个接收者同时收到。由于Go的channel默认是点对点的（一发一收），要实现广播，需要借助额外的结构和模式。以下是几种常见且实用的方法。
使用带缓冲的channel和goroutine复制消息
最直接的方式是：由一个中心化的广播器将消息发送给多个订阅者的channel。
每个接收者拥有自己的channel，广播器通过遍历所有订阅者的channel，把消息逐一发送。
注意：为避免阻塞，通常使用带缓冲的channel或非阻塞发送。示例代码：
立即学习“go语言免费学习笔记（深入）”；
type Broadcaster struct {
subscribers []chan string
addCh chan chan string
removeCh chan chan string
messageCh chan string
}
func NewBroadcaster() *Broadcaster {
b := &Broadcaster{
subscribers: make([]chan string, 0),
addCh: make(chan chan string),
removeCh: make(chan chan string),
messageCh: make(chan string),
}
go b.run()
return b
}
func (b *Broadcaster) run() {
for {
select {
case msg := <-b.messageCh:
// 广播给所有订阅者（使用非阻塞发送避免卡住）
for _, ch := range b.subscribers {
select {
case ch <- msg:
default: // 如果某个channel满或无接收者，跳过
}
}
case newSub := <-b.addCh:
b.subscribers = append(b.subscribers, newSub)
case removedSub := <-b.removeCh:
for i, sub := range b.subscribers {
if sub == removedSub {
b.subscribers = append(b.subscribers[:i], b.subscribers[i+1:]...)
close(sub)
break
}
}
}
}
}
func (b *Broadcaster) Subscribe() chan string {
ch := make(chan string, 10) // 带缓冲，防止快速消息丢失
b.addCh <- ch
return ch
}
func (b *Broadcaster) Unsubscribe(ch chan string) {
b.removeCh <- ch
}
func (b *Broadcaster) Broadcast(msg string) {
b.messageCh <- msg
}
使用方式：
b := NewBroadcaster()// 订阅者1 ch1 := b.Subscribe() go func() { for msg := range ch1 { fmt.Println("Subscriber 1 received:", msg) } }()
// 订阅者2 ch2 := b.Subscribe() go func() { for msg := range ch2 { fmt.Println("Subscriber 2 received:", msg) } }()
// 发送广播 b.Broadcast("Hello, everyone!")
使用close(channel)触发广播退出信号
有时不需要传递数据，而是通知所有协程退出。这时可以利用close(channel)特性：已关闭的channel读操作立即返回零值。
本文档主要讲述的是android rtsp流媒体播放介绍；实时流协议（RTSP）是应用级协议，控制实时数据的发送。RTSP提供了一个可扩展框架，使实时数据，如音频与视频，的受控、点播成为可能。数据源包括现场数据与存储在剪辑中数据。该协议目的在于控制多个数据发送连接，为选择发送通道，如UDP、组播UDP与TCP，提供途径，并为选择基于RTP上发送机制提供方法。希望本文档会给有需要的朋友带来帮助；感兴趣的朋友可以过来看看
这种模式常用于上下文取消或服务关闭通知。
示例：
var done = make(chan struct{})
// 启动多个监听goroutine
for i := 0; i < 5; i++ {
go func(id int) {
<-done
fmt.Printf("Worker %d stopped\n", id)
}(i)
}
// 触发广播：关闭channel，所有等待的goroutine被唤醒
close(done)
使用第三方库（如github.com/pojol/braid）
对于复杂场景，可使用封装好的事件总线或发布-订阅库，内部基于channel实现广播，提供更高级的API，比如主题过滤、异步投递等。
这类库本质仍是上述模式的封装，适合大型项目解耦模块通信。
关键注意事项
- 避免阻塞广播器：使用非阻塞发送或带缓冲channel，否则一个慢消费者会拖慢整体。
- 及时清理失效subscriber：长时间运行系统需支持退订，防止内存泄漏。
- 选择同步或异步语义：同步广播需等待所有接收者处理完；异步更常见，用缓冲channel实现。
- 不要滥用close：仅当明确不再发送时才close channel，向已关闭channel发数据会panic。
基本上就这些。Go没有内置广播channel，但通过组合channel和select，能灵活实现所需行为。关键是根据性能要求和生命周期管理设计合适的结构。
