Golang实现一个简单的事件处理程序

1
2
3
4
5

.
├── events
│   └── event.go
├── go.mod
└── main.go

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

package events

type EventHandler func(event Event)

type Event interface {
	GetName() string
	GetData() interface{}
}

type EventBus struct {
	handlers map[string]EventHandler
}

func NewEventBus() *EventBus {
	return &EventBus{
		handlers: make(map[string]EventHandler),
	}
}

func (bus *EventBus) Register(name string, handler EventHandler) {
	bus.handlers[name] = handler
}

func (bus *EventBus) Dispatch(event Event) {
	if handler, ok := bus.handlers[event.GetName()]; ok {
		handler(event)
	}
}

func (bus *EventBus) DispatchAsync(event Event) {
	go bus.Dispatch(event)
}

var defaultEventBus *EventBus = nil

func init() {
	if defaultEventBus == nil {
		defaultEventBus = NewEventBus()
	}
}

func DefaultEventBus() *EventBus {
	return defaultEventBus
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12

const TickEventName = "TickerEvent"

type TickerEvent struct {
}

func (e TickerEvent) GetName() string {
	return TickEventName
}

func (e TickerEvent) GetData() interface{} {
	return time.Now()
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42

package main

import (
	"fmt"
	"simpleEvent/events"
	"time"
)

const TickEventName = "TickerEvent"

type TickerEvent struct {
}

func (e TickerEvent) GetName() string {
	return TickEventName
}

func (e TickerEvent) GetData() interface{} {
	return time.Now()
}

func makeEvents() {
	ticker := time.NewTicker(time.Second * 1)
	for true {
		<-ticker.C
		//触发事件
		events.DefaultEventBus().DispatchAsync(TickerEvent{})
	}
}

func main() {
	go makeEvents()

	//监听事件
	events.DefaultEventBus().Register(TickEventName, func(e events.Event) {
		fmt.Println("event received:", e.GetData())
	})

	for true {
		time.Sleep(time.Second * 10)
	}
}

1
2
3
4
5
6

event received: 2022-08-08 11:22:48.61607 +0800 CST m=+1.000275696
event received: 2022-08-08 11:22:49.616192 +0800 CST m=+2.000391077
event received: 2022-08-08 11:22:50.616163 +0800 CST m=+3.000355464
event received: 2022-08-08 11:22:51.616159 +0800 CST m=+4.000344450
event received: 2022-08-08 11:22:52.616195 +0800 CST m=+5.000373565
...