• 6.1 创建消息管理模块
    • A) 创建消息管理模块抽象类
    • B) 实现消息管理模块

    6.1 创建消息管理模块

    A) 创建消息管理模块抽象类

    在zinx/ziface下创建imsghandler.go文件。

    1. package ziface
    2. /*
    3.     消息管理抽象层
    4.  */
    5. type IMsgHandle interface{
    6.     DoMsgHandler(request IRequest)            //马上以非阻塞方式处理消息
    7.     AddRouter(msgId uint32, router IRouter)    //为消息添加具体的处理逻辑
    8. }

    这里面有两个方法，AddRouter()就是添加一个msgId和一个路由关系到Apis中，那么DoMsgHandler()则是调用Router中具体Handle()等方法的接口。

    B) 实现消息管理模块

    在zinx/znet下创建msghandler.go文件。

    1. package znet
    3. import (
    4.     "fmt"
    5.     "strconv"
    6.     "zinx/ziface"
    7. )
    9. type MsgHandle struct{
    10.     Apis map[uint32] ziface.IRouter //存放每个MsgId 所对应的处理方法的map属性
    11. }
    13. func NewMsgHandle() *MsgHandle {
    14.     return &MsgHandle {
    15.         Apis:make(map[uint32]ziface.IRouter),
    16.     }
    17. }
    19. //马上以非阻塞方式处理消息
    20. func (mh *MsgHandle) DoMsgHandler(request ziface.IRequest)    {
    21.     handler, ok := mh.Apis[request.GetMsgID()]
    22.     if !ok {
    23.         fmt.Println("api msgId = ", request.GetMsgID(), " is not FOUND!")
    24.         return
    25.     }
    27.     //执行对应处理方法
    28.     handler.PreHandle(request)
    29.     handler.Handle(request)
    30.     handler.PostHandle(request)
    31. }
    32. //为消息添加具体的处理逻辑
    33. func (mh *MsgHandle) AddRouter(msgId uint32, router ziface.IRouter) {
    34.     //1 判断当前msg绑定的API处理方法是否已经存在
    35.     if _, ok := mh.Apis[msgId]; ok {
    36.         panic("repeated api , msgId = " + strconv.Itoa(int(msgId)))
    37.     }
    38.     //2 添加msg与api的绑定关系
    39.     mh.Apis[msgId] = router
    40.     fmt.Println("Add api msgId = ", msgId)
    41. }