答案：Golang通过接口定义命令，使用channel实现队列，goroutine并发执行，解耦任务提交与处理。1. 定义Command接口及PrintCommand、SaveCommand等实现；2. 创建CommandQueue结构体，用buffered channel存储命令，workers数量控制并发执行；3. Start方法启动多个goroutine从channel读取并执行命令；4. AddCommand提交任务，Stop关闭队列；5. 主函数示例展示提交打印与保存命令，输出有序执行结果；6. 建议扩展：支持context、错误处理、优先级、持久化和动态扩缩容。该模式利用Golang并发特性，实现高效、灵活的命令队列系统。
在高并发或异步处理场景中，命令队列模式能有效解耦任务的提交与执行。Golang凭借其轻量级goroutine和强大的channel机制，非常适合实现这种模式。下面介绍如何用Golang构建一个简单但实用的命令队列系统。
定义命令接口与具体命令
命令队列的核心是“命令”本身。我们可以定义一个统一的接口，让所有具体任务实现它。
比如：
type Command interface {
Execute()
}
接着实现几个具体的命令：
立即学习“go语言免费学习笔记（深入）”；
type PrintCommand struct {
Msg string
}
func (p *PrintCommand) Execute() {
fmt.Println("打印消息:", p.Msg)
}
type SaveCommand struct {
Data string
}
func (s *SaveCommand) Execute() {
fmt.Println("保存数据:", s.Data)
}
创建命令队列和处理器
使用channel作为任务队列，启动一个或多个goroutine来消费这些命令。
基本结构如下：
type CommandQueue struct {
commands chan Command
workers int
}
func NewCommandQueue(workers int) *CommandQueue {
return &CommandQueue{
commands: make(chan Command, 100), // 缓冲队列
workers: workers,
}
}
func (cq *CommandQueue) Start() {
for i := 0; i < cq.workers; i++ {
go func() {
for cmd := range cq.commands {
cmd.Execute()
}
}()
}
}
func (cq *CommandQueue) AddCommand(cmd Command) {
cq.commands <- cmd
}
func (cq *CommandQueue) Stop() {
close(cq.commands)
}
实际使用示例
把上面的组件组合起来，可以这样使用：
func main() {
queue := NewCommandQueue(2) // 启动两个工作协程
queue.Start()
// 提交一些命令
queue.AddCommand(&PrintCommand{Msg: "Hello"})
queue.AddCommand(&SaveCommand{Data: "user123"})
queue.AddCommand(&PrintCommand{Msg: "World"})
// 简单等待
time.Sleep(time.Second)
queue.Stop()}
输出会是：
打印消息: Hello 保存数据: user123 打印消息: World
增强功能建议
生产环境中可考虑以下扩展：
- 带上下文的命令：让Execute接收context.Context，支持超时和取消
- 错误处理：返回error，记录失败任务
- 优先级队列：使用多个channel或优先级调度器
- 持久化：结合数据库或消息队列（如RabbitMQ）防止崩溃丢失任务
- 动态扩缩容：根据队列长度调整worker数量
基本上就这些。Golang的channel天然适合做队列，配合interface轻松实现多态命令处理，整个模式简洁又灵活。
