1

server/gamesapi/middleware/caforward.go

@@ -26,6 +26,8 @@ func CaForward(c *gin.Context) {
 		return
 	}
 
+	cLock := service.SApiForward.AcquireLock(accountId)
+	defer service.SApiForward.ReleaseLock(cLock)
 	service.SApiForward.IncTotalTimes()
 	beginTick := q5.GetTickCount()
 	defer func() {

server/gamesapi/service/sapi_forward.go

@@ -90,12 +90,13 @@ func (this *sApiForward) UpdateCostTime(costTime int64) {
 
 func (this *sApiForward) getOrCreate(c *SApiForwardLockCache, accountId string) *SApiForwardLock {
 	c.lock.Lock()
-	defer c.lock.Lock()
+	defer c.lock.Unlock()
 	if u, ok := (*c.userHash)[accountId]; ok {
 		return u
 	} else {
 		u = new(SApiForwardLock)
 		u.accountId = accountId
+		u.lock = new(sync.Mutex)
 		return u
 	}
 }

server/gamesapi/service/servicemgr.go

@@ -4,9 +4,10 @@ type serviceMgr struct {
 }
 
 func (this *serviceMgr) Init() {
-
+	SApiForward = new(sApiForward)
+	SApiForward.init()
 }
 
 func (this *serviceMgr) UnInit() {
-
+	SApiForward.unInit()
 }