当前位置：首页 > news >正文

设计模式-控制反转【golang】

news 2026/7/4 8:58:04

设计模式-控制反转【golang】

听不懂的概念

将程序中对象的创建、依赖管理的控制权，从代码内部转移到外部容器/框架

获取mysql数据，存入redis

packagemrimport("fmt""log""os""testing")typeDatabaseinterface{Query(sqlstring)string}typeCacheinterface{Set(key,valuestring)}// Mysql操作typeMySQLDatabasestruct{}func(db*MySQLDatabase)Query(sqlstring)string{returnfmt.Sprintf("MySQL result: %s",sql)}// Pg操作typePgDatabasestruct{}func(db*PgDatabase)Query(sqlstring)string{returnfmt.Sprintf("PgSQL result: %s",sql)}// Redis操作typeRedisCachestruct{}func(c*RedisCache)Set(key,valuestring){fmt.Printf("Redis set: %s = %s\n",key,value)}// 业务逻辑funcTestManual(t*testing.T){db:=&MySQLDatabase{}cache:=&RedisCache{}// 下面为业务逻辑代码user:=db.Query("SELECT * FROM users WHERE id=1")cache.Set("user:1",user)// ………………}

定义好了查询 mysql、设置 redis 的方法，TestManual需要做的事情是，查询 mysql 的值存入 redis

这时，TestManual方法需要依赖两个依赖DatabaseCache

当我的业务逻辑代码不变，需要更换一下两个依赖时，例如我要把mysql切换成PostgreSql时，那只能修改我的业务逻辑方法了，例如

// 业务逻辑funcTestManual(t*testing.T){// db := &MySQLDatabase{}db:=&PgSQLDatabase{}cache:=&RedisCache{}// 下面为业务逻辑代码user:=db.Query("SELECT * FROM users WHERE id=1")cache.Set("user:1",user)// ………………}

所以，我需要把依赖的这部分代码提出来，以后换库还是什么的，不去动我的业务逻辑方法->TestManual

换一种写法，添加一个RunUserService，叫做管理容器也好方法也好，总之是一块儿代码封装

packagemrimport("fmt""log""os""testing")typeDatabaseinterface{Query(sqlstring)string}typeCacheinterface{Set(key,valuestring)}// Mysql操作typeMySQLDatabasestruct{}func(db*MySQLDatabase)Query(sqlstring)string{returnfmt.Sprintf("MySQL result: %s",sql)}// Pg操作typePgSqlDatabasestruct{}func(db*PgSqlDatabase)Query(sqlstring)string{returnfmt.Sprintf("PgSQL result: %s",sql)}// Redis操作typeRedisCachestruct{}func(c*RedisCache)Set(key,valuestring){fmt.Printf("Redis set: %s = %s\n",key,value)}// 数据服务操作函数typeDataServiceHandlerfunc(db Database,cache Cache)funcRunUserService(handler DataServiceHandler){// 依赖代码迁移到这里db:=&MySQLDatabase{}// db := &PgSqlDatabase{}cache:=&RedisCache{}handler(db,cache)}// 业务逻辑funcTestManual(t*testing.T){RunUserService(func(db Database,cache Cache){// 下面为业务逻辑代码user:=db.Query("SELECT * FROM users WHERE id=1")cache.Set("user:1",user)})}