基于dispatcher模式的事件与数据分发处理器的go语言实现( 二 )

2023-01-30 dispatcher

应用创建EventServer
type EventServer struct {IDispatchCenter}func NewEventServer() *EventServer { es := &EventServer{IDispatchCenter: NewDataDispatchCenter(), } return es}定义事件
type MyEvent struct { namespace string keystring eventstring data[]byte}func (m *MyEvent) Namespace() string { return m.namespace}func (m *MyEvent) Event() string { return m.event}func (m *MyEvent) Key() string { return m.key}func (m *MyEvent) Data() []byte { return m.data}定义Handler并注册
func Handler(e IEvent) error {//根据自己的业务要求}es.Register(Handler)发送事件
es.Send(&MyEvent{namespace: "a",key:"b",event:"set",data:[]byte(fmt.Sprint(index)),})

【基于dispatcher模式的事件与数据分发处理器的go语言实现】