From 10cf431ccf48e9fcf84c584ac128f8877cd66075 Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Thu, 9 Mar 2023 14:43:09 +0800 Subject: [PATCH 01/12] script --- cmd/rpc/auth/main.go | 2 +- pkg/common/cmd/rpc.go | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/cmd/rpc/auth/main.go b/cmd/rpc/auth/main.go index 634162e4b..8923228ba 100644 --- a/cmd/rpc/auth/main.go +++ b/cmd/rpc/auth/main.go @@ -12,7 +12,7 @@ func main() { authCmd := cmd.NewAuthCmd() authCmd.AddPortFlag() authCmd.AddPrometheusPortFlag() - if err := authCmd.Execute(); err != nil { + if err := authCmd.Exec(); err != nil { fmt.Println(err.Error()) os.Exit(1) } diff --git a/pkg/common/cmd/rpc.go b/pkg/common/cmd/rpc.go index 3e7ee4f30..20ed935ab 100644 --- a/pkg/common/cmd/rpc.go +++ b/pkg/common/cmd/rpc.go @@ -17,9 +17,10 @@ func NewAuthCmd() *AuthCmd { } func (a *AuthCmd) Exec() error { - a.Command.Run = func(cmd *cobra.Command, args []string) { + a.Command.RunE = func(cmd *cobra.Command, args []string) error { a.port = a.getPortFlag(cmd) a.prometheusPort = a.getPrometheusPortFlag(cmd) + return a.getConfFromCmdAndInit(cmd) } return a.Execute() } From 82f499f942fc426b032bfcaaad8f2421ad88d6a3 Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Thu, 9 Mar 2023 14:54:05 +0800 Subject: [PATCH 02/12] script --- cmd/rpc/auth/main.go | 2 +- cmd/rpc/conversation/main.go | 6 +++++- cmd/rpc/friend/main.go | 6 +++++- cmd/rpc/group/main.go | 6 +++++- cmd/rpc/msg/main.go | 6 +++++- cmd/rpc/third/main.go | 6 +++++- cmd/rpc/user/main.go | 6 +++++- pkg/common/cmd/push.go | 2 +- pkg/common/cmd/root.go | 4 ++-- pkg/common/cmd/rpc.go | 13 ++++++------- 10 files changed, 40 insertions(+), 17 deletions(-) diff --git a/cmd/rpc/auth/main.go b/cmd/rpc/auth/main.go index 8923228ba..f1417366f 100644 --- a/cmd/rpc/auth/main.go +++ b/cmd/rpc/auth/main.go @@ -9,7 +9,7 @@ import ( ) func main() { - authCmd := cmd.NewAuthCmd() + authCmd := cmd.NewRpcCmd() authCmd.AddPortFlag() authCmd.AddPrometheusPortFlag() if err := authCmd.Exec(); err != nil { diff --git a/cmd/rpc/conversation/main.go b/cmd/rpc/conversation/main.go index 4e5006815..aa81a8de1 100644 --- a/cmd/rpc/conversation/main.go +++ b/cmd/rpc/conversation/main.go @@ -12,7 +12,11 @@ func main() { rpcCmd := cmd.NewRpcCmd() rpcCmd.AddPortFlag() rpcCmd.AddPrometheusPortFlag() - if err := rpcCmd.Exec(config.Config.RpcRegisterName.OpenImConversationName, conversation.Start); err != nil { + if err := rpcCmd.Exec(); err != nil { + fmt.Println(err.Error()) + os.Exit(1) + } + if err := rpcCmd.StartSvr(config.Config.RpcRegisterName.OpenImConversationName, conversation.Start); err != nil { fmt.Println(err.Error()) os.Exit(1) } diff --git a/cmd/rpc/friend/main.go b/cmd/rpc/friend/main.go index caf5750bf..7be637804 100644 --- a/cmd/rpc/friend/main.go +++ b/cmd/rpc/friend/main.go @@ -12,7 +12,11 @@ func main() { rpcCmd := cmd.NewRpcCmd() rpcCmd.AddPortFlag() rpcCmd.AddPrometheusPortFlag() - if err := rpcCmd.Exec(config.Config.RpcRegisterName.OpenImFriendName, friend.Start); err != nil { + if err := rpcCmd.Exec(); err != nil { + fmt.Println(err.Error()) + os.Exit(1) + } + if err := rpcCmd.StartSvr(config.Config.RpcRegisterName.OpenImFriendName, friend.Start); err != nil { fmt.Println(err.Error()) os.Exit(1) } diff --git a/cmd/rpc/group/main.go b/cmd/rpc/group/main.go index 1a4fa1355..0a96d28d4 100644 --- a/cmd/rpc/group/main.go +++ b/cmd/rpc/group/main.go @@ -12,7 +12,11 @@ func main() { rpcCmd := cmd.NewRpcCmd() rpcCmd.AddPortFlag() rpcCmd.AddPrometheusPortFlag() - if err := rpcCmd.Exec(config.Config.RpcRegisterName.OpenImGroupName, friend.Start); err != nil { + if err := rpcCmd.Exec(); err != nil { + fmt.Println(err.Error()) + os.Exit(1) + } + if err := rpcCmd.StartSvr(config.Config.RpcRegisterName.OpenImGroupName, friend.Start); err != nil { fmt.Println(err.Error()) os.Exit(1) } diff --git a/cmd/rpc/msg/main.go b/cmd/rpc/msg/main.go index be88b22a8..84bc8178a 100644 --- a/cmd/rpc/msg/main.go +++ b/cmd/rpc/msg/main.go @@ -12,7 +12,11 @@ func main() { rpcCmd := cmd.NewRpcCmd() rpcCmd.AddPortFlag() rpcCmd.AddPrometheusPortFlag() - if err := rpcCmd.Exec(config.Config.RpcRegisterName.OpenImMsgName, msg.Start); err != nil { + if err := rpcCmd.Exec(); err != nil { + fmt.Println(err.Error()) + os.Exit(1) + } + if err := rpcCmd.StartSvr(config.Config.RpcRegisterName.OpenImMsgName, msg.Start); err != nil { fmt.Println(err.Error()) os.Exit(1) } diff --git a/cmd/rpc/third/main.go b/cmd/rpc/third/main.go index 20dcbb421..3360bbd14 100644 --- a/cmd/rpc/third/main.go +++ b/cmd/rpc/third/main.go @@ -12,7 +12,11 @@ func main() { rpcCmd := cmd.NewRpcCmd() rpcCmd.AddPortFlag() rpcCmd.AddPrometheusPortFlag() - if err := rpcCmd.Exec(config.Config.RpcRegisterName.OpenImThirdName, third.Start); err != nil { + if err := rpcCmd.Exec(); err != nil { + fmt.Println(err.Error()) + os.Exit(1) + } + if err := rpcCmd.StartSvr(config.Config.RpcRegisterName.OpenImThirdName, third.Start); err != nil { fmt.Println(err.Error()) os.Exit(1) } diff --git a/cmd/rpc/user/main.go b/cmd/rpc/user/main.go index 9f82776b2..6438280d1 100644 --- a/cmd/rpc/user/main.go +++ b/cmd/rpc/user/main.go @@ -12,7 +12,11 @@ func main() { rpcCmd := cmd.NewRpcCmd() rpcCmd.AddPortFlag() rpcCmd.AddPrometheusPortFlag() - if err := rpcCmd.Exec(config.Config.RpcRegisterName.OpenImUserName, user.Start); err != nil { + if err := rpcCmd.Exec(); err != nil { + fmt.Println(err.Error()) + os.Exit(1) + } + if err := rpcCmd.StartSvr(config.Config.RpcRegisterName.OpenImUserName, user.Start); err != nil { fmt.Println(err.Error()) os.Exit(1) } diff --git a/pkg/common/cmd/push.go b/pkg/common/cmd/push.go index 432a49720..372be53a5 100644 --- a/pkg/common/cmd/push.go +++ b/pkg/common/cmd/push.go @@ -8,7 +8,7 @@ import ( ) type PushCmd struct { - *AuthCmd + *RpcCmd } func NewPushCmd() *PushCmd { diff --git a/pkg/common/cmd/root.go b/pkg/common/cmd/root.go index c2f43f266..cebbc0fe0 100644 --- a/pkg/common/cmd/root.go +++ b/pkg/common/cmd/root.go @@ -23,7 +23,7 @@ func NewRootCmd() (rootCmd *RootCmd) { }, } rootCmd.Command = c - rootCmd.init() + rootCmd.addConfFlag() return rootCmd } @@ -39,7 +39,7 @@ func (r *RootCmd) AddRpc(f func(port, prometheusPort int) error) { } } -func (r *RootCmd) init() { +func (r *RootCmd) addConfFlag() { r.Command.Flags().StringP(constant.FlagConf, "c", "", "Path to config file folder") } diff --git a/pkg/common/cmd/rpc.go b/pkg/common/cmd/rpc.go index 20ed935ab..a5a4e80c7 100644 --- a/pkg/common/cmd/rpc.go +++ b/pkg/common/cmd/rpc.go @@ -7,24 +7,23 @@ import ( "google.golang.org/grpc" ) -type AuthCmd struct { +type RpcCmd struct { *RootCmd } -func NewAuthCmd() *AuthCmd { - authCmd := &AuthCmd{NewRootCmd()} +func NewRpcCmd() *RpcCmd { + authCmd := &RpcCmd{NewRootCmd()} return authCmd } -func (a *AuthCmd) Exec() error { - a.Command.RunE = func(cmd *cobra.Command, args []string) error { +func (a *RpcCmd) Exec() error { + a.Command.Run = func(cmd *cobra.Command, args []string) { a.port = a.getPortFlag(cmd) a.prometheusPort = a.getPrometheusPortFlag(cmd) - return a.getConfFromCmdAndInit(cmd) } return a.Execute() } -func (a *AuthCmd) StartSvr(name string, rpcFn func(client discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) error) error { +func (a *RpcCmd) StartSvr(name string, rpcFn func(client discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) error) error { return startrpc.Start(a.GetPortFlag(), name, a.GetPrometheusPortFlag(), rpcFn) } From ae2e09e48b74b33cf527573c7a2233dbd3341e52 Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Thu, 9 Mar 2023 14:59:45 +0800 Subject: [PATCH 03/12] script --- cmd/push/main.go | 9 +++++++-- internal/startrpc/start.go | 8 ++++---- pkg/common/cmd/push.go | 13 +++++-------- 3 files changed, 16 insertions(+), 14 deletions(-) diff --git a/cmd/push/main.go b/cmd/push/main.go index 6a39c283a..2e46382d0 100644 --- a/cmd/push/main.go +++ b/cmd/push/main.go @@ -1,7 +1,9 @@ package main import ( + "OpenIM/internal/push" "OpenIM/pkg/common/cmd" + "OpenIM/pkg/common/config" "fmt" "os" ) @@ -10,8 +12,11 @@ func main() { pushCmd := cmd.NewPushCmd() pushCmd.AddPortFlag() pushCmd.AddPrometheusPortFlag() - pushCmd.AddPush() - if err := pushCmd.Execute(); err != nil { + if err := pushCmd.Exec(); err != nil { + fmt.Println(err.Error()) + os.Exit(1) + } + if err := pushCmd.StartSvr(config.Config.RpcRegisterName.OpenImPushName, push.Start); err != nil { fmt.Println(err.Error()) os.Exit(1) } diff --git a/internal/startrpc/start.go b/internal/startrpc/start.go index c65ec398f..fcf48bf0d 100644 --- a/internal/startrpc/start.go +++ b/internal/startrpc/start.go @@ -16,7 +16,7 @@ import ( "net" ) -func start(rpcPort int, rpcRegisterName string, prometheusPort int, rpcFn func(client discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) error, options []grpc.ServerOption) error { +func Start(rpcPort int, rpcRegisterName string, prometheusPort int, rpcFn func(client discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) error, options ...grpc.ServerOption) error { fmt.Println("start", rpcRegisterName, "rpc server, port: ", rpcPort, "prometheusPort:", prometheusPort, ", OpenIM version: ", config.Version) log.NewPrivateLog(constant.LogFileName) listener, err := net.Listen("tcp", fmt.Sprintf("%s:%d", config.Config.ListenIP, rpcPort)) @@ -60,6 +60,6 @@ func start(rpcPort int, rpcRegisterName string, prometheusPort int, rpcFn func(c return rpcFn(zkClient, srv) } -func Start(rpcPort int, rpcRegisterName string, prometheusPort int, rpcFn func(client discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) error, options ...grpc.ServerOption) error { - return start(rpcPort, rpcRegisterName, prometheusPort, rpcFn, options) -} +//func Start(rpcPort int, rpcRegisterName string, prometheusPort int, rpcFn func(client discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) error, options ...grpc.ServerOption) error { +// return start(rpcPort, rpcRegisterName, prometheusPort, rpcFn, options) +//} diff --git a/pkg/common/cmd/push.go b/pkg/common/cmd/push.go index 372be53a5..498492fb8 100644 --- a/pkg/common/cmd/push.go +++ b/pkg/common/cmd/push.go @@ -1,10 +1,9 @@ package cmd import ( - "OpenIM/internal/push" "OpenIM/internal/startrpc" - "OpenIM/pkg/common/config" - "github.com/spf13/cobra" + "OpenIM/pkg/discoveryregistry" + "google.golang.org/grpc" ) type PushCmd struct { @@ -12,11 +11,9 @@ type PushCmd struct { } func NewPushCmd() *PushCmd { - return &PushCmd{NewAuthCmd()} + return &PushCmd{NewRpcCmd()} } -func (r *PushCmd) AddPush() { - r.Command.RunE = func(cmd *cobra.Command, args []string) error { - return startrpc.Start(r.getPortFlag(cmd), config.Config.RpcRegisterName.OpenImPushName, r.getPrometheusPortFlag(cmd), push.Start) - } +func (r *PushCmd) StartSvr(name string, rpcFn func(client discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) error) error { + return startrpc.Start(r.GetPortFlag(), name, r.GetPrometheusPortFlag(), rpcFn) } From a957f2227bceab85a5aefaadca4e95454ce2226d Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Thu, 9 Mar 2023 15:00:32 +0800 Subject: [PATCH 04/12] script --- internal/startrpc/start.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/internal/startrpc/start.go b/internal/startrpc/start.go index fcf48bf0d..a7378ae65 100644 --- a/internal/startrpc/start.go +++ b/internal/startrpc/start.go @@ -13,6 +13,7 @@ import ( "github.com/OpenIMSDK/openKeeper" grpcPrometheus "github.com/grpc-ecosystem/go-grpc-prometheus" "google.golang.org/grpc" + "google.golang.org/grpc/credentials/insecure" "net" ) @@ -47,7 +48,7 @@ func Start(rpcPort int, rpcRegisterName string, prometheusPort int, rpcFn func(c } srv := grpc.NewServer(options...) defer srv.GracefulStop() - err = zkClient.Register(rpcRegisterName, registerIP, rpcPort) + err = zkClient.Register(rpcRegisterName, registerIP, rpcPort, grpc.WithTransportCredentials(insecure.NewCredentials())) if err != nil { return utils.Wrap1(err) } From 946fba17ef183f8c302a3c40514cec03f65ed6fb Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Thu, 9 Mar 2023 15:07:35 +0800 Subject: [PATCH 05/12] script --- internal/startrpc/start.go | 13 +++++++++---- 1 file changed, 9 insertions(+), 4 deletions(-) diff --git a/internal/startrpc/start.go b/internal/startrpc/start.go index a7378ae65..18fe7cef4 100644 --- a/internal/startrpc/start.go +++ b/internal/startrpc/start.go @@ -52,11 +52,16 @@ func Start(rpcPort int, rpcRegisterName string, prometheusPort int, rpcFn func(c if err != nil { return utils.Wrap1(err) } - if config.Config.Prometheus.Enable && prometheusPort != 0 { - err := prome.StartPrometheusSrv(prometheusPort) - if err != nil { - return err + go func() { + if config.Config.Prometheus.Enable && prometheusPort != 0 { + if err := prome.StartPrometheusSrv(prometheusPort); err != nil { + panic(err.Error()) + } } + }() + err = srv.Serve(listener) + if err != nil { + return utils.Wrap1(err) } return rpcFn(zkClient, srv) } From 955e776d3f6a17884f609dcda71c4ef43520d0c9 Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Thu, 9 Mar 2023 15:09:36 +0800 Subject: [PATCH 06/12] script --- pkg/common/cmd/root.go | 12 ------------ 1 file changed, 12 deletions(-) diff --git a/pkg/common/cmd/root.go b/pkg/common/cmd/root.go index cebbc0fe0..25b1ec485 100644 --- a/pkg/common/cmd/root.go +++ b/pkg/common/cmd/root.go @@ -27,18 +27,6 @@ func NewRootCmd() (rootCmd *RootCmd) { return rootCmd } -func (r *RootCmd) AddRunE(f func(cmd RootCmd) error) { - r.Command.RunE = func(cmd *cobra.Command, args []string) error { - return f(*r) - } -} - -func (r *RootCmd) AddRpc(f func(port, prometheusPort int) error) { - r.Command.RunE = func(cmd *cobra.Command, args []string) error { - return f(r.getPortFlag(cmd), r.getPrometheusPortFlag(cmd)) - } -} - func (r *RootCmd) addConfFlag() { r.Command.Flags().StringP(constant.FlagConf, "c", "", "Path to config file folder") } From acadfd2c3526f26694a686c80eb87d23280b85c7 Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Thu, 9 Mar 2023 15:17:46 +0800 Subject: [PATCH 07/12] script --- cmd/push/main.go | 2 +- pkg/common/cmd/push.go | 19 ------------------- pkg/common/config/config.go | 1 - 3 files changed, 1 insertion(+), 21 deletions(-) delete mode 100644 pkg/common/cmd/push.go diff --git a/cmd/push/main.go b/cmd/push/main.go index 2e46382d0..a89a3c111 100644 --- a/cmd/push/main.go +++ b/cmd/push/main.go @@ -9,7 +9,7 @@ import ( ) func main() { - pushCmd := cmd.NewPushCmd() + pushCmd := cmd.NewRpcCmd() pushCmd.AddPortFlag() pushCmd.AddPrometheusPortFlag() if err := pushCmd.Exec(); err != nil { diff --git a/pkg/common/cmd/push.go b/pkg/common/cmd/push.go deleted file mode 100644 index 498492fb8..000000000 --- a/pkg/common/cmd/push.go +++ /dev/null @@ -1,19 +0,0 @@ -package cmd - -import ( - "OpenIM/internal/startrpc" - "OpenIM/pkg/discoveryregistry" - "google.golang.org/grpc" -) - -type PushCmd struct { - *RpcCmd -} - -func NewPushCmd() *PushCmd { - return &PushCmd{NewRpcCmd()} -} - -func (r *PushCmd) StartSvr(name string, rpcFn func(client discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) error) error { - return startrpc.Start(r.GetPortFlag(), name, r.GetPrometheusPortFlag(), rpcFn) -} diff --git a/pkg/common/config/config.go b/pkg/common/config/config.go index ed0f5a0d9..11c358ecf 100644 --- a/pkg/common/config/config.go +++ b/pkg/common/config/config.go @@ -515,7 +515,6 @@ func (c *config) initConfig(config interface{}, configName, configFolderPath str return err } configPath = filepath.Join(Root, "config", configName) - fmt.Println("use", configPath) } else { Root = filepath.Dir(configPath) } From 4081ed2ac67c027e29ca42914d21ad67ab6aa534 Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Thu, 9 Mar 2023 15:26:29 +0800 Subject: [PATCH 08/12] script --- script/path_info.cfg | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/script/path_info.cfg b/script/path_info.cfg index 5cb47772f..1ccf816cb 100644 --- a/script/path_info.cfg +++ b/script/path_info.cfg @@ -19,7 +19,7 @@ msg_transfer_source_root="../cmd/msgtransfer/" msg_transfer_service_num=4 -sdk_server_name="sdk_ws_server" +sdk_server_name="open_im_sdk_ws_server" sdk_server_binary_root="../bin/" sdk_server_source_root="../cmd/Open-IM-SDK-Core/" From 05f4333152fa99463800205b48b28a4893bc5dc7 Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Thu, 9 Mar 2023 15:30:02 +0800 Subject: [PATCH 09/12] script --- script/path_info.cfg | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/script/path_info.cfg b/script/path_info.cfg index 1ccf816cb..5ada746df 100644 --- a/script/path_info.cfg +++ b/script/path_info.cfg @@ -19,7 +19,7 @@ msg_transfer_source_root="../cmd/msgtransfer/" msg_transfer_service_num=4 -sdk_server_name="open_im_sdk_ws_server" +sdk_server_name="open_im_sdk_server" sdk_server_binary_root="../bin/" sdk_server_source_root="../cmd/Open-IM-SDK-Core/" From 2be3c9b0ad143eb48a7aefa09e50d63f264473d5 Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Thu, 9 Mar 2023 15:34:42 +0800 Subject: [PATCH 10/12] script --- script/sdk_svr_start.sh | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/script/sdk_svr_start.sh b/script/sdk_svr_start.sh index e10ff6bf8..ab9c6eb08 100644 --- a/script/sdk_svr_start.sh +++ b/script/sdk_svr_start.sh @@ -24,7 +24,7 @@ fi #Waiting port recycling sleep 1 cd ${sdk_server_binary_root} - nohup ./${sdk_server_name} -openIM_ws_address ${ws_address} -sdkws_port ${sdkws_ports[0]} -openIM_api_address ${api_address} -openIM_log_level ${logLevel} >>../logs/openIM.log 2>&1 & + nohup ./${sdk_server_name} -openIM_ws_address ${ws_address} -sdk_ws_port ${sdkws_ports[0]} -openIM_api_address ${api_address} -openIM_log_level ${logLevel} >>../logs/openIM.log 2>&1 & #Check launched service process sleep 3 From 5447f27c80ccd6bec3c134d48a203394407aee2f Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Thu, 9 Mar 2023 15:47:00 +0800 Subject: [PATCH 11/12] script --- pkg/common/db/table/relation/chatlog.go | 2 -- 1 file changed, 2 deletions(-) diff --git a/pkg/common/db/table/relation/chatlog.go b/pkg/common/db/table/relation/chatlog.go index dcf39aca5..5d04edbe9 100644 --- a/pkg/common/db/table/relation/chatlog.go +++ b/pkg/common/db/table/relation/chatlog.go @@ -1,7 +1,6 @@ package relation import ( - "gorm.io/gorm" "time" pbMsg "OpenIM/pkg/proto/msg" @@ -27,7 +26,6 @@ type ChatLogModel struct { SendTime time.Time `gorm:"column:send_time;index:sendTime;index:content_type,priority:1;index:session_type,priority:1;index:recv_id,priority:1;index:send_id,priority:1" json:"sendTime"` CreateTime time.Time `gorm:"column:create_time" json:"createTime"` Ex string `gorm:"column:ex;type:varchar(1024)" json:"ex"` - DB *gorm.DB } func (ChatLogModel) TableName() string { From 7e622ae784131c67029532dd88ddfcd5c72ff532 Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Thu, 9 Mar 2023 15:47:51 +0800 Subject: [PATCH 12/12] script --- internal/msgtransfer/init.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/msgtransfer/init.go b/internal/msgtransfer/init.go index 9b5b4b6cc..dd154a3c4 100644 --- a/internal/msgtransfer/init.go +++ b/internal/msgtransfer/init.go @@ -67,6 +67,7 @@ func (m *MsgTransfer) initPrometheus() { func (m *MsgTransfer) Start(prometheusPort int) error { var wg sync.WaitGroup wg.Add(4) + fmt.Println("start msg transfer", "prometheusPort:", prometheusPort) if config.Config.ChatPersistenceMysql { go m.persistentCH.persistentConsumerGroup.RegisterHandleAndConsumer(m.persistentCH) } else {