Blame view

common/conf.go 3.26 KB
765431a4   zhangqijia   增加schema接口, 抽象 mo...
1
  package common
ee23102d   zhangqijia   支持mongo, grpc接服务器
2
3
  
  import (
cad2b7f3   zhangqijia   reactor: 重构目录, 重构...
4
  	"encoding/json"
ee23102d   zhangqijia   支持mongo, grpc接服务器
5
  	"fmt"
ee23102d   zhangqijia   支持mongo, grpc接服务器
6
7
  	"gopkg.in/yaml.v3"
  	"io/ioutil"
765431a4   zhangqijia   增加schema接口, 抽象 mo...
8
  	"pro2d/common/logger"
436e0af4   zhangqijia   reactor: dir; Ac...
9
  	"pro2d/common/snow"
cad2b7f3   zhangqijia   reactor: 重构目录, 重构...
10
  	"strings"
ee23102d   zhangqijia   支持mongo, grpc接服务器
11
12
13
14
  )
  
  type RedisConf struct {
  	Address string `json:"address"`
b499527e   zhangqijia   feat: 消息包用aes加密
15
16
  	Auth    string `json:"auth"`
  	DB      int    `json:"db"`
ee23102d   zhangqijia   支持mongo, grpc接服务器
17
18
  }
  
ee23102d   zhangqijia   支持mongo, grpc接服务器
19
  type Etcd struct {
b499527e   zhangqijia   feat: 消息包用aes加密
20
21
  	Endpoints   []string `json:"endpoints"`
  	DialTimeout int      `json:"dialtimeout"`
ee23102d   zhangqijia   支持mongo, grpc接服务器
22
23
24
  }
  
  type MongoConf struct {
b499527e   zhangqijia   feat: 消息包用aes加密
25
26
27
28
29
30
31
  	User     string `yaml:"user"`
  	Password string `yaml:"password"`
  	Host     string `yaml:"host"`
  	Port     int    `yaml:"port"`
  	TimeOut  int    `yaml:"timeout"`
  	MaxNum   int    `yaml:"maxnum"`
  	DBName   string `yaml:"dbname"`
ee23102d   zhangqijia   支持mongo, grpc接服务器
32
33
  }
  
ee23102d   zhangqijia   支持mongo, grpc接服务器
34
  type SConf struct {
b499527e   zhangqijia   feat: 消息包用aes加密
35
36
37
38
39
40
41
42
43
44
  	ID             string     `yaml:"id"`
  	Name           string     `yaml:"name"`
  	IP             string     `yaml:"ip"`
  	Port           int        `yaml:"port"`
  	Encipher       bool       `yaml:"encipher"`
  	DebugPort      int        `yaml:"debugport"`
  	MongoConf      *MongoConf `yaml:"mongo"`
  	RedisConf      *RedisConf `yaml:"redis"`
  	WorkerPoolSize int        `yaml:"pool_size"`
  	PluginPath     string     `yaml:"plugin_path"`
cad2b7f3   zhangqijia   reactor: 重构目录, 重构...
45
46
47
  }
  
  type LogConsole struct {
b499527e   zhangqijia   feat: 消息包用aes加密
48
49
  	Level string `yaml:"level" json:"level"`
  	Color bool   `yaml:"color" json:"color"`
cad2b7f3   zhangqijia   reactor: 重构目录, 重构...
50
51
52
  }
  
  type LogFile struct {
b499527e   zhangqijia   feat: 消息包用aes加密
53
54
55
56
57
58
59
  	Level    string `yaml:"level" json:"level"`
  	Daily    bool   `yaml:"daily" json:"daily"`
  	Maxlines int    `yaml:"maxlines" json:"maxlines"`
  	Maxsize  int    `yaml:"maxsize" json:"maxsize"`
  	Maxdays  int    `yaml:"maxdays" json:"maxdays"`
  	Append   bool   `yaml:"append" json:"append"`
  	Permit   string `yaml:"permit" json:"permit"`
cad2b7f3   zhangqijia   reactor: 重构目录, 重构...
60
61
62
  }
  
  type LogConn struct {
b499527e   zhangqijia   feat: 消息包用aes加密
63
64
65
66
67
  	Net            string `yaml:"net" json:"net"`
  	Addr           string `yaml:"addr" json:"addr"`
  	Level          string `yaml:"level" json:"level"`
  	Reconnect      bool   `yaml:"reconnect" json:"reconnect"`
  	ReconnectOnMsg bool   `yaml:"reconnectOnMsg" json:"reconnectOnMsg"`
cad2b7f3   zhangqijia   reactor: 重构目录, 重构...
68
69
70
  }
  
  type LogConf struct {
b499527e   zhangqijia   feat: 消息包用aes加密
71
72
73
74
  	TimeFormat string      `yaml:"TimeFormat" json:"TimeFormat"`
  	LogConsole *LogConsole `yaml:"Console" json:"Console"`
  	LogFile    *LogFile    `yaml:"File" json:"File"`
  	LogConn    *LogConn    `yaml:"Conn" json:"Conn"`
ee23102d   zhangqijia   支持mongo, grpc接服务器
75
76
  }
  
54b3f133   zhangqijia   add connector int...
77
  type TestClient struct {
b499527e   zhangqijia   feat: 消息包用aes加密
78
79
80
  	Ip    string `yaml:"ip"`
  	Port  int    `yaml:"port"`
  	Count int    `yaml:"count"`
54b3f133   zhangqijia   add connector int...
81
82
  }
  
ee23102d   zhangqijia   支持mongo, grpc接服务器
83
  type ServerConf struct {
b499527e   zhangqijia   feat: 消息包用aes加密
84
85
86
87
88
89
90
91
92
  	ID           string      `yaml:"id"`
  	Name         string      `yaml:"name"`
  	WorkerID     int64       `yaml:"workerid"`
  	DatacenterID int64       `yaml:"datacenterid"`
  	AccountConf  *SConf      `yaml:"server_account"`
  	GameConf     *SConf      `yaml:"server_game"`
  	LogConf      *LogConf    `yaml:"logconf" json:"logconf"`
  	TestClient   *TestClient `yaml:"test_client"`
  	Etcd         *Etcd       `yaml:"etcd"`
ee23102d   zhangqijia   支持mongo, grpc接服务器
93
94
  }
  
b499527e   zhangqijia   feat: 消息包用aes加密
95
  var (
eb417b0b   zhangqijia   reactor mongo
96
  	GlobalConf ServerConf
436e0af4   zhangqijia   reactor: dir; Ac...
97
  	SnowFlack  *snow.Snowflake
eb417b0b   zhangqijia   reactor mongo
98
  )
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
99
  
ee23102d   zhangqijia   支持mongo, grpc接服务器
100
101
102
103
104
105
106
107
108
109
110
111
  func init() {
  	configFile, err := ioutil.ReadFile("conf/conf.yaml")
  	if err != nil {
  		fmt.Printf("conf faild: %v", err)
  		return
  	}
  	//初始化配置
  	if err = yaml.Unmarshal(configFile, &GlobalConf); err != nil {
  		fmt.Printf("yaml unmarshal faild: %v", err)
  		return
  	}
  
cad2b7f3   zhangqijia   reactor: 重构目录, 重构...
112
113
114
115
116
  	c, err := json.Marshal(&GlobalConf.LogConf)
  	if err != nil {
  		fmt.Errorf("log conf %v", err)
  		return
  	}
ee23102d   zhangqijia   支持mongo, grpc接服务器
117
  	//初始化日志
cad2b7f3   zhangqijia   reactor: 重构目录, 重构...
118
119
120
121
122
  	err = logger.SetLogger(string(c), strings.ToLower(GlobalConf.GameConf.Name))
  	if err != nil {
  		fmt.Errorf("log conf %v", err)
  		return
  	}
ee23102d   zhangqijia   支持mongo, grpc接服务器
123
124
  
  	//初始化雪花算法
436e0af4   zhangqijia   reactor: dir; Ac...
125
  	SnowFlack = snow.NewSnowflake(GlobalConf.WorkerID, GlobalConf.DatacenterID)
b499527e   zhangqijia   feat: 消息包用aes加密
126
  }