面试题：Go语言匿名函数在复杂事件监听与处理中的应用

Question

在一个基于Go语言的分布式系统中，有多个节点，每个节点需要监听特定的系统事件（例如资源不足事件、网络连接中断事件等）。当事件发生时，需要根据不同的事件类型执行不同的处理逻辑，且不同节点的处理逻辑可能有差异。请设计一个使用匿名函数来实现事件监听与处理的架构，并给出关键代码示例，阐述如何管理不同类型事件的处理逻辑。

Answer 1

架构设计思路

1. 事件类型定义：定义一个枚举类型来表示不同的系统事件。
2. 事件处理器映射：使用一个 map 来存储不同事件类型对应的处理函数，每个处理函数为匿名函数。
3. 事件监听：每个节点启动一个 goroutine 来监听系统事件，当事件发生时，从映射中获取对应的处理函数并执行。

关键代码示例

package main

import (
    "fmt"
)

// 定义事件类型
type EventType int

const (
    ResourceShortage EventType = iota
    NetworkDisconnect
)

// 定义事件处理器映射
var eventHandlers = make(map[EventType]func())

// 注册事件处理器
func RegisterEventHandler(eventType EventType, handler func()) {
    eventHandlers[eventType] = handler
}

// 模拟事件监听
func ListenForEvents() {
    // 模拟事件发生
    for _, event := range []EventType{ResourceShortage, NetworkDisconnect} {
        if handler, exists := eventHandlers[event]; exists {
            handler()
        } else {
            fmt.Printf("No handler for event %v\n", event)
        }
    }
}

func main() {
    // 注册资源不足事件处理器
    RegisterEventHandler(ResourceShortage, func() {
        fmt.Println("Handling Resource Shortage event")
        // 具体处理逻辑
    })

    // 注册网络连接中断事件处理器
    RegisterEventHandler(NetworkDisconnect, func() {
        fmt.Println("Handling Network Disconnect event")
        // 具体处理逻辑
    })

    ListenForEvents()
}

处理逻辑管理

1. 注册机制：通过 RegisterEventHandler 函数，不同节点可以根据自身需求注册特定事件类型的处理逻辑。这样不同节点可以对相同事件类型有不同的处理。
2. 事件处理器映射：eventHandlers 这个 map 作为一个集中管理不同事件处理逻辑的地方，添加新的事件类型只需要在 EventType 枚举中添加，并在不同节点按需注册对应的匿名函数处理逻辑。
3. 监听与执行：ListenForEvents 函数模拟事件监听过程，当事件发生时，从映射中查找并执行对应的处理函数，实现了事件监听与处理的解耦。