cdk

RO_Server_Trunk-branch_0.1.39/rocommon/service/yamlconfig.go

@@ -106,6 +106,7 @@ type configServerDB struct {
 	Password     string   `yaml:"password"`
 	DBIndex      int      `yaml:"dbindex"`
 	DBIndex2     int      `yaml:"dbindex2"`
+	DBIndex3     int      `yaml:"dbindex3"`
 	MysqlAddr    string   `yaml:"mysqladdr"`
 	RedisCluster int      `yaml:"cluster"`
 }

RO_Server_Trunk-branch_0.1.39/roserver/gmweb/main.go

@@ -51,6 +51,16 @@ func main() {
 		}, sConfig)
 	}
 
+	msg.RedisCdk2 = service.NewNetRedisConnector(sConfig.Redis.RedisAddr,
+		sConfig.Redis.Password,
+		sConfig.Redis.DBIndex3,
+		sConfig.Redis.RedisCluster)
+	_, err := msg.RedisCdk2.RedisCli().Ping().Result()
+	if err != nil {
+		util.PanicF("New RedisConnector ping failed er=%v", err)
+		return
+	}
+
 	for _, concern := range sConfig.Node.Concern {
 		//建立需要链接的服务器,可以通过服务器发现etcd来处理(包含在了CreateConnector中)
 		baseserver.CreateConnector(baseserver.ServiceParam{