在现代软件开发中,依赖注入(Dependency Injection,简称 DI)已成为一种不可或缺的设计模式和编程范式。它不仅能够提高代码的可维护性和可测试性,还能帮助开发者构建更加灵活、松耦合的系统。本文将带您深入了解依赖注入的核心概念,探讨它如何改变我们设计和实现软件的方式,并通过实际的代码示例,展示如何在项目中有效地应用这一技术。

相信各位对 依赖注入 不会陌生,相信大多数使用 Java 或者其他 JVM 语言作为主力语言的测试同行来说,更多经验是集中在 Spring 框架学习和使用当中。在Java和Spring框架中,依赖注入是构建灵活、可维护应用程序的核心技术。Spring的IoC容器通过构造器注入、Setter注入或字段注入等方式自动管理对象间的依赖关系。开发者使用@Autowired、@Component等注解或 XML 配置来声明依赖和组件,让 Spring 负责对象的创建和生命周期管理。这种方法不仅简化了代码结构,还提高了应用的可测试性和模块化程度,使得 Java 开发者能够专注于业务逻辑的实现,而不必手动处理复杂的对象依赖关系。

而对于 Go 语言来说,显然没有类似 Spring 一统天下的局面。对于提升编程效率,可以说是百家争鸣,好不热闹。在 Go 语言中,虽然没有像 Java 或 C# 那样内置的依赖注入框架,但依赖注入的需求同样存在。开发者通常需要手动注入依赖项,这种方式在应用规模扩大后变得繁琐且易出错。fx 框架提供了一种自动化和模块化的依赖注入方式,使开发者可以更专注于业务逻辑,而不是依赖管理。

其中 fx 显得比较耀眼夺目,下面我们来开始 fx 框架的学习。

fx 介绍

fx 框架是由 Uber 开发的。为了应对自身复杂的分布式系统和微服务架构的需求,Uber 开发了许多开源工具和框架,其中包括 fx。fx 框架主要用于简化 Go 语言应用程序的依赖注入和生命周期管理,并且已经在 Uber 内部和外部的许多项目中得到了广泛应用。

fx 框架是一个用于构建 Go 应用程序的依赖注入框架,它简化了应用程序的初始化、启动和停止过程。fx 通过自动管理依赖关系,使开发者能够专注于业务逻辑,而无需手动处理依赖注入。fx 提供了模块化的依赖注入方式,通过 fx.Provide 注册依赖项,通过 fx.Invoke 调用需要的组件。同时,fx.In 和 fx.Out 结构体帮助开发者更方便地声明和管理依赖项,支持按名称和分组注入。fx.Lifecycle 是 fx 的核心功能之一,它允许开发者在应用程序的不同生命周期阶段执行特定逻辑。通过 fx.Hook,可以在应用启动和停止时执行初始化和清理操作,如连接数据库、启动后台任务等。

fx 的模块化设计使其易于扩展和维护,通过将各个功能模块化,开发者可以灵活地组合和重用不同的组件。总之,fx 提供了简洁且强大的工具,使得构建复杂的 Go 应用程序更加高效和可维护。

fx 依赖注入

首先我们来先看一个 fx 框架启动的例子。

func main() {  
    app := fx.New() //创建一个fx.App实例  
    app.Run()       //运行fx.App实例  
}

这是一个标准的语法,所有的应用都可以用这个语法进行创建和启动。其中 fx.New() 方法为: func New(opts ...Option) *App {} ,其中参数 Option 是我们后面主要学习对象。

说到 依赖注入 ,我首先意识到两个概念,就是依赖对象的提供者和使用者。得有一些对象的创建需要依赖其他对象,然后还需要提供被依赖对象,然后通过 fx 框架将这些复杂的逻辑关系进行管理,并且提供简单的 API 给用户。

fx 的核心功能是依赖注入,它简化了依赖项的管理和注入过程,主要通过以下 API 实现:

下面我们通过一个例子来演示 fx 如何进行简单依赖注入:

package main  

import (  
    "go.uber.org/fx"  
    "go.uber.org/zap")  

func main() {  
    app := fx.New( //创建fx.App实例  
       fx.Provide(NewTester, func() *Age {  
          return &Age{Num: 18} //提供Age实例  
       }, func() *zap.Logger {  
          production, _ := zap.NewProduction() //提供zap.Logger实例  
          return production  
       }), //提供NewTester函数  
    )  
    app.Run() //运行fx.App实例  
}  

type Age struct {  
    Num int //年龄,整型  
}  

type Tester struct {  
    Log *zap.Logger //日志  
    Age *Age        //年龄  
}  

func NewTester(age *Age, log *zap.Logger) *Tester {  
    return &Tester{  
       Age: age,  
       Log: log,  
    }  

}

这段代码展示了如何使用 Uber 的 Fx 框架进行依赖注入和应用程序启动。代码通过 fx.Provide 提供了三个构造函数:一个用于 Age 实例,一个用于 zap.Logger 实例,另一个用于 Tester 实例。然后通过 fx.New 创建一个 Fx 应用,并通过 app.Run() 运行这个应用。下面是更详细的解释:

  1. 依赖注入:
  2. 运行应用:
  3. 类型定义:
  4. 构造函数 NewTester:

这个例子中,既可以将创建方法传给 fx.Provide 也可以使用匿名方法,相比较来说是灵活的。这里不建议使用匿名方法,因为写多了容易乱,特别是对于 zap.Logger 这种对象来讲,真实的创建代码可能超过 20 行,用匿名方法更是灾难了。

生命周期管理

fx.Lifecycle 是 Uber Fx 框架中用于管理应用程序生命周期的一部分。它允许你在应用程序的启动和停止阶段执行特定的逻辑。fx.Lifecycle 提供了一种添加启动和停止钩子的机制,使你能够在应用程序的不同阶段执行初始化和清理工作。

这里用到了 fx.Invoke 方法,顾名思义,就是调用某些方法,可以传入已有的方法名也可以使用匿名方法(不建议)。 fx 声明周期管理中 Hook 就是通过这个 API 实现的,案例如下:

package main  

import (  
    "context"  
    "go.uber.org/fx"    "go.uber.org/zap")  

func main() {  
    app := fx.New( //创建fx.App实例  
       fx.Provide(NewTester, func() *Age {  
          return &Age{Num: 18} //提供Age实例  
       }, func() *zap.Logger {  
          production, _ := zap.NewProduction() //提供zap.Logger实例  
          return production  
       }), //提供NewTester函数  
       fx.Invoke(register), //调用register函数  
    )  
    app.Run() //运行fx.App实例  
}  

type Age struct {  
    Num int //年龄,整型  
}  

type Tester struct {  
    Log *zap.Logger //日志  
    Age *Age        //年龄  
}  

func NewTester(age *Age, log *zap.Logger) *Tester {  
    return &Tester{  
       Age: age,  
       Log: log,  
    }  

}  

func register(lifecycle fx.Lifecycle, tester *Tester) {  
    lifecycle.Append(fx.Hook{  
       OnStart: func(context.Context) error {  
          tester.Log.Info("Starting server")  
          return nil  
       },  
       OnStop: func(context.Context) error {  
          tester.Log.Info("Stopping server")  
          return nil  
       },  
    })  
}

新增的 register 方法,通过 fx.Lifecycle 在应用程序启动和停止时执行一些自定义逻辑。具体的含义如下:

  1. register 函数:
  2. lifecycle.Append(fx.Hook{...}):
  3. OnStart 函数:
  4. OnStop 函数:

在 Uber 的 Fx 框架中,fx.Hook 和 fx.Lifecycle 通常一起使用,用于管理应用程序的生命周期和执行特定的初始化或清理逻辑。下面分别介绍它们的使用场景:

fx.Lifecycle 的使用场景

  1. 管理资源生命周期:
  2. 服务启动和停止:
  3. 日志记录和监控:

fx.Hook 的使用场景

  1. 自定义初始化和清理逻辑:
  2. 启动和停止通知:
  3. 调试和审计:

相信通过基础的学习,已经对 fx 有了了解,并且可以着手构建测试项目了。下期我们继续分享 fx 上手进阶内容。


↙↙↙阅读原文可查看相关链接,并与作者交流