新增：队列增加休眠时间

module.go

@@ -7,6 +7,7 @@ import (
 	"github.com/farseer-go/fs/trace"
 	"github.com/farseer-go/queue"
 	"strings"
+	"time"
 )
 
 // Enable 是否启用
@@ -37,6 +38,6 @@ func (module Module) PreInitialize() {
 		if !strings.HasSuffix(FopsServer, "/") {
 			FopsServer += "/"
 		}
-		queue.Subscribe("TraceContext", "SaveTraceContext", 1000, SaveTraceContextConsumer)
+		queue.Subscribe("TraceContext", "SaveTraceContext", 1000,5*time.Second, SaveTraceContextConsumer)
 	}
 }

saveTraceContextConsumer.go

@@ -12,16 +12,13 @@ import (
 	"github.com/farseer-go/fs/parse"
 	"github.com/farseer-go/fs/trace"
 	"net/http"
-	"time"
 )
 
 // FopsServer fops地址
 var FopsServer string
 
 // SaveTraceContextConsumer 上传链路记录到FOPS中心
 func SaveTraceContextConsumer(subscribeName string, lstMessage collections.ListAny, remainingCount int) {
-	// 控制3秒执行一次
-	<-time.After(3 * time.Second)
 	if traceContext := trace.CurTraceContext.Get(); traceContext != nil {
 		traceContext.Ignore()
 	}