From 3502013cce0a25e5e2953378b5a58076a05c582b Mon Sep 17 00:00:00 2001 From: liuxiaobo <1224730913@qq.com> Date: Mon, 16 Jun 2025 01:05:57 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E6=97=A5=E5=BF=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- db/db.go | 5 ++++- service/natsService.go | 1 + 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/db/db.go b/db/db.go index 271175d..cb732e8 100644 --- a/db/db.go +++ b/db/db.go @@ -7,6 +7,7 @@ import ( "gorm.io/driver/mysql" "gorm.io/gorm" "gorm.io/gorm/schema" + "net/url" ) func InitMysql(username, password, address, port, dbName string) (*gorm.DB, error) { @@ -29,7 +30,9 @@ func InitRedis(password, address, port string, dbName int) (*redis.Client, error } func InitClickHouse(host, port, user, password, database string) (*gorm.DB, error) { - dsn := fmt.Sprintf("tcp://%v:%v?database=%v&username=%v&password=%v&read_timeout=10&write_timeout=20", host, port, database, user, password) + password = url.QueryEscape(password) + dsn := fmt.Sprintf("clickhouse://%v:%v?database=%v&username=%v&password=%v&read_timeout=10s", host, port, database, user, password) + fmt.Println(dsn) db, err := gorm.Open(clickhouse.Open(dsn), &gorm.Config{ Logger: &dbLogger{}, NamingStrategy: schema.NamingStrategy{ diff --git a/service/natsService.go b/service/natsService.go index a4275d4..bdfd882 100644 --- a/service/natsService.go +++ b/service/natsService.go @@ -107,6 +107,7 @@ func (n *NatsService) subscribeRpc() error { return n.SubscribeCb(RpcTopic(n), func(m *nats.Msg) { var iMsg = &ipb.InternalMsg{} _ = proto.Unmarshal(m.Data, iMsg) + log.DebugF("recv rpc msg:%v", iMsg.String()) rsp, err := n.RpcProcessor.Dispatch(iMsg.RpcMsgId, iMsg) if err != nil { log.Error(err.Error())