From 854f8dbd2f80cf71a16c5a3a3a4db5d38ac65da7 Mon Sep 17 00:00:00 2001
From: Xinwei Xiong <3293172751NSS@gmail.com>
Date: Fri, 2 Feb 2024 21:59:12 +0800
Subject: [PATCH 1/2] feat: Optimize openim scripts and standard output logs
 (#1866)

* feat: add component check func

* fix: fix the outpu error

* fix: fix the stderr outpu

* fix: fix the component check func

* fix: fix the error

* fix: fix the output error

* fix: del the disruptions code

* fix the log output format

* fix: fix the tools version

* fix: fix the cycle detection

* fix: fix the error

* fix: fix the flag

* fix: add mongo ping detection

* fix: fix the tools pkg version

* fix: del the err

* feat: support openim readme docs

Signed-off-by: Xinwei Xiong (cubxxw) <3293172751nss@gmail.com>

* feat: support openim readme docs

Signed-off-by: Xinwei Xiong (cubxxw) <3293172751nss@gmail.com>

* feat: support openim readme docs

Signed-off-by: Xinwei Xiong (cubxxw) <3293172751nss@gmail.com>

* fix: fix the minio nil error

* fix: del the repeated wrap and add err print

* fix: fix this bug scripts

* Revert "Check"

---------

Signed-off-by: Xinwei Xiong (cubxxw) <3293172751nss@gmail.com>
Co-authored-by: luhaoling <2198702716@qq.com>
---
 cmd/openim-api/main.go                        |  3 ++-
 cmd/openim-cmdutils/main.go                   |  5 +++-
 cmd/openim-crontask/main.go                   |  5 +++-
 cmd/openim-msggateway/main.go                 |  5 +++-
 cmd/openim-msgtransfer/main.go                |  5 +++-
 cmd/openim-push/main.go                       |  5 +++-
 cmd/openim-rpc/openim-rpc-auth/main.go        |  5 +++-
 .../openim-rpc-conversation/main.go           |  5 +++-
 cmd/openim-rpc/openim-rpc-friend/main.go      |  5 +++-
 cmd/openim-rpc/openim-rpc-group/main.go       |  5 +++-
 cmd/openim-rpc/openim-rpc-msg/main.go         |  5 +++-
 cmd/openim-rpc/openim-rpc-third/main.go       |  5 +++-
 cmd/openim-rpc/openim-rpc-user/main.go        |  5 +++-
 go.mod                                        |  2 +-
 go.sum                                        |  4 +--
 pkg/common/cmd/root.go                        |  1 -
 pkg/common/db/unrelation/mongo.go             |  5 ++--
 .../discoveryregister/zookeeper/zookeeper.go  |  2 +-
 pkg/common/startrpc/start.go                  |  7 ++---
 scripts/check-all.sh                          | 10 +++++++
 scripts/install/openim-api.sh                 | 10 ++++---
 scripts/install/openim-crontask.sh            |  7 ++++-
 scripts/install/openim-msggateway.sh          |  5 +++-
 scripts/install/openim-msgtransfer.sh         |  5 +++-
 scripts/install/openim-push.sh                |  7 +++--
 scripts/install/openim-rpc.sh                 |  5 +++-
 scripts/lib/logging.sh                        |  4 +++
 scripts/lib/util.sh                           | 27 +++++++++++++------
 tools/component/component.go                  | 26 +++++++++++-------
 tools/ncpu/ncpu.go                            | 23 +++++-----------
 30 files changed, 146 insertions(+), 67 deletions(-)

diff --git a/cmd/openim-api/main.go b/cmd/openim-api/main.go
index 59e0b7f9e..755b35591 100644
--- a/cmd/openim-api/main.go
+++ b/cmd/openim-api/main.go
@@ -43,7 +43,8 @@ func main() {
 	apiCmd.AddPortFlag()
 	apiCmd.AddApi(run)
 	if err := apiCmd.Execute(); err != nil {
-		panic(err.Error())
+		fmt.Fprintf(os.Stderr, "\n\nexit -1: \n%+v\n\n", err)
+		os.Exit(-1)
 	}
 }
 
diff --git a/cmd/openim-cmdutils/main.go b/cmd/openim-cmdutils/main.go
index 058aa2e29..a13bc4f33 100644
--- a/cmd/openim-cmdutils/main.go
+++ b/cmd/openim-cmdutils/main.go
@@ -15,7 +15,9 @@
 package main
 
 import (
+	"fmt"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/cmd"
+	"os"
 )
 
 func main() {
@@ -54,6 +56,7 @@ func main() {
 	// openIM clear msg --clearAll
 	msgUtilsCmd.AddCommand(&getCmd.Command, &fixCmd.Command, &clearCmd.Command)
 	if err := msgUtilsCmd.Execute(); err != nil {
-		panic(err)
+		fmt.Fprintf(os.Stderr, "\n\nexit -1: \n%+v\n\n", err)
+		os.Exit(-1)
 	}
 }
diff --git a/cmd/openim-crontask/main.go b/cmd/openim-crontask/main.go
index 3bd0d882b..5061c5408 100644
--- a/cmd/openim-crontask/main.go
+++ b/cmd/openim-crontask/main.go
@@ -15,13 +15,16 @@
 package main
 
 import (
+	"fmt"
 	"github.com/openimsdk/open-im-server/v3/internal/tools"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/cmd"
+	"os"
 )
 
 func main() {
 	cronTaskCmd := cmd.NewCronTaskCmd()
 	if err := cronTaskCmd.Exec(tools.StartTask); err != nil {
-		panic(err.Error())
+		fmt.Fprintf(os.Stderr, "\n\nexit -1: \n%+v\n\n", err)
+		os.Exit(-1)
 	}
 }
diff --git a/cmd/openim-msggateway/main.go b/cmd/openim-msggateway/main.go
index 6d212e467..25cfe5fa8 100644
--- a/cmd/openim-msggateway/main.go
+++ b/cmd/openim-msggateway/main.go
@@ -15,7 +15,9 @@
 package main
 
 import (
+	"fmt"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/cmd"
+	"os"
 )
 
 func main() {
@@ -25,6 +27,7 @@ func main() {
 	msgGatewayCmd.AddPrometheusPortFlag()
 
 	if err := msgGatewayCmd.Exec(); err != nil {
-		panic(err.Error())
+		fmt.Fprintf(os.Stderr, "\n\nexit -1: \n%+v\n\n", err)
+		os.Exit(-1)
 	}
 }
diff --git a/cmd/openim-msgtransfer/main.go b/cmd/openim-msgtransfer/main.go
index 6895bcecc..e3c2f374f 100644
--- a/cmd/openim-msgtransfer/main.go
+++ b/cmd/openim-msgtransfer/main.go
@@ -15,7 +15,9 @@
 package main
 
 import (
+	"fmt"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/cmd"
+	"os"
 )
 
 func main() {
@@ -23,6 +25,7 @@ func main() {
 	msgTransferCmd.AddPrometheusPortFlag()
 	msgTransferCmd.AddTransferProgressFlag()
 	if err := msgTransferCmd.Exec(); err != nil {
-		panic(err.Error())
+		fmt.Fprintf(os.Stderr, "\n\nexit -1: \n%+v\n\n", err)
+		os.Exit(-1)
 	}
 }
diff --git a/cmd/openim-push/main.go b/cmd/openim-push/main.go
index c19cfda60..79152f945 100644
--- a/cmd/openim-push/main.go
+++ b/cmd/openim-push/main.go
@@ -15,9 +15,11 @@
 package main
 
 import (
+	"fmt"
 	"github.com/openimsdk/open-im-server/v3/internal/push"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/cmd"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/config"
+	"os"
 )
 
 func main() {
@@ -28,6 +30,7 @@ func main() {
 		panic(err.Error())
 	}
 	if err := pushCmd.StartSvr(config.Config.RpcRegisterName.OpenImPushName, push.Start); err != nil {
-		panic(err.Error())
+		fmt.Fprintf(os.Stderr, "\n\nexit -1: \n%+v\n\n", err)
+		os.Exit(-1)
 	}
 }
diff --git a/cmd/openim-rpc/openim-rpc-auth/main.go b/cmd/openim-rpc/openim-rpc-auth/main.go
index 645d8cab8..8ee7053f3 100644
--- a/cmd/openim-rpc/openim-rpc-auth/main.go
+++ b/cmd/openim-rpc/openim-rpc-auth/main.go
@@ -15,9 +15,11 @@
 package main
 
 import (
+	"fmt"
 	"github.com/openimsdk/open-im-server/v3/internal/rpc/auth"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/cmd"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/config"
+	"os"
 )
 
 func main() {
@@ -28,6 +30,7 @@ func main() {
 		panic(err.Error())
 	}
 	if err := authCmd.StartSvr(config.Config.RpcRegisterName.OpenImAuthName, auth.Start); err != nil {
-		panic(err.Error())
+		fmt.Fprintf(os.Stderr, "\n\nexit -1: \n%+v\n\n", err)
+		os.Exit(-1)
 	}
 }
diff --git a/cmd/openim-rpc/openim-rpc-conversation/main.go b/cmd/openim-rpc/openim-rpc-conversation/main.go
index 13d7db605..259d79abf 100644
--- a/cmd/openim-rpc/openim-rpc-conversation/main.go
+++ b/cmd/openim-rpc/openim-rpc-conversation/main.go
@@ -15,9 +15,11 @@
 package main
 
 import (
+	"fmt"
 	"github.com/openimsdk/open-im-server/v3/internal/rpc/conversation"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/cmd"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/config"
+	"os"
 )
 
 func main() {
@@ -28,6 +30,7 @@ func main() {
 		panic(err.Error())
 	}
 	if err := rpcCmd.StartSvr(config.Config.RpcRegisterName.OpenImConversationName, conversation.Start); err != nil {
-		panic(err.Error())
+		fmt.Fprintf(os.Stderr, "\n\nexit -1: \n%+v\n\n", err)
+		os.Exit(-1)
 	}
 }
diff --git a/cmd/openim-rpc/openim-rpc-friend/main.go b/cmd/openim-rpc/openim-rpc-friend/main.go
index ec18306a2..bd85da7b0 100644
--- a/cmd/openim-rpc/openim-rpc-friend/main.go
+++ b/cmd/openim-rpc/openim-rpc-friend/main.go
@@ -15,9 +15,11 @@
 package main
 
 import (
+	"fmt"
 	"github.com/openimsdk/open-im-server/v3/internal/rpc/friend"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/cmd"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/config"
+	"os"
 )
 
 func main() {
@@ -28,6 +30,7 @@ func main() {
 		panic(err.Error())
 	}
 	if err := rpcCmd.StartSvr(config.Config.RpcRegisterName.OpenImFriendName, friend.Start); err != nil {
-		panic(err.Error())
+		fmt.Fprintf(os.Stderr, "\n\nexit -1: \n%+v\n\n", err)
+		os.Exit(-1)
 	}
 }
diff --git a/cmd/openim-rpc/openim-rpc-group/main.go b/cmd/openim-rpc/openim-rpc-group/main.go
index 887329926..e40c04d19 100644
--- a/cmd/openim-rpc/openim-rpc-group/main.go
+++ b/cmd/openim-rpc/openim-rpc-group/main.go
@@ -15,9 +15,11 @@
 package main
 
 import (
+	"fmt"
 	"github.com/openimsdk/open-im-server/v3/internal/rpc/group"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/cmd"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/config"
+	"os"
 )
 
 func main() {
@@ -28,6 +30,7 @@ func main() {
 		panic(err.Error())
 	}
 	if err := rpcCmd.StartSvr(config.Config.RpcRegisterName.OpenImGroupName, group.Start); err != nil {
-		panic(err.Error())
+		fmt.Fprintf(os.Stderr, "\n\nexit -1: \n%+v\n\n", err)
+		os.Exit(-1)
 	}
 }
diff --git a/cmd/openim-rpc/openim-rpc-msg/main.go b/cmd/openim-rpc/openim-rpc-msg/main.go
index dcc3abef5..989746dc7 100644
--- a/cmd/openim-rpc/openim-rpc-msg/main.go
+++ b/cmd/openim-rpc/openim-rpc-msg/main.go
@@ -15,9 +15,11 @@
 package main
 
 import (
+	"fmt"
 	"github.com/openimsdk/open-im-server/v3/internal/rpc/msg"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/cmd"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/config"
+	"os"
 )
 
 func main() {
@@ -28,6 +30,7 @@ func main() {
 		panic(err.Error())
 	}
 	if err := rpcCmd.StartSvr(config.Config.RpcRegisterName.OpenImMsgName, msg.Start); err != nil {
-		panic(err.Error())
+		fmt.Fprintf(os.Stderr, "\n\nexit -1: \n%+v\n\n", err)
+		os.Exit(-1)
 	}
 }
diff --git a/cmd/openim-rpc/openim-rpc-third/main.go b/cmd/openim-rpc/openim-rpc-third/main.go
index cf0bf4b70..fbd386946 100644
--- a/cmd/openim-rpc/openim-rpc-third/main.go
+++ b/cmd/openim-rpc/openim-rpc-third/main.go
@@ -15,9 +15,11 @@
 package main
 
 import (
+	"fmt"
 	"github.com/openimsdk/open-im-server/v3/internal/rpc/third"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/cmd"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/config"
+	"os"
 )
 
 func main() {
@@ -28,6 +30,7 @@ func main() {
 		panic(err.Error())
 	}
 	if err := rpcCmd.StartSvr(config.Config.RpcRegisterName.OpenImThirdName, third.Start); err != nil {
-		panic(err.Error())
+		fmt.Fprintf(os.Stderr, "\n\nexit -1: \n%+v\n\n", err)
+		os.Exit(-1)
 	}
 }
diff --git a/cmd/openim-rpc/openim-rpc-user/main.go b/cmd/openim-rpc/openim-rpc-user/main.go
index cbf2a8fc3..160bbe311 100644
--- a/cmd/openim-rpc/openim-rpc-user/main.go
+++ b/cmd/openim-rpc/openim-rpc-user/main.go
@@ -15,9 +15,11 @@
 package main
 
 import (
+	"fmt"
 	"github.com/openimsdk/open-im-server/v3/internal/rpc/user"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/cmd"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/config"
+	"os"
 )
 
 func main() {
@@ -28,6 +30,7 @@ func main() {
 		panic(err.Error())
 	}
 	if err := rpcCmd.StartSvr(config.Config.RpcRegisterName.OpenImUserName, user.Start); err != nil {
-		panic(err.Error())
+		fmt.Fprintf(os.Stderr, "\n\nexit -1: \n%+v\n\n", err)
+		os.Exit(-1)
 	}
 }
diff --git a/go.mod b/go.mod
index 16a10a945..d82d3390b 100644
--- a/go.mod
+++ b/go.mod
@@ -5,7 +5,7 @@ go 1.19
 require (
 	firebase.google.com/go v3.13.0+incompatible
 	github.com/OpenIMSDK/protocol v0.0.48
-	github.com/OpenIMSDK/tools v0.0.32
+	github.com/OpenIMSDK/tools v0.0.33
 	github.com/bwmarrin/snowflake v0.3.0 // indirect
 	github.com/dtm-labs/rockscache v0.1.1
 	github.com/gin-gonic/gin v1.9.1
diff --git a/go.sum b/go.sum
index 136035cef..fb047dfdc 100644
--- a/go.sum
+++ b/go.sum
@@ -20,8 +20,8 @@ github.com/IBM/sarama v1.41.3 h1:MWBEJ12vHC8coMjdEXFq/6ftO6DUZnQlFYcxtOJFa7c=
 github.com/IBM/sarama v1.41.3/go.mod h1:Xxho9HkHd4K/MDUo/T/sOqwtX/17D33++E9Wib6hUdQ=
 github.com/OpenIMSDK/protocol v0.0.48 h1:8MIMjyzJRsruYhVv2ZKArFiOveroaofDOb3dlAdgjsw=
 github.com/OpenIMSDK/protocol v0.0.48/go.mod h1:F25dFrwrIx3lkNoiuf6FkCfxuwf8L4Z8UIsdTHP/r0Y=
-github.com/OpenIMSDK/tools v0.0.32 h1:b8KwtxXKZTsyyHUcZ4OtSo6s/vVXx4HjMuPxH7Kb7Gg=
-github.com/OpenIMSDK/tools v0.0.32/go.mod h1:wBfR5CYmEyvxl03QJbTkhz1CluK6J4/lX0lviu8JAjE=
+github.com/OpenIMSDK/tools v0.0.33 h1:rvFCxXaXxLv1MJFC4qcoWRGwKBnV+hR68UN2N0/zZhE=
+github.com/OpenIMSDK/tools v0.0.33/go.mod h1:wBfR5CYmEyvxl03QJbTkhz1CluK6J4/lX0lviu8JAjE=
 github.com/QcloudApi/qcloud_sign_golang v0.0.0-20141224014652-e4130a326409/go.mod h1:1pk82RBxDY/JZnPQrtqHlUFfCctgdorsd9M06fMynOM=
 github.com/alcortesm/tgz v0.0.0-20161220082320-9c5fe88206d7 h1:uSoVVbwJiQipAclBbw+8quDsfcvFjOpI5iCf4p/cqCs=
 github.com/alcortesm/tgz v0.0.0-20161220082320-9c5fe88206d7/go.mod h1:6zEj6s6u/ghQa61ZWa/C2Aw3RkjiTBOix7dkqa1VLIs=
diff --git a/pkg/common/cmd/root.go b/pkg/common/cmd/root.go
index 66bec61a7..98ca8f892 100644
--- a/pkg/common/cmd/root.go
+++ b/pkg/common/cmd/root.go
@@ -20,7 +20,6 @@ import (
 	config2 "github.com/openimsdk/open-im-server/v3/pkg/common/config"
 
 	"github.com/spf13/cobra"
-	_ "go.uber.org/automaxprocs"
 
 	"github.com/OpenIMSDK/protocol/constant"
 	"github.com/OpenIMSDK/tools/log"
diff --git a/pkg/common/db/unrelation/mongo.go b/pkg/common/db/unrelation/mongo.go
index fe89c6b8a..2bade9a62 100644
--- a/pkg/common/db/unrelation/mongo.go
+++ b/pkg/common/db/unrelation/mongo.go
@@ -54,14 +54,15 @@ func NewMongo() (*Mongo, error) {
 		defer cancel()
 		mongoClient, err = mongo.Connect(ctx, options.Client().ApplyURI(uri))
 		if err == nil {
+			if err = mongoClient.Ping(ctx, nil); err != nil {
+				return nil, errs.Wrap(err, uri)
+			}
 			return &Mongo{db: mongoClient}, nil
 		}
 		if shouldRetry(err) {
-			fmt.Printf("Failed to connect to MongoDB, retrying: %s\n", err)
 			time.Sleep(time.Second) // exponential backoff could be implemented here
 			continue
 		}
-		return nil, errs.Wrap(err, uri)
 	}
 	return nil, errs.Wrap(err, uri)
 }
diff --git a/pkg/common/discoveryregister/zookeeper/zookeeper.go b/pkg/common/discoveryregister/zookeeper/zookeeper.go
index 0082e9833..9c58807c1 100644
--- a/pkg/common/discoveryregister/zookeeper/zookeeper.go
+++ b/pkg/common/discoveryregister/zookeeper/zookeeper.go
@@ -45,7 +45,7 @@ func NewZookeeperDiscoveryRegister() (discoveryregistry.SvcDiscoveryRegistry, er
 		openkeeper.WithLogger(log.NewZkLogger()),
 	)
 	if err != nil {
-		uriFormat := "address:%s, username :%s, password :%s, schema:%s."
+		uriFormat := "address:%s, username:%s, password:%s, schema:%s."
 		errInfo := fmt.Sprintf(uriFormat,
 			config.Config.Zookeeper.ZkAddr,
 			config.Config.Zookeeper.Username,
diff --git a/pkg/common/startrpc/start.go b/pkg/common/startrpc/start.go
index 31fe4fdd5..f7b547834 100644
--- a/pkg/common/startrpc/start.go
+++ b/pkg/common/startrpc/start.go
@@ -17,7 +17,6 @@ package startrpc
 import (
 	"errors"
 	"fmt"
-	"github.com/OpenIMSDK/tools/errs"
 	"log"
 	"net"
 	"net/http"
@@ -28,6 +27,8 @@ import (
 	"syscall"
 	"time"
 
+	"github.com/OpenIMSDK/tools/errs"
+
 	"github.com/prometheus/client_golang/prometheus"
 	"github.com/prometheus/client_golang/prometheus/promhttp"
 	"golang.org/x/sync/errgroup"
@@ -96,7 +97,7 @@ func Start(
 
 	err = rpcFn(client, srv)
 	if err != nil {
-		return errs.Wrap(err)
+		return err
 	}
 	err = client.Register(
 		rpcRegisterName,
@@ -116,7 +117,7 @@ func Start(
 			// Create a HTTP server for prometheus.
 			httpServer := &http.Server{Handler: promhttp.HandlerFor(reg, promhttp.HandlerOpts{}), Addr: fmt.Sprintf("0.0.0.0:%d", prometheusPort)}
 			if err := httpServer.ListenAndServe(); err != nil {
-				log.Fatal("Unable to start a http server.")
+				log.Fatal("Unable to start a http server. ", err.Error(), "PrometheusPort:", prometheusPort)
 			}
 		}
 		return nil
diff --git a/scripts/check-all.sh b/scripts/check-all.sh
index 1f6b740e6..062605ae1 100755
--- a/scripts/check-all.sh
+++ b/scripts/check-all.sh
@@ -49,6 +49,14 @@ print_services_and_ports() {
   echo "+-------------------------+----------+"
 }
 
+handle_error() {
+  echo "An error occurred. Printing ${STDERR_LOG_FILE} contents:"
+  cat "${STDERR_LOG_FILE}"
+  exit 1
+}
+
+trap handle_error ERR
+
 # Assuming OPENIM_SERVER_NAME_TARGETS and OPENIM_SERVER_PORT_TARGETS are defined
 # Similarly for OPENIM_DEPENDENCY_TARGETS and OPENIM_DEPENDENCY_PORT_TARGETS
 
@@ -94,3 +102,5 @@ else
 fi
 
 set -e
+
+trap - ERR
\ No newline at end of file
diff --git a/scripts/install/openim-api.sh b/scripts/install/openim-api.sh
index 2c3c19afb..c81dfcd0d 100755
--- a/scripts/install/openim-api.sh
+++ b/scripts/install/openim-api.sh
@@ -34,12 +34,15 @@ readonly OPENIM_API_SERVICE_TARGETS=(
 readonly OPENIM_API_SERVICE_LISTARIES=("${OPENIM_API_SERVICE_TARGETS[@]##*/}")
 
 function openim::api::start() {
+
+  rm -rf "$TMP_LOG_FILE"
+
   echo "++ OPENIM_API_SERVICE_LISTARIES: ${OPENIM_API_SERVICE_LISTARIES[@]}"
   echo "++ OPENIM_API_PORT_LISTARIES: ${OPENIM_API_PORT_LISTARIES[@]}"
   echo "++ OpenIM API config path: ${OPENIM_API_CONFIG}"
-  
+
   openim::log::info "Starting ${SERVER_NAME} ..."
-  
+
   printf "+------------------------+--------------+\n"
   printf "| Service Name           | Port         |\n"
   printf "+------------------------+--------------+\n"
@@ -80,8 +83,7 @@ function openim::api::start_service() {
   local prometheus_port="$3"
   
   local cmd="${OPENIM_OUTPUT_HOSTBIN}/${binary_name} --port ${service_port} -c ${OPENIM_API_CONFIG}"
-  
-  nohup ${cmd} >> "${LOG_FILE}" 2>&1 &
+  nohup ${cmd} >> "${LOG_FILE}" 2> >(tee -a "${STDERR_LOG_FILE}" "$TMP_LOG_FILE") &
   
   if [ $? -ne 0 ]; then
     openim::log::error_exit "Failed to start ${binary_name} on port ${service_port}."
diff --git a/scripts/install/openim-crontask.sh b/scripts/install/openim-crontask.sh
index cc9e686ff..6068e97d5 100755
--- a/scripts/install/openim-crontask.sh
+++ b/scripts/install/openim-crontask.sh
@@ -44,14 +44,19 @@ OPENIM_ROOT=$(cd "$(dirname "${BASH_SOURCE[0]}")"/../.. && pwd -P)
 SERVER_NAME="openim-crontask"
 
 function openim::crontask::start() {
+
+  rm -rf "$TMP_LOG_FILE"
+
   openim::log::info "Start OpenIM Cron, binary root: ${SERVER_NAME}"
   openim::log::status "Start OpenIM Cron, path: ${OPENIM_CRONTASK_BINARY}"
   
   openim::util::stop_services_with_name ${OPENIM_CRONTASK_BINARY}
   
   openim::log::status "start cron_task process, path: ${OPENIM_CRONTASK_BINARY}"
-  nohup ${OPENIM_CRONTASK_BINARY} -c ${OPENIM_PUSH_CONFIG} >> ${LOG_FILE} 2>&1 &
+
+  nohup ${OPENIM_CRONTASK_BINARY} -c ${OPENIM_PUSH_CONFIG} >> ${LOG_FILE} 2> >(tee -a "${STDERR_LOG_FILE}" "$TMP_LOG_FILE") &
   openim::util::check_process_names ${SERVER_NAME}
+
 }
 
 ###################################### Linux Systemd ######################################
diff --git a/scripts/install/openim-msggateway.sh b/scripts/install/openim-msggateway.sh
index d9fec4928..4e591deca 100755
--- a/scripts/install/openim-msggateway.sh
+++ b/scripts/install/openim-msggateway.sh
@@ -26,6 +26,9 @@ openim::util::set_max_fd 200000
 SERVER_NAME="openim-msggateway"
 
 function openim::msggateway::start() {
+
+  rm -rf "$TMP_LOG_FILE"
+
   openim::log::info "Start OpenIM Msggateway, binary root: ${SERVER_NAME}"
   openim::log::status "Start OpenIM Msggateway, path: ${OPENIM_MSGGATEWAY_BINARY}"
   
@@ -61,7 +64,7 @@ function openim::msggateway::start() {
             PROMETHEUS_PORT_OPTION="--prometheus_port ${MSG_GATEWAY_PROM_PORTS_ARRAY[$i]}"
         fi
 
-        nohup ${OPENIM_MSGGATEWAY_BINARY} --port ${OPENIM_MSGGATEWAY_PORTS_ARRAY[$i]} --ws_port ${OPENIM_WS_PORTS_ARRAY[$i]} $PROMETHEUS_PORT_OPTION -c ${OPENIM_MSGGATEWAY_CONFIG} >> ${LOG_FILE} 2>&1 &
+        nohup ${OPENIM_MSGGATEWAY_BINARY} --port ${OPENIM_MSGGATEWAY_PORTS_ARRAY[$i]} --ws_port ${OPENIM_WS_PORTS_ARRAY[$i]} $PROMETHEUS_PORT_OPTION -c ${OPENIM_MSGGATEWAY_CONFIG} >> ${LOG_FILE} 2> >(tee -a "${STDERR_LOG_FILE}" "$TMP_LOG_FILE") &
     done
 
     openim::util::check_process_names ${SERVER_NAME}
diff --git a/scripts/install/openim-msgtransfer.sh b/scripts/install/openim-msgtransfer.sh
index 1cead3a9a..def22c38b 100755
--- a/scripts/install/openim-msgtransfer.sh
+++ b/scripts/install/openim-msgtransfer.sh
@@ -28,6 +28,9 @@ openim::util::set_max_fd 200000
 SERVER_NAME="openim-msgtransfer"
 
 function openim::msgtransfer::start() {
+
+  rm -rf "$TMP_LOG_FILE"
+
   openim::log::info "Start OpenIM Msggateway, binary root: ${SERVER_NAME}"
   openim::log::status "Start OpenIM Msggateway, path: ${OPENIM_MSGTRANSFER_BINARY}"
   
@@ -56,7 +59,7 @@ function openim::msgtransfer::start() {
     if [[ -n "${OPENIM_PROMETHEUS_PORTS[$i]}" ]]; then
       PROMETHEUS_PORT_OPTION="--prometheus_port ${OPENIM_PROMETHEUS_PORTS[$i]}"
     fi
-    nohup ${OPENIM_MSGTRANSFER_BINARY} ${PROMETHEUS_PORT_OPTION} -c ${OPENIM_MSGTRANSFER_CONFIG} -n ${i}>> ${LOG_FILE} 2>&1 &
+    nohup ${OPENIM_MSGTRANSFER_BINARY} ${PROMETHEUS_PORT_OPTION} -c ${OPENIM_MSGTRANSFER_CONFIG} -n ${i} >> ${LOG_FILE} 2> >(tee -a "${STDERR_LOG_FILE}" "$TMP_LOG_FILE") &
   done
   
   openim::util::check_process_names  "${OPENIM_OUTPUT_HOSTBIN}/${SERVER_NAME}"
diff --git a/scripts/install/openim-push.sh b/scripts/install/openim-push.sh
index d43743e4f..4d14ca675 100755
--- a/scripts/install/openim-push.sh
+++ b/scripts/install/openim-push.sh
@@ -50,6 +50,9 @@ OPENIM_ROOT=$(cd "$(dirname "${BASH_SOURCE[0]}")"/../.. && pwd -P)
 SERVER_NAME="openim-push"
 
 function openim::push::start() {
+
+  rm -rf "$TMP_LOG_FILE"
+
   openim::log::status "Start OpenIM Push, binary root: ${SERVER_NAME}"
   openim::log::info "Start OpenIM Push, path: ${OPENIM_PUSH_BINARY}"
   
@@ -70,9 +73,9 @@ function openim::push::start() {
   
   for (( i=0; i<${#OPENIM_PUSH_PORTS_ARRAY[@]}; i++ )); do
     openim::log::info "start push process, port: ${OPENIM_PUSH_PORTS_ARRAY[$i]}, prometheus port: ${PUSH_PROM_PORTS_ARRAY[$i]}"
-    nohup ${OPENIM_PUSH_BINARY} --port ${OPENIM_PUSH_PORTS_ARRAY[$i]} -c ${OPENIM_PUSH_CONFIG} --prometheus_port ${PUSH_PROM_PORTS_ARRAY[$i]} >> ${LOG_FILE} 2>&1 &
+    nohup ${OPENIM_PUSH_BINARY} --port ${OPENIM_PUSH_PORTS_ARRAY[$i]} -c ${OPENIM_PUSH_CONFIG} --prometheus_port ${PUSH_PROM_PORTS_ARRAY[$i]} >${LOG_FILE} 2> >(tee -a "${STDERR_LOG_FILE}" "$TMP_LOG_FILE") &
   done
-  
+
   openim::util::check_process_names ${SERVER_NAME}
 }
 
diff --git a/scripts/install/openim-rpc.sh b/scripts/install/openim-rpc.sh
index 966eef928..00031f211 100755
--- a/scripts/install/openim-rpc.sh
+++ b/scripts/install/openim-rpc.sh
@@ -102,6 +102,8 @@ readonly OPENIM_RPC_PROM_PORT_TARGETS
 readonly OPENIM_RPC_PROM_PORT_LISTARIES=("${OPENIM_RPC_PROM_PORT_TARGETS[@]##*/}")
 
 function openim::rpc::start() {
+    rm -rf "$TMP_LOG_FILE"
+
     echo "OPENIM_RPC_SERVICE_LISTARIES: ${OPENIM_RPC_SERVICE_LISTARIES[@]}"
     echo "OPENIM_RPC_PROM_PORT_LISTARIES: ${OPENIM_RPC_PROM_PORT_LISTARIES[@]}"
     echo "OPENIM_RPC_PORT_LISTARIES: ${OPENIM_RPC_PORT_LISTARIES[@]}"
@@ -123,6 +125,7 @@ function openim::rpc::start() {
     for ((i = 0; i < ${#OPENIM_RPC_SERVICE_LISTARIES[*]}; i++)); do
         # openim::util::stop_services_with_name ${OPENIM_RPC_SERVICE_LISTARIES
         openim::util::stop_services_on_ports ${OPENIM_RPC_PORT_LISTARIES[$i]}
+        openim::util::stop_services_on_ports ${OPENIM_RPC_PROM_PORT_LISTARIES[$i]}
 
         openim::log::info "OpenIM ${OPENIM_RPC_SERVICE_LISTARIES[$i]} config path: ${OPENIM_RPC_CONFIG}"
 
@@ -157,7 +160,7 @@ function openim::rpc::start_service() {
     printf "Specifying prometheus port: %s\n" "${prometheus_port}"
     cmd="${cmd} --prometheus_port ${prometheus_port}"
   fi
-  nohup ${cmd} >> "${LOG_FILE}" 2>&1 &
+  nohup ${cmd} >> "${LOG_FILE}" 2> >(tee -a "${STDERR_LOG_FILE}" "$TMP_LOG_FILE") &
 }
 
 ###################################### Linux Systemd ######################################
diff --git a/scripts/lib/logging.sh b/scripts/lib/logging.sh
index c520850e8..2fa77dd83 100755
--- a/scripts/lib/logging.sh
+++ b/scripts/lib/logging.sh
@@ -26,10 +26,14 @@ fi
 
 # Set the log file path
 LOG_FILE="${OPENIM_OUTPUT}/logs/openim_$(date '+%Y%m%d').log"
+STDERR_LOG_FILE="${OPENIM_OUTPUT}/logs/openim_error_$(date '+%Y%m%d').log"
+TMP_LOG_FILE="${OPENIM_OUTPUT}/logs/openim_tmp_$(date '+%Y%m%d').log"
 
 if [[ ! -d "${OPENIM_OUTPUT}/logs" ]]; then
   mkdir -p "${OPENIM_OUTPUT}/logs"
   touch "$LOG_FILE"
+  touch "$STDERR_LOG_FILE"
+  touch "$TMP_LOG_FILE"
 fi
 
 # Define the logging function
diff --git a/scripts/lib/util.sh b/scripts/lib/util.sh
index a40668d70..b93f45205 100755
--- a/scripts/lib/util.sh
+++ b/scripts/lib/util.sh
@@ -360,7 +360,9 @@ openim::util::check_ports() {
   
   # If any of the processes is not running, return a status of 1.
   if [[ ${#not_started[@]} -ne 0 ]]; then
-    echo "++++ OpenIM Log >> cat ${LOG_FILE}"
+    openim::color::echo $COLOR_RED " OpenIM Stdout Log >> cat ${LOG_FILE}"
+    openim::color::echo $COLOR_RED " OpenIM Stderr Log >> cat ${STDERR_LOG_FILE}"
+    cat "$TMP_LOG_FILE" | awk '{print "\033[31m" $0 "\033[0m"}'
     return 1
   else
     openim::log::success "All specified processes are running."
@@ -444,9 +446,12 @@ openim::util::check_process_names() {
   
   # Return status
   if [[ ${#not_started[@]} -ne 0 ]]; then
-    echo "++++ OpenIM Log >> cat ${LOG_FILE}"
+    openim::color::echo $COLOR_RED " OpenIM Stdout Log >> cat ${LOG_FILE}"
+    openim::color::echo $COLOR_RED " OpenIM Stderr Log >> cat ${STDERR_LOG_FILE}"
+    cat "$TMP_LOG_FILE" | awk '{print "\033[31m" $0 "\033[0m"}'
     return 1
   else
+    echo ""
     openim::log::success "All processes are running."
     return 0
   fi
@@ -1536,12 +1541,12 @@ openim::util::check_ports() {
         if [[ "$OSTYPE" == "linux-gnu"* ]]; then
             if command -v ss > /dev/null 2>&1; then
                 info=$(ss -ltnp | grep ":$port" || true)
-                echo "!!!!!!!!!!! port=$port"
-                echo "!!!!!!!!!!! info=$info"
+                openim::color::echo $COLOR_RED "!!!!!!!! port=$port"
+                openim::color::echo $COLOR_RED "!!!!!!!! info=$info"
             else
                 info=$(netstat -ltnp | grep ":$port" || true)
-                echo "!!!!!!!!!!! port=$port"
-                echo "!!!!!!!!!!! info=$info"
+                openim::color::echo $COLOR_RED "!!!!!!!! port=$port"
+                openim::color::echo $COLOR_RED "!!!!!!!! info=$info"
             fi
         elif [[ "$OSTYPE" == "darwin"* ]]; then
             # For macOS, use lsof
@@ -1594,7 +1599,10 @@ openim::util::check_ports() {
 
     # If any of the processes is not running, return a status of 1.
     if [[ ${#not_started[@]} -ne 0 ]]; then
-        echo "++++ OpenIM Log >> cat ${LOG_FILE}"
+        openim::color::echo $COLOR_RED " OpenIM Stdout Log >> cat ${LOG_FILE}"
+        openim::color::echo $COLOR_RED " OpenIM Stderr Log >> cat ${STDERR_LOG_FILE}"
+        echo ""
+        cat "$TMP_LOG_FILE" | awk '{print "\033[31m" $0 "\033[0m"}'
         return 1
     else
         openim::log::success "All specified processes are running."
@@ -1678,9 +1686,12 @@ openim::util::check_process_names() {
 
     # Return status
     if [[ ${#not_started[@]} -ne 0 ]]; then
-        echo "++++ OpenIM Log >> cat ${LOG_FILE}"
+        openim::color::echo $COLOR_RED " OpenIM Stdout Log >> cat ${LOG_FILE}"
+        openim::color::echo $COLOR_RED " OpenIM Stderr Log >> cat ${STDERR_LOG_FILE}"
+        cat "$TMP_LOG_FILE" | awk '{print "\033[31m" $0 "\033[0m"}'
         return 1
     else
+        echo ""
         openim::log::success "All processes are running."
         return 0
     fi
diff --git a/tools/component/component.go b/tools/component/component.go
index 787ca8af6..bd6007015 100644
--- a/tools/component/component.go
+++ b/tools/component/component.go
@@ -15,6 +15,7 @@
 package main
 
 import (
+	"errors"
 	"flag"
 	"fmt"
 	"github.com/IBM/sarama"
@@ -56,6 +57,7 @@ func initCfg() error {
 type checkFunc struct {
 	name     string
 	function func() error
+	flag     bool
 }
 
 func main() {
@@ -86,13 +88,17 @@ func main() {
 
 		var err error
 		allSuccess := true
-		for _, check := range checks {
-			err = check.function()
-			if err != nil {
-				component.ErrorPrint(fmt.Sprintf("Starting %s failed:%v.", check.name, err))
-				allSuccess = false
-			} else {
-				component.SuccessPrint(fmt.Sprintf("%s connected successfully", check.name))
+		for index, check := range checks {
+			if !check.flag {
+				err = check.function()
+				if err != nil {
+					component.ErrorPrint(fmt.Sprintf("Starting %s failed:%v.", check.name, err))
+					allSuccess = false
+
+				} else {
+					checks[index].flag = true
+					component.SuccessPrint(fmt.Sprintf("%s connected successfully", check.name))
+				}
 			}
 		}
 
@@ -120,7 +126,7 @@ func checkMinio() error {
 
 	// Check if MinIO is enabled
 	if config.Config.Object.Enable != "minio" {
-		return nil
+		return errs.Wrap(errors.New("minio.Enable is empty"))
 	}
 	minio := &component.Minio{
 		ApiURL:          config.Config.Object.ApiURL,
@@ -130,7 +136,7 @@ func checkMinio() error {
 		SignEndpoint:    config.Config.Object.Minio.SignEndpoint,
 		UseSSL:          getEnv("MINIO_USE_SSL", "false"),
 	}
-	_, err := component.CheckMinio(minio)
+	err := component.CheckMinio(minio)
 	return err
 }
 
@@ -149,7 +155,7 @@ func checkKafka() error {
 		Addr:     config.Config.Kafka.Addr,
 	}
 
-	_, kafkaClient, err := component.CheckKafka(kafkaStu)
+	kafkaClient, err := component.CheckKafka(kafkaStu)
 	if err != nil {
 		return err
 	}
diff --git a/tools/ncpu/ncpu.go b/tools/ncpu/ncpu.go
index 7ca3dff5e..ca2409a6f 100644
--- a/tools/ncpu/ncpu.go
+++ b/tools/ncpu/ncpu.go
@@ -1,17 +1,3 @@
-// Copyright © 2023 OpenIM. All rights reserved.
-//
-// Licensed under the Apache License, Version 2.0 (the "License");
-// you may not use this file except in compliance with the License.
-// You may obtain a copy of the License at
-//
-//     http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing, software
-// distributed under the License is distributed on an "AS IS" BASIS,
-// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-// See the License for the specific language governing permissions and
-// limitations under the License.
-
 package main
 
 import (
@@ -22,6 +8,11 @@ import (
 )
 
 func main() {
-	maxprocs.Set()
-	fmt.Print(runtime.GOMAXPROCS(0))
+	// Set maxprocs with a custom logger that does nothing to ignore logs.
+	maxprocs.Set(maxprocs.Logger(func(string, ...interface{}) {
+		// Intentionally left blank to suppress all log output from automaxprocs.
+	}))
+
+	// Now this will print the GOMAXPROCS value without printing the automaxprocs log message.
+	fmt.Println(runtime.GOMAXPROCS(0))
 }

From 8729f90d0293347763b57961b9aeb8a1f14e855f Mon Sep 17 00:00:00 2001
From: OpenIM Bot <124379614+kubbot@users.noreply.github.com>
Date: Sun, 4 Feb 2024 10:40:26 +0800
Subject: [PATCH 2/2] cicd: bump League Patch (#1874)

---
 cmd/openim-api/main.go                             |  4 +++-
 cmd/openim-cmdutils/main.go                        |  3 ++-
 cmd/openim-crontask/main.go                        |  3 ++-
 cmd/openim-msggateway/main.go                      |  3 ++-
 cmd/openim-msgtransfer/main.go                     |  3 ++-
 cmd/openim-push/main.go                            |  3 ++-
 cmd/openim-rpc/openim-rpc-auth/main.go             |  3 ++-
 cmd/openim-rpc/openim-rpc-conversation/main.go     |  3 ++-
 cmd/openim-rpc/openim-rpc-friend/main.go           |  3 ++-
 cmd/openim-rpc/openim-rpc-group/main.go            |  3 ++-
 cmd/openim-rpc/openim-rpc-msg/main.go              |  3 ++-
 cmd/openim-rpc/openim-rpc-third/main.go            |  3 ++-
 cmd/openim-rpc/openim-rpc-user/main.go             |  3 ++-
 go.mod                                             |  1 -
 go.sum                                             |  3 ---
 internal/msgtransfer/init.go                       |  3 ++-
 internal/tools/cron_task.go                        |  3 ++-
 pkg/common/db/mgo/conversation.go                  |  3 ++-
 pkg/common/db/mgo/group.go                         |  3 ++-
 pkg/common/db/mgo/group_member.go                  |  1 +
 pkg/common/db/mgo/group_request.go                 |  1 +
 pkg/common/db/unrelation/mongo.go                  |  1 +
 .../discoveryregister/zookeeper/zookeeper.go       |  3 ++-
 pkg/common/kafka/consumer_group.go                 |  3 ++-
 pkg/common/kafka/producer.go                       |  3 ++-
 tools/component/component.go                       |  8 +++++---
 tools/ncpu/ncpu.go                                 | 14 ++++++++++++++
 27 files changed, 63 insertions(+), 27 deletions(-)

diff --git a/cmd/openim-api/main.go b/cmd/openim-api/main.go
index 755b35591..a45bcbdd8 100644
--- a/cmd/openim-api/main.go
+++ b/cmd/openim-api/main.go
@@ -17,7 +17,6 @@ package main
 import (
 	"context"
 	"fmt"
-	"github.com/OpenIMSDK/tools/errs"
 	"net"
 	"net/http"
 	_ "net/http/pprof"
@@ -27,8 +26,11 @@ import (
 	"syscall"
 	"time"
 
+	"github.com/OpenIMSDK/tools/errs"
+
 	"github.com/OpenIMSDK/protocol/constant"
 	"github.com/OpenIMSDK/tools/discoveryregistry"
+
 	"github.com/openimsdk/open-im-server/v3/internal/api"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/cmd"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/config"
diff --git a/cmd/openim-cmdutils/main.go b/cmd/openim-cmdutils/main.go
index a13bc4f33..45b324766 100644
--- a/cmd/openim-cmdutils/main.go
+++ b/cmd/openim-cmdutils/main.go
@@ -16,8 +16,9 @@ package main
 
 import (
 	"fmt"
-	"github.com/openimsdk/open-im-server/v3/pkg/common/cmd"
 	"os"
+
+	"github.com/openimsdk/open-im-server/v3/pkg/common/cmd"
 )
 
 func main() {
diff --git a/cmd/openim-crontask/main.go b/cmd/openim-crontask/main.go
index 5061c5408..324001690 100644
--- a/cmd/openim-crontask/main.go
+++ b/cmd/openim-crontask/main.go
@@ -16,9 +16,10 @@ package main
 
 import (
 	"fmt"
+	"os"
+
 	"github.com/openimsdk/open-im-server/v3/internal/tools"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/cmd"
-	"os"
 )
 
 func main() {
diff --git a/cmd/openim-msggateway/main.go b/cmd/openim-msggateway/main.go
index 25cfe5fa8..5339891c8 100644
--- a/cmd/openim-msggateway/main.go
+++ b/cmd/openim-msggateway/main.go
@@ -16,8 +16,9 @@ package main
 
 import (
 	"fmt"
-	"github.com/openimsdk/open-im-server/v3/pkg/common/cmd"
 	"os"
+
+	"github.com/openimsdk/open-im-server/v3/pkg/common/cmd"
 )
 
 func main() {
diff --git a/cmd/openim-msgtransfer/main.go b/cmd/openim-msgtransfer/main.go
index e3c2f374f..cf1b44a55 100644
--- a/cmd/openim-msgtransfer/main.go
+++ b/cmd/openim-msgtransfer/main.go
@@ -16,8 +16,9 @@ package main
 
 import (
 	"fmt"
-	"github.com/openimsdk/open-im-server/v3/pkg/common/cmd"
 	"os"
+
+	"github.com/openimsdk/open-im-server/v3/pkg/common/cmd"
 )
 
 func main() {
diff --git a/cmd/openim-push/main.go b/cmd/openim-push/main.go
index 79152f945..77f75cb4e 100644
--- a/cmd/openim-push/main.go
+++ b/cmd/openim-push/main.go
@@ -16,10 +16,11 @@ package main
 
 import (
 	"fmt"
+	"os"
+
 	"github.com/openimsdk/open-im-server/v3/internal/push"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/cmd"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/config"
-	"os"
 )
 
 func main() {
diff --git a/cmd/openim-rpc/openim-rpc-auth/main.go b/cmd/openim-rpc/openim-rpc-auth/main.go
index 8ee7053f3..b29efd484 100644
--- a/cmd/openim-rpc/openim-rpc-auth/main.go
+++ b/cmd/openim-rpc/openim-rpc-auth/main.go
@@ -16,10 +16,11 @@ package main
 
 import (
 	"fmt"
+	"os"
+
 	"github.com/openimsdk/open-im-server/v3/internal/rpc/auth"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/cmd"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/config"
-	"os"
 )
 
 func main() {
diff --git a/cmd/openim-rpc/openim-rpc-conversation/main.go b/cmd/openim-rpc/openim-rpc-conversation/main.go
index 259d79abf..f9ac8cd27 100644
--- a/cmd/openim-rpc/openim-rpc-conversation/main.go
+++ b/cmd/openim-rpc/openim-rpc-conversation/main.go
@@ -16,10 +16,11 @@ package main
 
 import (
 	"fmt"
+	"os"
+
 	"github.com/openimsdk/open-im-server/v3/internal/rpc/conversation"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/cmd"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/config"
-	"os"
 )
 
 func main() {
diff --git a/cmd/openim-rpc/openim-rpc-friend/main.go b/cmd/openim-rpc/openim-rpc-friend/main.go
index bd85da7b0..82d71d522 100644
--- a/cmd/openim-rpc/openim-rpc-friend/main.go
+++ b/cmd/openim-rpc/openim-rpc-friend/main.go
@@ -16,10 +16,11 @@ package main
 
 import (
 	"fmt"
+	"os"
+
 	"github.com/openimsdk/open-im-server/v3/internal/rpc/friend"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/cmd"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/config"
-	"os"
 )
 
 func main() {
diff --git a/cmd/openim-rpc/openim-rpc-group/main.go b/cmd/openim-rpc/openim-rpc-group/main.go
index e40c04d19..360042f84 100644
--- a/cmd/openim-rpc/openim-rpc-group/main.go
+++ b/cmd/openim-rpc/openim-rpc-group/main.go
@@ -16,10 +16,11 @@ package main
 
 import (
 	"fmt"
+	"os"
+
 	"github.com/openimsdk/open-im-server/v3/internal/rpc/group"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/cmd"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/config"
-	"os"
 )
 
 func main() {
diff --git a/cmd/openim-rpc/openim-rpc-msg/main.go b/cmd/openim-rpc/openim-rpc-msg/main.go
index 989746dc7..bed57f522 100644
--- a/cmd/openim-rpc/openim-rpc-msg/main.go
+++ b/cmd/openim-rpc/openim-rpc-msg/main.go
@@ -16,10 +16,11 @@ package main
 
 import (
 	"fmt"
+	"os"
+
 	"github.com/openimsdk/open-im-server/v3/internal/rpc/msg"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/cmd"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/config"
-	"os"
 )
 
 func main() {
diff --git a/cmd/openim-rpc/openim-rpc-third/main.go b/cmd/openim-rpc/openim-rpc-third/main.go
index fbd386946..4868ce149 100644
--- a/cmd/openim-rpc/openim-rpc-third/main.go
+++ b/cmd/openim-rpc/openim-rpc-third/main.go
@@ -16,10 +16,11 @@ package main
 
 import (
 	"fmt"
+	"os"
+
 	"github.com/openimsdk/open-im-server/v3/internal/rpc/third"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/cmd"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/config"
-	"os"
 )
 
 func main() {
diff --git a/cmd/openim-rpc/openim-rpc-user/main.go b/cmd/openim-rpc/openim-rpc-user/main.go
index 160bbe311..a77a2f768 100644
--- a/cmd/openim-rpc/openim-rpc-user/main.go
+++ b/cmd/openim-rpc/openim-rpc-user/main.go
@@ -16,10 +16,11 @@ package main
 
 import (
 	"fmt"
+	"os"
+
 	"github.com/openimsdk/open-im-server/v3/internal/rpc/user"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/cmd"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/config"
-	"os"
 )
 
 func main() {
diff --git a/go.mod b/go.mod
index d82d3390b..3da7c3ecd 100644
--- a/go.mod
+++ b/go.mod
@@ -41,7 +41,6 @@ require (
 	github.com/spf13/pflag v1.0.5
 	github.com/stathat/consistent v1.0.0
 	github.com/tencentyun/cos-go-sdk-v5 v0.7.45
-	go.uber.org/automaxprocs v1.5.3
 	golang.org/x/sync v0.4.0
 	gopkg.in/src-d/go-git.v4 v4.13.1
 	gotest.tools v2.2.0+incompatible
diff --git a/go.sum b/go.sum
index fb047dfdc..84620fe7d 100644
--- a/go.sum
+++ b/go.sum
@@ -277,7 +277,6 @@ github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4=
 github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
-github.com/prashantv/gostub v1.1.0 h1:BTyx3RfQjRHnUWaGF9oQos79AlQ5k8WNktv7VGvVH4g=
 github.com/prometheus/client_golang v1.17.0 h1:rl2sfwZMtSthVU752MqfjQozy7blglC+1SOtjMAMh+Q=
 github.com/prometheus/client_golang v1.17.0/go.mod h1:VeL+gMmOAxkS2IqfCq0ZmHSL+LjWfWDUmp1mBz9JgUY=
 github.com/prometheus/client_model v0.0.0-20190812154241-14fe0d1b01d4/go.mod h1:xMI15A0UPsDsEKsMN9yxemIoYk6Tm2C1GtYGdfGttqA=
@@ -352,8 +351,6 @@ go.opencensus.io v0.24.0 h1:y73uSU6J157QMP2kn2r30vwW1A2W2WFwSCGnAVxeaD0=
 go.opencensus.io v0.24.0/go.mod h1:vNK8G9p7aAivkbmorf4v+7Hgx+Zs0yY+0fOtgBfjQKo=
 go.uber.org/atomic v1.7.0 h1:ADUqmZGgLDDfbSL9ZmPxKTybcoEYHgpYfELNoN+7hsw=
 go.uber.org/atomic v1.7.0/go.mod h1:fEN4uk6kAWBTFdckzkM89CLk9XfWZrxpCo0nPH17wJc=
-go.uber.org/automaxprocs v1.5.3 h1:kWazyxZUrS3Gs4qUpbwo5kEIMGe/DAvi5Z4tl2NW4j8=
-go.uber.org/automaxprocs v1.5.3/go.mod h1:eRbA25aqJrxAbsLO0xy5jVwPt7FQnRgjW+efnwa1WM0=
 go.uber.org/goleak v1.1.11 h1:wy28qYRKZgnJTxGxvye5/wgWr1EKjmUDGYox5mGlRlI=
 go.uber.org/multierr v1.11.0 h1:blXXJkSxSSfBVBlC76pxqeO+LN3aDfLQo+309xJstO0=
 go.uber.org/multierr v1.11.0/go.mod h1:20+QtiLqy0Nd6FdQB9TLXag12DsQkrbs3htMFfDN80Y=
diff --git a/internal/msgtransfer/init.go b/internal/msgtransfer/init.go
index 969761a9d..83ec00749 100644
--- a/internal/msgtransfer/init.go
+++ b/internal/msgtransfer/init.go
@@ -18,11 +18,12 @@ import (
 	"context"
 	"errors"
 	"fmt"
-	"github.com/OpenIMSDK/tools/errs"
 	"log"
 	"net/http"
 	"sync"
 
+	"github.com/OpenIMSDK/tools/errs"
+
 	"github.com/OpenIMSDK/tools/mw"
 	"github.com/prometheus/client_golang/prometheus"
 	"github.com/prometheus/client_golang/prometheus/collectors"
diff --git a/internal/tools/cron_task.go b/internal/tools/cron_task.go
index cf2068d8e..40e1c0a87 100644
--- a/internal/tools/cron_task.go
+++ b/internal/tools/cron_task.go
@@ -17,12 +17,13 @@ package tools
 import (
 	"context"
 	"fmt"
-	"github.com/OpenIMSDK/tools/errs"
 	"os"
 	"os/signal"
 	"syscall"
 	"time"
 
+	"github.com/OpenIMSDK/tools/errs"
+
 	"github.com/redis/go-redis/v9"
 	"github.com/robfig/cron/v3"
 
diff --git a/pkg/common/db/mgo/conversation.go b/pkg/common/db/mgo/conversation.go
index 0b8d597dc..d0a46ae47 100644
--- a/pkg/common/db/mgo/conversation.go
+++ b/pkg/common/db/mgo/conversation.go
@@ -16,9 +16,10 @@ package mgo
 
 import (
 	"context"
-	"github.com/OpenIMSDK/tools/errs"
 	"time"
 
+	"github.com/OpenIMSDK/tools/errs"
+
 	"github.com/OpenIMSDK/protocol/constant"
 	"github.com/OpenIMSDK/tools/mgoutil"
 	"github.com/OpenIMSDK/tools/pagination"
diff --git a/pkg/common/db/mgo/group.go b/pkg/common/db/mgo/group.go
index 9a4c660a6..922bfd424 100644
--- a/pkg/common/db/mgo/group.go
+++ b/pkg/common/db/mgo/group.go
@@ -16,9 +16,10 @@ package mgo
 
 import (
 	"context"
-	"github.com/OpenIMSDK/tools/errs"
 	"time"
 
+	"github.com/OpenIMSDK/tools/errs"
+
 	"github.com/OpenIMSDK/tools/mgoutil"
 	"github.com/OpenIMSDK/tools/pagination"
 	"go.mongodb.org/mongo-driver/bson"
diff --git a/pkg/common/db/mgo/group_member.go b/pkg/common/db/mgo/group_member.go
index fce79830e..e28432b11 100644
--- a/pkg/common/db/mgo/group_member.go
+++ b/pkg/common/db/mgo/group_member.go
@@ -16,6 +16,7 @@ package mgo
 
 import (
 	"context"
+
 	"github.com/OpenIMSDK/tools/errs"
 
 	"github.com/OpenIMSDK/protocol/constant"
diff --git a/pkg/common/db/mgo/group_request.go b/pkg/common/db/mgo/group_request.go
index dce0878ee..d20682239 100644
--- a/pkg/common/db/mgo/group_request.go
+++ b/pkg/common/db/mgo/group_request.go
@@ -16,6 +16,7 @@ package mgo
 
 import (
 	"context"
+
 	"github.com/OpenIMSDK/tools/errs"
 
 	"github.com/OpenIMSDK/tools/mgoutil"
diff --git a/pkg/common/db/unrelation/mongo.go b/pkg/common/db/unrelation/mongo.go
index 2bade9a62..4c093b3c3 100644
--- a/pkg/common/db/unrelation/mongo.go
+++ b/pkg/common/db/unrelation/mongo.go
@@ -27,6 +27,7 @@ import (
 
 	"github.com/OpenIMSDK/tools/errs"
 	"github.com/OpenIMSDK/tools/mw/specialerror"
+
 	"github.com/openimsdk/open-im-server/v3/pkg/common/config"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/db/table/unrelation"
 )
diff --git a/pkg/common/discoveryregister/zookeeper/zookeeper.go b/pkg/common/discoveryregister/zookeeper/zookeeper.go
index 9c58807c1..6e55b6b8b 100644
--- a/pkg/common/discoveryregister/zookeeper/zookeeper.go
+++ b/pkg/common/discoveryregister/zookeeper/zookeeper.go
@@ -16,11 +16,12 @@ package zookeeper
 
 import (
 	"fmt"
-	"github.com/OpenIMSDK/tools/errs"
 	"os"
 	"strings"
 	"time"
 
+	"github.com/OpenIMSDK/tools/errs"
+
 	"github.com/OpenIMSDK/tools/discoveryregistry"
 	openkeeper "github.com/OpenIMSDK/tools/discoveryregistry/zookeeper"
 	"github.com/OpenIMSDK/tools/log"
diff --git a/pkg/common/kafka/consumer_group.go b/pkg/common/kafka/consumer_group.go
index 87e6d5686..6e6f83fca 100644
--- a/pkg/common/kafka/consumer_group.go
+++ b/pkg/common/kafka/consumer_group.go
@@ -16,9 +16,10 @@ package kafka
 
 import (
 	"context"
-	"github.com/OpenIMSDK/tools/errs"
 	"strings"
 
+	"github.com/OpenIMSDK/tools/errs"
+
 	"github.com/OpenIMSDK/tools/log"
 
 	"github.com/openimsdk/open-im-server/v3/pkg/common/config"
diff --git a/pkg/common/kafka/producer.go b/pkg/common/kafka/producer.go
index b9f0b4656..417aadb54 100644
--- a/pkg/common/kafka/producer.go
+++ b/pkg/common/kafka/producer.go
@@ -18,10 +18,11 @@ import (
 	"bytes"
 	"context"
 	"errors"
-	"github.com/OpenIMSDK/tools/errs"
 	"strings"
 	"time"
 
+	"github.com/OpenIMSDK/tools/errs"
+
 	"github.com/IBM/sarama"
 	"github.com/OpenIMSDK/protocol/constant"
 	"github.com/OpenIMSDK/tools/log"
diff --git a/tools/component/component.go b/tools/component/component.go
index bd6007015..6b879d7f8 100644
--- a/tools/component/component.go
+++ b/tools/component/component.go
@@ -18,14 +18,16 @@ import (
 	"errors"
 	"flag"
 	"fmt"
+	"os"
+	"strings"
+	"time"
+
 	"github.com/IBM/sarama"
+
 	"github.com/openimsdk/open-im-server/v3/pkg/common/db/cache"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/db/unrelation"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/discoveryregister/zookeeper"
 	"github.com/openimsdk/open-im-server/v3/pkg/common/kafka"
-	"os"
-	"strings"
-	"time"
 
 	"github.com/OpenIMSDK/tools/component"
 	"github.com/OpenIMSDK/tools/errs"
diff --git a/tools/ncpu/ncpu.go b/tools/ncpu/ncpu.go
index ca2409a6f..062618b27 100644
--- a/tools/ncpu/ncpu.go
+++ b/tools/ncpu/ncpu.go
@@ -1,3 +1,17 @@
+// Copyright © 2024 OpenIM. All rights reserved.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
 package main
 
 import (