调整：移除routine依赖，改用asyncLocal类型

global.go

@@ -1,19 +1,9 @@
 package linkTrace
 
 import (
+	"github.com/farseer-go/fs/asyncLocal"
 	"github.com/farseer-go/fs/trace"
-	"github.com/timandy/routine"
 )
 
 // CurTraceContext 当前请求的Trace上下文
-var curTraceContext = routine.NewInheritableThreadLocal[trace.ITraceContext]()
-
-// getCurTrace 获取当前TrackContext
-func getCurTrace() trace.ITraceContext {
-	return curTraceContext.Get()
-}
-
-// setCurTrace 设置当前TrackContext
-func setCurTrace(context trace.ITraceContext) {
-	curTraceContext.Set(context)
-}
+var curTraceContext = asyncLocal.New[trace.ITraceContext]()

go.mod

@@ -8,12 +8,12 @@ require (
 	github.com/farseer-go/fs v0.8.0
 	github.com/farseer-go/mapper v0.8.0
 	github.com/farseer-go/queue v0.8.0
-	github.com/timandy/routine v1.1.1
 )
 
 require (
 	github.com/devfeel/mapper v0.7.13 // indirect
 	github.com/eiannone/keyboard v0.0.0-20220611211555-0d226195f203 // indirect
+	github.com/farseer-go/utils v0.8.0 // indirect
 	github.com/josharian/intern v1.0.0 // indirect
 	github.com/mailru/easyjson v0.7.7 // indirect
 	github.com/olivere/elastic/v7 v7.0.32 // indirect

module.go

@@ -23,7 +23,7 @@ func (module Module) PreInitialize() {
 	defConfig = configure.ParseConfig[config]("LinkTrace")
 	// 使用了链路追踪组件，则要把空组件移除后，重新注册
 	container.Remove[trace.IManager]()
-	container.Register[trace.IManager](func() trace.IManager {
+	container.Register(func() trace.IManager {
 		return &traceManager{}
 	})
 }

traceManager.go

@@ -15,7 +15,7 @@ type traceManager struct {
 }
 
 func (*traceManager) GetCurTrace() trace.ITraceContext {
-	return getCurTrace()
+	return curTraceContext.Get()
 }
 
 // TraceWebApi Webapi入口
@@ -42,7 +42,7 @@ func (*traceManager) TraceWebApi(domain string, path string, method string, cont
 		List:          collections.NewList[trace.ITraceDetail](),
 		//ExceptionDetail: ExceptionDetail{},
 	}
-	setCurTrace(context)
+	curTraceContext.Set(context)
 	return context
 }
 
@@ -152,7 +152,7 @@ func newTraceDetail(callType eumCallType.Enum, callMethod string) trace.BaseTrac
 }
 
 func add(traceDetail trace.ITraceDetail) {
-	if t := getCurTrace(); t != nil && defConfig.Enable {
+	if t := curTraceContext.Get(); t != nil && defConfig.Enable {
 		detail := traceDetail.GetTraceDetail()
 		// 时间轴：上下文入口起点时间到本次开始时间
 		detail.Timeline = time.Duration(detail.StartTs-t.GetStartTs()) * time.Microsecond

update.sh

@@ -1,3 +1,6 @@
 go get github.com/farseer-go/collections
+go get github.com/farseer-go/elasticSearch
 go get github.com/farseer-go/fs
-go get github.com/farseer-go/utils
+go get github.com/farseer-go/mapper
+go get github.com/farseer-go/queue
+go get github.com/farseer-go/utils