Golang Command命令模式任务调度示例-Golang-PHP中文网

Golang Command命令模式任务调度示例

P粉602998670

发布： 2025-10-13 17:14:03

原创

320人浏览过

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

golang command命令模式任务调度示例

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

命令模式核心结构

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

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

基本命令接口与任务实现

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

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

百度GBI

百度GBI-你的大模型商业分析助手

104

查看详情

<span style="color:blue;">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>

登录后复制

任务调度器实现

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

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

<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>

登录后复制

使用示例

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

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

<span style="color:blue;">func</span> main() {
    receiver := &PrintReceiver{}
<pre class='brush:php;toolbar:false;'>scheduler := NewScheduler(3 * time.Second)
scheduler.AddCommand(&SendEmailCommand{Receiver: receiver})
scheduler.AddCommand(&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 Command命令模式任务调度示例的详细内容，更多请关注php中文网其它相关文章！

大家都在看：

Go语言中函数或方法存在性检查的策略与实践 Go语言中如何优雅地将包封装进接口：原理与实践深入探索Go语言：程序化获取包中所有已定义类型的方法 Go语言：使用fmt.Fscanln从文件读取混合类型数据 Go 语言：利用 go/importer 动态解析包并获取导出类型