代理模式属于结构型设计模式,核心思想是通过一个代理对象来控制对真实对象的访问,延迟加载则是将对象的初始化时机推迟到真正需要使用该对象的时候,避免在程序启动阶段就加载不必要的资源,减少内存占用和启动耗时。在Golang中实现代理模式延迟加载,需要定义统一的接口,让真实对象和代理对象都实现这个接口,代理对象内部持有真实对象的引用,在调用方法时判断真实对象是否已经初始化,未初始化则先完成初始化再执行对应逻辑。
核心实现思路
实现过程主要分为三个步骤:
- 定义业务接口,声明真实对象和代理对象都需要实现的方法
- 实现真实对象,包含实际的业务逻辑,初始化成本较高
- 实现代理对象,内部持有真实对象的指针,调用方法时先检查真实对象是否初始化,未初始化则先创建真实对象再调用其方法
完整代码示例
业务接口定义
首先定义一个数据查询接口,模拟一个初始化成本较高的资源,比如需要连接远程数据库或者加载大文件的数据服务。
package main
// DataService 数据查询接口,真实对象和代理对象都需要实现这个接口
type DataService interface {
// Query 查询数据的方法
Query(id int) string
}
真实对象实现
真实对象实现DataService接口,模拟初始化时需要耗时操作的场景,比如模拟加载大文件或者建立远程连接的过程。
// RealDataService 真实的数据服务对象,初始化成本较高
type RealDataService struct {
// 可以包含一些需要初始化的资源字段
config string
}
// NewRealDataService 真实对象的构造函数,模拟耗时的初始化过程
func NewRealDataService() *RealDataService {
// 模拟初始化耗时,比如加载配置文件、建立连接等
// time.Sleep(time.Second * 2)
return &RealDataService{
config: "已加载的数据库配置信息",
}
}
// Query 实现DataService接口的查询方法
func (r *RealDataService) Query(id int) string {
return "查询到ID为" + string(rune(id)) + "的数据,配置信息:" + r.config
}
代理对象实现
代理对象同样实现DataService接口,内部持有真实对象的指针,通过懒加载的方式在第一次调用方法时初始化真实对象。
// DataServiceProxy 数据服务代理对象,实现延迟加载
type DataServiceProxy struct {
// 持有真实对象的引用,初始为nil
realService *RealDataService
}
// Query 实现DataService接口的查询方法,调用时先检查真实对象是否初始化
func (p *DataServiceProxy) Query(id int) string {
// 如果真实对象还未初始化,先执行初始化
if p.realService == nil {
p.realService = NewRealDataService()
}
// 调用真实对象的方法返回结果
return p.realService.Query(id)
}
调用测试
编写测试代码验证延迟加载的效果,可以看到只有在第一次调用Query方法时才会初始化真实对象。
func main() {
// 创建代理对象,此时不会初始化真实对象
var service DataService = &DataServiceProxy{}
// 第一次调用方法,此时会触发真实对象的初始化
result1 := service.Query(1)
println("第一次调用结果:" + result1)
// 第二次调用方法,直接使用已经初始化的真实对象
result2 := service.Query(2)
println("第二次调用结果:" + result2)
}
实现优势与适用场景
这种实现方式的优势十分明显:首先在程序启动阶段不会加载高成本资源,缩短启动时间;其次只有在真正需要使用时才会初始化资源,减少不必要的内存占用;最后代理对象和真实对象实现同一个接口,对调用方完全透明,不需要修改调用逻辑。
适用场景包括:资源初始化耗时较长的对象,比如数据库连接池、远程服务客户端、大文件解析对象;或者对象的使用频率较低,不需要在程序启动时就加载的场景,比如某些低频的报表生成服务、特定的数据导出工具等。
注意事项
在实际开发中需要注意线程安全问题,如果代理对象会在多个goroutine中同时调用,那么真实对象的初始化过程需要加锁,避免多个goroutine同时触发初始化导致重复创建对象。可以在代理对象的Query方法中加入互斥锁,保证初始化过程只执行一次。
import "sync"
// SafeDataServiceProxy 线程安全的数据服务代理对象
type SafeDataServiceProxy struct {
realService *RealDataService
lock sync.Mutex
}
// Query 线程安全的方法实现
func (p *SafeDataServiceProxy) Query(id int) string {
p.lock.Lock()
defer p.lock.Unlock()
if p.realService == nil {
p.realService = NewRealDataService()
}
return p.realService.Query(id)
}