Blame view

common/conf.go 3.32 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 {
101d1cc1   zhangqijia   feat: 一个基于redis的自...
35
  	ID             int64      `yaml:"id"`
b499527e   zhangqijia   feat: 消息包用aes加密
36
37
38
  	Name           string     `yaml:"name"`
  	IP             string     `yaml:"ip"`
  	Port           int        `yaml:"port"`
b499527e   zhangqijia   feat: 消息包用aes加密
39
  	DebugPort      int        `yaml:"debugport"`
c47aa250   zhangqijia   feat: 增加GM相关接口。详情...
40
41
  	GMPort         int        `yaml:"gm"`
  	Encipher       bool       `yaml:"encipher"`
b499527e   zhangqijia   feat: 消息包用aes加密
42
43
44
45
  	MongoConf      *MongoConf `yaml:"mongo"`
  	RedisConf      *RedisConf `yaml:"redis"`
  	WorkerPoolSize int        `yaml:"pool_size"`
  	PluginPath     string     `yaml:"plugin_path"`
cad2b7f3   zhangqijia   reactor: 重构目录, 重构...
46
47
48
  }
  
  type LogConsole struct {
b499527e   zhangqijia   feat: 消息包用aes加密
49
50
  	Level string `yaml:"level" json:"level"`
  	Color bool   `yaml:"color" json:"color"`
cad2b7f3   zhangqijia   reactor: 重构目录, 重构...
51
52
53
  }
  
  type LogFile struct {
b499527e   zhangqijia   feat: 消息包用aes加密
54
55
56
57
58
59
60
  	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: 重构目录, 重构...
61
62
63
  }
  
  type LogConn struct {
b499527e   zhangqijia   feat: 消息包用aes加密
64
65
66
67
68
  	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: 重构目录, 重构...
69
70
71
  }
  
  type LogConf struct {
b499527e   zhangqijia   feat: 消息包用aes加密
72
73
74
75
  	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接服务器
76
77
  }
  
54b3f133   zhangqijia   add connector int...
78
  type TestClient struct {
b499527e   zhangqijia   feat: 消息包用aes加密
79
80
81
  	Ip    string `yaml:"ip"`
  	Port  int    `yaml:"port"`
  	Count int    `yaml:"count"`
54b3f133   zhangqijia   add connector int...
82
83
  }
  
ee23102d   zhangqijia   支持mongo, grpc接服务器
84
  type ServerConf struct {
b499527e   zhangqijia   feat: 消息包用aes加密
85
86
87
88
89
90
91
92
93
  	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接服务器
94
95
  }
  
b499527e   zhangqijia   feat: 消息包用aes加密
96
  var (
f415f471   zhangqijia   fix: roleID自增加上限制...
97
98
99
  	GlobalConf  ServerConf
  	GlobalSconf *SConf
  	SnowFlack   *snow.Snowflake
eb417b0b   zhangqijia   reactor mongo
100
  )
9644352a   zhangqijia   登录服改为http,游戏服改为长连...
101
  
ee23102d   zhangqijia   支持mongo, grpc接服务器
102
103
104
105
106
107
108
109
110
111
112
113
  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: 重构目录, 重构...
114
115
116
117
118
  	c, err := json.Marshal(&GlobalConf.LogConf)
  	if err != nil {
  		fmt.Errorf("log conf %v", err)
  		return
  	}
ee23102d   zhangqijia   支持mongo, grpc接服务器
119
  	//初始化日志
cad2b7f3   zhangqijia   reactor: 重构目录, 重构...
120
121
122
123
124
  	err = logger.SetLogger(string(c), strings.ToLower(GlobalConf.GameConf.Name))
  	if err != nil {
  		fmt.Errorf("log conf %v", err)
  		return
  	}
ee23102d   zhangqijia   支持mongo, grpc接服务器
125
126
  
  	//初始化雪花算法
436e0af4   zhangqijia   reactor: dir; Ac...
127
  	SnowFlack = snow.NewSnowflake(GlobalConf.WorkerID, GlobalConf.DatacenterID)
b499527e   zhangqijia   feat: 消息包用aes加密
128
  }