使用命令模式结合请求队列可实现Go语言中的异步任务处理。通过定义Command接口和具体命令如SendEmailCommand，将请求封装为对象；利用CommandQueue基于channel实现命令的排队与多worker并发执行；客户端创建命令并添加到队列，调用Start启动处理，最后Close等待完成。该模式支持解耦、异步执行和系统扩展，适用于邮件发送等后台任务场景。
在Go语言开发中，处理异步任务或延迟执行的请求时，使用命令模式结合请求队列是一种清晰且可扩展的解决方案。命令模式将请求封装为独立对象，使得你可以参数化对象、支持撤销操作、记录日志，以及最重要的一点——实现请求的排队与异步执行。
命令模式的基本结构
命令模式包含几个核心角色：
- Command（命令）：定义执行操作的接口，通常包含一个 Execute 方法。
- ConcreteCommand（具体命令）：实现 Command 接口，持有对接收者（Receiver）的引用，并在 Execute 中调用接收者的具体方法。
- Receiver（接收者）：真正执行操作的对象。
- Invoker（调用者）：持有命令对象，负责触发命令的执行，比如队列处理器。
- Client（客户端）：创建命令对象并绑定接收者。
在Go中，我们可以通过接口和结构体来实现这一模式。
定义命令接口与具体命令
首先定义一个通用的命令接口：
立即学习“go语言免费学习笔记（深入）”；
type Command interface {
Execute()
}接着实现一个具体命令，例如发送邮件的请求：
type EmailService struct{}
func (e *EmailService) SendEmail(to, subject, body string) {
fmt.Printf("发送邮件到 %s，主题：%s\n", to, subject)
}
type SendEmailCommand struct {
service *EmailService
To string
Subject string
Body string
}
func (c *SendEmailCommand) Execute() {
c.service.SendEmail(c.To, c.Subject, c.Body)
}
这里，SendEmailCommand 封装了发送邮件所需的所有参数和行为，实现了 Execute 方法。
构建请求队列与执行器
接下来创建一个简单的队列系统，用于存储待处理的命令：
type CommandQueue struct {
commands chan Command
wg sync.WaitGroup
}
func NewCommandQueue(size int) *CommandQueue {
return &CommandQueue{
commands: make(chan Command, size),
}
}
func (q *CommandQueue) AddCommand(cmd Command) {
q.commands <- cmd
}
func (q *CommandQueue) Start(workers int) {
for i := 0; i < workers; i++ {
q.wg.Add(1)
go func() {
defer q.wg.Done()
for cmd := range q.commands {
cmd.Execute()
}
}()
}
}
func (q *CommandQueue) Close() {
close(q.commands)
q.wg.Wait()
}
这个队列使用带缓冲的 channel 存储命令，支持多 worker 并发处理。Start 方法启动多个协程从队列中取出命令并执行。
实际使用示例
现在将所有部分组合起来：
func main() {
queue := NewCommandQueue(10)
emailService := &EmailService{}
// 创建多个命令
cmd1 := &SendEmailCommand{
service: emailService,
To: "user1@example.com",
Subject: "欢迎注册",
Body: "感谢您加入我们！",
}
cmd2 := &SendEmailCommand{
service: emailService,
To: "user2@example.com",
Subject: "订单确认",
Body: "您的订单已发货。",
}
// 添加到队列
queue.AddCommand(cmd1)
queue.AddCommand(cmd2)
// 启动处理协程
queue.Start(2)
// 模拟其他任务后关闭队列
time.Sleep(time.Second)
queue.Close()
fmt.Println("所有命令已处理完成")}
运行结果会看到两条“发送邮件”的输出，说明命令被成功排队并异步执行。
基本上就这些。通过命令模式，你可以轻松扩展更多类型的请求（如短信通知、日志记录等），只需实现新的 ConcreteCommand 即可。队列机制让系统具备解耦、异步、流量削峰的能力，非常适合后台任务处理场景。
