Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type IMsgHandle ¶
type IMsgHandle interface { DoMsgHandler(request IMessage, workerID int) //马上以非阻塞方式处理消息 AddRouter(bizType string, router IRouter) //为消息添加具体的处理逻辑 StartWorkerPool() //启动worker工作池 SendMsgToTaskQueue(request IMessage) //将消息交给TaskQueue,由worker进行处理 StartOneWorker(workerID int, taskQueue chan IMessage) Stop() Stat() []atomic2.Int64 }
消息管理抽象层
Click to show internal directories.
Click to hide internal directories.