office tag async send

cmd/rpc/open_im_admin_cms/main.go

@@ -2,12 +2,14 @@ package main
 
 import (
 	rpcMessageCMS "Open_IM/internal/rpc/admin_cms"
+	"Open_IM/pkg/common/config"
 	"flag"
 	"fmt"
 )
 
 func main() {
-	rpcPort := flag.Int("port", 11000, "rpc listening port")
+	defaultPorts := config.Config.RpcPort.OpenImAdminCmsPort
+	rpcPort := flag.Int("port", defaultPorts[0], "rpc listening port")
 	flag.Parse()
 	fmt.Println("start cms rpc server, port: ", *rpcPort)
 	rpcServer := rpcMessageCMS.NewAdminCMSServer(*rpcPort)

cmd/rpc/open_im_auth/main.go

@@ -2,12 +2,14 @@ package main
 
 import (
 	rpcAuth "Open_IM/internal/rpc/auth"
+	"Open_IM/pkg/common/config"
 	"flag"
 	"fmt"
 )
 
 func main() {
-	rpcPort := flag.Int("port", 10600, "RpcToken default listen port 10800")
+	defaultPorts := config.Config.RpcPort.OpenImAuthPort
+	rpcPort := flag.Int("port", defaultPorts[0], "RpcToken default listen port 10800")
 	flag.Parse()
 	fmt.Println("start auth rpc server, port: ", *rpcPort)
 	rpcServer := rpcAuth.NewRpcAuthServer(*rpcPort)

cmd/rpc/open_im_cache/main.go

@@ -2,12 +2,14 @@ package main
 
 import (
 	rpcCache "Open_IM/internal/rpc/cache"
+	"Open_IM/pkg/common/config"
 	"flag"
 	"fmt"
 )
 
 func main() {
-	rpcPort := flag.Int("port", 10600, "RpcToken default listen port 10800")
+	defaultPorts := config.Config.RpcPort.OpenImCachePort
+	rpcPort := flag.Int("port", defaultPorts[0], "RpcToken default listen port 10800")
 	flag.Parse()
 	fmt.Println("start auth rpc server, port: ", *rpcPort)
 	rpcServer := rpcCache.NewCacheServer(*rpcPort)

cmd/rpc/open_im_conversation/main.go

@@ -2,12 +2,14 @@ package main
 
 import (
 	rpcConversation "Open_IM/internal/rpc/conversation"
+	"Open_IM/pkg/common/config"
 	"flag"
 	"fmt"
 )
 
 func main() {
-	rpcPort := flag.Int("port", 11400, "RpcConversation default listen port 11300")
+	defaultPorts := config.Config.RpcPort.OpenImConversationPort
+	rpcPort := flag.Int("port", defaultPorts[0], "RpcConversation default listen port 11300")
 	flag.Parse()
 	fmt.Println("start conversation rpc server, port: ", *rpcPort)
 	rpcServer := rpcConversation.NewRpcConversationServer(*rpcPort)

cmd/rpc/open_im_friend/main.go

@@ -2,13 +2,14 @@ package main
 
 import (
 	"Open_IM/internal/rpc/friend"
+	"Open_IM/pkg/common/config"
 	"flag"
 	"fmt"
 )
 
 func main() {
-
-	rpcPort := flag.Int("port", 10200, "get RpcFriendPort from cmd,default 12000 as port")
+	defaultPorts := config.Config.RpcPort.OpenImFriendPort
+	rpcPort := flag.Int("port", defaultPorts[0], "get RpcFriendPort from cmd,default 12000 as port")
 	flag.Parse()
 	fmt.Println("start friend rpc server, port: ", *rpcPort)
 	rpcServer := friend.NewFriendServer(*rpcPort)

cmd/rpc/open_im_group/main.go

@@ -2,12 +2,14 @@ package main
 
 import (
 	"Open_IM/internal/rpc/group"
+	"Open_IM/pkg/common/config"
 	"flag"
 	"fmt"
 )
 
 func main() {
-	rpcPort := flag.Int("port", 10500, "get RpcGroupPort from cmd,default 16000 as port")
+	defaultPorts := config.Config.RpcPort.OpenImGroupPort
+	rpcPort := flag.Int("port", defaultPorts[0], "get RpcGroupPort from cmd,default 16000 as port")
 	flag.Parse()
 	fmt.Println("start group rpc server, port: ", *rpcPort)
 	rpcServer := group.NewGroupServer(*rpcPort)

cmd/rpc/open_im_message_cms/main.go

@@ -2,12 +2,14 @@ package main
 
 import (
 	rpcMessageCMS "Open_IM/internal/rpc/message_cms"
+	"Open_IM/pkg/common/config"
 	"flag"
 	"fmt"
 )
 
 func main() {
-	rpcPort := flag.Int("port", 10900, "rpc listening port")
+	defaultPorts := config.Config.RpcPort.OpenImMessageCmsPort[0]
+	rpcPort := flag.Int("port", defaultPorts, "rpc listening port")
 	flag.Parse()
 	fmt.Println("start msg cms rpc server, port: ", *rpcPort)
 	rpcServer := rpcMessageCMS.NewMessageCMSServer(*rpcPort)

cmd/rpc/open_im_msg/main.go

@@ -2,12 +2,14 @@ package main
 
 import (
 	rpcChat "Open_IM/internal/rpc/msg"
+	"Open_IM/pkg/common/config"
 	"flag"
 	"fmt"
 )
 
 func main() {
-	rpcPort := flag.Int("port", 10300, "rpc listening port")
+	defaultPorts := config.Config.RpcPort.OpenImMessagePort
+	rpcPort := flag.Int("port", defaultPorts[0], "rpc listening port")
 	flag.Parse()
 	fmt.Println("start msg rpc server, port: ", *rpcPort)
 	rpcServer := rpcChat.NewRpcChatServer(*rpcPort)

cmd/rpc/open_im_office/main.go

@@ -2,12 +2,14 @@ package main
 
 import (
 	rpc "Open_IM/internal/rpc/office"
+	"Open_IM/pkg/common/config"
 	"flag"
 	"fmt"
 )
 
 func main() {
-	rpcPort := flag.Int("port", 11100, "rpc listening port")
+	defaultPorts := config.Config.RpcPort.OpenImOfficePort
+	rpcPort := flag.Int("port", defaultPorts[0], "rpc listening port")
 	flag.Parse()
 	fmt.Println("start office rpc server, port: ", *rpcPort)
 	rpcServer := rpc.NewOfficeServer(*rpcPort)

cmd/rpc/open_im_organization/main.go

@@ -2,12 +2,14 @@ package main
 
 import (
 	"Open_IM/internal/rpc/organization"
+	"Open_IM/pkg/common/config"
 	"flag"
 	"fmt"
 )
 
 func main() {
-	rpcPort := flag.Int("port", 11200, "get RpcOrganizationPort from cmd,default 11200 as port")
+	defaultPorts := config.Config.RpcPort.OpenImOrganizationPort
+	rpcPort := flag.Int("port", defaultPorts[0], "get RpcOrganizationPort from cmd,default 11200 as port")
 	flag.Parse()
 	fmt.Println("start organization rpc server, port: ", *rpcPort)
 	rpcServer := organization.NewServer(*rpcPort)

cmd/rpc/open_im_statistics/main.go

@@ -2,12 +2,14 @@ package main
 
 import (
 	"Open_IM/internal/rpc/statistics"
+	"Open_IM/pkg/common/config"
 	"flag"
 	"fmt"
 )
 
 func main() {
-	rpcPort := flag.Int("port", 10800, "rpc listening port")
+	defaultPorts := config.Config.RpcPort.OpenImStatisticsPort
+	rpcPort := flag.Int("port", defaultPorts[0], "rpc listening port")
 	flag.Parse()
 	fmt.Println("start statistics rpc server, port: ", *rpcPort)
 	rpcServer := statistics.NewStatisticsServer(*rpcPort)

cmd/rpc/open_im_user/main.go

@@ -2,12 +2,14 @@ package main
 
 import (
 	"Open_IM/internal/rpc/user"
+	"Open_IM/pkg/common/config"
 	"flag"
 	"fmt"
 )
 
 func main() {
-	rpcPort := flag.Int("port", 10100, "rpc listening port")
+	defaultPorts := config.Config.RpcPort.OpenImUserPort
+	rpcPort := flag.Int("port", defaultPorts[0], "rpc listening port")
 	flag.Parse()
 	fmt.Println("start user rpc server, port: ", *rpcPort)
 	rpcServer := user.NewUserServer(*rpcPort)