go语言连续监控事件并回调处理

前言

go语言中使用回调函数处理事件：事件监测部分（如无限循环中的事件检测逻辑）可以独立于具体的业务处理逻辑。这使得代码的各个部分更加清晰，易于理解和维护。如果需要更改事件处理的方式，只需要修改注册的回调函数，而不需要修改事件监测的核心代码。例如，如果要改变对特定事件的响应行为，只需重新定义一个不同的回调函数并注册即可，不会影响事件监测的机制。

一、回调函数的定义

// 定义事件处理函数类型
type EventHandler func(eventData interface{})// 模拟事件源
type EventSource struct {eventHandlers []EventHandler
}

二、 添加结构体的方法

// 注册事件处理函数
func (es *EventSource) RegisterHandler(handler EventHandler) {es.eventHandlers = append(es.eventHandlers, handler)
}// 触发事件
func (es *EventSource) TriggerEvent(eventData interface{}) {for _, handler := range es.eventHandlers {handler(eventData)}
}

三、回调函数的实现 

// 单独定义的回调函数
func myEventHandler(data interface{}) {fmt.Println("Event handled by named function:", data)
}

四、事件检测 

func monitorEvents(eventSource *EventSource) {for {// 模拟检测事件，这里可以是实际的事件检测逻辑// 假设每2秒检测到一个事件time.Sleep(2 * time.Second)eventData := "Detected event!"eventSource.TriggerEvent(eventData)}
}

五、主函数实现 

func main() {eventSource := &EventSource{}// 注册单独定义的回调函数eventSource.RegisterHandler(myEventHandler)go monitorEvents(eventSource)// 让主程序持续运行，以保持监控事件的 goroutine 运行select {}
}