Go语言事件处理如何实现

在Go语言中，事件处理通常是通过通道（channel）和goroutine来实现的。通道是Go语言中的一种内置数据结构，可以用于在不同的goroutine之间传递数据。goroutine是Go语言中的轻量级线程，可以并发执行。

下面是一个简单的示例，展示了如何使用通道和goroutine实现事件处理：

package main

import (
	"fmt"
	"time"
)

// 定义一个事件类型
type Event struct {
	ID int
	Message string
}

// 定义一个事件处理器接口
type EventHandler interface {
	HandleEvent(event Event)
}

// 定义一个具体的事件处理器
type MyEventHandler struct{}

func (h *MyEventHandler) HandleEvent(event Event) {
	fmt.Printf("处理事件: ID=%d, Message=%s\n", event.ID, event.Message)
}

// 定义一个事件分发器
type EventDispatcher struct {
	eventHandler EventHandler
	eventChan    chan Event
}

func NewEventDispatcher(eventHandler EventHandler) *EventDispatcher {
	return &EventDispatcher{
		eventHandler: eventHandler,
		eventChan:    make(chan Event),
	}
}

func (d *EventDispatcher) Start() {
	go func() {
		for event := range d.eventChan {
			d.eventHandler.HandleEvent(event)
		}
	}()
}

func (d *EventDispatcher) DispatchEvent(event Event) {
	d.eventChan <- event
}

func main() {
	// 创建一个事件处理器
	eventHandler := &MyEventHandler{}

	// 创建一个事件分发器
	eventDispatcher := NewEventDispatcher(eventHandler)

	// 启动事件分发器
	eventDispatcher.Start()

	// 分发一些事件
	for i := 0; i < 5; i++ {
		event := Event{
			ID: i,
			Message: fmt.Sprintf("这是事件 %d", i),
		}
		eventDispatcher.DispatchEvent(event)
		time.Sleep(1 * time.Second)
	}
}

在这个示例中，我们定义了一个Event类型来表示事件，一个EventHandler接口来定义事件处理的方法，以及一个具体的MyEventHandler结构体来实现事件处理。我们还定义了一个EventDispatcher结构体来分发事件，它包含一个事件处理器和一个事件通道。

EventDispatcher的Start方法启动一个新的goroutine来监听事件通道，并在接收到事件时调用事件处理器的HandleEvent方法。DispatchEvent方法用于向事件通道发送事件。

在main函数中，我们创建了一个事件处理器和一个事件分发器，然后启动事件分发器并分发一些事件。每个事件处理完成后，程序会等待1秒钟再发送下一个事件。