gookit/event
Go 实现的轻量级的事件管理、调度程序库, 支持设置监听器的优先级, 支持使用通配符来进行一组事件的监听。
*
来进行一组事件的匹配监听.ModeSimple
- 注册 app.db.*
事件的监听,触发 app.db.run
app.db.end
时,都将同时会触发 app.db.*
监听器ModePath
- NEW *
只匹配一段非 .
的字符,可以进行更精细的监听; **
匹配任意多个字符,只能用于开头或结尾*
来监听全部事件的触发chan
, 异步进行消费处理. 触发方法: Async(), FireAsync()
> 95%
go get github.com/gookit/event
On/Listen(name string, listener Listener, priority ...int)
注册事件监听Subscribe/AddSubscriber(sbr Subscriber)
订阅,支持注册多个事件监听Trigger/Fire(name string, params M) (error, Event)
触发事件MustTrigger/MustFire(name string, params M) Event
触发事件,有错误则会 panicFireEvent(e Event) (err error)
根据给定的事件实例,触发事件FireBatch(es ...interface{}) (ers []error)
一次触发多个事件Async/FireC(name string, params M)
触发投递事件到 chan
,异步消费处理FireAsync(e Event)
触发投递事件到 chan
,异步消费处理AsyncFire(e Event)
简单的通过 go
异步触发事件package main
import (
"fmt"
"github.com/gookit/event"
)
func main() {
// 注册事件监听器
event.On("evt1", event.ListenerFunc(func(e event.Event) error {
fmt.Printf("handle event: %s\n", e.Name())
return nil
}), event.Normal)
// 注册多个监听器
event.On("evt1", event.ListenerFunc(func(e event.Event) error {
fmt.Printf("handle event: %s\n", e.Name())
return nil
}), event.High)
// ... ...
// 触发事件
// 注意:第二个监听器的优先级更高,所以它会先被执行
event.MustFire("evt1", event.M{"arg0": "val0", "arg1": "val1"})
}
Note: 注意:第二个监听器的优先级更高,所以它会先被执行
可以使用 Async/FireC/FireAsync
方法触发事件,事件将会写入 chan 异步消费。可以使用 CloseWait()
关闭 chan 并等待事件全部消费完成。
新增配置选项:
ChannelSize
设置 chan
的缓冲大小ConsumerNum
设置启动多少个协程来消费事件func main() {
// 注意:在程序退出时关闭事件 chan
defer event.Close()
// defer event.CloseWait()
// 注册事件监听器
event.On("app.evt1", event.ListenerFunc(func(e event.Event) error {
fmt.Printf("handle event: %s\n", e.Name())
return nil
}), event.Normal)
// 注册多个监听器
event.On("app.evt1", event.ListenerFunc(func(e event.Event) error {
fmt.Printf("handle event: %s\n", e.Name())
return nil
}), event.High)
// ... ...
// 异步消费事件
event.FireC("app.evt1", event.M{"arg0": "val0", "arg1": "val1"})
}
Note: 应当在程序退出时关闭事件 chan. 可以使用下面的方法:
event.Close()
立即关闭 chan
不再接受新的事件event.CloseWait()
关闭 chan
并等待所有事件处理完成更多使用说明请看 README
1
ruanimal 2023-06-20 11:34:17 +08:00
感觉写 go 的真牛 x ,各种库信手拈来
|