| | |
|---|
| | | "encoding/json" |
|---|
| | | "errors" |
|---|
| | | "fmt" |
|---|
| | | "github.com/go-yaml/yaml" |
|---|
| | | "github.com/golang/protobuf/proto" |
|---|
| | | "io/ioutil" |
|---|
| | | "math" |
|---|
| | | "nanomsg.org/go-mangos" |
|---|
| | | "nanomsg.org/go-mangos/protocol/req" |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | func Init() { |
|---|
| | | data, err := ioutil.ReadFile("./config/conf.yml") |
|---|
| | | if err != nil { |
|---|
| | | fmt.Println("读取配置文件出错--", err) |
|---|
| | | logger.Error("读取配置文件出错--", err) |
|---|
| | | } |
|---|
| | | c := conf{} |
|---|
| | | //把yaml形式的字符串解析成struct类型 |
|---|
| | | yaml.Unmarshal(data, &c) |
|---|
| | | logger.Debug("配置文件的值为：", c) |
|---|
| | | serverIp = c.ServerIp |
|---|
| | | serverPort = c.ServerPort |
|---|
| | | dbTablePersons = c.DbTablePersons |
|---|
| | | localConfig, err1 := cache.GetServerInfo() |
|---|
| | | if err1 != nil { |
|---|
| | | logger.Error("查询本机信息失败！") |
|---|
| | | } |
|---|
| | | //logger.Debug("本机信息和server信息：", localConfig, serverIp, serverPort) |
|---|
| | | //bigCache.Init(dbTablePersons, serverIp, serverPort, localConfig.ServerId) |
|---|
| | | go Push1() |
|---|
