Golang如何使用命令模式实现请求队列_Golang命令模式请求队列实践详解-Golang-PHP中文网

Golang如何使用命令模式实现请求队列_Golang命令模式请求队列实践详解

P粉602998670

发布： 2025-11-05 22:56:02

原创

490人浏览过

使用命令模式结合请求队列可实现Go语言中的异步任务处理。通过定义Command接口和具体命令如SendEmailCommand，将请求封装为对象；利用CommandQueue基于channel实现命令的排队与多worker并发执行；客户端创建命令并添加到队列，调用Start启动处理，最后Close等待完成。该模式支持解耦、异步执行和系统扩展，适用于邮件发送等后台任务场景。

golang如何使用命令模式实现请求队列_golang命令模式请求队列实践详解

在Go语言开发中，处理异步任务或延迟执行的请求时，使用命令模式结合请求队列是一种清晰且可扩展的解决方案。命令模式将请求封装为独立对象，使得你可以参数化对象、支持撤销操作、记录日志，以及最重要的一点——实现请求的排队与异步执行。

命令模式的基本结构

命令模式包含几个核心角色：

Command（命令）：定义执行操作的接口，通常包含一个 Execute 方法。
ConcreteCommand（具体命令）：实现 Command 接口，持有对接收者（Receiver）的引用，并在 Execute 中调用接收者的具体方法。
Receiver（接收者）：真正执行操作的对象。
Invoker（调用者）：持有命令对象，负责触发命令的执行，比如队列处理器。
Client（客户端）：创建命令对象并绑定接收者。

在Go中，我们可以通过接口和结构体来实现这一模式。

定义命令接口与具体命令

首先定义一个通用的命令接口：

立即学习“go语言免费学习笔记（深入）”；

type Command interface {
    Execute()
}

登录后复制

接着实现一个具体命令，例如发送邮件的请求：

type EmailService struct{}
<p>func (e *EmailService) SendEmail(to, subject, body string) {
fmt.Printf("发送邮件到 %s，主题：%s\n", to, subject)
}</p><p>type SendEmailCommand struct {
service *EmailService
To      string
Subject string
Body    string
}</p><p>func (c *SendEmailCommand) Execute() {
c.service.SendEmail(c.To, c.Subject, c.Body)
}

登录后复制

这里，SendEmailCommand 封装了发送邮件所需的所有参数和行为，实现了 Execute 方法。

序列猴子开放平台

具有长序列、多模态、单模型、大数据等特点的超大规模语言模型

查看详情

构建请求队列与执行器

接下来创建一个简单的队列系统，用于存储待处理的命令：

type CommandQueue struct {
    commands chan Command
    wg       sync.WaitGroup
}
<p>func NewCommandQueue(size int) *CommandQueue {
return &CommandQueue{
commands: make(chan Command, size),
}
}</p><p>func (q *CommandQueue) AddCommand(cmd Command) {
q.commands <- cmd
}</p><p>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()
}
}()
}
}</p><p>func (q *CommandQueue) Close() {
close(q.commands)
q.wg.Wait()
}

登录后复制

这个队列使用带缓冲的 channel 存储命令，支持多 worker 并发处理。Start 方法启动多个协程从队列中取出命令并执行。

实际使用示例

现在将所有部分组合起来：

func main() {
    queue := NewCommandQueue(10)
<pre class='brush:php;toolbar:false;'>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 即可。队列机制让系统具备解耦、异步、流量削峰的能力，非常适合后台任务处理场景。

以上就是Golang如何使用命令模式实现请求队列_Golang命令模式请求队列实践详解的详细内容，更多请关注php中文网其它相关文章！