Golang命令模式任务调度详解

各位小伙伴们，大家好呀！看看今天我又给各位带来了什么文章？本文标题是《Golang Command模式任务调度教程》，很明显是关于Golang的文章哈哈哈，其中内容主要会涉及到等等，如果能帮到你，觉得很不错的话，欢迎各位多多点评和分享！

命令模式通过封装请求实现任务调度，Go中定义Command接口与具体命令，结合Scheduler定时执行，解耦任务注册与执行逻辑，支持灵活扩展。

在Go语言中，命令模式（Command Pattern）是一种行为设计模式，它将请求封装为对象，从而使你可以用不同的请求、队列或日志来参数化其他对象。结合任务调度系统，命令模式可以很好地实现任务的注册、执行与管理。

命令模式核心结构

命令模式通常包含以下几个部分：

• Command接口：定义执行操作的方法，如Execute()
• 具体命令：实现Command接口，持有接收者并调用其方法
• Receiver：真正执行任务的对象
• Invoker：调用命令的对象，比如调度器
• Client：创建命令并绑定接收者

基本命令接口与任务实现

我们先定义一个通用的Command接口，并实现几个具体任务：

<span   style="max-width:100%">package</span> main
<p><span style="color:blue;">import</span> (
<span style="color:darkred;">"fmt"</span><span style="color:darkred;">"time"</span>
)</p><p><span style="color:gray;">// Command 接口</span><span style="color:blue;">type</span> Command <span style="color:blue;">interface</span> {
Execute()
}</p><p><span style="color:gray;">// 打印消息的接收者</span><span style="color:blue;">type</span> PrintReceiver <span style="color:blue;">struct</span> {
Message <span style="color:blue;">string</span>
}</p><p><span style="color:blue;">func</span> (p *PrintReceiver) Print() {
fmt.Println(<span style="color:darkred;">"打印:"</span>, p.Message, <span style="color:darkred;">" | 时间:"</span>, time.Now().Format(<span style="color:darkred;">"15:04:05"</span>))
}</p><p><span style="color:gray;">// 发送邮件命令</span><span style="color:blue;">type</span> SendEmailCommand <span style="color:blue;">struct</span> {
Receiver *PrintReceiver
}</p><p><span style="color:blue;">func</span> (c *SendEmailCommand) Execute() {
c.Receiver.Message = <span style="color:darkred;">"发送用户通知邮件"</span>
c.Receiver.Print()
}</p><p><span style="color:gray;">// 备份数据库命令</span><span style="color:blue;">type</span> BackupDBCommand <span style="color:blue;">struct</span> {
Receiver *PrintReceiver
}</p><p><span style="color:blue;">func</span> (c *BackupDBCommand) Execute() {
c.Receiver.Message = <span style="color:darkred;">"正在备份数据库"</span>
c.Receiver.Print()
}</p>

任务调度器实现

接下来我们构建一个简单的调度器，支持定时执行注册的命令：

<span style="color:blue;">type</span> Scheduler <span style="color:blue;">struct</span> {
    commands []Command
    interval time.Duration
}
<p><span style="color:blue;">func</span> NewScheduler(interval time.Duration) *Scheduler {
<span style="color:blue;">return</span> &Scheduler{
commands: make([]Command, 0),
interval: interval,
}
}</p><p><span style="color:blue;">func</span> (s *Scheduler) AddCommand(cmd Command) {
s.commands = append(s.commands, cmd)
}</p><p><span style="color:blue;">func</span> (s *Scheduler) Start() {
ticker := time.NewTicker(s.interval)
<span style="color:blue;">go func</span>() {
<span style="color:blue;">for</span> <span style="color:blue;">range</span> ticker.C {
<span style="color:blue;">for</span> _, cmd := <span style="color:blue;">range</span> s.commands {
cmd.Execute()
}
}
}()
}</p>

使用示例

最后是主函数中的调度使用方式：

<span style="color:blue;">func</span> main() {
    receiver := &PrintReceiver{}
<pre class="brush:php;toolbar:false;">scheduler := NewScheduler(3 * time.Second)
scheduler.AddCommand(&amp;SendEmailCommand{Receiver: receiver})
scheduler.AddCommand(&amp;BackupDBCommand{Receiver: receiver})

fmt.Println(<span style="color:darkred;">"任务调度已启动..."</span>)
scheduler.Start()

<span style="color:gray;">// 防止主程序退出</span>
select{}

}

运行结果会每隔3秒依次输出：

打印: 发送用户通知邮件 | 时间: 10:30:01
打印: 正在备份数据库 | 时间: 10:30:01

这个例子展示了如何使用命令模式解耦任务定义与执行逻辑，同时通过调度器统一管理多个任务的周期性执行。你可以扩展支持延迟执行、任务取消、错误重试等功能。

基本上就这些，结构清晰且易于维护。

好了，本文到此结束，带大家了解了《Golang命令模式任务调度详解》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多Golang知识！