答案是使用带缓冲channel可直接实现FIFO消息队列,生产者向channel发送消息,消费者从中接收,利用其并发安全和阻塞特性实现解耦,如make(chan string, 100)创建容量为100的字符串队列。

用Golang的channel实现消息队列,核心是利用其并发安全和阻塞特性,让生产者和消费者解耦。一个简单的队列可以用带缓冲的channel直接充当,而更复杂的场景则需要封装结构体来管理任务、控制并发和处理生命周期。
使用缓冲channel构建基础队列
最直接的方式是创建一个有容量的channel,它天然就是一个FIFO(先进先出)的消息队列。
- 定义一个存放特定类型数据的channel,比如messages := make(chan string, 100),这里的100是缓冲区大小,决定了队列能暂存多少条消息而不阻塞生产者。
- 生产者goroutine通过messages 向队列发送消息。只要缓冲区没满,操作就会立即返回。
- 消费者goroutine通过msg := 从队列接收消息。当队列为空时,消费者会自动阻塞等待,无需手动加锁或轮询。
- 当所有生产者完成工作后,调用close(messages)关闭channel。这会让消费者的for range循环自然退出,优雅地结束程序。
封装结构体实现高级队列
对于需要更多控制的场景,比如管理多个消费者或支持停止信号,可以将channel包装在一个结构体中。
- 创建一个MessageQueue结构体,内部包含一个数据channel和一个用于通知停止的布尔标志或另一个stop channel。
- 提供Add(message)方法供外部提交任务,该方法负责将消息写入内部channel。
- 提供Start(workerCount int)方法,根据指定的数量启动多个消费者goroutine。每个goroutine在一个for循环里读取channel,执行业务逻辑,直到收到关闭信号。
- 提供Stop()方法,用于安全地关闭数据channel并等待所有worker退出,确保正在处理的消息不被中断。
基本上就这些,从简单缓冲到封装管理,能覆盖大部分需求。
立即学习“go语言免费学习笔记(深入)”;










