通过工厂模式、装饰器模式、观察者模式和单例模式的综合应用,实现了一个可扩展的任务调度系统。首先,工厂模式配合注册机制支持任务类型的动态注册与创建,提升扩展性;接着,装饰器模式为任务添加日志、重试等横切功能,实现关注点分离;观察者模式用于任务状态监控与通知,增强可观测性;单例模式确保调度器核心组件全局唯一,避免资源浪费;最后,通过接口组合与Go的结构体嵌入特性,实现灵活的能力拆分与复用。该设计在Go语言简洁、组合优先的哲学下,兼顾了可维护性、可扩展性和职责清晰性,展示了设计模式在实际项目中的有效落地方式。

在Go语言的实际项目开发中,设计模式的合理运用能显著提升代码的可维护性、扩展性和复用性。虽然Go推崇简洁和组合优于继承,但设计模式依然在复杂业务场景中发挥着重要作用。下面通过一个典型的项目实战案例——实现一个可扩展的任务调度系统,综合应用多种常用设计模式。
假设我们需要开发一个任务调度系统,支持多种任务类型(如HTTP请求、文件处理、数据库备份等),任务可动态注册,支持异步执行、失败重试、日志记录和监控。系统需具备良好的扩展性,便于后续新增任务类型或执行策略。
为支持任务类型的动态扩展,使用工厂模式配合注册中心,避免硬编码创建任务实例。
定义任务接口:
立即学习“go语言免费学习笔记(深入)”;
type Task interface {
Execute() error
GetName() string
}
使用工厂函数和注册表:
var taskRegistry = make(map[string]func() Task)
<p>func RegisterTask(name string, factory func() Task) {
taskRegistry[name] = factory
}</p><p>func CreateTask(name string) (Task, error) {
factory, exists := taskRegistry[name]
if !exists {
return nil, fmt.Errorf("task %s not registered", name)
}
return factory(), nil
}</p>注册具体任务:
type HttpTask struct{ Url string }
func (h *HttpTask) Execute() error { /* 发起HTTP请求 */ }
func (h *HttpTask) GetName() string { return "http" }
<p>func init() {
RegisterTask("http", func() Task {
return &HttpTask{Url: "<a href="https://www.php.cn/link/374cad868cb62202053d308252bc4040">https://www.php.cn/link/374cad868cb62202053d308252bc4040</a>"}
})
}</p>为任务添加通用功能,如日志、重试、超时控制,使用装饰器模式实现功能叠加。
type LoggingTask struct {
Task
}
<p>func (l *LoggingTask) Execute() error {
log.Printf("开始执行任务: %s", l.Task.GetName())
err := l.Task.Execute()
if err != nil {
log.Printf("任务执行失败: %v", err)
} else {
log.Printf("任务执行成功: %s", l.Task.GetName())
}
return err
}</p>重试装饰器:
type RetryTask struct {
Task
MaxRetries int
}
<p>func (r <em>RetryTask) Execute() error {
var err error
for i := 0; i <= r.MaxRetries; i++ {
err = r.Task.Execute()
if err == nil {
return nil
}
log.Printf("第 %d 次重试失败: %v", i+1, err)
time.Sleep(1 << i </em> time.Second) // 指数退避
}
return fmt.Errorf("重试 %d 次后仍失败: %v", r.MaxRetries, err)
}</p>使用装饰器组合:
task, _ := CreateTask("http")
task = &RetryTask{Task: task, MaxRetries: 3}
task = &LoggingTask{Task: task}
task.Execute()
实现任务执行状态的监控和通知,便于集成告警或UI展示。
type Observer interface {
Update(taskName, status string)
}
<p>var observers []Observer</p><p>func RegisterObserver(o Observer) {
observers = append(observers, o)
}</p><p>func notify(taskName, status string) {
for _, o := range observers {
o.Update(taskName, status)
}
}</p>在任务执行前后通知:
func (l *LoggingTask) Execute() error {
notify(l.Task.GetName(), "started")
err := l.Task.Execute()
if err != nil {
notify(l.Task.GetName(), "failed")
} else {
notify(l.Task.GetName(), "success")
}
return err
}
调度器核心组件(如任务队列、配置管理)使用单例模式确保全局唯一。
type Scheduler struct {
tasks chan Task
}
<p>var once sync.Once
var instance *Scheduler</p><p>func GetScheduler() *Scheduler {
once.Do(func() {
instance = &Scheduler{
tasks: make(chan Task, 100),
}
go instance.run()
})
return instance
}</p><p>func (s *Scheduler) Submit(task Task) {
s.tasks <- task
}</p><p>func (s *Scheduler) run() {
for task := range s.tasks {
go func(t Task) {
t.Execute()
}(task)
}
}</p>Go语言没有继承,但通过接口组合实现多态。例如,将执行、重试、日志等能力拆分为小接口,按需组合。
type Retriable interface {
CanRetry() bool
}
<p>type TimeOutable interface {
Timeout() time.Duration
}</p>装饰器可判断任务是否支持特定行为,实现更智能的控制逻辑。
通过上述设计模式的综合应用,该任务调度系统具备以下优势:
Go语言虽不强调传统OOP,但设计模式的思想——如解耦、复用、抽象——依然至关重要。关键是根据语言特性(如接口隐式实现、结构体组合)灵活应用,而非生搬硬套。
基本上就这些,实际项目中可根据复杂度调整模式使用粒度。
以上就是Golang设计模式综合应用 项目实战案例的详细内容,更多请关注php中文网其它相关文章!
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号