From 1871b616ba89b8869f001452180069f644c732bb Mon Sep 17 00:00:00 2001
From: brennanli <brennanli@tencent.com>
Date: Sun, 17 Oct 2021 13:25:10 +0800
Subject: [PATCH 01/13] Modify bug for getting lastest seq

---
 src/common/db/redisModel.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/common/db/redisModel.go b/src/common/db/redisModel.go
index f86dbb638..2e3277914 100644
--- a/src/common/db/redisModel.go
+++ b/src/common/db/redisModel.go
@@ -66,7 +66,7 @@ func (d *DataBases) SetLastGetSeq(uid string) (err error) {
 
 //获取用户上一次主动拉取Seq的值
 func (d *DataBases) GetLastGetSeq(uid string) (int64, error) {
-	key := userIncrSeq + uid
+	key := lastGetSeq + uid
 	return redis.Int64(d.Exec("GET", key))
 }
 

From 7caf5a0df9a757e077adb275eb749a863c2a30ca Mon Sep 17 00:00:00 2001
From: Yaxian <yaxian.gu@gmail.com>
Date: Wed, 20 Oct 2021 23:03:55 +0800
Subject: [PATCH 02/13] ci: ignore files created by docker-compose (#19)

---
 .gitignore | 2 ++
 1 file changed, 2 insertions(+)
 create mode 100644 .gitignore

diff --git a/.gitignore b/.gitignore
new file mode 100644
index 000000000..6913e8f09
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1,2 @@
+components
+logs
\ No newline at end of file

From c8155553b84268efbb9032544d264106f2ab5656 Mon Sep 17 00:00:00 2001
From: Yaxian <yaxian.gu@gmail.com>
Date: Thu, 21 Oct 2021 11:30:48 +0800
Subject: [PATCH 03/13] feat: optimise get server ip (#20)

* feat: optimise get server ip

* feat: test ServerIP
---
 src/common/config/config.go     | 17 +++++++++++++----
 src/utils/get_server_ip.go      | 23 +++++++----------------
 src/utils/get_server_ip_test.go | 12 ++++++++++++
 3 files changed, 32 insertions(+), 20 deletions(-)
 create mode 100644 src/utils/get_server_ip_test.go

diff --git a/src/common/config/config.go b/src/common/config/config.go
index faf75a5b8..6294a031c 100644
--- a/src/common/config/config.go
+++ b/src/common/config/config.go
@@ -1,8 +1,17 @@
 package config
 
 import (
-	"gopkg.in/yaml.v3"
 	"io/ioutil"
+	"path/filepath"
+	"runtime"
+
+	"gopkg.in/yaml.v3"
+)
+
+var (
+	_, b, _, _ = runtime.Caller(0)
+	// Root folder of this project
+	Root = filepath.Join(filepath.Dir(b), "../../..")
 )
 
 var Config config
@@ -147,14 +156,14 @@ type config struct {
 }
 
 func init() {
-	bytes, err := ioutil.ReadFile("../config/config.yaml")
+	// if we cd Open-IM-Server/src/utils and run go test
+	// it will panic cannot find config/config.yaml
+	bytes, err := ioutil.ReadFile(Root + "/config/config.yaml")
 	if err != nil {
 		panic(err)
-		return
 	}
 	if err = yaml.Unmarshal(bytes, &Config); err != nil {
 		panic(err)
-		return
 	}
 
 }
diff --git a/src/utils/get_server_ip.go b/src/utils/get_server_ip.go
index 21092ffa1..ec5824cb8 100644
--- a/src/utils/get_server_ip.go
+++ b/src/utils/get_server_ip.go
@@ -13,23 +13,14 @@ func init() {
 		ServerIP = config.Config.ServerIP
 		return
 	}
-	//fixme Get the ip of the local network card
-	netInterfaces, err := net.Interfaces()
+
+	// see https://gist.github.com/jniltinho/9787946#gistcomment-3019898
+	conn, err := net.Dial("udp", "8.8.8.8:80")
 	if err != nil {
 		panic(err)
 	}
-	for i := 0; i < len(netInterfaces); i++ {
-		//Exclude useless network cards by judging the net.flag Up flag
-		if (netInterfaces[i].Flags & net.FlagUp) != 0 {
-			address, _ := netInterfaces[i].Addrs()
-			for _, addr := range address {
-				if ipNet, ok := addr.(*net.IPNet); ok && !ipNet.IP.IsLoopback() {
-					if ipNet.IP.To4() != nil {
-						ServerIP = ipNet.IP.String()
-						return
-					}
-				}
-			}
-		}
-	}
+
+	defer conn.Close()
+	localAddr := conn.LocalAddr().(*net.UDPAddr)
+	ServerIP = localAddr.IP.String()
 }
diff --git a/src/utils/get_server_ip_test.go b/src/utils/get_server_ip_test.go
new file mode 100644
index 000000000..54e2142ef
--- /dev/null
+++ b/src/utils/get_server_ip_test.go
@@ -0,0 +1,12 @@
+package utils
+
+import (
+	"net"
+	"testing"
+)
+
+func TestServerIP(t *testing.T) {
+	if net.ParseIP(ServerIP) == nil {
+		t.Fail()
+	}
+}

From 72b23ca2358089f693394e86450bb94b3f0967ff Mon Sep 17 00:00:00 2001
From: Zzr <bhg889@163.com>
Date: Thu, 21 Oct 2021 12:10:38 +0800
Subject: [PATCH 04/13] fix issue#15 (#18)

Co-authored-by: Gordon <46924906+FGadvancer@users.noreply.github.com>
---
 .gitignore                    |   4 +-
 src/rpc/chat/chat/send_msg.go | 123 ++++++++++++++++------------------
 2 files changed, 61 insertions(+), 66 deletions(-)

diff --git a/.gitignore b/.gitignore
index 6913e8f09..6726c686a 100644
--- a/.gitignore
+++ b/.gitignore
@@ -1,2 +1,4 @@
+
 components
-logs
\ No newline at end of file
+logs
+
diff --git a/src/rpc/chat/chat/send_msg.go b/src/rpc/chat/chat/send_msg.go
index 21a1a7be8..602ad03e3 100644
--- a/src/rpc/chat/chat/send_msg.go
+++ b/src/rpc/chat/chat/send_msg.go
@@ -88,84 +88,77 @@ func (rpc *rpcChat) UserSendMsg(_ context.Context, pb *pbChat.UserSendMsgReq) (*
 				return returnMsg(&replay, pb, m.ResponseErrCode, m.ErrMsg, "", 0)
 			} else {
 				pbData.Content = m.ResponseResult.ModifiedMsg
-				err1 := rpc.sendMsgToKafka(&pbData, pbData.RecvID)
-				err2 := rpc.sendMsgToKafka(&pbData, pbData.SendID)
-				if err1 != nil || err2 != nil {
-					return returnMsg(&replay, pb, 201, "kafka send msg err", "", 0)
-				}
-				return returnMsg(&replay, pb, 0, "", serverMsgID, pbData.SendTime)
 			}
 		}
-	} else {
-		switch pbData.SessionType {
-		case constant.SingleChatType:
-			err1 := rpc.sendMsgToKafka(&pbData, pbData.RecvID)
-			err2 := rpc.sendMsgToKafka(&pbData, pbData.SendID)
-			if err1 != nil || err2 != nil {
-				return returnMsg(&replay, pb, 201, "kafka send msg err", "", 0)
-			}
-			return returnMsg(&replay, pb, 0, "", serverMsgID, pbData.SendTime)
-		case constant.GroupChatType:
-			etcdConn := getcdv3.GetConn(config.Config.Etcd.EtcdSchema, strings.Join(config.Config.Etcd.EtcdAddr, ","), config.Config.RpcRegisterName.OpenImGroupName)
-			client := pbGroup.NewGroupClient(etcdConn)
-			req := &pbGroup.GetGroupAllMemberReq{
-				GroupID:     pbData.RecvID,
-				Token:       pbData.Token,
-				OperationID: pbData.OperationID,
-			}
-			reply, err := client.GetGroupAllMember(context.Background(), req)
+	}
+	switch pbData.SessionType {
+	case constant.SingleChatType:
+		err1 := rpc.sendMsgToKafka(&pbData, pbData.RecvID)
+		err2 := rpc.sendMsgToKafka(&pbData, pbData.SendID)
+		if err1 != nil || err2 != nil {
+			return returnMsg(&replay, pb, 201, "kafka send msg err", "", 0)
+		}
+		return returnMsg(&replay, pb, 0, "", serverMsgID, pbData.SendTime)
+	case constant.GroupChatType:
+		etcdConn := getcdv3.GetConn(config.Config.Etcd.EtcdSchema, strings.Join(config.Config.Etcd.EtcdAddr, ","), config.Config.RpcRegisterName.OpenImGroupName)
+		client := pbGroup.NewGroupClient(etcdConn)
+		req := &pbGroup.GetGroupAllMemberReq{
+			GroupID:     pbData.RecvID,
+			Token:       pbData.Token,
+			OperationID: pbData.OperationID,
+		}
+		reply, err := client.GetGroupAllMember(context.Background(), req)
+		if err != nil {
+			log.Error(pbData.Token, pbData.OperationID, "rpc send_msg getGroupInfo failed, err = %s", err.Error())
+			return returnMsg(&replay, pb, 201, err.Error(), "", 0)
+		}
+		if reply.ErrorCode != 0 {
+			log.Error(pbData.Token, pbData.OperationID, "rpc send_msg getGroupInfo failed, err = %s", reply.ErrorMsg)
+			return returnMsg(&replay, pb, reply.ErrorCode, reply.ErrorMsg, "", 0)
+		}
+		var addUidList []string
+		switch pbData.ContentType {
+		case constant.KickGroupMemberTip:
+			var notification content_struct.NotificationContent
+			var kickContent group.KickGroupMemberReq
+			err := utils.JsonStringToStruct(pbData.Content, &notification)
 			if err != nil {
-				log.Error(pbData.Token, pbData.OperationID, "rpc send_msg getGroupInfo failed, err = %s", err.Error())
-				return returnMsg(&replay, pb, 201, err.Error(), "", 0)
-			}
-			if reply.ErrorCode != 0 {
-				log.Error(pbData.Token, pbData.OperationID, "rpc send_msg getGroupInfo failed, err = %s", reply.ErrorMsg)
-				return returnMsg(&replay, pb, reply.ErrorCode, reply.ErrorMsg, "", 0)
-			}
-			var addUidList []string
-			switch pbData.ContentType {
-			case constant.KickGroupMemberTip:
-				var notification content_struct.NotificationContent
-				var kickContent group.KickGroupMemberReq
-				err := utils.JsonStringToStruct(pbData.Content, &notification)
+				log.ErrorByKv("json unmarshall err", pbData.OperationID, "err", err.Error())
+				return returnMsg(&replay, pb, 200, err.Error(), "", 0)
+			} else {
+				err := utils.JsonStringToStruct(notification.Detail, &kickContent)
 				if err != nil {
 					log.ErrorByKv("json unmarshall err", pbData.OperationID, "err", err.Error())
 					return returnMsg(&replay, pb, 200, err.Error(), "", 0)
-				} else {
-					err := utils.JsonStringToStruct(notification.Detail, &kickContent)
-					if err != nil {
-						log.ErrorByKv("json unmarshall err", pbData.OperationID, "err", err.Error())
-						return returnMsg(&replay, pb, 200, err.Error(), "", 0)
-					}
-					for _, v := range kickContent.UidListInfo {
-						addUidList = append(addUidList, v.UserId)
-					}
-				}
-			case constant.QuitGroupTip:
-				addUidList = append(addUidList, pbData.SendID)
-			default:
-			}
-			groupID := pbData.RecvID
-			for i, v := range reply.MemberList {
-				pbData.RecvID = v.UserId + " " + groupID
-				err := rpc.sendMsgToKafka(&pbData, utils.IntToString(i))
-				if err != nil {
-					return returnMsg(&replay, pb, 201, "kafka send msg err", "", 0)
 				}
-			}
-			for i, v := range addUidList {
-				pbData.RecvID = v + " " + groupID
-				err := rpc.sendMsgToKafka(&pbData, utils.IntToString(i+1))
-				if err != nil {
-					return returnMsg(&replay, pb, 201, "kafka send msg err", "", 0)
+				for _, v := range kickContent.UidListInfo {
+					addUidList = append(addUidList, v.UserId)
 				}
 			}
-			return returnMsg(&replay, pb, 0, "", serverMsgID, pbData.SendTime)
+		case constant.QuitGroupTip:
+			addUidList = append(addUidList, pbData.SendID)
 		default:
-
 		}
+		groupID := pbData.RecvID
+		for i, v := range reply.MemberList {
+			pbData.RecvID = v.UserId + " " + groupID
+			err := rpc.sendMsgToKafka(&pbData, utils.IntToString(i))
+			if err != nil {
+				return returnMsg(&replay, pb, 201, "kafka send msg err", "", 0)
+			}
+		}
+		for i, v := range addUidList {
+			pbData.RecvID = v + " " + groupID
+			err := rpc.sendMsgToKafka(&pbData, utils.IntToString(i+1))
+			if err != nil {
+				return returnMsg(&replay, pb, 201, "kafka send msg err", "", 0)
+			}
+		}
+		return returnMsg(&replay, pb, 0, "", serverMsgID, pbData.SendTime)
+	default:
 
 	}
+
 	return returnMsg(&replay, pb, 203, "unkonwn sessionType", "", 0)
 
 }

From 0dfaa49c97edccb8e76b7313aa6705d91c354232 Mon Sep 17 00:00:00 2001
From: Away <42713450+memory-qianxiao@users.noreply.github.com>
Date: Fri, 22 Oct 2021 10:14:32 +0800
Subject: [PATCH 05/13] Reduce the MongoDB version to adapt to a few machine
 (#22)

---
 docker-compose.yaml | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/docker-compose.yaml b/docker-compose.yaml
index a9fa9a1c9..1d64dcd9f 100644
--- a/docker-compose.yaml
+++ b/docker-compose.yaml
@@ -15,7 +15,7 @@ services:
     restart: always
 
   mongodb:
-    image: mongo
+    image: mongo:4.0
     ports:
       - 27017:27017
     container_name: mongo

From 0e6432f95a55544dedb4b4e77f1854cfe70f3cc7 Mon Sep 17 00:00:00 2001
From: Yaxian <yaxian.gu@gmail.com>
Date: Fri, 22 Oct 2021 18:49:44 +0800
Subject: [PATCH 06/13] Feature/optimise jwt token (#24)

---
 go.mod                      |   1 +
 go.sum                      |   2 +
 src/utils/jwt_token.go      | 155 ++++++++++++++----------------------
 src/utils/jwt_token_test.go |  86 ++++++++++++++++++++
 4 files changed, 150 insertions(+), 94 deletions(-)
 create mode 100644 src/utils/jwt_token_test.go

diff --git a/go.mod b/go.mod
index ac0c9edf0..e70c37bda 100644
--- a/go.mod
+++ b/go.mod
@@ -32,6 +32,7 @@ require (
 	github.com/rcrowley/go-metrics v0.0.0-20201227073835-cf1acfcdf475 // indirect
 	github.com/rifflock/lfshook v0.0.0-20180920164130-b9218ef580f5
 	github.com/sirupsen/logrus v1.6.0
+	github.com/stretchr/testify v1.7.0
 	github.com/tencentyun/qcloud-cos-sts-sdk v0.0.0-20210325043845-84a0811633ca
 	github.com/tmc/grpc-websocket-proxy v0.0.0-20190109142713-0ad062ec5ee5 // indirect
 	go.etcd.io/etcd v0.0.0-20200402134248-51bdeb39e698
diff --git a/go.sum b/go.sum
index fbbe5ea96..3cfde6ff6 100644
--- a/go.sum
+++ b/go.sum
@@ -233,6 +233,8 @@ github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UV
 github.com/stretchr/testify v1.4.0/go.mod h1:j7eGeouHqKxXV5pUuKE4zz7dFj8WfuZ+81PSLYec5m4=
 github.com/stretchr/testify v1.6.1 h1:hDPOHmpOpP40lSULcqw7IrRb/u7w6RpDC9399XyoNd0=
 github.com/stretchr/testify v1.6.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
+github.com/stretchr/testify v1.7.0 h1:nwc3DEeHmmLAfoZucVR881uASk0Mfjw8xYJ99tb5CcY=
+github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
 github.com/tencentyun/qcloud-cos-sts-sdk v0.0.0-20210325043845-84a0811633ca h1:G/aIr3WiUesWHL2YGYgEqjM5tCAJ43Ml+0C18wDkWWs=
 github.com/tencentyun/qcloud-cos-sts-sdk v0.0.0-20210325043845-84a0811633ca/go.mod h1:b18KQa4IxHbxeseW1GcZox53d7J0z39VNONTxvvlkXw=
 github.com/tmc/grpc-websocket-proxy v0.0.0-20170815181823-89b8d40f7ca8/go.mod h1:ncp9v5uamzpCO7NfCPTXjqaC+bZgJeR0sMTm6dMHP7U=
diff --git a/src/utils/jwt_token.go b/src/utils/jwt_token.go
index 264da2483..938cf6ede 100644
--- a/src/utils/jwt_token.go
+++ b/src/utils/jwt_token.go
@@ -4,8 +4,9 @@ import (
 	"Open_IM/src/common/config"
 	"Open_IM/src/common/db"
 	"errors"
-	"github.com/dgrijalva/jwt-go"
 	"time"
+
+	"github.com/dgrijalva/jwt-go"
 )
 
 var (
@@ -25,21 +26,16 @@ type Claims struct {
 func BuildClaims(uid, accountAddr, platform string, ttl int64) Claims {
 	now := time.Now().Unix()
 	//if ttl=-1 Permanent token
-	if ttl == -1 {
-		return Claims{
-			UID:      uid,
-			Platform: platform,
-			StandardClaims: jwt.StandardClaims{
-				ExpiresAt: -1,
-				IssuedAt:  now,
-				NotBefore: now,
-			}}
+	expiresAt := int64(-1)
+	if ttl != -1 {
+		expiresAt = now + ttl
 	}
+
 	return Claims{
 		UID:      uid,
 		Platform: platform,
 		StandardClaims: jwt.StandardClaims{
-			ExpiresAt: now + ttl, //Expiration time
+			ExpiresAt: expiresAt, //Expiration time
 			IssuedAt:  now,       //Issuing time
 			NotBefore: now,       //Begin Effective time
 		}}
@@ -59,7 +55,7 @@ func secret() jwt.Keyfunc {
 	}
 }
 
-func ParseToken(tokensString string) (claims *Claims, err error) {
+func getClaimFromToken(tokensString string) (*Claims, error) {
 	token, err := jwt.ParseWithClaims(tokensString, &Claims{}, secret())
 	if err != nil {
 		if ve, ok := err.(*jwt.ValidationError); ok {
@@ -75,73 +71,63 @@ func ParseToken(tokensString string) (claims *Claims, err error) {
 		}
 	}
 	if claims, ok := token.Claims.(*Claims); ok && token.Valid {
-		//	1.check userid and platform class   0 not exists and  1 exists
-		existsInterface, err := db.DB.ExistsUserIDAndPlatform(claims.UID, Platform2class[claims.Platform])
+		return claims, nil
+	}
+	return nil, err
+}
+
+func ParseToken(tokensString string) (claims *Claims, err error) {
+	claims, err = getClaimFromToken(tokensString)
+
+	if err != nil {
+		return nil, err
+	}
+
+	//	1.check userid and platform class   0 not exists and  1 exists
+	existsInterface, err := db.DB.ExistsUserIDAndPlatform(claims.UID, Platform2class[claims.Platform])
+	if err != nil {
+		return nil, err
+	}
+	exists := existsInterface.(int64)
+	//get config multi login policy
+	if config.Config.MultiLoginPolicy.OnlyOneTerminalAccess {
+		//OnlyOneTerminalAccess policy need to check all terminal
+		//When only one end is allowed to log in, there is a situation that needs to be paid attention to. After PC login,
+		//mobile login should check two platform times. One of them is less than the redis storage time, which is the invalid token.
+		platform := "PC"
+		if Platform2class[claims.Platform] == "PC" {
+			platform = "Mobile"
+		}
+
+		existsInterface, err = db.DB.ExistsUserIDAndPlatform(claims.UID, platform)
 		if err != nil {
 			return nil, err
 		}
-		exists := existsInterface.(int64)
-		//get config multi login policy
-		if config.Config.MultiLoginPolicy.OnlyOneTerminalAccess {
-			//OnlyOneTerminalAccess policy need to check all terminal
-			//When only one end is allowed to log in, there is a situation that needs to be paid attention to. After PC login,
-			//mobile login should check two platform times. One of them is less than the redis storage time, which is the invalid token.
-			if Platform2class[claims.Platform] == "PC" {
-				existsInterface, err = db.DB.ExistsUserIDAndPlatform(claims.UID, "Mobile")
-				if err != nil {
-					return nil, err
-				}
-				exists = existsInterface.(int64)
-				if exists == 1 {
-					res, err := MakeTheTokenInvalid(*claims, "Mobile")
-					if err != nil {
-						return nil, err
-					}
-					if res {
-						return nil, TokenInvalid
-					}
-				}
-			} else {
-				existsInterface, err = db.DB.ExistsUserIDAndPlatform(claims.UID, "PC")
-				if err != nil {
-					return nil, err
-				}
-				exists = existsInterface.(int64)
-				if exists == 1 {
-					res, err := MakeTheTokenInvalid(*claims, "PC")
-					if err != nil {
-						return nil, err
-					}
-					if res {
-						return nil, TokenInvalid
-					}
-				}
-			}
 
-			if exists == 1 {
-				res, err := MakeTheTokenInvalid(*claims, Platform2class[claims.Platform])
-				if err != nil {
-					return nil, err
-				}
-				if res {
-					return nil, TokenInvalid
-				}
+		exists = existsInterface.(int64)
+		if exists == 1 {
+			res, err := MakeTheTokenInvalid(*claims, platform)
+			if err != nil {
+				return nil, err
 			}
-
-		} else if config.Config.MultiLoginPolicy.MobileAndPCTerminalAccessButOtherTerminalKickEachOther {
-			if exists == 1 {
-				res, err := MakeTheTokenInvalid(*claims, Platform2class[claims.Platform])
-				if err != nil {
-					return nil, err
-				}
-				if res {
-					return nil, TokenInvalid
-				}
+			if res {
+				return nil, TokenInvalid
 			}
 		}
-		return claims, nil
 	}
-	return nil, TokenUnknown
+	// config.Config.MultiLoginPolicy.MobileAndPCTerminalAccessButOtherTerminalKickEachOther == true
+	// or  PC/Mobile validate success
+	// final check
+	if exists == 1 {
+		res, err := MakeTheTokenInvalid(*claims, Platform2class[claims.Platform])
+		if err != nil {
+			return nil, err
+		}
+		if res {
+			return nil, TokenInvalid
+		}
+	}
+	return claims, nil
 }
 
 func MakeTheTokenInvalid(currentClaims Claims, platformClass string) (bool, error) {
@@ -159,35 +145,16 @@ func MakeTheTokenInvalid(currentClaims Claims, platformClass string) (bool, erro
 	}
 	return false, nil
 }
+
 func ParseRedisInterfaceToken(redisToken interface{}) (*Claims, error) {
-	token, err := jwt.ParseWithClaims(string(redisToken.([]uint8)), &Claims{}, secret())
-	if err != nil {
-		if ve, ok := err.(*jwt.ValidationError); ok {
-			if ve.Errors&jwt.ValidationErrorMalformed != 0 {
-				return nil, TokenMalformed
-			} else if ve.Errors&jwt.ValidationErrorExpired != 0 {
-				return nil, TokenExpired
-			} else if ve.Errors&jwt.ValidationErrorNotValidYet != 0 {
-				return nil, TokenNotValidYet
-			} else {
-				return nil, TokenInvalid
-			}
-		}
-	}
-	if claims, ok := token.Claims.(*Claims); ok && token.Valid {
-		return claims, nil
-	}
-	return nil, err
+	return getClaimFromToken(string(redisToken.([]uint8)))
 }
 
 //Validation token, false means failure, true means successful verification
 func VerifyToken(token, uid string) bool {
 	claims, err := ParseToken(token)
-	if err != nil {
-		return false
-	} else if claims.UID != uid {
+	if err != nil || claims.UID != uid {
 		return false
-	} else {
-		return true
 	}
+	return true
 }
diff --git a/src/utils/jwt_token_test.go b/src/utils/jwt_token_test.go
new file mode 100644
index 000000000..0d5ac7463
--- /dev/null
+++ b/src/utils/jwt_token_test.go
@@ -0,0 +1,86 @@
+package utils
+
+import (
+	"Open_IM/src/common/config"
+	"testing"
+	"time"
+
+	"github.com/stretchr/testify/assert"
+)
+
+func Test_BuildClaims(t *testing.T) {
+	uid := "1"
+	accountAddr := "accountAddr"
+	platform := "PC"
+	ttl := int64(-1)
+	claim := BuildClaims(uid, accountAddr, platform, ttl)
+	now := time.Now().Unix()
+
+	assert.Equal(t, claim.UID, uid, "uid should equal")
+	assert.Equal(t, claim.Platform, platform, "platform should equal")
+	assert.Equal(t, claim.StandardClaims.ExpiresAt, int64(-1), "StandardClaims.ExpiresAt should be equal")
+	// time difference within 1s
+	assert.Equal(t, claim.StandardClaims.IssuedAt, now, "StandardClaims.IssuedAt should be equal")
+	assert.Equal(t, claim.StandardClaims.NotBefore, now, "StandardClaims.NotBefore should be equal")
+
+	ttl = int64(60)
+	now = time.Now().Unix()
+	claim = BuildClaims(uid, accountAddr, platform, ttl)
+	// time difference within 1s
+	assert.Equal(t, claim.StandardClaims.ExpiresAt, int64(60)+now, "StandardClaims.ExpiresAt should be equal")
+	assert.Equal(t, claim.StandardClaims.IssuedAt, now, "StandardClaims.IssuedAt should be equal")
+	assert.Equal(t, claim.StandardClaims.NotBefore, now, "StandardClaims.NotBefore should be equal")
+}
+
+func Test_CreateToken(t *testing.T) {
+	uid := "1"
+	accountAddr := "accountAddr"
+	platform := int32(1)
+	now := time.Now().Unix()
+
+	tokenString, expiresAt, err := CreateToken(uid, accountAddr, platform)
+
+	assert.NotEmpty(t, tokenString)
+	assert.Equal(t, expiresAt, 604800+now)
+	assert.Nil(t, err)
+}
+
+func Test_VerifyToken(t *testing.T) {
+	uid := "1"
+	accountAddr := "accountAddr"
+	platform := int32(1)
+	tokenString, _, _ := CreateToken(uid, accountAddr, platform)
+	result := VerifyToken(tokenString, uid)
+	assert.True(t, result)
+	result = VerifyToken(tokenString, "2")
+	assert.False(t, result)
+}
+
+func Test_ParseRedisInterfaceToken(t *testing.T) {
+	uid := "1"
+	accountAddr := "accountAddr"
+	platform := int32(1)
+	tokenString, _, _ := CreateToken(uid, accountAddr, platform)
+
+	claims, err := ParseRedisInterfaceToken([]uint8(tokenString))
+	assert.Nil(t, err)
+	assert.Equal(t, claims.UID, uid)
+
+	// timeout
+	config.Config.TokenPolicy.AccessExpire = -80
+	tokenString, _, _ = CreateToken(uid, accountAddr, platform)
+	claims, err = ParseRedisInterfaceToken([]uint8(tokenString))
+	assert.Equal(t, err, TokenExpired)
+	assert.Nil(t, claims)
+}
+
+func Test_ParseToken(t *testing.T) {
+	uid := "1"
+	accountAddr := "accountAddr"
+	platform := int32(1)
+	tokenString, _, _ := CreateToken(uid, accountAddr, platform)
+	claims, err := ParseToken(tokenString)
+	if err == nil {
+		assert.Equal(t, claims.UID, uid)
+	}
+}

From d6ba0a803d4488cb9230983b8f3cdf1936391ed8 Mon Sep 17 00:00:00 2001
From: Away <42713450+memory-qianxiao@users.noreply.github.com>
Date: Fri, 22 Oct 2021 21:20:31 +0800
Subject: [PATCH 07/13] Pr branch (#25)

* fix update jwt-token version to avoid attackers to bypass intended access restrictions in situations with []string{} for m["aud"]

* del accountAddr
---
 go.mod                          | 2 +-
 go.sum                          | 2 ++
 src/rpc/auth/auth/user_token.go | 2 +-
 src/utils/jwt_token.go          | 9 ++++-----
 4 files changed, 8 insertions(+), 7 deletions(-)

diff --git a/go.mod b/go.mod
index e70c37bda..00fe22cb0 100644
--- a/go.mod
+++ b/go.mod
@@ -7,7 +7,6 @@ require (
 	github.com/Shopify/toxiproxy v2.1.4+incompatible // indirect
 	github.com/antonfisher/nested-logrus-formatter v1.3.0
 	github.com/coreos/go-semver v0.3.0 // indirect
-	github.com/dgrijalva/jwt-go v3.2.0+incompatible
 	github.com/dustin/go-humanize v1.0.0 // indirect
 	github.com/eapache/go-resiliency v1.2.0 // indirect
 	github.com/eapache/go-xerial-snappy v0.0.0-20180814174437-776d5712da21 // indirect
@@ -16,6 +15,7 @@ require (
 	github.com/garyburd/redigo v1.6.2
 	github.com/gin-gonic/gin v1.7.0
 	github.com/go-playground/validator/v10 v10.4.1
+	github.com/golang-jwt/jwt/v4 v4.1.0 // indirect
 	github.com/golang/protobuf v1.5.2
 	github.com/golang/snappy v0.0.3 // indirect
 	github.com/gorilla/websocket v1.4.2
diff --git a/go.sum b/go.sum
index 3cfde6ff6..664a73e93 100644
--- a/go.sum
+++ b/go.sum
@@ -74,6 +74,8 @@ github.com/godbus/dbus/v5 v5.0.3/go.mod h1:xhWf0FNVPg57R7Z0UbKHbJfkEywrmjJnf7w5x
 github.com/gogo/protobuf v1.1.1/go.mod h1:r8qH/GZQm5c6nD/R0oafs1akxWv10x8SbQlK7atdtwQ=
 github.com/gogo/protobuf v1.2.1 h1:/s5zKNz0uPFCZ5hddgPdo2TK2TVrUNMn0OOX8/aZMTE=
 github.com/gogo/protobuf v1.2.1/go.mod h1:hp+jE20tsWTFYpLwKvXlhS1hjn+gTNwPg2I6zVXpSg4=
+github.com/golang-jwt/jwt/v4 v4.1.0 h1:XUgk2Ex5veyVFVeLm0xhusUTQybEbexJXrvPNOKkSY0=
+github.com/golang-jwt/jwt/v4 v4.1.0/go.mod h1:/xlHOz8bRuivTWchD4jCa+NbatV+wEUSzwAxVc6locg=
 github.com/golang-sql/civil v0.0.0-20190719163853-cb61b32ac6fe h1:lXe2qZdvpiX5WZkZR4hgp4KJVfY3nMkvmwbVkpv1rVY=
 github.com/golang-sql/civil v0.0.0-20190719163853-cb61b32ac6fe/go.mod h1:8vg3r2VgvsThLBIFL93Qb5yWzgyZWhEmBwUJWevAkK0=
 github.com/golang/glog v0.0.0-20160126235308-23def4e6c14b/go.mod h1:SBH7ygxi8pfUlaOkMMuAQtPIUF8ecWP5IEl/CR7VP2Q=
diff --git a/src/rpc/auth/auth/user_token.go b/src/rpc/auth/auth/user_token.go
index 59e91c33b..c89e4312d 100644
--- a/src/rpc/auth/auth/user_token.go
+++ b/src/rpc/auth/auth/user_token.go
@@ -18,7 +18,7 @@ func (rpc *rpcAuth) UserToken(_ context.Context, pb *pbAuth.UserTokenReq) (*pbAu
 	}
 	log.Info("", "", "rpc user_token call..., im_mysql_model.AppServerFindFromUserByUserID")
 
-	tokens, expTime, err := utils.CreateToken(pb.UID, "", pb.Platform)
+	tokens, expTime, err := utils.CreateToken(pb.UID, pb.Platform)
 	if err != nil {
 		log.Error("", "", "rpc user_token call..., utils.CreateToken fail [uid: %s] [err: %s]", pb.UID, err.Error())
 		return &pbAuth.UserTokenResp{ErrCode: 500, ErrMsg: err.Error()}, err
diff --git a/src/utils/jwt_token.go b/src/utils/jwt_token.go
index 938cf6ede..19fdb9a3b 100644
--- a/src/utils/jwt_token.go
+++ b/src/utils/jwt_token.go
@@ -4,9 +4,8 @@ import (
 	"Open_IM/src/common/config"
 	"Open_IM/src/common/db"
 	"errors"
+	"github.com/golang-jwt/jwt/v4"
 	"time"
-
-	"github.com/dgrijalva/jwt-go"
 )
 
 var (
@@ -23,7 +22,7 @@ type Claims struct {
 	jwt.StandardClaims
 }
 
-func BuildClaims(uid, accountAddr, platform string, ttl int64) Claims {
+func BuildClaims(uid, platform string, ttl int64) Claims {
 	now := time.Now().Unix()
 	//if ttl=-1 Permanent token
 	expiresAt := int64(-1)
@@ -41,8 +40,8 @@ func BuildClaims(uid, accountAddr, platform string, ttl int64) Claims {
 		}}
 }
 
-func CreateToken(userID, accountAddr string, platform int32) (string, int64, error) {
-	claims := BuildClaims(userID, accountAddr, PlatformIDToName(platform), config.Config.TokenPolicy.AccessExpire)
+func CreateToken(userID string, platform int32) (string, int64, error) {
+	claims := BuildClaims(userID, PlatformIDToName(platform), config.Config.TokenPolicy.AccessExpire)
 	token := jwt.NewWithClaims(jwt.SigningMethodHS256, claims)
 	tokenString, err := token.SignedString([]byte(config.Config.TokenPolicy.AccessSecret))
 

From b2cc5977557cbaafe97d0f9f5505d88b02733f49 Mon Sep 17 00:00:00 2001
From: Away <42713450+memory-qianxiao@users.noreply.github.com>
Date: Sat, 23 Oct 2021 09:21:05 +0800
Subject: [PATCH 08/13] Create codeql-analysis.yml

---
 .github/workflows/codeql-analysis.yml | 71 +++++++++++++++++++++++++++
 1 file changed, 71 insertions(+)
 create mode 100644 .github/workflows/codeql-analysis.yml

diff --git a/.github/workflows/codeql-analysis.yml b/.github/workflows/codeql-analysis.yml
new file mode 100644
index 000000000..f106438e3
--- /dev/null
+++ b/.github/workflows/codeql-analysis.yml
@@ -0,0 +1,71 @@
+# For most projects, this workflow file will not need changing; you simply need
+# to commit it to your repository.
+#
+# You may wish to alter this file to override the set of languages analyzed,
+# or to provide custom queries or build logic.
+#
+# ******** NOTE ********
+# We have attempted to detect the languages in your repository. Please check
+# the `language` matrix defined below to confirm you have the correct set of
+# supported CodeQL languages.
+#
+name: "CodeQL"
+
+on:
+  push:
+    branches: [ main ]
+  pull_request:
+    # The branches below must be a subset of the branches above
+    branches: [ main ]
+  schedule:
+    - cron: '23 2 * * 2'
+
+jobs:
+  analyze:
+    name: Analyze
+    runs-on: ubuntu-latest
+    permissions:
+      actions: read
+      contents: read
+      security-events: write
+
+    strategy:
+      fail-fast: false
+      matrix:
+        language: [ 'go' ]
+        # CodeQL supports [ 'cpp', 'csharp', 'go', 'java', 'javascript', 'python' ]
+        # Learn more:
+        # https://docs.github.com/en/free-pro-team@latest/github/finding-security-vulnerabilities-and-errors-in-your-code/configuring-code-scanning#changing-the-languages-that-are-analyzed
+
+    steps:
+    - name: Checkout repository
+      uses: actions/checkout@v2
+
+    # Initializes the CodeQL tools for scanning.
+    - name: Initialize CodeQL
+      uses: github/codeql-action/init@v1
+      with:
+        languages: ${{ matrix.language }}
+        # If you wish to specify custom queries, you can do so here or in a config file.
+        # By default, queries listed here will override any specified in a config file.
+        # Prefix the list here with "+" to use these queries and those in the config file.
+        # queries: ./path/to/local/query, your-org/your-repo/queries@main
+
+    # Autobuild attempts to build any compiled languages  (C/C++, C#, or Java).
+    # If this step fails, then you should remove it and run the build manually (see below)
+    - name: Autobuild
+      uses: github/codeql-action/autobuild@v1
+
+    # ℹ️ Command-line programs to run using the OS shell.
+    # 📚 https://git.io/JvXDl
+
+    # ✏️ If the Autobuild fails above, remove it and uncomment the following three lines
+    #    and modify them (or add more) to build your code if your project
+    #    uses a compiled language
+
+    #- run: |
+    #   make bootstrap
+    #   make release
+
+    - name: Perform CodeQL Analysis
+      uses: github/codeql-action/analyze@v1

From 3d7fd2c19214ca7a4aaea8e3d96a2069a777e5b5 Mon Sep 17 00:00:00 2001
From: senyu <1819625428@qq.com>
Date: Sat, 23 Oct 2021 10:51:57 +0800
Subject: [PATCH 09/13] del unuse filed

---
 src/utils/jwt_token_test.go | 19 +++++++------------
 1 file changed, 7 insertions(+), 12 deletions(-)

diff --git a/src/utils/jwt_token_test.go b/src/utils/jwt_token_test.go
index 0d5ac7463..31e5a4d4a 100644
--- a/src/utils/jwt_token_test.go
+++ b/src/utils/jwt_token_test.go
@@ -10,10 +10,9 @@ import (
 
 func Test_BuildClaims(t *testing.T) {
 	uid := "1"
-	accountAddr := "accountAddr"
 	platform := "PC"
 	ttl := int64(-1)
-	claim := BuildClaims(uid, accountAddr, platform, ttl)
+	claim := BuildClaims(uid, platform, ttl)
 	now := time.Now().Unix()
 
 	assert.Equal(t, claim.UID, uid, "uid should equal")
@@ -25,7 +24,7 @@ func Test_BuildClaims(t *testing.T) {
 
 	ttl = int64(60)
 	now = time.Now().Unix()
-	claim = BuildClaims(uid, accountAddr, platform, ttl)
+	claim = BuildClaims(uid, platform, ttl)
 	// time difference within 1s
 	assert.Equal(t, claim.StandardClaims.ExpiresAt, int64(60)+now, "StandardClaims.ExpiresAt should be equal")
 	assert.Equal(t, claim.StandardClaims.IssuedAt, now, "StandardClaims.IssuedAt should be equal")
@@ -34,11 +33,10 @@ func Test_BuildClaims(t *testing.T) {
 
 func Test_CreateToken(t *testing.T) {
 	uid := "1"
-	accountAddr := "accountAddr"
 	platform := int32(1)
 	now := time.Now().Unix()
 
-	tokenString, expiresAt, err := CreateToken(uid, accountAddr, platform)
+	tokenString, expiresAt, err := CreateToken(uid, platform)
 
 	assert.NotEmpty(t, tokenString)
 	assert.Equal(t, expiresAt, 604800+now)
@@ -47,9 +45,8 @@ func Test_CreateToken(t *testing.T) {
 
 func Test_VerifyToken(t *testing.T) {
 	uid := "1"
-	accountAddr := "accountAddr"
 	platform := int32(1)
-	tokenString, _, _ := CreateToken(uid, accountAddr, platform)
+	tokenString, _, _ := CreateToken(uid, platform)
 	result := VerifyToken(tokenString, uid)
 	assert.True(t, result)
 	result = VerifyToken(tokenString, "2")
@@ -58,9 +55,8 @@ func Test_VerifyToken(t *testing.T) {
 
 func Test_ParseRedisInterfaceToken(t *testing.T) {
 	uid := "1"
-	accountAddr := "accountAddr"
 	platform := int32(1)
-	tokenString, _, _ := CreateToken(uid, accountAddr, platform)
+	tokenString, _, _ := CreateToken(uid, platform)
 
 	claims, err := ParseRedisInterfaceToken([]uint8(tokenString))
 	assert.Nil(t, err)
@@ -68,7 +64,7 @@ func Test_ParseRedisInterfaceToken(t *testing.T) {
 
 	// timeout
 	config.Config.TokenPolicy.AccessExpire = -80
-	tokenString, _, _ = CreateToken(uid, accountAddr, platform)
+	tokenString, _, _ = CreateToken(uid, platform)
 	claims, err = ParseRedisInterfaceToken([]uint8(tokenString))
 	assert.Equal(t, err, TokenExpired)
 	assert.Nil(t, claims)
@@ -76,9 +72,8 @@ func Test_ParseRedisInterfaceToken(t *testing.T) {
 
 func Test_ParseToken(t *testing.T) {
 	uid := "1"
-	accountAddr := "accountAddr"
 	platform := int32(1)
-	tokenString, _, _ := CreateToken(uid, accountAddr, platform)
+	tokenString, _, _ := CreateToken(uid, platform)
 	claims, err := ParseToken(tokenString)
 	if err == nil {
 		assert.Equal(t, claims.UID, uid)

From 8913ca161f1726435b9d69bb24dc601833c8517c Mon Sep 17 00:00:00 2001
From: Zzr <bhg889@163.com>
Date: Sat, 23 Oct 2021 14:18:55 +0800
Subject: [PATCH 10/13] Fix #21 (#23)

* fix issue#15

* fix #21

Co-authored-by: Gordon <46924906+FGadvancer@users.noreply.github.com>
---
 .gitignore                         | 2 +-
 src/msg_gateway/gate/rpc_server.go | 7 ++++---
 2 files changed, 5 insertions(+), 4 deletions(-)

diff --git a/.gitignore b/.gitignore
index 6726c686a..74a748ab0 100644
--- a/.gitignore
+++ b/.gitignore
@@ -1,4 +1,4 @@
-
+.devcontainer
 components
 logs
 
diff --git a/src/msg_gateway/gate/rpc_server.go b/src/msg_gateway/gate/rpc_server.go
index e9aa28033..54bb78076 100644
--- a/src/msg_gateway/gate/rpc_server.go
+++ b/src/msg_gateway/gate/rpc_server.go
@@ -10,10 +10,11 @@ import (
 	"context"
 	"encoding/json"
 	"fmt"
-	"github.com/gorilla/websocket"
-	"google.golang.org/grpc"
 	"net"
 	"strings"
+
+	"github.com/gorilla/websocket"
+	"google.golang.org/grpc"
 )
 
 type RPCServer struct {
@@ -41,7 +42,7 @@ func (r *RPCServer) run() {
 	srv := grpc.NewServer()
 	defer srv.GracefulStop()
 	pbRelay.RegisterOnlineMessageRelayServiceServer(srv, r)
-	err = getcdv3.RegisterEtcd4Unique(r.etcdSchema, strings.Join(r.etcdAddr, ","), ip, r.rpcPort, r.rpcRegisterName, 10)
+	err = getcdv3.RegisterEtcd(r.etcdSchema, strings.Join(r.etcdAddr, ","), ip, r.rpcPort, r.rpcRegisterName, 10)
 	if err != nil {
 		log.ErrorByKv("register push message rpc to etcd err", "", "err", err.Error())
 	}

From 65157ede231b90f7b392de2e97b396aa16fd67d1 Mon Sep 17 00:00:00 2001
From: Away <42713450+memory-qianxiao@users.noreply.github.com>
Date: Mon, 25 Oct 2021 11:08:10 +0800
Subject: [PATCH 11/13] Update jwt token version (#27)

* add sdk svr to docker script

* panic handle

* fix build from dockerfile on docker-compose

* Update deploy.Dockerfile

* log and scripts optimization

* ci: ignore files created by docker-compose (#19)

* feat: optimise get server ip (#20)

* feat: optimise get server ip

* feat: test ServerIP

* fix issue#15 (#18)

Co-authored-by: Gordon <46924906+FGadvancer@users.noreply.github.com>

* Modify bug for getting lastest seq

* Reduce the MongoDB version to adapt to a few machine (#22)

* Feature/optimise jwt token (#24)

* Pr branch (#25)

* fix update jwt-token version to avoid attackers to bypass intended access restrictions in situations with []string{} for m["aud"]

* del accountAddr

* Create codeql-analysis.yml

* del unuse filed

* fix update jwt-token version to avoid attackers to bypass intended access restrictions in situations with []string{} for m["aud"]

Co-authored-by: Gordon <1432970085@qq.com>
Co-authored-by: Yaxian <yaxian.gu@gmail.com>
Co-authored-by: Zzr <bhg889@163.com>
Co-authored-by: Gordon <46924906+FGadvancer@users.noreply.github.com>
Co-authored-by: brennanli <brennanli@tencent.com>
---
 config/config.yaml          |  4 ++--
 src/utils/jwt_token.go      | 28 +++++++++++-----------------
 src/utils/jwt_token_test.go | 12 ++++++------
 3 files changed, 19 insertions(+), 25 deletions(-)

diff --git a/config/config.yaml b/config/config.yaml
index 9e8741b48..d7becbbb4 100644
--- a/config/config.yaml
+++ b/config/config.yaml
@@ -134,8 +134,8 @@ multiloginpolicy:
 tokenpolicy:
   accessSecret: "open_im_server"
   # Token effective time seconds as a unit
-  #Seven days   7*24*60*60
-  accessExpire: 604800
+  #Seven days
+  accessExpire: 7
 
 messagecallback:
   callbackSwitch: false
diff --git a/src/utils/jwt_token.go b/src/utils/jwt_token.go
index 19fdb9a3b..14977f7ae 100644
--- a/src/utils/jwt_token.go
+++ b/src/utils/jwt_token.go
@@ -19,24 +19,18 @@ var (
 type Claims struct {
 	UID      string
 	Platform string //login platform
-	jwt.StandardClaims
+	jwt.RegisteredClaims
 }
 
 func BuildClaims(uid, platform string, ttl int64) Claims {
-	now := time.Now().Unix()
-	//if ttl=-1 Permanent token
-	expiresAt := int64(-1)
-	if ttl != -1 {
-		expiresAt = now + ttl
-	}
-
+	now := time.Now()
 	return Claims{
 		UID:      uid,
 		Platform: platform,
-		StandardClaims: jwt.StandardClaims{
-			ExpiresAt: expiresAt, //Expiration time
-			IssuedAt:  now,       //Issuing time
-			NotBefore: now,       //Begin Effective time
+		RegisteredClaims: jwt.RegisteredClaims{
+			ExpiresAt: jwt.NewNumericDate(now.Add(time.Duration(ttl*24) * time.Hour)), //Expiration time
+			IssuedAt:  jwt.NewNumericDate(now),                                        //Issuing time
+			NotBefore: jwt.NewNumericDate(now),                                        //Begin Effective time
 		}}
 }
 
@@ -45,7 +39,7 @@ func CreateToken(userID string, platform int32) (string, int64, error) {
 	token := jwt.NewWithClaims(jwt.SigningMethodHS256, claims)
 	tokenString, err := token.SignedString([]byte(config.Config.TokenPolicy.AccessSecret))
 
-	return tokenString, claims.ExpiresAt, err
+	return tokenString, claims.ExpiresAt.Time.Unix(), err
 }
 
 func secret() jwt.Keyfunc {
@@ -105,7 +99,7 @@ func ParseToken(tokensString string) (claims *Claims, err error) {
 
 		exists = existsInterface.(int64)
 		if exists == 1 {
-			res, err := MakeTheTokenInvalid(*claims, platform)
+			res, err := MakeTheTokenInvalid(claims, platform)
 			if err != nil {
 				return nil, err
 			}
@@ -118,7 +112,7 @@ func ParseToken(tokensString string) (claims *Claims, err error) {
 	// or  PC/Mobile validate success
 	// final check
 	if exists == 1 {
-		res, err := MakeTheTokenInvalid(*claims, Platform2class[claims.Platform])
+		res, err := MakeTheTokenInvalid(claims, Platform2class[claims.Platform])
 		if err != nil {
 			return nil, err
 		}
@@ -129,7 +123,7 @@ func ParseToken(tokensString string) (claims *Claims, err error) {
 	return claims, nil
 }
 
-func MakeTheTokenInvalid(currentClaims Claims, platformClass string) (bool, error) {
+func MakeTheTokenInvalid(currentClaims *Claims, platformClass string) (bool, error) {
 	storedRedisTokenInterface, err := db.DB.GetPlatformToken(currentClaims.UID, platformClass)
 	if err != nil {
 		return false, err
@@ -139,7 +133,7 @@ func MakeTheTokenInvalid(currentClaims Claims, platformClass string) (bool, erro
 		return false, err
 	}
 	//if issue time less than redis token then make this token invalid
-	if currentClaims.IssuedAt < storedRedisPlatformClaims.IssuedAt {
+	if currentClaims.IssuedAt.Time.Unix() < storedRedisPlatformClaims.IssuedAt.Time.Unix() {
 		return true, TokenInvalid
 	}
 	return false, nil
diff --git a/src/utils/jwt_token_test.go b/src/utils/jwt_token_test.go
index 31e5a4d4a..83b9bb91c 100644
--- a/src/utils/jwt_token_test.go
+++ b/src/utils/jwt_token_test.go
@@ -17,18 +17,18 @@ func Test_BuildClaims(t *testing.T) {
 
 	assert.Equal(t, claim.UID, uid, "uid should equal")
 	assert.Equal(t, claim.Platform, platform, "platform should equal")
-	assert.Equal(t, claim.StandardClaims.ExpiresAt, int64(-1), "StandardClaims.ExpiresAt should be equal")
+	assert.Equal(t, claim.RegisteredClaims.ExpiresAt, int64(-1), "StandardClaims.ExpiresAt should be equal")
 	// time difference within 1s
-	assert.Equal(t, claim.StandardClaims.IssuedAt, now, "StandardClaims.IssuedAt should be equal")
-	assert.Equal(t, claim.StandardClaims.NotBefore, now, "StandardClaims.NotBefore should be equal")
+	assert.Equal(t, claim.RegisteredClaims.IssuedAt, now, "StandardClaims.IssuedAt should be equal")
+	assert.Equal(t, claim.RegisteredClaims.NotBefore, now, "StandardClaims.NotBefore should be equal")
 
 	ttl = int64(60)
 	now = time.Now().Unix()
 	claim = BuildClaims(uid, platform, ttl)
 	// time difference within 1s
-	assert.Equal(t, claim.StandardClaims.ExpiresAt, int64(60)+now, "StandardClaims.ExpiresAt should be equal")
-	assert.Equal(t, claim.StandardClaims.IssuedAt, now, "StandardClaims.IssuedAt should be equal")
-	assert.Equal(t, claim.StandardClaims.NotBefore, now, "StandardClaims.NotBefore should be equal")
+	assert.Equal(t, claim.RegisteredClaims.ExpiresAt, int64(60)+now, "StandardClaims.ExpiresAt should be equal")
+	assert.Equal(t, claim.RegisteredClaims.IssuedAt, now, "StandardClaims.IssuedAt should be equal")
+	assert.Equal(t, claim.RegisteredClaims.NotBefore, now, "StandardClaims.NotBefore should be equal")
 }
 
 func Test_CreateToken(t *testing.T) {

From 7c3aa7ee0b6321e7888d484ec87947dde671378e Mon Sep 17 00:00:00 2001
From: antcorp <527455294@qq.com>
Date: Mon, 25 Oct 2021 16:42:56 +0800
Subject: [PATCH 12/13] fix: Startup error (#11)

* fix: Startup error

Fixed a path error that prompted that the configuration file could not be found at startup

* Update config.go

Co-authored-by: Gordon <46924906+FGadvancer@users.noreply.github.com>
---
 src/common/config/config.go | 13 +++++--------
 1 file changed, 5 insertions(+), 8 deletions(-)

diff --git a/src/common/config/config.go b/src/common/config/config.go
index 6294a031c..5d7084653 100644
--- a/src/common/config/config.go
+++ b/src/common/config/config.go
@@ -2,17 +2,15 @@ package config
 
 import (
 	"io/ioutil"
+
+	"os"
+
 	"path/filepath"
 	"runtime"
 
 	"gopkg.in/yaml.v3"
 )
 
-var (
-	_, b, _, _ = runtime.Caller(0)
-	// Root folder of this project
-	Root = filepath.Join(filepath.Dir(b), "../../..")
-)
 
 var Config config
 
@@ -156,9 +154,8 @@ type config struct {
 }
 
 func init() {
-	// if we cd Open-IM-Server/src/utils and run go test
-	// it will panic cannot find config/config.yaml
-	bytes, err := ioutil.ReadFile(Root + "/config/config.yaml")
+	path, _ := os.Getwd()
+	bytes, err := ioutil.ReadFile(path + "/config/config.yaml")
 	if err != nil {
 		panic(err)
 	}

From 37a8ddbae61f431a2e38001d9503ed027c986660 Mon Sep 17 00:00:00 2001
From: skiffer-git <72860476+skiffer-git@users.noreply.github.com>
Date: Fri, 29 Oct 2021 15:02:52 +0800
Subject: [PATCH 13/13] Update README.md (#30)

* Update README.md

* Add files via upload

update config

* Add files via upload

update script
---
 README.md                      |   2 +-
 docs/config.yaml               | 146 +++++++++++++++++++++++++++++++++
 script/build_all_service.sh    |  60 +++++++-------
 script/check_all.sh            |  74 ++++++++++-------
 script/docker_check_service.sh |  66 +++++++--------
 script/docker_start_all.sh     |  46 +++++------
 script/function.sh             |  20 ++---
 script/msg_gateway_start.sh    |  96 +++++++++++-----------
 script/msg_transfer_start.sh   |  74 ++++++++---------
 script/mysql_database_init.sh  |  76 ++++++++---------
 script/path_info.cfg           | 125 ++++++++++++++--------------
 script/push_start.sh           |  90 ++++++++++----------
 script/sdk_svr_start.sh        |  94 ++++++++++-----------
 script/start_all.sh            |  36 ++++----
 script/start_rpc_service.sh    | 118 +++++++++++++-------------
 script/stop_all.sh             |  38 ++++-----
 script/style_info.cfg          |  18 ++--
 17 files changed, 668 insertions(+), 511 deletions(-)
 create mode 100644 docs/config.yaml

diff --git a/README.md b/README.md
index 8b32d0903..669b57926 100644
--- a/README.md
+++ b/README.md
@@ -1,4 +1,4 @@
-# Open-IM-Server
+# Open-IM-Server 
 
 ![avatar](https://github.com/OpenIMSDK/Open-IM-Server/blob/main/docs/open-im-logo.png)
 
diff --git a/docs/config.yaml b/docs/config.yaml
new file mode 100644
index 000000000..765cbb21b
--- /dev/null
+++ b/docs/config.yaml
@@ -0,0 +1,146 @@
+# The class cannot be named by Pascal or camel case.
+# If it is not used, the corresponding structure will not be set,
+# and it will not be read naturally.
+serverversion: 1.0.0
+#---------------Infrastructure configuration---------------------#
+etcd:
+  etcdSchema: openIM
+  etcdAddr: [ 127.0.0.1:2379 ]
+
+mysql:
+  dbMysqlAddress: [ 127.0.0.1:3306 ]
+  dbMysqlUserName: root
+  dbMysqlPassword: openIM
+  dbMysqlDatabaseName: openIM
+  dbTableName: eMsg
+  dbMsgTableNum: 1
+  dbMaxOpenConns: 20
+  dbMaxIdleConns: 10
+  dbMaxLifeTime: 120
+
+mongo:
+  dbAddress: [ 127.0.0.1:27017 ]
+  dbDirect: false
+  dbTimeout: 10
+  dbDatabase: openIM
+  dbSource: admin
+  dbUserName:
+  dbPassword:
+  dbMaxPoolSize: 20
+  dbRetainChatRecords: 7
+
+redis:
+  dbAddress: 127.0.0.1:6379
+  dbMaxIdle: 128
+  dbMaxActive: 0
+  dbIdleTimeout: 120
+  dbPassWord: openIM
+
+kafka:
+  ws2mschat:
+    addr: [ 127.0.0.1:9092 ]
+    topic: "ws2ms_chat"
+  ms2pschat:
+    addr: [ 127.0.0.1:9092 ]
+    topic: "ms2ps_chat"
+  consumergroupid:
+    msgToMongo: mongo
+    msgToMySql: mysql
+    msgToPush: push
+
+
+
+#---------------Internal service configuration---------------------#
+
+# The service ip default is empty,
+# automatically obtain the machine's valid network card ip as the service ip,
+# otherwise the configuration ip is preferred
+serverip:
+
+api:
+  openImApiPort: [ 10000 ]
+sdk:
+  openImSdkWsPort: [ 30000 ]
+
+credential:
+  tencent:
+    appID: 1302656840
+    region: ap-chengdu
+    bucket: echat-1302656840
+    secretID: AKIDGNYVChzIQinu7QEgtNp0hnNgqcV8vZTC
+    secretKey: kz15vW83qM6dBUWIq681eBZA0c0vlIbe
+
+
+rpcport:
+  openImUserPort: [ 10100 ]
+  openImFriendPort: [ 10200 ]
+  openImOfflineMessagePort: [ 10300 ]
+  openImOnlineRelayPort: [ 10400 ]
+  openImGroupPort: [ 10500  ]
+  openImAuthPort: [ 10600 ]
+  openImPushPort: [ 10700 ]
+
+
+rpcregistername:
+  openImUserName: User
+  openImFriendName: Friend
+  openImOfflineMessageName: OfflineMessage
+  openImPushName: Push
+  openImOnlineMessageRelayName: OnlineMessageRelay
+  openImGroupName: Group
+  openImAuthName: Auth
+
+log:
+  storageLocation: ../logs/
+  rotationTime: 24
+  remainRotationCount: 5
+  remainLogLevel: 6
+  elasticSearchSwitch: false
+  elasticSearchAddr: [ 127.0.0.1:9201 ]
+  elasticSearchUser: ""
+  elasticSearchPassword: ""
+
+modulename:
+  longConnSvrName: msg_gateway
+  msgTransferName: msg_transfer
+  pushName: push
+
+longconnsvr:
+  openImWsPort: [ 17778 ]
+  websocketMaxConnNum: 10000
+  websocketMaxMsgLen: 4096
+  websocketTimeOut: 10
+
+push:
+  tpns:
+    ios:
+      accessID: 1600018281
+      secretKey: 3cd68a77a95b89e5089a1aca523f318f
+    android:
+      accessID: 111
+      secretKey: 111
+  jpns:
+    appKey: 2783339cee4de379cc798fe1
+    masterSecret: 66e5f309e032c68cc668c28a
+    pushUrl: "https://api.jpush.cn/v3/push"
+manager:
+  appManagerUid: ["openIM123456","openIM654321"]
+  secrets: ["openIM1","openIM2"]
+
+secret: tuoyun
+
+multiloginpolicy:
+  onlyOneTerminalAccess: false
+  mobileAndPCTerminalAccessButOtherTerminalKickEachOther: true
+  allTerminalAccess: false
+
+#token config
+tokenpolicy:
+  accessSecret: "open_im_server"
+  # Token effective time seconds as a unit
+  #Seven days   7*24*60*60
+  accessExpire: 604800
+
+messagecallback:
+  callbackSwitch: false
+  callbackUrl: "http://www.xxx.com/msg/judge"
\ No newline at end of file
diff --git a/script/build_all_service.sh b/script/build_all_service.sh
index 07a34bb08..6f563b6f6 100644
--- a/script/build_all_service.sh
+++ b/script/build_all_service.sh
@@ -1,30 +1,30 @@
-#!/usr/bin/env bash
-
-source ./style_info.cfg
-source ./path_info.cfg
-source ./function.sh
-
-bin_dir="../bin"
-logs_dir="../logs"
-sdk_db_dir="../db/sdk/"
-#Automatically created when there is no bin, logs folder
-if [ ! -d $bin_dir ]; then
-  mkdir -p $bin_dir
-fi
-if [ ! -d $logs_dir ]; then
-  mkdir -p $logs_dir
-fi
-if [ ! -d $sdk_db_dir ]; then
-  mkdir -p $sdk_db_dir
-fi
-
-#begin path
-begin_path=$PWD
-
-for ((i = 0; i < ${#service_source_root[*]}; i++)); do
-  cd $begin_path
-  service_path=${service_source_root[$i]}
-  cd $service_path && echo -e "${SKY_BLUE_PREFIX}Current directory: $PWD $COLOR_SUFFIX"
-  make install && echo -e "${SKY_BLUE_PREFIX}build ${service_names[$i]} success,moving binary file to the bin directory${COLOR_SUFFIX}" &&
-    echo -e "${SKY_BLUE_PREFIX}Successful moved ${service_names[$i]} to the bin directory${COLOR_SUFFIX}\n"
-done
+#!/usr/bin/env bash
+
+source ./style_info.cfg
+source ./path_info.cfg
+source ./function.sh
+
+bin_dir="../bin"
+logs_dir="../logs"
+sdk_db_dir="../db/sdk/"
+#Automatically created when there is no bin, logs folder
+if [ ! -d $bin_dir ]; then
+  mkdir -p $bin_dir
+fi
+if [ ! -d $logs_dir ]; then
+  mkdir -p $logs_dir
+fi
+if [ ! -d $sdk_db_dir ]; then
+  mkdir -p $sdk_db_dir
+fi
+
+#begin path
+begin_path=$PWD
+
+for ((i = 0; i < ${#service_source_root[*]}; i++)); do
+  cd $begin_path
+  service_path=${service_source_root[$i]}
+  cd $service_path && echo -e "${SKY_BLUE_PREFIX}Current directory: $PWD $COLOR_SUFFIX"
+  make install && echo -e "${SKY_BLUE_PREFIX}build ${service_names[$i]} success,moving binary file to the bin directory${COLOR_SUFFIX}" &&
+    echo -e "${SKY_BLUE_PREFIX}Successful moved ${service_names[$i]} to the bin directory${COLOR_SUFFIX}\n"
+done
diff --git a/script/check_all.sh b/script/check_all.sh
index dd8042fde..b984cc10a 100644
--- a/script/check_all.sh
+++ b/script/check_all.sh
@@ -1,31 +1,43 @@
-#!/usr/bin/env bash
-
-source ./style_info.cfg
-source ./path_info.cfg
-source ./function.sh
-service_port_name=(
-  openImApiPort
-  openImUserPort
-  openImFriendPort
-  openImOfflineMessagePort
-  openImOnlineRelayPort
-  openImGroupPort
-  openImAuthPort
-  openImPushPort
-  openImWsPort
-  openImSdkWsPort
-)
-  for i in ${service_port_name[*]};do
-      list=$(cat $config_path | grep -w ${i} | awk -F '[:]' '{print $NF}')
-      list_to_string $list
-      for j in ${ports_array};do
-         port=`netstat -netulp |grep ./open_im| awk '{print $4}'|grep -w ${j}|awk -F '[:]' '{print $NF}'`
-         if [[ ${port} -ne ${j} ]]; then
-           echo -e ${YELLOW_PREFIX}${i}${COLOR_SUFFIX}${RED_PREFIX}" service does not start normally,not initiated port is "${COLOR_SUFFIX}${YELLOW_PREFIX}${j}${COLOR_SUFFIX}
-           exit 1
-         else
-              echo -e ${j}${GREEN_PREFIX}" port has been listening,belongs service is "${i}${COLOR_SUFFIX}
-         fi
-        done
-  done
-  echo -e ${YELLOW_PREFIX}"all services launch success"${COLOR_SUFFIX}
+#!/usr/bin/env bash
+
+source ./style_info.cfg
+source ./path_info.cfg
+source ./function.sh
+service_port_name=(
+  openImApiPort
+  openImUserPort
+  openImFriendPort
+  openImOfflineMessagePort
+  openImOnlineRelayPort
+  openImGroupPort
+  openImAuthPort
+  openImPushPort
+  openImWsPort
+  openImSdkWsPort
+)
+for i in ${service_port_name[*]}; do
+  list=$(cat $config_path | grep -w ${i} | awk -F '[:]' '{print $NF}')
+  list_to_string $list
+  for j in ${ports_array}; do
+    port=$(netstat -netulp | grep ./open_im | awk '{print $4}' | grep -w ${j} | awk -F '[:]' '{print $NF}')
+    if [[ ${port} -ne ${j} ]]; then
+      echo -e ${YELLOW_PREFIX}${i}${COLOR_SUFFIX}${RED_PREFIX}" service does not start normally,not initiated port is "${COLOR_SUFFIX}${YELLOW_PREFIX}${j}${COLOR_SUFFIX}
+      echo -e ${RED_PREFIX}"please check ../logs/openIM.log "${COLOR_SUFFIX}
+      exit -1
+    else
+      echo -e ${j}${GREEN_PREFIX}" port has been listening,belongs service is "${i}${COLOR_SUFFIX}
+    fi
+  done
+done
+
+#Check launched service process
+check=$(ps aux | grep -w ./${msg_transfer_name} | grep -v grep | wc -l)
+if [ $check -eq ${msg_transfer_service_num} ]; then
+  echo -e ${GREEN_PREFIX}"service has been starting,belongs service is openImMsgTransfer"${COLOR_SUFFIX}
+else
+  echo -e ${RED_PREFIX}"openImMsgTransfer service does not start normally, num err"${COLOR_SUFFIX}
+        echo -e ${RED_PREFIX}"please check ../logs/openIM.log "${COLOR_SUFFIX}
+      exit -1
+fi
+
+echo -e ${YELLOW_PREFIX}"all services launch success"${COLOR_SUFFIX}
diff --git a/script/docker_check_service.sh b/script/docker_check_service.sh
index e380cb3fb..c9fd54ec8 100644
--- a/script/docker_check_service.sh
+++ b/script/docker_check_service.sh
@@ -1,33 +1,33 @@
-#!/usr/bin/env bash
-
-source ./style_info.cfg
-
-docker_compose_components=(
-  etcd
-  mongo
-  mysql
-  open-im-server
-  redis
-  kafka
-  zookeeper
-)
-
-component_server_count=0
-
-for ((i = 0; i < ${#docker_compose_components[*]}; i++)); do
-  component_server="docker-compose ps|grep -w ${docker_compose_components[$i]}|grep Up"
-  count="${component_server}|wc -l"
-
-  if [ $(eval ${count}) -gt 0 ]; then
-    echo -e "${SKY_BLUE_PREFIX}docker-compose ${docker_compose_components[$i]} is Up!${COLOR_SUFFIX}"
-    let component_server_count+=1
-  else
-    echo -e "${RED_PREFIX} ${docker_compose_components[$i]} start failed!${COLOR_SUFFIX}"
-  fi
-done
-
-if [ ${component_server_count} -eq 7 ]; then
-  echo -e "${YELLOW_PREFIX}\ndocker-compose all services is Up!${COLOR_SUFFIX}"
-else
-  echo -e "${RED_PREFIX}\nsome docker-compose services start failed,please check red logs on console ${COLOR_SUFFIX}"
-fi
+#!/usr/bin/env bash
+
+source ./style_info.cfg
+
+docker_compose_components=(
+  etcd
+  mongo
+  mysql
+  open-im-server
+  redis
+  kafka
+  zookeeper
+)
+
+component_server_count=0
+
+for ((i = 0; i < ${#docker_compose_components[*]}; i++)); do
+  component_server="docker-compose ps|grep -w ${docker_compose_components[$i]}|grep Up"
+  count="${component_server}|wc -l"
+
+  if [ $(eval ${count}) -gt 0 ]; then
+    echo -e "${SKY_BLUE_PREFIX}docker-compose ${docker_compose_components[$i]} is Up!${COLOR_SUFFIX}"
+    let component_server_count+=1
+  else
+    echo -e "${RED_PREFIX} ${docker_compose_components[$i]} start failed!${COLOR_SUFFIX}"
+  fi
+done
+
+if [ ${component_server_count} -eq 7 ]; then
+  echo -e "${YELLOW_PREFIX}\ndocker-compose all services is Up!${COLOR_SUFFIX}"
+else
+  echo -e "${RED_PREFIX}\nsome docker-compose services start failed,please check red logs on console ${COLOR_SUFFIX}"
+fi
diff --git a/script/docker_start_all.sh b/script/docker_start_all.sh
index 740b88e85..fce59c41a 100644
--- a/script/docker_start_all.sh
+++ b/script/docker_start_all.sh
@@ -1,23 +1,23 @@
-#!/usr/bin/env bash
-#fixme This script is the total startup script
-#fixme The full name of the shell script that needs to be started is placed in the need_to_start_server_shell array
-
-#fixme Put the shell script name here
-need_to_start_server_shell=(
-  start_rpc_service.sh
-  msg_gateway_start.sh
-  push_start.sh
-  msg_transfer_start.sh
-  sdk_svr_start.sh
-)
-
-#fixme The 10 second delay to start the project is for the docker-compose one-click to start openIM when the infrastructure dependencies are not started
-sleep 10
-
-for i in ${need_to_start_server_shell[*]}; do
-  chmod +x $i
-  ./$i
-done
-
-#fixme prevents the openIM service exit after execution in the docker container
-tail -f /dev/null
+#!/usr/bin/env bash
+#fixme This script is the total startup script
+#fixme The full name of the shell script that needs to be started is placed in the need_to_start_server_shell array
+
+#fixme Put the shell script name here
+need_to_start_server_shell=(
+  start_rpc_service.sh
+  msg_gateway_start.sh
+  push_start.sh
+  msg_transfer_start.sh
+  sdk_svr_start.sh
+)
+
+#fixme The 10 second delay to start the project is for the docker-compose one-click to start openIM when the infrastructure dependencies are not started
+sleep 10
+
+for i in ${need_to_start_server_shell[*]}; do
+  chmod +x $i
+  ./$i
+done
+
+#fixme prevents the openIM service exit after execution in the docker container
+tail -f /dev/null
diff --git a/script/function.sh b/script/function.sh
index 0deb52b38..b57373c72 100644
--- a/script/function.sh
+++ b/script/function.sh
@@ -1,11 +1,11 @@
-#!/usr/bin/env bash
-#input:[10023,2323,3434]
-#output:10023 2323 3434
-list_to_string(){
-ports_list=$*
-sub_s1=`echo $ports_list | sed 's/ //g'`
-sub_s2=${sub_s1//,/ }
-sub_s3=${sub_s2#*[}
-sub_s4=${sub_s3%]*}
-ports_array=$sub_s4
+#!/usr/bin/env bash
+#input:[10023,2323,3434]
+#output:10023 2323 3434
+list_to_string(){
+ports_list=$*
+sub_s1=`echo $ports_list | sed 's/ //g'`
+sub_s2=${sub_s1//,/ }
+sub_s3=${sub_s2#*[}
+sub_s4=${sub_s3%]*}
+ports_array=$sub_s4
 }
\ No newline at end of file
diff --git a/script/msg_gateway_start.sh b/script/msg_gateway_start.sh
index 197c28743..c21d335ca 100644
--- a/script/msg_gateway_start.sh
+++ b/script/msg_gateway_start.sh
@@ -1,48 +1,48 @@
-#!/usr/bin/env bash
-#Include shell font styles and some basic information
-source ./style_info.cfg
-source ./path_info.cfg
-source ./function.sh
-list1=$(cat $config_path | grep openImOnlineRelayPort | awk -F '[:]' '{print $NF}')
-list2=$(cat $config_path | grep openImWsPort | awk -F '[:]' '{print $NF}')
-list_to_string $list1
-rpc_ports=($ports_array)
-list_to_string $list2
-ws_ports=($ports_array)
-if [ ${#rpc_ports[@]} -ne ${#ws_ports[@]} ]; then
-
-  echo -e ${RED_PREFIX}"ws_ports does not match push_rpc_ports in quantity!!!"${COLOR_SUFFIX}
-  exit 0
-
-fi
-#Check if the service exists
-#If it is exists,kill this process
-check=$(ps aux | grep -w ./${msg_gateway_name} | grep -v grep | wc -l)
-if [ $check -ge 1 ]; then
-  oldPid=$(ps aux | grep -w ./${msg_gateway_name} | grep -v grep | awk '{print $2}')
-    kill -9 ${oldPid}
-fi
-#Waiting port recycling
-sleep 1
-cd ${msg_gateway_binary_root}
-for ((i = 0; i < ${#ws_ports[@]}; i++)); do
-  nohup ./${msg_gateway_name} -rpc_port ${rpc_ports[$i]} -ws_port ${ws_ports[$i]} >>../logs/openIM.log 2>&1 &
-done
-
-#Check launched service process
-sleep 3
-check=$(ps aux | grep -w ./${msg_gateway_name} | grep -v grep | wc -l)
-allPorts=""
-if [ $check -ge 1 ]; then
-  allNewPid=$(ps aux | grep -w ./${msg_gateway_name} | grep -v grep | awk '{print $2}')
-  for i in $allNewPid; do
-    ports=$(netstat -netulp | grep -w ${i} | awk '{print $4}' | awk -F '[:]' '{print $NF}')
-      allPorts=${allPorts}"$ports "
-  done
-  echo -e ${SKY_BLUE_PREFIX}"SERVICE START SUCCESS"${COLOR_SUFFIX}
-  echo -e ${SKY_BLUE_PREFIX}"SERVICE_NAME: "${COLOR_SUFFIX}${YELLOW_PREFIX}${msg_gateway_name}${COLOR_SUFFIX}
-  echo -e ${SKY_BLUE_PREFIX}"PID: "${COLOR_SUFFIX}${YELLOW_PREFIX}${allNewPid}${COLOR_SUFFIX}
-  echo -e ${SKY_BLUE_PREFIX}"LISTENING_PORT: "${COLOR_SUFFIX}${YELLOW_PREFIX}${allPorts}${COLOR_SUFFIX}
-else
-  echo -e ${YELLOW_PREFIX}${msg_gateway_name}${COLOR_SUFFIX}${RED_PREFIX}"SERVICE START ERROR !!! PLEASE CHECK ERROR LOG"${COLOR_SUFFIX}
-fi
+#!/usr/bin/env bash
+#Include shell font styles and some basic information
+source ./style_info.cfg
+source ./path_info.cfg
+source ./function.sh
+list1=$(cat $config_path | grep openImOnlineRelayPort | awk -F '[:]' '{print $NF}')
+list2=$(cat $config_path | grep openImWsPort | awk -F '[:]' '{print $NF}')
+list_to_string $list1
+rpc_ports=($ports_array)
+list_to_string $list2
+ws_ports=($ports_array)
+if [ ${#rpc_ports[@]} -ne ${#ws_ports[@]} ]; then
+
+  echo -e ${RED_PREFIX}"ws_ports does not match push_rpc_ports in quantity!!!"${COLOR_SUFFIX}
+  exit 0
+
+fi
+#Check if the service exists
+#If it is exists,kill this process
+check=$(ps aux | grep -w ./${msg_gateway_name} | grep -v grep | wc -l)
+if [ $check -ge 1 ]; then
+  oldPid=$(ps aux | grep -w ./${msg_gateway_name} | grep -v grep | awk '{print $2}')
+    kill -9 ${oldPid}
+fi
+#Waiting port recycling
+sleep 1
+cd ${msg_gateway_binary_root}
+for ((i = 0; i < ${#ws_ports[@]}; i++)); do
+  nohup ./${msg_gateway_name} -rpc_port ${rpc_ports[$i]} -ws_port ${ws_ports[$i]} >>../logs/openIM.log 2>&1 &
+done
+
+#Check launched service process
+sleep 3
+check=$(ps aux | grep -w ./${msg_gateway_name} | grep -v grep | wc -l)
+allPorts=""
+if [ $check -ge 1 ]; then
+  allNewPid=$(ps aux | grep -w ./${msg_gateway_name} | grep -v grep | awk '{print $2}')
+  for i in $allNewPid; do
+    ports=$(netstat -netulp | grep -w ${i} | awk '{print $4}' | awk -F '[:]' '{print $NF}')
+      allPorts=${allPorts}"$ports "
+  done
+  echo -e ${SKY_BLUE_PREFIX}"SERVICE START SUCCESS"${COLOR_SUFFIX}
+  echo -e ${SKY_BLUE_PREFIX}"SERVICE_NAME: "${COLOR_SUFFIX}${YELLOW_PREFIX}${msg_gateway_name}${COLOR_SUFFIX}
+  echo -e ${SKY_BLUE_PREFIX}"PID: "${COLOR_SUFFIX}${YELLOW_PREFIX}${allNewPid}${COLOR_SUFFIX}
+  echo -e ${SKY_BLUE_PREFIX}"LISTENING_PORT: "${COLOR_SUFFIX}${YELLOW_PREFIX}${allPorts}${COLOR_SUFFIX}
+else
+  echo -e ${YELLOW_PREFIX}${msg_gateway_name}${COLOR_SUFFIX}${RED_PREFIX}"SERVICE START ERROR, PLEASE CHECK openIM.log"${COLOR_SUFFIX}
+fi
diff --git a/script/msg_transfer_start.sh b/script/msg_transfer_start.sh
index 30caeb466..0b645596c 100644
--- a/script/msg_transfer_start.sh
+++ b/script/msg_transfer_start.sh
@@ -1,38 +1,36 @@
-#!/usr/bin/env bash
-#Include shell font styles and some basic information
-source ./style_info.cfg
-source ./path_info.cfg
-
-
-
-#Check if the service exists
-#If it is exists,kill this process
-check=`ps aux | grep -w ./${msg_transfer_name} | grep -v grep| wc -l`
-if [ $check -eq 1 ]
-then
-oldPid=`ps aux | grep -w ./${msg_transfer_name} | grep -v grep|awk '{print $2}'`
- kill -9 $oldPid
-fi
-#Waiting port recycling
-sleep 1
-cd ${msg_transfer_binary_root}
-    nohup ./${msg_transfer_name}  >>../logs/openIM.log 2>&1 &
-#Check launched service process
-check=`ps aux | grep -w ./${msg_transfer_name} | grep -v grep| wc -l`
-if [ $check -eq 1 ]
-then
-newPid=`ps aux | grep -w ./${msg_transfer_name} | grep -v grep|awk '{print $2}'`
-ports=`netstat -netulp | grep -w ${newPid}|awk '{print $4}'|awk -F '[:]' '{print $NF}'`
-allPorts=""
-
-for i in $ports ;
-do
-     allPorts=${allPorts}"$i "
-done
-    echo -e ${SKY_BLUE_PREFIX}"SERVICE START SUCCESS "${COLOR_SUFFIX}
-    echo -e ${SKY_BLUE_PREFIX}"SERVICE_NAME: "${COLOR_SUFFIX}${YELLOW_PREFIX}${msg_transfer_name}${COLOR_SUFFIX}
-    echo -e ${SKY_BLUE_PREFIX}"PID: "${COLOR_SUFFIX}${YELLOW_PREFIX}${newPid}${COLOR_SUFFIX}
-    echo -e ${SKY_BLUE_PREFIX}"LISTENING_PORT: "${COLOR_SUFFIX}${YELLOW_PREFIX}${allPorts}${COLOR_SUFFIX}
-else
-    echo -e ${YELLOW_PREFIX}${msg_transfer_name}${COLOR_SUFFIX}${RED_PREFIX}"SERVICE START ERROR !!! PLEASE CHECK ERROR LOG"${COLOR_SUFFIX}
-fi
+#!/usr/bin/env bash
+#Include shell font styles and some basic information
+source ./style_info.cfg
+source ./path_info.cfg
+
+
+
+#Check if the service exists
+#If it is exists,kill this process
+check=`ps aux | grep -w ./${msg_transfer_name} | grep -v grep| wc -l`
+if [ $check -ge 1 ]
+then
+oldPid=`ps aux | grep -w ./${msg_transfer_name} | grep -v grep|awk '{print $2}'`
+ kill -9 $oldPid
+fi
+#Waiting port recycling
+sleep 1
+
+cd ${msg_transfer_binary_root}
+for ((i = 0; i < ${msg_transfer_service_num}; i++)); do
+      nohup ./${msg_transfer_name}  >>../logs/openIM.log 2>&1 &
+done
+
+#Check launched service process
+check=`ps aux | grep -w ./${msg_transfer_name} | grep -v grep| wc -l`
+if [ $check -ge 1 ]
+then
+newPid=`ps aux | grep -w ./${msg_transfer_name} | grep -v grep|awk '{print $2}'`
+allPorts=""
+    echo -e ${SKY_BLUE_PREFIX}"SERVICE START SUCCESS "${COLOR_SUFFIX}
+    echo -e ${SKY_BLUE_PREFIX}"SERVICE_NAME: "${COLOR_SUFFIX}${YELLOW_PREFIX}${msg_transfer_name}${COLOR_SUFFIX}
+    echo -e ${SKY_BLUE_PREFIX}"PID: "${COLOR_SUFFIX}${YELLOW_PREFIX}${newPid}${COLOR_SUFFIX}
+    echo -e ${SKY_BLUE_PREFIX}"LISTENING_PORT: "${COLOR_SUFFIX}${YELLOW_PREFIX}${allPorts}${COLOR_SUFFIX}
+else
+    echo -e ${YELLOW_PREFIX}${msg_transfer_name}${COLOR_SUFFIX}${RED_PREFIX}"SERVICE START ERROR, PLEASE CHECK openIM.log"${COLOR_SUFFIX}
+fi
diff --git a/script/mysql_database_init.sh b/script/mysql_database_init.sh
index 2a5135e8e..f8e4caa59 100644
--- a/script/mysql_database_init.sh
+++ b/script/mysql_database_init.sh
@@ -1,38 +1,38 @@
-#!/usr/bin/env bash
-
-source ./style_info.cfg
-source ./path_info.cfg
-source ./function.sh
-
-#define database attributes
-address=$(cat $config_path | grep -w dbMysqlAddress)
-list_to_string ${address}
-hostAndPort=($ports_array)
-DATABASE_HOST=$(echo $hostAndPort | awk -F '[:]' '{print $1}')
-DATABASE_PORT=$(echo $hostAndPort | awk -F '[:]' '{print $NF}')
-DATABASE_USERNAME=$(cat $config_path | grep -w dbMysqlUserName | awk -F '[:]' '{print $NF}')
-DATABASE_PWD=`eval echo $(cat $config_path | grep -w dbMysqlPassword | awk -F '[:]' '{print $NF}')`
-DATABASE_NAME=$(cat $config_path | grep -w dbMysqlDatabaseName | awk -F '[:]' '{print $NF}')
-SQL_FILE="../config/mysql_sql_file/openIM.sql"
-
-
-create_data_sql="create database IF NOT EXISTS $DATABASE_NAME"
-set_character_code_sql="alter database $DATABASE_NAME character set utf8mb4 collate utf8mb4_general_ci"
-
-echo -e "${SKY_BLUE_PREFIX}start to create database.....$COLOR_SUFFIX"
-mysql -h $DATABASE_HOST -P $DATABASE_PORT -u $DATABASE_USERNAME -p$DATABASE_PWD -e "$create_data_sql"
-
-if [ $? -eq 0 ]; then
-  echo -e "${SKY_BLUE_PREFIX}create database ${DATABASE_NAME} successfully$COLOR_SUFFIX"
-  mysql -h $DATABASE_HOST -P $DATABASE_PORT -u $DATABASE_USERNAME -p$DATABASE_PWD -e "$set_character_code_sql"
-else
-  echo -e "${RED_PREFIX}create database failed or exists the database$COLOR_SUFFIX\n"
-fi
-
-echo -e "${SKY_BLUE_PREFIX}start to source openIM.sql .....$COLOR_SUFFIX"
-mysql -h $DATABASE_HOST -P $DATABASE_PORT -u $DATABASE_USERNAME -p$DATABASE_PWD -D $DATABASE_NAME <$SQL_FILE
-if [ $? -eq 0 ]; then
-  echo -e "${SKY_BLUE_PREFIX}source openIM.sql successfully$COLOR_SUFFIX"
-else
-  echo -e "${RED_PREFIX}source openIM.sql failed$COLOR_SUFFIX\n"
-fi
+#!/usr/bin/env bash
+
+source ./style_info.cfg
+source ./path_info.cfg
+source ./function.sh
+
+#define database attributes
+address=$(cat $config_path | grep -w dbMysqlAddress)
+list_to_string ${address}
+hostAndPort=($ports_array)
+DATABASE_HOST=$(echo $hostAndPort | awk -F '[:]' '{print $1}')
+DATABASE_PORT=$(echo $hostAndPort | awk -F '[:]' '{print $NF}')
+DATABASE_USERNAME=$(cat $config_path | grep -w dbMysqlUserName | awk -F '[:]' '{print $NF}')
+DATABASE_PWD=`eval echo $(cat $config_path | grep -w dbMysqlPassword | awk -F '[:]' '{print $NF}')`
+DATABASE_NAME=$(cat $config_path | grep -w dbMysqlDatabaseName | awk -F '[:]' '{print $NF}')
+SQL_FILE="../config/mysql_sql_file/openIM.sql"
+
+
+create_data_sql="create database IF NOT EXISTS $DATABASE_NAME"
+set_character_code_sql="alter database $DATABASE_NAME character set utf8mb4 collate utf8mb4_general_ci"
+
+echo -e "${SKY_BLUE_PREFIX}start to create database.....$COLOR_SUFFIX"
+mysql -h $DATABASE_HOST -P $DATABASE_PORT -u $DATABASE_USERNAME -p$DATABASE_PWD -e "$create_data_sql"
+
+if [ $? -eq 0 ]; then
+  echo -e "${SKY_BLUE_PREFIX}create database ${DATABASE_NAME} successfully$COLOR_SUFFIX"
+  mysql -h $DATABASE_HOST -P $DATABASE_PORT -u $DATABASE_USERNAME -p$DATABASE_PWD -e "$set_character_code_sql"
+else
+  echo -e "${RED_PREFIX}create database failed or exists the database$COLOR_SUFFIX\n"
+fi
+
+echo -e "${SKY_BLUE_PREFIX}start to source openIM.sql .....$COLOR_SUFFIX"
+mysql -h $DATABASE_HOST -P $DATABASE_PORT -u $DATABASE_USERNAME -p$DATABASE_PWD -D $DATABASE_NAME <$SQL_FILE
+if [ $? -eq 0 ]; then
+  echo -e "${SKY_BLUE_PREFIX}source openIM.sql successfully$COLOR_SUFFIX"
+else
+  echo -e "${RED_PREFIX}source openIM.sql failed$COLOR_SUFFIX\n"
+fi
diff --git a/script/path_info.cfg b/script/path_info.cfg
index ed250d29d..4529c93d6 100644
--- a/script/path_info.cfg
+++ b/script/path_info.cfg
@@ -1,62 +1,63 @@
-#Don't put the space between "="
-msg_gateway_name="open_im_msg_gateway"
-msg_gateway_binary_root="../bin/"
-msg_gateway_source_root="../src/msg_gateway/"
-
-msg_name="open_im_msg"
-msg_binary_root="../bin/"
-msg_source_root="../src/rpc/chat/"
-
-push_name="open_im_push"
-push_binary_root="../bin/"
-push_source_root="../src/push/"
-
-
-
-msg_transfer_name="open_im_msg_transfer"
-msg_transfer_binary_root="../bin/"
-msg_transfer_source_root="../src/msg_transfer/"
-
-
-sdk_server_name="open_im_sdk_server"
-sdk_server_binary_root="../bin/"
-sdk_server_source_root="../src/Open-IM-SDK-Core/"
-
-
-#Global configuration file default dir
-config_path="../config/config.yaml"
-
-#servicefile dir path
-service_source_root=(
-  #api service file
-  ../src/api/
-  #rpc service file
-  ../src/rpc/user/
-  ../src/rpc/friend/
-  ../src/rpc/group/
-  ../src/rpc/auth/
-  ${msg_gateway_source_root}
-  ${msg_transfer_source_root}
-  ${msg_source_root}
-  ${push_source_root}
-  ${sdk_server_source_root}
-)
-#service filename
-service_names=(
-  #api service filename
-  open_im_api
-  #rpc service filename
-  open_im_user
-  open_im_friend
-  open_im_group
-  open_im_auth
-  ${msg_gateway_name}
-  ${msg_transfer_name}
-  ${msg_name}
-  ${push_name}
-  ${sdk_server_name}
-)
-
-
-
-
+#Don't put the space between "="
+msg_gateway_name="open_im_msg_gateway"
+msg_gateway_binary_root="../bin/"
+msg_gateway_source_root="../src/msg_gateway/"
+
+msg_name="open_im_msg"
+msg_binary_root="../bin/"
+msg_source_root="../src/rpc/chat/"
+
+push_name="open_im_push"
+push_binary_root="../bin/"
+push_source_root="../src/push/"
+
+
+
+msg_transfer_name="open_im_msg_transfer"
+msg_transfer_binary_root="../bin/"
+msg_transfer_source_root="../src/msg_transfer/"
+msg_transfer_service_num=2
+
+
+sdk_server_name="open_im_sdk_server"
+sdk_server_binary_root="../bin/"
+sdk_server_source_root="../src/Open-IM-SDK-Core/"
+
+
+#Global configuration file default dir
+config_path="../config/config.yaml"
+
+#servicefile dir path
+service_source_root=(
+  #api service file
+  ../src/api/
+  #rpc service file
+  ../src/rpc/user/
+  ../src/rpc/friend/
+  ../src/rpc/group/
+  ../src/rpc/auth/
+  ${msg_gateway_source_root}
+  ${msg_transfer_source_root}
+  ${msg_source_root}
+  ${push_source_root}
+  ${sdk_server_source_root}
+)
+#service filename
+service_names=(
+  #api service filename
+  open_im_api
+  #rpc service filename
+  open_im_user
+  open_im_friend
+  open_im_group
+  open_im_auth
+  ${msg_gateway_name}
+  ${msg_transfer_name}
+  ${msg_name}
+  ${push_name}
+  ${sdk_server_name}
+)
+
+
+
+
diff --git a/script/push_start.sh b/script/push_start.sh
index 668c0068f..51ec1d6ba 100644
--- a/script/push_start.sh
+++ b/script/push_start.sh
@@ -1,45 +1,45 @@
-#!/usr/bin/env bash
-#Include shell font styles and some basic information
-source ./style_info.cfg
-source ./path_info.cfg
-source ./function.sh
-
-
-
-list1=$(cat $config_path | grep openImPushPort | awk -F '[:]' '{print $NF}')
-list_to_string $list1
-rpc_ports=($ports_array)
-
-#Check if the service exists
-#If it is exists,kill this process
-check=$(ps aux | grep -w ./${push_name} | grep -v grep | wc -l)
-if [ $check -eq 1 ]; then
-  oldPid=$(ps aux | grep -w ./${push_name} | grep -v grep | awk '{print $2}')
-  kill -9 $oldPid
-fi
-#Waiting port recycling
-sleep 1
-cd ${push_binary_root}
-
-for ((i = 0; i < ${#rpc_ports[@]}; i++)); do
-  nohup ./${push_name} -port ${rpc_ports[$i]} >>../logs/openIM.log 2>&1 &
-done
-
-sleep 3
-#Check launched service process
-check=$(ps aux | grep -w ./${push_name} | grep -v grep | wc -l)
-if [ $check -eq 1 ]; then
-  newPid=$(ps aux | grep -w ./${push_name} | grep -v grep | awk '{print $2}')
-  ports=$(netstat -netulp | grep -w ${newPid} | awk '{print $4}' | awk -F '[:]' '{print $NF}')
-  allPorts=""
-
-  for i in $ports; do
-    allPorts=${allPorts}"$i "
-  done
-  echo -e ${SKY_BLUE_PREFIX}"SERVICE START SUCCESS "${COLOR_SUFFIX}
-  echo -e ${SKY_BLUE_PREFIX}"SERVICE_NAME: "${COLOR_SUFFIX}${YELLOW_PREFIX}${push_name}${COLOR_SUFFIX}
-  echo -e ${SKY_BLUE_PREFIX}"PID: "${COLOR_SUFFIX}${YELLOW_PREFIX}${newPid}${COLOR_SUFFIX}
-  echo -e ${SKY_BLUE_PREFIX}"LISTENING_PORT: "${COLOR_SUFFIX}${YELLOW_PREFIX}${allPorts}${COLOR_SUFFIX}
-else
-  echo -e ${YELLOW_PREFIX}${push_name}${COLOR_SUFFIX}${RED_PREFIX}"SERVICE START ERROR !!! PLEASE CHECK ERROR LOG"${COLOR_SUFFIX}
-fi
+#!/usr/bin/env bash
+#Include shell font styles and some basic information
+source ./style_info.cfg
+source ./path_info.cfg
+source ./function.sh
+
+
+
+list1=$(cat $config_path | grep openImPushPort | awk -F '[:]' '{print $NF}')
+list_to_string $list1
+rpc_ports=($ports_array)
+
+#Check if the service exists
+#If it is exists,kill this process
+check=$(ps aux | grep -w ./${push_name} | grep -v grep | wc -l)
+if [ $check -ge 1 ]; then
+  oldPid=$(ps aux | grep -w ./${push_name} | grep -v grep | awk '{print $2}')
+  kill -9 $oldPid
+fi
+#Waiting port recycling
+sleep 1
+cd ${push_binary_root}
+
+for ((i = 0; i < ${#rpc_ports[@]}; i++)); do
+  nohup ./${push_name} -port ${rpc_ports[$i]} >>../logs/openIM.log 2>&1 &
+done
+
+sleep 3
+#Check launched service process
+check=$(ps aux | grep -w ./${push_name} | grep -v grep | wc -l)
+if [ $check -ge 1 ]; then
+  newPid=$(ps aux | grep -w ./${push_name} | grep -v grep | awk '{print $2}')
+  ports=$(netstat -netulp | grep -w ${newPid} | awk '{print $4}' | awk -F '[:]' '{print $NF}')
+  allPorts=""
+
+  for i in $ports; do
+    allPorts=${allPorts}"$i "
+  done
+  echo -e ${SKY_BLUE_PREFIX}"SERVICE START SUCCESS "${COLOR_SUFFIX}
+  echo -e ${SKY_BLUE_PREFIX}"SERVICE_NAME: "${COLOR_SUFFIX}${YELLOW_PREFIX}${push_name}${COLOR_SUFFIX}
+  echo -e ${SKY_BLUE_PREFIX}"PID: "${COLOR_SUFFIX}${YELLOW_PREFIX}${newPid}${COLOR_SUFFIX}
+  echo -e ${SKY_BLUE_PREFIX}"LISTENING_PORT: "${COLOR_SUFFIX}${YELLOW_PREFIX}${allPorts}${COLOR_SUFFIX}
+else
+  echo -e ${YELLOW_PREFIX}${push_name}${COLOR_SUFFIX}${RED_PREFIX}"SERVICE START ERROR, PLEASE CHECK openIM.log"${COLOR_SUFFIX}
+fi
diff --git a/script/sdk_svr_start.sh b/script/sdk_svr_start.sh
index 28d764b73..4d6af3999 100644
--- a/script/sdk_svr_start.sh
+++ b/script/sdk_svr_start.sh
@@ -1,47 +1,47 @@
-#!/usr/bin/env bash
-#Include shell font styles and some basic information
-source ./style_info.cfg
-source ./path_info.cfg
-source ./function.sh
-list1=$(cat $config_path | grep openImApiPort | awk -F '[:]' '{print $NF}')
-list2=$(cat $config_path | grep openImWsPort | awk -F '[:]' '{print $NF}')
-list3=$(cat $config_path | grep openImSdkWsPort | awk -F '[:]' '{print $NF}')
-list_to_string $list1
-api_ports=($ports_array)
-list_to_string $list2
-ws_ports=($ports_array)
-list_to_string $list3
-sdk_ws_ports=($ports_array)
-
-
-
-
-#Check if the service exists
-#If it is exists,kill this process
-check=$(ps aux | grep -w ./${sdk_server_name} | grep -v grep | wc -l)
-if [ $check -ge 1 ]; then
-  oldPid=$(ps aux | grep -w ./${sdk_server_name} | grep -v grep | awk '{print $2}')
-    kill -9 ${oldPid}
-fi
-#Waiting port recycling
-sleep 1
-cd ${sdk_server_binary_root}
-  nohup ./${sdk_server_name} -openIM_api_port ${api_ports[0]} -openIM_ws_port ${ws_ports[0]} -sdk_ws_port ${sdk_ws_ports[0]} >>../logs/openIM.log 2>&1 &
-
-#Check launched service process
-sleep 3
-check=$(ps aux | grep -w ./${sdk_server_name} | grep -v grep | wc -l)
-allPorts=""
-if [ $check -ge 1 ]; then
-  allNewPid=$(ps aux | grep -w ./${sdk_server_name} | grep -v grep | awk '{print $2}')
-  for i in $allNewPid; do
-    ports=$(netstat -netulp | grep -w ${i} | awk '{print $4}' | awk -F '[:]' '{print $NF}')
-      allPorts=${allPorts}"$ports "
-  done
-  echo -e ${SKY_BLUE_PREFIX}"SERVICE START SUCCESS "${COLOR_SUFFIX}
-  echo -e ${SKY_BLUE_PREFIX}"SERVICE_NAME: "${COLOR_SUFFIX}${YELLOW_PREFIX}${sdk_server_name}${COLOR_SUFFIX}
-  echo -e ${SKY_BLUE_PREFIX}"PID: "${COLOR_SUFFIX}${YELLOW_PREFIX}${allNewPid}${COLOR_SUFFIX}
-  echo -e ${SKY_BLUE_PREFIX}"LISTENING_PORT: "${COLOR_SUFFIX}${YELLOW_PREFIX}${allPorts}${COLOR_SUFFIX}
-else
-  echo -e ${YELLOW_PREFIX}${sdk_server_name}${COLOR_SUFFIX}${RED_PREFIX}"SERVICE START ERROR !!! PLEASE CHECK ERROR LOG"${COLOR_SUFFIX}
-fi
+#!/usr/bin/env bash
+#Include shell font styles and some basic information
+source ./style_info.cfg
+source ./path_info.cfg
+source ./function.sh
+list1=$(cat $config_path | grep openImApiPort | awk -F '[:]' '{print $NF}')
+list2=$(cat $config_path | grep openImWsPort | awk -F '[:]' '{print $NF}')
+list3=$(cat $config_path | grep openImSdkWsPort | awk -F '[:]' '{print $NF}')
+list_to_string $list1
+api_ports=($ports_array)
+list_to_string $list2
+ws_ports=($ports_array)
+list_to_string $list3
+sdk_ws_ports=($ports_array)
+
+
+
+
+#Check if the service exists
+#If it is exists,kill this process
+check=$(ps aux | grep -w ./${sdk_server_name} | grep -v grep | wc -l)
+if [ $check -ge 1 ]; then
+  oldPid=$(ps aux | grep -w ./${sdk_server_name} | grep -v grep | awk '{print $2}')
+    kill -9 ${oldPid}
+fi
+#Waiting port recycling
+sleep 1
+cd ${sdk_server_binary_root}
+  nohup ./${sdk_server_name} -openIM_api_port ${api_ports[0]} -openIM_ws_port ${ws_ports[0]} -sdk_ws_port ${sdk_ws_ports[0]} >>../logs/openIM.log 2>&1 &
+
+#Check launched service process
+sleep 3
+check=$(ps aux | grep -w ./${sdk_server_name} | grep -v grep | wc -l)
+allPorts=""
+if [ $check -ge 1 ]; then
+  allNewPid=$(ps aux | grep -w ./${sdk_server_name} | grep -v grep | awk '{print $2}')
+  for i in $allNewPid; do
+    ports=$(netstat -netulp | grep -w ${i} | awk '{print $4}' | awk -F '[:]' '{print $NF}')
+      allPorts=${allPorts}"$ports "
+  done
+  echo -e ${SKY_BLUE_PREFIX}"SERVICE START SUCCESS "${COLOR_SUFFIX}
+  echo -e ${SKY_BLUE_PREFIX}"SERVICE_NAME: "${COLOR_SUFFIX}${YELLOW_PREFIX}${sdk_server_name}${COLOR_SUFFIX}
+  echo -e ${SKY_BLUE_PREFIX}"PID: "${COLOR_SUFFIX}${YELLOW_PREFIX}${allNewPid}${COLOR_SUFFIX}
+  echo -e ${SKY_BLUE_PREFIX}"LISTENING_PORT: "${COLOR_SUFFIX}${YELLOW_PREFIX}${allPorts}${COLOR_SUFFIX}
+else
+  echo -e ${YELLOW_PREFIX}${sdk_server_name}${COLOR_SUFFIX}${RED_PREFIX}"SERVICE START ERROR PLEASE CHECK openIM.log"${COLOR_SUFFIX}
+fi
diff --git a/script/start_all.sh b/script/start_all.sh
index 43a02b34d..9990cb6c8 100644
--- a/script/start_all.sh
+++ b/script/start_all.sh
@@ -1,18 +1,18 @@
-#!/usr/bin/env bash
-#fixme This script is the total startup script
-#fixme The full name of the shell script that needs to be started is placed in the need_to_start_server_shell array
-
-#fixme Put the shell script name here
-need_to_start_server_shell=(
-  start_rpc_service.sh
-  msg_gateway_start.sh
-  push_start.sh
-  msg_transfer_start.sh
-  sdk_svr_start.sh
-)
-
-for i in ${need_to_start_server_shell[*]}; do
-  chmod +x $i
-  ./$i
-done
-
+#!/usr/bin/env bash
+#fixme This script is the total startup script
+#fixme The full name of the shell script that needs to be started is placed in the need_to_start_server_shell array
+
+#fixme Put the shell script name here
+need_to_start_server_shell=(
+  start_rpc_service.sh
+  msg_gateway_start.sh
+  push_start.sh
+  msg_transfer_start.sh
+  sdk_svr_start.sh
+)
+
+for i in ${need_to_start_server_shell[*]}; do
+  chmod +x $i
+  ./$i
+done
+
diff --git a/script/start_rpc_service.sh b/script/start_rpc_service.sh
index 74f00a3f4..6307ca1c0 100644
--- a/script/start_rpc_service.sh
+++ b/script/start_rpc_service.sh
@@ -1,59 +1,59 @@
-#!/usr/bin/env bash
-
-source ./style_info.cfg
-source ./path_info.cfg
-source ./function.sh
-
-#service filename
-service_filename=(
-  #api
-  open_im_api
-  #rpc
-  open_im_user
-  open_im_friend
-  open_im_group
-  open_im_auth
-  ${msg_name}
-)
-
-#service config port name
-service_port_name=(
-  #api port name
-  openImApiPort
-  #rpc port name
-  openImUserPort
-  openImFriendPort
-  openImGroupPort
-  openImAuthPort
-  openImOfflineMessagePort
-
-)
-
-for ((i = 0; i < ${#service_filename[*]}; i++)); do
-  #Check whether the service exists
-  service_name="ps -aux |grep -w ${service_filename[$i]} |grep -v grep"
-  count="${service_name}| wc -l"
-
-  if [ $(eval ${count}) -gt 0 ]; then
-    pid="${service_name}| awk '{print \$2}'"
-    echo -e "${SKY_BLUE_PREFIX}${service_filename[$i]} service has been started,pid:$(eval $pid)$COLOR_SUFFIX"
-    echo -e "${SKY_BLUE_PREFIX}Killing the service ${service_filename[$i]} pid:$(eval $pid)${COLOR_SUFFIX}"
-    #kill the service that existed
-    kill -9 $(eval $pid)
-    sleep 0.5
-  fi
-  cd ../bin && echo -e "${SKY_BLUE_PREFIX}${service_filename[$i]} service is starting${COLOR_SUFFIX}"
-  #Get the rpc port in the configuration file
-  portList=$(cat $config_path | grep ${service_port_name[$i]} | awk -F '[:]' '{print $NF}')
-  list_to_string ${portList}
-  #Start related rpc services based on the number of ports
-  for j in ${ports_array}; do
-    echo -e "${SKY_BLUE_PREFIX}${service_filename[$i]} Service is starting,port number:$j $COLOR_SUFFIX"
-    #Start the service in the background
-    #    ./${service_filename[$i]} -port $j &
-    nohup ./${service_filename[$i]} -port $j >>../logs/openIM.log 2>&1 &
-    sleep 1
-    pid="netstat -ntlp|grep $j |awk '{printf \$7}'|cut -d/ -f1"
-    echo -e "${RED_PREFIX}${service_filename[$i]} Service is started,port number:$j pid:$(eval $pid)$COLOR_SUFFIX"
-  done
-done
+#!/usr/bin/env bash
+
+source ./style_info.cfg
+source ./path_info.cfg
+source ./function.sh
+
+#service filename
+service_filename=(
+  #api
+  open_im_api
+  #rpc
+  open_im_user
+  open_im_friend
+  open_im_group
+  open_im_auth
+  ${msg_name}
+)
+
+#service config port name
+service_port_name=(
+  #api port name
+  openImApiPort
+  #rpc port name
+  openImUserPort
+  openImFriendPort
+  openImGroupPort
+  openImAuthPort
+  openImOfflineMessagePort
+
+)
+
+for ((i = 0; i < ${#service_filename[*]}; i++)); do
+  #Check whether the service exists
+  service_name="ps -aux |grep -w ${service_filename[$i]} |grep -v grep"
+  count="${service_name}| wc -l"
+
+  if [ $(eval ${count}) -gt 0 ]; then
+    pid="${service_name}| awk '{print \$2}'"
+    echo -e "${SKY_BLUE_PREFIX}${service_filename[$i]} service has been started,pid:$(eval $pid)$COLOR_SUFFIX"
+    echo -e "${SKY_BLUE_PREFIX}Killing the service ${service_filename[$i]} pid:$(eval $pid)${COLOR_SUFFIX}"
+    #kill the service that existed
+    kill -9 $(eval $pid)
+    sleep 0.5
+  fi
+  cd ../bin && echo -e "${SKY_BLUE_PREFIX}${service_filename[$i]} service is starting${COLOR_SUFFIX}"
+  #Get the rpc port in the configuration file
+  portList=$(cat $config_path | grep ${service_port_name[$i]} | awk -F '[:]' '{print $NF}')
+  list_to_string ${portList}
+  #Start related rpc services based on the number of ports
+  for j in ${ports_array}; do
+    echo -e "${SKY_BLUE_PREFIX}${service_filename[$i]} Service is starting,port number:$j $COLOR_SUFFIX"
+    #Start the service in the background
+    #    ./${service_filename[$i]} -port $j &
+    nohup ./${service_filename[$i]} -port $j >>../logs/openIM.log 2>&1 &
+    sleep 1
+    pid="netstat -ntlp|grep $j |awk '{printf \$7}'|cut -d/ -f1"
+    echo -e "${RED_PREFIX}${service_filename[$i]} Service is started,port number:$j pid:$(eval $pid)$COLOR_SUFFIX"
+  done
+done
diff --git a/script/stop_all.sh b/script/stop_all.sh
index 2e1e119c1..ef7237ab5 100644
--- a/script/stop_all.sh
+++ b/script/stop_all.sh
@@ -1,19 +1,19 @@
-#!/usr/bin/env bash
-#fixme This script is to stop the service
-
-source ./style_info.cfg
-source ./path_info.cfg
-
-
-for i in ${service_names[*]}; do
-  #Check whether the service exists
-  name="ps -aux |grep -w $i |grep -v grep"
-  count="${name}| wc -l"
-  if [ $(eval ${count}) -gt 0 ]; then
-    pid="${name}| awk '{print \$2}'"
-    echo -e "${SKY_BLUE_PREFIX}Killing service:$i pid:$(eval $pid)${COLOR_SUFFIX}"
-    #kill the service that existed
-    kill -9 $(eval $pid)
-    echo -e "${SKY_BLUE_PREFIX}service:$i was killed ${COLOR_SUFFIX}"
-  fi
-done
+#!/usr/bin/env bash
+#fixme This script is to stop the service
+
+source ./style_info.cfg
+source ./path_info.cfg
+
+
+for i in ${service_names[*]}; do
+  #Check whether the service exists
+  name="ps -aux |grep -w $i |grep -v grep"
+  count="${name}| wc -l"
+  if [ $(eval ${count}) -gt 0 ]; then
+    pid="${name}| awk '{print \$2}'"
+    echo -e "${SKY_BLUE_PREFIX}Killing service:$i pid:$(eval $pid)${COLOR_SUFFIX}"
+    #kill the service that existed
+    kill -9 $(eval $pid)
+    echo -e "${SKY_BLUE_PREFIX}service:$i was killed ${COLOR_SUFFIX}"
+  fi
+done
diff --git a/script/style_info.cfg b/script/style_info.cfg
index ff28dcb88..92cc5da49 100644
--- a/script/style_info.cfg
+++ b/script/style_info.cfg
@@ -1,9 +1,9 @@
-#Shell font formatting information
-COLOR_SUFFIX="\033[0m"
-BLACK_PREFIX="\033[30m"
-RED_PREFIX="\033[31m"
-GREEN_PREFIX="\033[32m"
-YELLOW_PREFIX="\033[33m"
-BLUE_PREFIX="\033[34m"
-PURPLE_PREFIX="\033[35m"
-SKY_BLUE_PREFIX="\033[36m"
+#Shell font formatting information
+COLOR_SUFFIX="\033[0m"
+BLACK_PREFIX="\033[30m"
+RED_PREFIX="\033[31m"
+GREEN_PREFIX="\033[32m"
+YELLOW_PREFIX="\033[33m"
+BLUE_PREFIX="\033[34m"
+PURPLE_PREFIX="\033[35m"
+SKY_BLUE_PREFIX="\033[36m"