go 依赖注入设计与实现

在现代的 web 框架里面,基本都有实现了依赖注入的功能,可以让我们很方便地对应用的依赖进行管理,同时免去在各个地方 new 对象的麻烦。比如 Laravel 里面的 Application,又或者 Java 的 Spring 框架也自带依赖注入功能。

今天我们来看看 go 里面实现依赖注入的一种方式,以 inject 库为例子(https://github.com/flamego/flamego/tree/main/inject)。

我们要了解一个软件的设计,先要看它定义了一个什么样的模型,但是在了解模型之前,我们更应该清楚了解,为什么会出现这个模型,也就是我们构建出了这个模型到底是为了解决什么问题。

依赖注入要解决的问题

我们先来看看,在没有依赖注入之前,我们需要的依赖是如何构建出来的,假设有如下 struct 定义:

type A struct {
}type B struct {a A
}type C struct {b B
}func test(c C) {println("c called")
}

假设我们要调用 test,就需要创建一个 C 的实例,而创建 C 的实例需要创建一个 B 的实例,而创建 B 的实例需要一个 A 的实例。如下是一个例子:

a := A{}
b := B{a: a}
c := C{b: b}
test(c)

我们可以看到,这个过程非常的繁琐,只有一个地方需要这样调用 test 还好,如果有多个地方都需要调用 test,那我们就要做很多创建实例的操作,而且一旦实例的构建过程发生变化,我们就需要改动很多地方

所以现在的 web 框架里面一般都将这个实例化的过程固化下来,在框架的某个地方注册一些实例化的函数,在我们需要的时候就调用之前注册的实例化的函数,实例化之后,再根据需要看看是否需要将这个实例保留在内存里面,从而在免去了手动实例化的过程之外,节省我们资源的开销(不用每次使用的时候都实例化一次)。

而这里说到的固化的实例化过程,其实就是我们本文所说的依赖注入。在 Laravel 里面我们可以通过 ServiceProviderapp()->register() 或者 app()->bind() 等函数来做依赖注入的一些操作。

inject 依赖注入模型/设计

以下是 Injector 的大概模型,Injector 接口里面嵌套了 ApplicatorInvokerTypeMapper 接口,之所以这样做是出于接口隔离原则考虑,因为这三者代表了细化的三种不同功能,分离出不同的接口可以让我们的代码更加的清晰,也会更利于代码的后续演进。

  • Injector:依赖注入容器
  • Applicator:结构体注入的接口
  • Invoker:使用注入的依赖来调用函数
  • TypeMapper:类型映射,需要特别注意的是,在 Injector 里面,是通过类型来绑定依赖(不同于 Laravel 的依赖注入容器可以通过字符串命名的方式来绑定依赖,当然将 Injector 稍微改改也是可以实现的,就看有没有这种需求罢了)。
// 依赖注入容器
type Injector interface {ApplicatorInvokerTypeMapper// 上一级 InjectorSetParent(Injector)
}// 给结构体字段注入依赖
type Applicator interface {Apply(interface{}) error
}// 调用函数,Invoke 的参数是被调用的函数,
// 这个函数的参数事先通过 Injector 注入,
// 调用的时候从 Injector 里面获取依赖
type Invoker interface {Invoke(interface{}) ([]reflect.Value, error)
}// 往 Injector 注入依赖
type TypeMapper interface {Map(...interface{}) TypeMapperMapTo(interface{}, interface{}) TypeMapperSet(reflect.Type, reflect.Value) TypeMapperValue(reflect.Type) reflect.Value
}

表示成图像大概如下:

在这里插入图片描述

我们可以通过 InjectorTypeMapper 来往依赖注入容器里面注入依赖,然后在我们需要为结构体的字段注入依赖,又或者为函数参数注入依赖的时候,可以通过 Applicator 或者 Invoker 来实现注入依赖。

SetParent 这个方法比较有意思,它其实将 Injector 这个模型拓展了,形成了一个有父子关系的模型。在其他语言里面可能作用不是很明显,但是在 go 里面,这个父子模型恰好和 go 的协程的父子模型一致。在 go 里面,我们可以在一个协程里面再创建一个 Injector,然后在这里面定义一些在当前协程以及当前协程子协程可以用到的一些依赖,而不用影响外部的 Injector

当然上面说到的协程只是 Injector 里面 SetParent 的一种用法,另外一种用法是,我们的 web 应用往往会根据路由前缀来划分为不同的组,而这种路由组的结构组织方式其实也是一种父子结构,在这种场景下,我们就可以针对全局注入一些依赖的情况下,再针对某个路由组来注入路由组特定的依赖。

injector 的依赖注入实现

我们来看看 injector 的结构体:

type injector struct {// 注入的依赖values map[reflect.Type]reflect.Value// 上级 Injectorparent Injector
}

这个结构体定义很简单,就只有两个字段,valuesparent,我们通过 TypeMapper 注入的依赖都保存在 values 里面,values 是通过反射来记录我们注入的参数类型和值的。

那我们是如何注入依赖的呢?再来看看 TypeMapperMap 方法:

func (inj *injector) Map(values ...interface{}) TypeMapper {for _, val := range values {inj.values[reflect.TypeOf(val)] = reflect.ValueOf(val)}return inj
}

我们可以看到,对于传入给 Map 的参数,这里获取了它的反射类型作为 values map 的 key,而获取了传入参数的反射值作为 values 里面 map 的值。其他的两个方法 MapToSet 也是类似的功能,最终的效果都是获取依赖的类型作为 values 的 key,依赖的值作为 values 的值

到此为止,我们知道 Injector 是如何注入依赖的了。

那么它又是如何去从依赖注入容器里面拿到我们注入的数据的呢?又是如何使用这些数据的呢?

我们再来看看 callInvoke 方法(也就是 InjectorInvoke 实现):

func (inj *injector) callInvoke(f interface{}, t reflect.Type, numIn int) ([]reflect.Value, error) {// 参数切片,用来保存从 Injector 里面获取的依赖var in []reflect.Value// 只有 f 有参数的时候,才需要从 Injector 获取依赖if numIn > 0 {// 初始化切片in = make([]reflect.Value, numIn)var argType reflect.Typevar val reflect.Value// 遍历 f 参数for i := 0; i < numIn; i++ {// 获取 f 参数类型argType = t.In(i)// 从 Injector 获取该类型对应的依赖val = inj.Value(argType)// 如果函数参数未注入,则调用出错if !val.IsValid() {return nil, fmt.Errorf("value not found for type %v", argType)}// 保存从 Injector 获取到的值in[i] = val}}// 通过反射调用 f 函数,in 是参数切片return reflect.ValueOf(f).Call(in), nil
}

参数和返回值说明:

  • 第一个参数是我们 Invoke 的函数,这个函数的参数,都会通过 Injector 根据函数参数类型获取
  • 第二个参数 f 的反射类型,也就是 reflect.TypeOf(f)
  • 第三个参数是 f 的参数个数
  • 返回值是 reflect.Value 切片,如果我们在调用过程出错,返回 error

在这个函数中,会通过反射来获取 f 的参数类型(reflect.Type),拿到这个类型之后,从 Injector 里面获取我们之前注入的依赖,这样我们就可以拿到所有参数对应的值。最后,通过 reflect.ValueOf(f) 来调用 f 函数,参数是我们从 Injector 获取到的值的切片。调用之后,返回函数调用结果,一个 reflect.Value 切片。

当然,这只是其中一种使用依赖的方式,另外一种方式也比较常见,就是为结构体注入依赖,这跟 hyperf 里面通过注释注解又或者 Spring 里面的注入方式有点类似。在 Injector 里面是通过 Apply 来为结构体字段注入依赖的:

// 参数 val 是待注入依赖的结构体
func (inj *injector) Apply(val interface{}) error {v := reflect.ValueOf(val)// 获取底层元素for v.Kind() == reflect.Ptr {v = v.Elem()}// 底层类型不是结构体则返回if v.Kind() != reflect.Struct {return nil // Should not panic here ?}// v 的反射类型t := v.Type()// 遍历结构体的字段for i := 0; i < v.NumField(); i++ {// 获取第 i 个结构体字段// v 的类型是 reflect.Value// v.Field 返回的是结构体字段的值f := v.Field(i)// t 的类型是 *reflect.rtype// t.Field 返回的是 reflect.Type,是类型信息structField := t.Field(i)// 检查是否有 inject tag,有这个 tag 才会进行依赖注入_, ok := structField.Tag.Lookup("inject")// 字段支持反射设置,并且存在 inject tag 才会进行注入if f.CanSet() && ok {// 通过反射类型从 Injector 中获取对应的值ft := f.Type()v := inj.Value(ft)// 获取不到注入的依赖,则返回错误if !v.IsValid() {return fmt.Errorf("value not found for type %v", ft)}// 设置结构体字段值f.Set(v)}}return nil
}

简单来说,Injector 里面,通过 TypeMapper 来注入依赖,然后通过 Apply 或者 Invoke 来使用注入的依赖。

例子

还是以一开始的例子为例,通过依赖注入的方式来改造一下:

a := A{}
b := B{a: a}
c := C{b: b}// 新建依赖注入容器
inj := injector{values: make(map[reflect.Type]reflect.Value),
}
// 注入依赖 c
inj.Map(c)
// 调用函数 test,test 的参数 `C` 会通过依赖注入容器获取
_, _ = inj.Invoke(test)
// 输出 "c called"

这个例子中,我们通过 inj.Map 来注入了依赖,在后续通过 inj.Invoke 来调用 test 函数的时候,将会从依赖注入容器里面获取 test 的参数,然后将这些参数传入 test 来调用。

这个例子也许比较简单,但是如果我们很多地方都需要用到 C 这个参数的话,我们通过 inj.Invoke 的方式来调用函数就可以避免每一次调用都要实例化 C 的繁琐操作了。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/643369.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

C++高精度问题

高精度前言 C中int不能超过2^31-1&#xff0c;最长的long long也不能超过2^63-1,所以我们在题目中如果碰到了很长很长的数&#xff0c;并且需要进行大数运算时&#xff0c;就需要高精度存储。 高精度总体思路 由于int和long long的限制&#xff0c;我们要想存放很长的数就需…

Power Apps 向Power Automate传一个数组参数

Power Apps传Power Automate数组参数 背景Power Apps传参方法画布开发我们现在power apps中设置一个集合**ArrCollect**准备一个按钮 Power Automate接收总结画布流 背景 我们通常会从Power Apps界面传递参数给Flow中&#xff0c;但是很多时候仅仅是一个字符串类型的已经不适用…

二进制计算

二进制的引入 十进制规则:满10进1&#xff0c;由数字0到9组成。 而所谓十六进制&#xff0c;八进制&#xff0c;二进制的规则也是类似。 这里为了区分十六进制和八进制&#xff0c;十六进制前面会加上0x&#xff0c;八进制前面会加个0作为区分 而二进制的规则类似于十进制&…

openssl3.2/test/certs - 025 - client intermediate ca: cca-cert

文章目录 openssl3.2/test/certs - 025 - client intermediate ca: cca-cert概述笔记END openssl3.2/test/certs - 025 - client intermediate ca: cca-cert 概述 openssl3.2 - 官方demo学习 - test - certs 笔记 // \file my_openssl_linux_log_doc_025.txt // \note open…

PLC协议转BACnet网关BA107

随着通讯技术和控制技术的发展&#xff0c;为了实现楼宇的高效、智能化管理&#xff0c;集中监控管理已成为楼宇智能管理发展的必然趋势。在此背景下&#xff0c;高性能的楼宇暖通数据传输解决方案——协议转换网关应运而生&#xff0c;广泛应用于楼宇自控和暖通空调系统应用中…

精品基于Uniapp+springboot智能家居环境检测App

《[含文档PPT源码等]精品基于Uniappspringboot智能家居环境检测App》该项目含有源码、文档、PPT、配套开发软件、软件安装教程、项目发布教程、包运行成功&#xff01; 软件开发环境及开发工具&#xff1a; 开发语言&#xff1a;Java 后台框架&#xff1a;springboot、ssm …

HTTP3/QUIC 性能测试与配套组件

背景 最近一年很多关于QUIC的文章层出&#xff0c;但是发现一个问题&#xff0c;这些文章都是在介绍QUIC或HTTP3是怎样的一个东西&#xff0c;以及它的优点和机制&#xff0c;将它夸的近乎上天了。然而有心的人估计会亲手做一些测试&#xff0c;就会发现这个被捧上天的东西性能…

宝塔+nextcloud+docker+Onlyoffice 全开启https

折腾了我三天的经验分享 1.宝塔创建网站 nextcloud版本为28.0.1 php8.2 &#xff0c;导入nextcloud绑定域名对应的证书 &#xff0c;不用创建mysql 因为nextcloud 要求是mariadb:10.7 宝塔里没有&#xff0c;就用docker安装一个 端口设置为3307 将数据库文件映射出来/ww…

Leetcode刷题(二十八)

找出字符串中第一个匹配项的下标&#xff08;Easy&#xff09; 给你两个字符串 haystack 和 needle &#xff0c;请你在 haystack 字符串中找出 needle 字符串的第一个匹配项的下标&#xff08;下标从 0 开始&#xff09;。如果 needle 不是 haystack 的一部分&#xff0c;则返…

基于springboot+vue的“衣依”服装销售平台系统(前后端分离)

博主主页&#xff1a;猫头鹰源码 博主简介&#xff1a;Java领域优质创作者、CSDN博客专家、公司架构师、全网粉丝5万、专注Java技术领域和毕业设计项目实战 主要内容&#xff1a;毕业设计(Javaweb项目|小程序等)、简历模板、学习资料、面试题库、技术咨询 文末联系获取 研究背景…

maven详细介绍

1.简介 Maven是一个基于项目对象模型&#xff08;POM&#xff09;的软件项目管理工具&#xff0c;主要用于Java项目的构建、依赖管理和项目信息管理。通过一小段描述信息&#xff0c;Maven能够管理项目的构建、报告和文档等各个环节。它提供了一种标准化的构建方式&#xff0c…

VSCode Debug 参数设置说明

如果想在vscode中debug一个项目&#xff0c;比如python3 run.py --args 这个时候你需要着重关注几个参数&#xff0c;参数用两个双引号分开&#xff0c;不能有空格。 cwd :运行代码的基础目录env: 设置环境变量 PYTHONPATH&#xff1a; 设置项目用到的模块搜索路径&#xff…

361. 观光奶牛(小数二分,spfa判断正环,01分数规划)

361. 观光奶牛 - AcWing题库 给定一张 L 个点、P 条边的有向图&#xff0c;每个点都有一个权值 f[i]&#xff0c;每条边都有一个权值 t[i]。 求图中的一个环&#xff0c;使“环上各点的权值之和”除以“环上各边的权值之和”最大。 输出这个最大值。 注意&#xff1a;数据保…

SpringBoot 整合RabbitMQ 之延迟队列实验

在Spring Boot中整合RabbitMQ并实现延迟队列的功能&#xff0c;可以按照以下步骤进行&#xff1a; 添加依赖&#xff1a;在pom.xml文件中添加RabbitMQ和Spring AMQP相关的依赖。 <dependency><groupId>org.springframework.boot</groupId><artifactId&g…

在PyCharm中安装GitHub Copilot插件,login之后报出如下错误:

Sign in failed. Reason: Request signInInitiate failed with message: connect ECONNABORTED 20.205.243.166:443, request id: 7, error code: -32603 前提&#xff1a; 设置网址&#xff1a;https://github.com/settings/copilot&#xff0c;已设置为允许 或者&#xff1…

速盾:服务器接入CDN后上传图片失败的解决方案

本文将探讨当服务器接入CDN后&#xff0c;上传图片失败的常见原因&#xff0c;并提供解决方案以解决这些问题。同时&#xff0c;我们还将附上一些相关的问题和解答&#xff0c;让读者更好地理解和应对这些挑战。 随着互联网的持续发展&#xff0c;网站的性能和速度对于用户体验…

Java基础面试题-4day

异常 Exception和Error有什么区别&#xff1f; Exception类和Error类有一个共同的父类Throwable类 Exception类为异常类&#xff0c;可以使用catch 捕获&#xff0c;捕获之后&#xff0c;Exception类又分为Checked Exception和 Uncheckend Exception Checked Exception是捕获…

工业智能网关储能物联网应用实现能源的高效利用及远程管理

储能电力物联网是指利用物联网技术和储能技术相结合&#xff0c;实现对电力系统中各种储能设备的智能管理和优化控制。随着可再生能源的不断发展和应用&#xff0c;电力系统面临着越来越大的电力调度和储能需求而储能电力物联网的出现可以有效解决这一问题&#xff0c;提高电力…

Spring5系列学习文章分享---第三篇(AOP概念+原理+动态代理+术语+Aspect+操作案例(注解与配置方式))

目录 AOP概念AOP底层原理AOP(JDK动态代理)使用 JDK 动态代理&#xff0c;使用 Proxy 类里面的方法创建代理对象**编写** **JDK** 动态代理代码 AOP(术语)AOP操作&#xff08;准备工作&#xff09;**AOP** **操作&#xff08;**AspectJ注解)**AOP** **操作&#xff08;**AspectJ…

oracle data block , extent 和segment区别

data block是数据库中最小的逻辑存储单元。当数据库的对象需要更多的物理存储空间时&#xff0c;连续的data block就组成了extent . 一个数据库对象拥有的所有extents被称为该对象的segment. Data block、extent和segment是数据库中不同层次的数据存储和管理单位&#xff0c;它…