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

在Go语言中,命令模式(Command Pattern)是一种行为设计模式,它将请求封装为对象,从而使你可以用不同的请求、队列或日志来参数化其他对象。结合任务调度系统,命令模式可以很好地实现任务的注册、执行与管理。
命令模式核心结构
命令模式通常包含以下几个部分:
- Command接口:定义执行操作的方法,如Execute()
- 具体命令:实现Command接口,持有接收者并调用其方法
- Receiver:真正执行任务的对象
- Invoker:调用命令的对象,比如调度器
- Client:创建命令并绑定接收者
基本命令接口与任务实现
我们先定义一个通用的Command接口,并实现几个具体任务:
立即学习“go语言免费学习笔记(深入)”;
package mainimport ( "fmt""time" )
// Command 接口type Command interface { Execute() }
// 打印消息的接收者type PrintReceiver struct { Message string }
func (p *PrintReceiver) Print() { fmt.Println("打印:", p.Message, " | 时间:", time.Now().Format("15:04:05")) }
// 发送邮件命令type SendEmailCommand struct { Receiver *PrintReceiver }
func (c *SendEmailCommand) Execute() { c.Receiver.Message = "发送用户通知邮件" c.Receiver.Print() }
// 备份数据库命令type BackupDBCommand struct { Receiver *PrintReceiver }
func (c *BackupDBCommand) Execute() { c.Receiver.Message = "正在备份数据库" c.Receiver.Print() }
任务调度器实现
接下来我们构建一个简单的调度器,支持定时执行注册的命令:
立即学习“go语言免费学习笔记(深入)”;
type Scheduler struct { commands []Command interval time.Duration }func NewScheduler(interval time.Duration) *Scheduler { return &Scheduler{ commands: make([]Command, 0), interval: interval, } }
func (s *Scheduler) AddCommand(cmd Command) { s.commands = append(s.commands, cmd) }
func (s *Scheduler) Start() { ticker := time.NewTicker(s.interval) go func() { for range ticker.C { for _, cmd := range s.commands { cmd.Execute() } } }() }
使用示例
最后是主函数中的调度使用方式:
立即学习“go语言免费学习笔记(深入)”;
func main() { receiver := &PrintReceiver{}scheduler := NewScheduler(3 * time.Second) scheduler.AddCommand(&SendEmailCommand{Receiver: receiver}) scheduler.AddCommand(&BackupDBCommand{Receiver: receiver}) fmt.Println("任务调度已启动...") scheduler.Start() // 防止主程序退出 select{}}
运行结果会每隔3秒依次输出:
打印: 发送用户通知邮件 | 时间: 10:30:01 打印: 正在备份数据库 | 时间: 10:30:01这个例子展示了如何使用命令模式解耦任务定义与执行逻辑,同时通过调度器统一管理多个任务的周期性执行。你可以扩展支持延迟执行、任务取消、错误重试等功能。
基本上就这些,结构清晰且易于维护。










