Spring Cloud 异步流程traceId和spanId为空,如EventBus或MQ等异步操作的traceId和spanId为空,需要手动生成traceId和spanId
@Slf4j
public abstract class MyJob implements SimpleJob {
@Override
public final void execute(ShardingContext shardingContext) {
log.info(String.format("任务总片数: %s, 当前分片项: %s, 分片参数: %s", shardingContext.getShardingTotalCount(),
shardingContext.getShardingItem(), shardingContext.getShardingParameter()));
TraceHelper.newTrace();
}
}
@Slf4j
@Component
public class TraceHelper {
private static Tracer tracer;
private static Environment env;
@Autowired
public void setTracer(Tracer tracer) {
TraceHelper.tracer = tracer;
}
@Autowired
public void setEnv(Environment env) {
TraceHelper.env = env;
}
public static void newTrace() {
tracer.startScopedSpanWithParent(getApplicationName(), tracer.newTrace().context());
}
private static boolean isNumber(String str) {
return str.matches("-?\\d+");
}
private static String getApplicationName() {
return env.getProperty("spring.application.name", "");
}
public static long getTraceId() {
return tracer.currentSpan().context().traceId();
}
public static long getSpanId() {
return tracer.currentSpan().context().spanId();
}
public static long getParentId() {
return tracer.currentSpan().context().parentId();
}
public static boolean getSampled() {
return tracer.currentSpan().context().sampled();
}
public static String getTraceIdString() {
return tracer.currentSpan().context().traceIdString();
}
public static String getSpanIdString() {
return tracer.currentSpan().context().spanIdString();
}
}




