• 8.1 创建消息队列

    8.1 创建消息队列

    首先，处理消息队列的部分，我们应该集成到MsgHandler模块下，因为属于我们消息模块范畴内的

    zinx/znet/msghandler.go

    1. type MsgHandle struct {
    2.     Apis           map[uint32]ziface.IRouter  //存放每个MsgId 所对应的处理方法的map属性
    3.     WorkerPoolSize uint32                     //业务工作Worker池的数量
    4.     TaskQueue      []chan ziface.IRequest     //Worker负责取任务的消息队列
    5. }
    7. func NewMsgHandle() *MsgHandle {
    8.     return &MsgHandle{
    9.         Apis: make(map[uint32]ziface.IRouter),
    10.         WorkerPoolSize:utils.GlobalObject.WorkerPoolSize,
    11.         //一个worker对应一个queue
    12.         TaskQueue:make([]chan ziface.IRequest, utils.GlobalObject.WorkerPoolSize), 
    13.     }
    14. }

    这里添加两个成员

    WokerPoolSize:作为工作池的数量，因为TaskQueue中的每个队列应该是和一个Worker对应的，所以我们在创建TaskQueue中队列数量要和Worker的数量一致。

    TaskQueue真是一个Request请求信息的channel集合。用来缓冲提供worker调用的Request请求信息，worker会从对应的队列中获取客户端的请求数据并且处理掉。

    当然WorkerPoolSize最好也可以从GlobalObject获取，并且zinx.json配置文件可以手动配置。

    zinx/utils/globalobj.go

    1. /*
    2.     存储一切有关Zinx框架的全局参数，供其他模块使用
    3.     一些参数也可以通过 用户根据 zinx.json来配置
    4. */
    5. type GlobalObj struct {
    6.     /*
    7.         Server
    8.     */
    9.     TcpServer ziface.IServer //当前Zinx的全局Server对象
    10.     Host      string         //当前服务器主机IP
    11.     TcpPort   int            //当前服务器主机监听端口号
    12.     Name      string         //当前服务器名称
    14.     /*
    15.         Zinx
    16.     */
    17.     Version          string //当前Zinx版本号
    18.     MaxPacketSize    uint32 //都需数据包的最大值
    19.     MaxConn          int    //当前服务器主机允许的最大链接个数
    20.     WorkerPoolSize   uint32 //业务工作Worker池的数量
    21.     MaxWorkerTaskLen uint32 //业务工作Worker对应负责的任务队列最大任务存储数量
    23.     /*
    24.         config file path
    25.     */
    26.     ConfFilePath string
    27. }
    29. //...
    30. //...
    32. /*
    33.     提供init方法，默认加载
    34. */
    35. func init() {
    36.     //初始化GlobalObject变量，设置一些默认值
    37.     GlobalObject = &GlobalObj{
    38.         Name:          "ZinxServerApp",
    39.         Version:       "V0.4",
    40.         TcpPort:       7777,
    41.         Host:          "0.0.0.0",
    42.         MaxConn:       12000,
    43.         MaxPacketSize: 4096,
    44.         ConfFilePath:  "conf/zinx.json",
    45.         WorkerPoolSize: 10,
    46.         MaxWorkerTaskLen: 1024,
    47.     }
    49.     //从配置文件中加载一些用户配置的参数
    50.     GlobalObject.Reload()
    51. }