|
|
@@ -5,18 +5,15 @@ package main
|
|
|
|
|
|
import (
|
|
|
"app.yhyue.com/moapp/MessageCenter/entity"
|
|
|
- "flag"
|
|
|
- "fmt"
|
|
|
- "github.com/go-xorm/xorm"
|
|
|
- clientv3 "go.etcd.io/etcd/client/v3"
|
|
|
- "log"
|
|
|
- "time"
|
|
|
-
|
|
|
"app.yhyue.com/moapp/MessageCenter/rpc/internal/config"
|
|
|
"app.yhyue.com/moapp/MessageCenter/rpc/internal/server"
|
|
|
"app.yhyue.com/moapp/MessageCenter/rpc/internal/svc"
|
|
|
"app.yhyue.com/moapp/MessageCenter/rpc/message"
|
|
|
+ "flag"
|
|
|
+ "fmt"
|
|
|
_ "github.com/go-sql-driver/mysql"
|
|
|
+ "github.com/go-xorm/xorm"
|
|
|
+ "log"
|
|
|
|
|
|
"github.com/tal-tech/go-zero/core/conf"
|
|
|
"github.com/tal-tech/go-zero/zrpc"
|
|
|
@@ -24,7 +21,6 @@ import (
|
|
|
)
|
|
|
|
|
|
var configFile = flag.String("f", "etc/message.yaml", "the config file")
|
|
|
-var EtcdCli *clientv3.Client
|
|
|
|
|
|
func main() {
|
|
|
flag.Parse()
|
|
|
@@ -55,16 +51,5 @@ func init() {
|
|
|
log.Fatal("数据库连接失败:", err)
|
|
|
}
|
|
|
fmt.Println(config.ConfigJson.DataSource + "链接成功")
|
|
|
-
|
|
|
- //var err error
|
|
|
- EtcdCli, err = clientv3.New(clientv3.Config{
|
|
|
- Endpoints: config.ConfigJson.Etcd.Hosts,
|
|
|
- DialTimeout: 5 * time.Second,
|
|
|
- })
|
|
|
- if err != nil {
|
|
|
- // handle error!
|
|
|
- log.Printf("connect to etcd failed, err:%v\n", err)
|
|
|
- return
|
|
|
- }
|
|
|
- log.Println("connect to etcd success")
|
|
|
+
|
|
|
}
|
