Go构建高性能的事件管理器实例详解

package events

type Event struct {
    Name string
    Data interface{}
}

type EventListener func(Event)

func NewEventListener(listener EventListener) EventListener {
    return listener
}

type Dispatcher struct {
    listeners map[string][]EventListener
}
func NewDispatcher() *Dispatcher {
    return &Dispatcher{
        listeners: make(map[string][]EventListener),
    }
}
func (d *Dispatcher) RegisterListener(eventName string, listener EventListener) {
    d.listeners[eventName] = append(d.listeners[eventName], listener)
}
func (d *Dispatcher) Dispatch(event Event) {
    for _, listener := range d.listeners[event.Name] {
        listener(event)
    }
}

func main() {
    dispatcher := events.NewDispatcher()
    // 注册事件监听器
    listener := events.NewEventListener(func(e events.Event) {
        fmt.Printf("Event received: %s\n", e.Name)
    })
    dispatcher.RegisterListener("testEvent", listener)
    // 触发事件
    dispatcher.Dispatch(events.Event{Name: "testEvent"})
}

func (d *Dispatcher) DispatchAsync(event Event) {
    for _, listener := range d.listeners[event.Name] {
        go listener(event) // 使用 goroutine 异步处理
    }
}

func (d *Dispatcher) Dispatch(event *Event) {
    for _, listener := range d.listeners[event.Name] {
        if event.Cancelled {
            break
        }
        if err := listener(event); err != nil {
            // 错误处理，例如打印日志、中断后续监听器执行等
            fmt.Printf("Error handling event %s: %v\n", event.Name, err)
            break
        }
    }
}

package events
type NetEvent struct {
    Type    string      // 事件类型，如 "connect", "disconnect", "receive"
    Conn    net.Conn    // 网络连接
    Message []byte      // 接收到的数据
    Err     error       // 错误信息
}

package main
import (
    "net"
    "fmt"
    "events"  // 假设这是我们自定义的事件包
)
func handleConnection(conn net.Conn, dispatcher *events.Dispatcher) {
    // 发送连接建立事件
    dispatcher.Dispatch(events.NetEvent{Type: "connect", Conn: conn})
    buffer := make([]byte, 1024)
    for {
        n, err := conn.Read(buffer)
        if err != nil {
            // 发送连接断开事件
            dispatcher.Dispatch(events.NetEvent{Type: "disconnect", Conn: conn, Err: err})
            return
        }
        // 发送数据接收事件
        dispatcher.Dispatch(events.NetEvent{Type: "receive", Conn: conn, Message: buffer[:n]})
    }
}
func startTCPServer(address string, dispatcher *events.Dispatcher) {
    listener, err := net.Listen("tcp", address)
    if err != nil {
        fmt.Println("Error starting TCP server:", err)
        return
    }
    for {
        conn, err := listener.Accept()
        if err != nil {
            fmt.Println("Error accepting connection:", err)
            continue
        }
        go handleConnection(conn, dispatcher)
    }
}
func main() {
    dispatcher := events.NewDispatcher()
    // 注册事件监听器
    // ...
    startTCPServer(":8080", dispatcher)
}

func main() {
    dispatcher := events.NewDispatcher()
    dispatcher.RegisterListener("connect", func(e events.Event) {
        netEvent := e.(events.NetEvent)
        fmt.Println("New connection:", netEvent.Conn.RemoteAddr())
    })
    dispatcher.RegisterListener("receive", func(e events.Event) {
        netEvent := e.(events.NetEvent)
        fmt.Printf("Received data: %s\n", string(netEvent.Message))
    })
    dispatcher.RegisterListener("disconnect", func(e events.Event) {
        netEvent := e.(events.NetEvent)
        fmt.Println("Connection closed:", netEvent.Conn.RemoteAddr())
    })
    startTCPServer(":8080", dispatcher)
}