You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

225 lines
4.9 KiB

package ConfigUtil
import (
"dsData/Utils/CommonUtil"
"fmt"
"gopkg.in/ini.v1"
)
var (
// mysql数据库服务器配置
MysqlIp string
MysqlPort string
MysqlUser string
MysqlPwd string
MysqlDataBase string
//要发布到的主机信息
DistributeIp string
DistributePort int32
DistributeUser string
DistributePwd string
DistributeRemotePath string
DistributeLocalPath string
//服务器的端口
ServerPort string
//REDIS配置
RedisIp string
RedisPort string
RedisDb string
RedisExpireTime int64
//私有key
PrivateKey string
//kafka地址
KafkaAddress string
//kafka web日志主题
KafkaAccessLogTopic string
// kafka手工日志主题
KafkaManualLogTopic string
//Elasticsearch
ElasticSearchAddress string
//统一数据系统对应的token的redis前缀
SystemTokenPrefix string
)
//OAuth2在redis中的前缀
var OAuth2RedisKeyPrefix="oauth2"
func init() {
//判断是不是单元测试,如果是的话,那么配置文件的路径需要加上一个.
var configIniFile = "./Config/Config.ini"
//判断文件不是存在
if !CommonUtil.Exists(configIniFile) {
configIniFile = "." + configIniFile
}
iniParser := IniParser{}
if err := iniParser.Load(configIniFile); err != nil {
fmt.Printf("try load config file[%s] error[%s]\n", configIniFile, err.Error())
return
}
//主机
MysqlIp = iniParser.GetString("mysql", "ip")
//端口
MysqlPort = iniParser.GetString("mysql", "port")
//数据库名称
MysqlDataBase = iniParser.GetString("mysql", "database")
//用户
MysqlUser = iniParser.GetString("mysql", "user")
//密码
MysqlPwd = iniParser.GetString("mysql", "pwd")
//发布的远端IP
DistributeIp = iniParser.GetString("distribute", "ip")
//发布的远端端口
DistributePort = iniParser.GetInt32("distribute", "port")
//发布的远端用户名
DistributeUser = iniParser.GetString("distribute", "user")
//发布的远端密码
DistributePwd = iniParser.GetString("distribute", "pwd")
//远端路径
DistributeRemotePath = iniParser.GetString("distribute", "remotePath")
//本地路径
DistributeLocalPath = iniParser.GetString("distribute", "localPath")
//服务器端口
ServerPort = iniParser.GetString("server", "port")
//读取redis配置
RedisIp = iniParser.GetString("redis", "ip")
RedisPort = iniParser.GetString("redis", "port")
RedisDb = iniParser.GetString("redis", "db")
RedisExpireTime = iniParser.GetInt64("redis", "expireTime")
//kafka地址
KafkaAddress=iniParser.GetString("kafka", "KafkaAddress")
//kafka WEB日志主题
KafkaAccessLogTopic =iniParser.GetString("kafka", "KafkaAccessLogTopic")
//kafka 手工日志主题
KafkaManualLogTopic=iniParser.GetString("kafka", "KafkaManualLogTopic")
//Elasticsearch
ElasticSearchAddress=iniParser.GetString("elasticsearch", "address")
//sso的系统在redis中的前缀
SystemTokenPrefix =iniParser.GetString("sso", "system_token_prefix")
}
type IniParser struct {
confReader *ini.File // config reader
}
type IniParserError struct {
errorInfo string
}
func (e *IniParserError) Error() string { return e.errorInfo }
func (this *IniParser) Load(configFileName string) error {
conf, err := ini.Load(configFileName)
if err != nil {
this.confReader = nil
return err
}
this.confReader = conf
return nil
}
func (this *IniParser) GetString(section string, key string) string {
if this.confReader == nil {
return ""
}
s := this.confReader.Section(section)
if s == nil {
return ""
}
return s.Key(key).String()
}
func (this *IniParser) GetInt32(section string, key string) int32 {
if this.confReader == nil {
return 0
}
s := this.confReader.Section(section)
if s == nil {
return 0
}
valueInt, _ := s.Key(key).Int()
return int32(valueInt)
}
func (this *IniParser) GetUint32(section string, key string) uint32 {
if this.confReader == nil {
return 0
}
s := this.confReader.Section(section)
if s == nil {
return 0
}
valueInt, _ := s.Key(key).Uint()
return uint32(valueInt)
}
func (this *IniParser) GetInt64(section string, key string) int64 {
if this.confReader == nil {
return 0
}
s := this.confReader.Section(section)
if s == nil {
return 0
}
valueInt, _ := s.Key(key).Int64()
return valueInt
}
func (this *IniParser) GetUint64(section string, key string) uint64 {
if this.confReader == nil {
return 0
}
s := this.confReader.Section(section)
if s == nil {
return 0
}
valueInt, _ := s.Key(key).Uint64()
return valueInt
}
func (this *IniParser) GetFloat32(section string, key string) float32 {
if this.confReader == nil {
return 0
}
s := this.confReader.Section(section)
if s == nil {
return 0
}
valueFloat, _ := s.Key(key).Float64()
return float32(valueFloat)
}
func (this *IniParser) GetFloat64(section string, key string) float64 {
if this.confReader == nil {
return 0
}
s := this.confReader.Section(section)
if s == nil {
return 0
}
valueFloat, _ := s.Key(key).Float64()
return valueFloat
}