# 修改错误配置项

main.go

@@ -29,7 +29,7 @@ func main() {
 
 	logger := log.New(file, "[Info]", log.LstdFlags|log.Llongfile)
 
-	logger.Println("项目启动" + port)
+	logger.Println(conf.GlobalConfig.AppName + "项目启动, port:" + port + ",环境:" + conf.GlobalConfig.Env)
 	defer logger.Println("项目结束")
 
 	//初始化redis连接池

service/conf/config.go

@@ -5,6 +5,7 @@ import "time"
 type Config struct {
 	AppName string `json:"app_name"`
 	Port string `json:"port"`
+	Env string
 	Redis Redis `json:"redis"`
 	Kafka Kafka `json:"kafka"`
 	InfluxDb InfluxDb `json:"influx_db"`

service/conf/dev/conf.json

@@ -13,6 +13,6 @@
   },
   "influx_db": {
     "host": "http://192.168.4.100",
-    "port": "8066"
+    "port": "8086"
   }
 }

service/conf/load_conf.go

@@ -21,6 +21,7 @@ func Init() {
 		fmt.Println("启动报错：未找到对应的环境变量配置。env: " + filename)
 	}
 	err = json.Unmarshal(bytes, &GlobalConfig)
+	GlobalConfig.Env = denv
 	if nil != err {
 		fmt.Println(err)
 	}

service/data/influxdb_conf.go

@@ -8,7 +8,7 @@ import (
 
 func NewClient() client.Client {
 	var httpConfig = client.HTTPConfig{
-		Addr: conf.GlobalConfig.InfluxDb.Host + conf.GlobalConfig.InfluxDb.Port,
+		Addr: conf.GlobalConfig.InfluxDb.Host + ":" + conf.GlobalConfig.InfluxDb.Port,
 	}
 	con, err := client.NewHTTPClient(httpConfig)
 

service/data/redis_conf.go

@@ -36,7 +36,7 @@ func newPool(server, password string) *redis.Pool {
 
 var (
 	Pool          *redis.Pool
-	redisServer   = flag.String("redisServer", "172.30.12.2:6379", "")
+	redisServer   = flag.String("redisServer", conf.GlobalConfig.Redis.Host+":"+conf.GlobalConfig.Redis.Port, "")
 	redisPassword = flag.String("redisPassword", "", "")
 )