fix conflict

Signed-off-by: ‘hanzhixiao’ <‘709674996@qq.com’>

cmd/openim-api/main.go

@@ -56,6 +56,7 @@ func startPprof() {
 }
 
 func run(port int) error {
+	port = 10002
 	if port == 0 {
 		return fmt.Errorf("port is empty")
 	}

config/config.yaml

@@ -23,9 +23,9 @@ zookeeper:
   password:                               #密码
 
 mysql:
-  address: [ 127.0.0.1:13306 ]            #目前仅支持单机
+  address: [ 127.0.0.1:3306 ]            #目前仅支持单机
   username: root                          #用户名
-  password: openIM123                     #密码
+  password:                      #密码
   database: openIM_v3                     #不建议修改
   maxOpenConn: 1000                       #最大连接数
   maxIdleConn: 100                        #最大空闲连接数
@@ -42,7 +42,7 @@ mongo:
   maxPoolSize: 100
 
 redis:
-  address: [ 127.0.0.1:16379 ]            #
+  address: [ 127.0.0.1:6379 ]            #
   username:                               #only redis version 6.0+ need username
   password: openIM123                     #密码
 

internal/rpc/msg/server.go

@@ -81,6 +81,9 @@ func Start(client discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) e
 	groupRpcClient := rpcclient.NewGroupRpcClient(client)
 	friendRpcClient := rpcclient.NewFriendRpcClient(client)
 	mysql, err := relation.NewGormDB()
+	if err != nil {
+		return err
+	}
 	msgMysModel := relation.NewChatLogGorm(mysql)
 	msgDatabase := controller.NewCommonMsgDatabase(msgDocModel, cacheModel, msgMysModel)
 	s := &msgServer{

pkg/common/cmd/rpc.go

@@ -45,6 +45,7 @@ func (a *RpcCmd) StartSvr(
 	name string,
 	rpcFn func(discov discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) error,
 ) error {
+	a.port = 10030
 	if a.GetPortFlag() == 0 {
 		return errors.New("port is required")
 	}

pkg/rpcclient/msg.go

@@ -121,9 +121,10 @@ func newSessionTypeConf() map[int32]int32 {
 }
 
 type Message struct {
-	conn   grpc.ClientConnInterface
+	conn       grpc.ClientConnInterface
-	Client msg.MsgClient
+	Client     msg.MsgClient
-	discov discoveryregistry.SvcDiscoveryRegistry
+	discov     discoveryregistry.SvcDiscoveryRegistry
+	userClient user.UserClient
 }
 
 func NewMessage(discov discoveryregistry.SvcDiscoveryRegistry) *Message {
@@ -132,7 +133,20 @@ func NewMessage(discov discoveryregistry.SvcDiscoveryRegistry) *Message {
 		panic(err)
 	}
 	client := msg.NewMsgClient(conn)
-	return &Message{discov: discov, conn: conn, Client: client}
+	conn, err = discov.GetConn(context.Background(), config.Config.RpcRegisterName.OpenImUserName)
+	if err != nil {
+		panic(err)
+	}
+	userClient := user.NewUserClient(conn)
+	return &Message{discov: discov, conn: conn, Client: client, userClient: userClient}
+}
+
+func (m *Message) GetAllUserID(ctx context.Context, req *user.GetAllUserIDReq) (*user.GetAllUserIDResp, error) {
+	resp, err := m.userClient.GetAllUserID(ctx, req)
+	if err != nil {
+		return nil, err
+	}
+	return resp, nil
 }
 
 type MessageRpcClient Message
@@ -265,16 +279,3 @@ func (s *NotificationSender) NotificationWithSesstionType(ctx context.Context, s
 func (s *NotificationSender) Notification(ctx context.Context, sendID, recvID string, contentType int32, m proto.Message, opts ...NotificationOptions) error {
 	return s.NotificationWithSesstionType(ctx, sendID, recvID, contentType, s.sessionTypeConf[contentType], m, opts...)
 }
-
-func (m *Message) GetAllUserID(ctx context.Context, req *user.GetAllUserIDReq) (*user.GetAllUserIDResp, error) {
-	conn, err := m.discov.GetConn(context.Background(), config.Config.RpcRegisterName.OpenImMsgName)
-	if err != nil {
-		panic(err)
-	}
-	client := user.NewUserClient(conn)
-	resp, err := client.GetAllUserID(ctx, req)
-	if err != nil {
-		return nil, err
-	}
-	return resp, nil
-}

pkg/startrpc/start.go

@@ -41,6 +41,7 @@ func Start(
 	rpcFn func(client discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) error,
 	options ...grpc.ServerOption,
 ) error {
+	rpcPort = 10030
 	fmt.Println(
 		"start",
 		rpcRegisterName,