Caddy 源码分析 启动流程与Event事件通知

介绍

Caddy 整个软件可以说是由不同的 插件 堆砌起来的。自己本身仅提供 Plugin 的注册运行逻辑和 Server 的监听服务功能。

学习 caddy 的源码，实际上是学习 如何构建一个松耦合的抽象 Plugin 设计，即模块化插拔的做法。

所以我们的源码阅读，围绕 Caddy 为 Plugin 提供的基础设施，和 Plugin 自身逻辑。

下面我们从第一步，启动流程开始阅读。 之后的路径应该是 Caddyfile 的解析，解析出的 配置文件如何消费，配置完成的服务器如何服务。

main.go

├── caddy # caddy主目录
│   ├── caddymain
│   │   ├── run.go # 运行文件
│   │   └── run_test.go
│   ├── main.go # 主文件
│   └── main_test.go

其中run.go 上篇笔记中已经分析 Caddy 源码分析 run.go

main.go

var run = caddymain.Run // replaced for tests

func main() {
	run()
}

通过改变 run 变量的值来方便测试，可以学习一下。

启动流程

启动 caddy 的流程

caddyfileLoader 加载 caddyfile 配置 --> 生成 Input 信息 Context --> 生成 Server

caddyfile 示例

Instans 是运行操作的 Server 实例，可以看到几个主要的操作都是在他身上

Server 两种监听模式 TCP UDP

启动服务器

发送 StartupEvent

// Executes Startup events 注册开始事件钩子(即插件相关启动都在此处注册 很多魔改框架都是改动的这里)
caddy.EmitEvent(caddy.StartupEvent, nil)

读取配置文件

caddyfileinput, err := caddy.LoadCaddyfile(serverType)

启动

instance, err := caddy.Start(caddyfileinput)

发送 InstanceStartupEvent

caddy.EmitEvent(caddy.InstanceStartupEvent, instance）

Start（）

// Start your engines 
instance, err := caddy.Start(caddyfileinput) 
if err != nil { 
    mustLogFatalf("%v", err) 
}

这里除了 Instance 之外还有两个新名词

Controller（控制器）：它是用来帮助 Directives（指令） 设置它自身的，通过读取 Token，这里的 Directives 实际上对应的就是上文所说的 caddyfile 中的配置文件选项。

这一点请参照 Caddy（三）中 Loader 下的 excuteDirective 理解。

Token ：是 caddy 自己的 词法分析器 解析 caddyfile 配置文件出的选项的标记。

这一点请Caddy（三）中 Loader 中的 Parser 理解

我们来看顺序，第一遍从顶向下看。

第一个是 Input，这是 caddyfile 的变量结构，他可以通过 Start（）方法新建实例 Instance

Instance 通过从 caddyfile 读取到信息的 Input 生成 Context

携带信息的 Context 承担 新建 Server 的任务

Context 读取 caddyfile 解析出的 ServerBlock 配置服务器

ServerBlock 包含 不同的 Tokens 他们会转换为 Directive

Directive 会被 Controller 消费，用于配置插件 安装到服务器上

值得注意的是 Controller 更改的是 Instance 对于 http 服务器来说还会增加 http 服务的中间件

如果不理解，首先记住 caddy 是 配置的 模块化的服务器，

通过 caddyfile 配置 -> caddyfile 读取它 -> Loader 解析配置目标-> token & directives 进行配置 -> controller & setup 启动 -> instance & Start()

记住这个流程就能理解了。

Event 事件通知启动插件

引入

我们看到，在 caddy 的 run.go 中有一行代码是

caddy.EmitEvent(caddy.StartupEvent, nil)

这就是 caddy 中的 事件通知系统，通知的是所有的 plugin。

变量

在 caddy/plugin.go 包中

// eventHooks is a map of hook name to Hook. All hooks plugins 
// must have a name. 
eventHooks = &sync.Map{}

是一个保存所有 plugin hook 的 sync.Map{}

这个标准包的 Map 是并发安全的， 通常我们使用 Load() 或者 LoadOrStore() 方法存读信息，Range() 方法遍历，如果你需要，可以引入你的 Go 程序中。

Logic

看内在实现

// EmitEvent executes the different hooks passing the EventType as an 
// argument. This is a blocking function. Hook developers should 
// use 'go' keyword if they don't want to block Caddy. 
func EmitEvent(event EventName, info interface{}) {
	eventHooks.Range(func(k, v interface{}) bool {
    	err := v.(EventHook)(event, info)
    	if err != nil {
      		log.Printf("error on '%s' hook: %v", k.(string), err)
    	}
    return true
  }) 
}

很简单，上文提过，eventHooks.Range 是遍历信息，会遍历所有保存的 EventHook 函数并运行。

那么 Plugin 想使用接收某一个事件通知做相应操作的时候，只需把自己的 EventHook 函数注册到这个 map 中

// eventHooks is a map of hook name to Hook. All hooks plugins 
// must have a name. 
eventHooks = &sync.Map{}

使用 RegisterEventHook 注册 type EventHook func(eventType EventName, eventInfo interface{}) error

// RegisterEventHook plugs in hook. All the hooks should register themselves
// and they must have a name.
func RegisterEventHook(name string, hook EventHook) {
    if name == "" {
        panic("event hook must have a name")
    }
    _, dup := eventHooks.LoadOrStore(name, hook)
    if dup {
        panic("hook named " + name + " already registered")
    }
}

那么可以监听哪些事件呢？在 Plugin 中有定义常量

// Define names for the various events
const (
    StartupEvent         EventName = "startup"
    ShutdownEvent                  = "shutdown"
    CertRenewEvent                 = "certrenew"
    InstanceStartupEvent           = "instancestartup"
    InstanceRestartEvent           = "instancerestart"
)

启动，关闭，刷新证书，这里提到的 Instance 是 caddy 中的 Server 实例