TRKJ/EdgeNode
2
0
Fork 0
mirror of https://github.com/TeaOSLab/EdgeNode.git synced 2025-12-11 21:00:25 +08:00
Code Issues Packages Projects Releases Wiki Activity

修复访问日志requestId可能重复的问题

Browse Source
This commit is contained in:
刘祥超
2021-11-21 10:40:19 +08:00
parent ac069fd7f3
commit 012233baf2
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
internal/nodes/http_access_log_queue.go
View File

@@ -4,6 +4,7 @@ import (
"github.com/TeaOSLab/EdgeCommon/pkg/rpc/pb" "github.com/TeaOSLab/EdgeCommon/pkg/rpc/pb"
"github.com/TeaOSLab/EdgeNode/internal/remotelogs" "github.com/TeaOSLab/EdgeNode/internal/remotelogs"
"github.com/TeaOSLab/EdgeNode/internal/rpc" "github.com/TeaOSLab/EdgeNode/internal/rpc"
"github.com/TeaOSLab/EdgeNode/internal/utils"
"strconv" "strconv"
"time" "time"
) )
@@ -59,15 +60,16 @@ Loop:
for { for {
select { select {
case accessLog := <-this.queue: case accessLog := <-this.queue:
if accessLog.Timestamp > timestamp { var unixTime = utils.UnixTime()
requestId = 10_000_000 if unixTime > timestamp {
timestamp = accessLog.Timestamp requestId = 1_000_000
timestamp = unixTime
} else { } else {
requestId++ requestId++
} }
// timestamp + requestId + nodeId // timestamp + requestId + nodeId
accessLog.RequestId = strconv.FormatInt(accessLog.Timestamp, 10) + strconv.Itoa(requestId) + strconv.FormatInt(accessLog.NodeId, 10) accessLog.RequestId = strconv.FormatInt(unixTime, 10) + strconv.Itoa(requestId) + strconv.FormatInt(accessLog.NodeId, 10)
accessLogs = append(accessLogs, accessLog) accessLogs = append(accessLogs, accessLog)
count++ count++