diff --git a/cmd/openim-api/main.go b/cmd/openim-api/main.go
index 7a7e06293..04a0f13df 100644
--- a/cmd/openim-api/main.go
+++ b/cmd/openim-api/main.go
@@ -119,7 +119,6 @@ func run(port int, proPort int) error {
 	defer cancel()
 	select {
 	case <-sigs:
-		util.SIGUSR1Exit()
 		err := server.Shutdown(ctx)
 		if err != nil {
 			return errs.Wrap(err, "shutdown err")
diff --git a/internal/msggateway/init.go b/internal/msggateway/init.go
index 321407f7e..b18efcd50 100644
--- a/internal/msggateway/init.go
+++ b/internal/msggateway/init.go
@@ -46,9 +46,7 @@ func RunWsAndServer(rpcPort, wsPort, prometheusPort int) error {
 	netDone := make(chan error)
 	go func() {
 		err = hubServer.Start()
-		if err != nil {
-			netDone <- err
-		}
+		netDone <- err
 	}()
 	return hubServer.LongConnServer.Run(netDone)
 }
diff --git a/internal/msgtransfer/init.go b/internal/msgtransfer/init.go
index 16d8613db..3948b32e9 100644
--- a/internal/msgtransfer/init.go
+++ b/internal/msgtransfer/init.go
@@ -22,8 +22,6 @@ import (
 	"github.com/OpenIMSDK/tools/errs"
 	"github.com/OpenIMSDK/tools/log"
 
-	util "github.com/openimsdk/open-im-server/v3/pkg/util/genutil"
-
 	"net/http"
 	"os"
 	"os/signal"
@@ -144,7 +142,6 @@ func (m *MsgTransfer) Start(prometheusPort int) error {
 	signal.Notify(sigs, syscall.SIGTERM)
 	select {
 	case <-sigs:
-		util.SIGUSR1Exit()
 		// graceful close kafka client.
 		m.cancel()
 		m.historyCH.historyConsumerGroup.Close()
diff --git a/pkg/common/startrpc/start.go b/pkg/common/startrpc/start.go
index 9251012e8..8f77ce841 100644
--- a/pkg/common/startrpc/start.go
+++ b/pkg/common/startrpc/start.go
@@ -29,8 +29,6 @@ import (
 
 	"github.com/OpenIMSDK/tools/errs"
 
-	util "github.com/openimsdk/open-im-server/v3/pkg/util/genutil"
-
 	"github.com/prometheus/client_golang/prometheus"
 	"github.com/prometheus/client_golang/prometheus/promhttp"
 
@@ -140,7 +138,6 @@ func Start(
 	signal.Notify(sigs, syscall.SIGTERM)
 	select {
 	case <-sigs:
-		util.SIGUSR1Exit()
 		ctx, cancel := context.WithTimeout(context.Background(), 15*time.Second)
 		defer cancel()
 		if err := gracefulStopWithCtx(ctx, srv.GracefulStop); err != nil {
@@ -152,11 +149,11 @@ func Start(
 		if err != nil {
 			return errs.Wrap(err, "shutdown err")
 		}
-		return errs.Wrap(errors.New("SIGTERM EXIT"))
 	case <-netDone:
 		close(netDone)
 		return netErr
 	}
+	return nil
 }
 
 func gracefulStopWithCtx(ctx context.Context, f func()) error {