use yuying env

liuxiaolong

2020-07-31 4579712dbef6eeb940a9e26409dab745313b5e8a

use yuying env

 extend/config/config.go

@@ -1,37 +1,37 @@
package config

import (
    "github.com/spf13/viper"
    "log"
)

type server []ServerInfo

type ServerInfo struct {
    ServerId string `mapstructure: "serverId"`
    ServerIp string `mapstructure: "serverIp"`
    VideoPort string   `mapstructure: "videoPort"`
    NgxIp string  `mapstructure: "ngxIp"`
    NgxPort string   `mapstructure: "ngxPort"`
}

var serverList = &server{}

var ServerMap = make(map[string]string,0)
var NgxMap = make(map[string]string,0)
func Init(env string, configPath string) {
    var err error
    viper.SetConfigType("yaml")
    viper.SetConfigName(env)
    viper.AddConfigPath(configPath)
    err = viper.ReadInConfig()
    if err != nil {
        log.Fatal("error on parsing configuration file",err)
    }
    viper.UnmarshalKey("server", serverList)
    for _,s :=range *serverList {
        si := s
        ServerMap[si.ServerId] = "http://"+si.ServerIp+":"+si.VideoPort+"/getRecordVideoPath"
        NgxMap[si.ServerId] = "http://"+si.NgxIp+":"+si.NgxPort+"/videosource"
    }
}
//import (
//    "github.com/spf13/viper"
//    "log"
//)
//
//type server []ServerInfo
//
//type ServerInfo struct {
//    ServerId string `mapstructure: "serverId"`
//    ServerIp string `mapstructure: "serverIp"`
//    VideoPort string   `mapstructure: "videoPort"`
//    NgxIp string  `mapstructure: "ngxIp"`
//    NgxPort string   `mapstructure: "ngxPort"`
//}
//
//var serverList = &server{}
//
//var ServerMap = make(map[string]string,0)
//var NgxMap = make(map[string]string,0)
//func Init(env string, configPath string) {
//    var err error
//    viper.SetConfigType("yaml")
//    viper.SetConfigName(env)
//    viper.AddConfigPath(configPath)
//    err = viper.ReadInConfig()
//    if err != nil {
//        log.Fatal("error on parsing configuration file",err)
//    }
//    viper.UnmarshalKey("server", serverList)
//    for _,s :=range *serverList {
//        si := s
//        ServerMap[si.ServerId] = "http://"+si.ServerIp+":"+si.VideoPort+"/getRecordVideoPath"
//        NgxMap[si.ServerId] = "http://"+si.NgxIp+":"+si.NgxPort+"/videosource"
//    }
//}

 server.go

@@ -9,13 +9,12 @@
    "time"

    "andriodServer/esutil"
    "andriodServer/extend/config"
    "andriodServer/log"
    "github.com/streadway/amqp"
)

var addr = flag.String("addr", "0.0.0.0", "The address to listen to")
var Eurl = flag.String("eurl", "http://192.168.20.10:9200/", "The port to listen on")
var Eurl = flag.String("eurl", "http://172.16.50.57:9200/", "The port to listen on")
//var Picurl = flag.String("picurl", "http://58.118.225.79:41242/", "picture url")

var port = flag.Int("port", 6000, "The port to listen on")
@@ -25,17 +24,15 @@
var IsHub = flag.String("hub", "hub", "hub is personIsHub=1")
var Size = flag.Int("size", 100, "size default is 100")
var env = flag.String("env", "config", "env set")
var mqIp = flag.String("mqIp", "192.168.20.10", "default mq ip")
var mqIp = flag.String("mqIp", "172.16.50.57", "default mq ip")
var mqPort = flag.Int("mqPort", 5672, "default mq port")
var mqUser = flag.String("mqUser", "basic", "default rabbitmq user")
var mqPass = flag.String("mqPass", "basic", "default rabbitmq pass")
var confPath = flag.String("confPath", "/home/basic/Apps/go/AndroidAlarmServer/config/","default config path")

func main() {
    flag.Parse()

    log.SetLogLevel(*Level)
    config.Init(*env, *confPath)
    fmt.Println(*port)

    controllers.EsUrl = *Eurl