package utils import ( "encoding/json" "github.com/aceld/zinx/ziface" "github.com/aceld/zinx/zlog" "io/ioutil" "os" ) /* 存储一切有关Zinx框架的全局参数,供其他模块使用 一些参数也可以通过 用户根据 zinx.json来配置 */ type GlobalObj struct { /* Server */ TcpServer ziface.IServer //当前Zinx的全局Server对象 Host string //当前服务器主机IP TcpPort int //当前服务器主机监听端口号 Name string //当前服务器名称 /* Zinx */ Version string //当前Zinx版本号 MaxPacketSize uint32 //都需数据包的最大值 MaxConn int //当前服务器主机允许的最大链接个数 WorkerPoolSize uint32 //业务工作Worker池的数量 MaxWorkerTaskLen uint32 //业务工作Worker对应负责的任务队列最大任务存储数量 MaxMsgChanLen uint32 //SendBuffMsg发送消息的缓冲最大长度 /* config file path */ ConfFilePath string /* logger */ LogDir string //日志所在文件夹 默认"./log" LogFile string //日志文件名称 默认"" --如果没有设置日志文件,打印信息将打印至stderr LogDebugClose bool //是否关闭Debug日志级别调试信息 默认false -- 默认打开debug信息 } /* 定义一个全局的对象 */ var GlobalObject *GlobalObj //判断一个文件是否存在 func PathExists(path string) (bool, error) { _, err := os.Stat(path) if err == nil { return true, nil } if os.IsNotExist(err) { return false, nil } return false, err } //读取用户的配置文件 func (g *GlobalObj) Reload() { if confFileExists, _ := PathExists(g.ConfFilePath); confFileExists != true { //fmt.Println("Config File ", g.ConfFilePath , " is not exist!!") return } data, err := ioutil.ReadFile(g.ConfFilePath) if err != nil { panic(err) } //将json数据解析到struct中 err = json.Unmarshal(data, g) if err != nil { panic(err) } //Logger 设置 if g.LogFile != "" { zlog.SetLogFile(g.LogDir, g.LogFile) } if g.LogDebugClose == true { zlog.CloseDebug() } } /* 提供init方法,默认加载 */ func init() { pwd, err := os.Getwd() if err != nil { pwd = "." } //初始化GlobalObject变量,设置一些默认值 GlobalObject = &GlobalObj{ Name: "ZinxServerApp", Version: "V0.11", TcpPort: 8999, Host: "0.0.0.0", MaxConn: 12000, MaxPacketSize: 4096, ConfFilePath: pwd+"/conf/zinx.json", WorkerPoolSize: 10, MaxWorkerTaskLen: 1024, MaxMsgChanLen: 1024, LogDir: pwd+"/log", LogFile: "", LogDebugClose: false, } //从配置文件中加载一些用户配置的参数 GlobalObject.Reload() }