提交

rpc/config.json

@@ -0,0 +1,15 @@
+{
+  "mysql": {
+    "dbName": "messageCentertest",
+    "address": "am-2ze6crwd6bb0283jn167320o.ads.aliyuncs.com",
+    "userName": "jianyu",
+    "passWord": "topnet@123",
+    "maxOpenConns": 5,
+    "maxIdleConns": 5
+  },
+  "etcd": {
+    "address": "127.0.0.1:2379",
+    "jyUserCenterKey": "usercenter.rpc",
+    "jyResourceCenterKey": "resourcescenter.rpc"
+  }
+}

rpc/db/config.go

@@ -0,0 +1,42 @@
+package db
+
+import (
+	qutil "app.yhyue.com/moapp/jybase/common"
+	"app.yhyue.com/moapp/jybase/mysql"
+	"log"
+)
+
+var Config *config
+
+type config struct {
+	Mysql mysqlConf
+	Etcd  map[string]interface{}
+}
+
+type mysqlConf struct {
+	DbName       string
+	Address      string
+	UserName     string
+	PassWord     string
+	MaxOpenConns int
+	MaxIdleConns int
+}
+
+var MainMysql *mysql.Mysql
+
+func init() {
+	//程序配置文件
+	qutil.ReadConfig(&Config)
+
+	log.Println("开始初始化数据库。。。。。")
+	//初始化mysql
+	MainMysql = &mysql.Mysql{
+		Address:      Config.Mysql.Address,
+		UserName:     Config.Mysql.UserName,
+		PassWord:     Config.Mysql.PassWord,
+		DBName:       Config.Mysql.DbName,
+		MaxOpenConns: Config.Mysql.MaxOpenConns,
+		MaxIdleConns: Config.Mysql.MaxIdleConns,
+	}
+	MainMysql.Init()
+}

rpc/message.go

@@ -5,6 +5,7 @@ package main
 
 import (
 	"app.yhyue.com/moapp/MessageCenter/entity"
+	_ "app.yhyue.com/moapp/MessageCenter/rpc/db"
 	"app.yhyue.com/moapp/MessageCenter/rpc/internal/config"
 	"app.yhyue.com/moapp/MessageCenter/rpc/internal/server"
 	"app.yhyue.com/moapp/MessageCenter/rpc/internal/svc"
@@ -45,6 +46,7 @@ func main() {
 func init() {
 	conf.MustLoad(*configFile, &config.ConfigJson)
 	var err error
+
 	//连接etcd
 	entity.EtcdCli, err = clientv3.New(clientv3.Config{
 		Endpoints:   config.ConfigJson.Etcd.Hosts,
@@ -78,7 +80,6 @@ func init() {
 	//}
 	//fmt.Println(config.ConfigJson.DataSource + "链接成功")
 
-
 	//entity.Mysql, err = sql.Open("mysql", config.ConfigJson.Mysql)
 	//if err != nil {
 	//	panic(err.Error())