0
私のアプリケーションは、spring-rabbitmqベースのアプリケーション（spring-cloudもspring-bootもない）で、1つのキューから要求を受け取り、別のキューに応答を送りました。brave（java）でrabbitmqアプリケーションのcurrentSpanを取得するには？
私はメッセージを送信する前にZipkinヘッダーを注入し、メッセージを受信した直後にZipkinヘッダーを抽出することで、システムをトレースするために勇敢に使用したいと考えています。
問題は次のシナリオのステップ3では、メッセージを送信する前にどのようにしてspan1を取得できますか？
シナリオ：メッセージを送信する前に
step1, app -> mq (new created span1, root span, client)
step2, mq -> app (receive span1, server)
step3, app -> mq (**new created span2, child span of span1, client**)
step4, mq -> app (receive span2, server)
コードスニペット：上記のコード、Span currentSpan = tracer.currentSpan();で
try{
Span currentSpan = tracer.currentSpan();
Span newSpan = null;
if(currentSpan == null){
newSpan = tracer.newTrace();
}else{
newSpan = tracer.newChild(currentSpan.context());
}
Map<String, String> strHeaders = new HashMap<String, String>();
tracing.propagation().injector(Map<String, String>::put).inject(newSpan.context(),strHeaders);
messageProperties.setHeader("zipkin.brave.tracing.headers", strHeaders);
newSpan.name("send").kind(Kind.CLIENT).start().flush();
}catch(Exception e){
logger.warn("zipkin problem", e);
}
、currentSpanは常にヌルあります。メッセージを受信した後
コードスニペット：
try{
Map<String, Object> msgHeaders = messageProperties.getHeaders();
Object headersObj = msgHeaders.get("zipkin.brave.tracing.headers");
Map<String, String> strHeaders = null;
if(headersObj != null){
strHeaders = (HashMap<String, String>)headersObj;
}
TraceContextOrSamplingFlags result = tracing.propagation().extractor(Map<String, String>::get).extract(strHeaders);
if(result.context() != null){
Span clientSpan = tracer.joinSpan(result.context());
clientSpan.name("receive").kind(Kind.SERVER).start().flush();
}
}catch(Exception e){
logger.warn("zipkin problem", e);
}
ブレイブ構成コード：後
@Configuration
public class BraveSpringConfiguration {
private static final Logger logger = LoggerFactory.getLogger(BraveSpringConfiguration.class);
/** Configuration for how to send spans to Zipkin */
@Bean
public Sender sender() {
logger.debug("okhttpsender");
return OkHttpSender.create("http://127.0.0.1:9411/api/v1/spans");
}
/** Configuration for how to buffer spans into messages for Zipkin */
@Bean
public Reporter<Span> reporter() {
logger.debug("asyncreporter");
return AsyncReporter.builder(sender()).build();
}
/** Controls aspects of tracing such as the name that shows up in the UI */
@Bean
public Tracing tracing() {
logger.debug("one tracing");
return Tracing.newBuilder()
.localServiceName("spring-rabbitmq-brave")
//// log4j2, import brave.context.log4j2.ThreadContextCurrentTraceContext;
//.currentTraceContext(ThreadContextCurrentTraceContext.create()) // puts trace IDs into logs
.currentTraceContext(MDCCurrentTraceContext.create()) // puts trace IDs into logs
.sampler(Sampler.ALWAYS_SAMPLE) // always sampler
.reporter(reporter())
.build();
}
/** Controls aspects of tracing such as the name that shows up in the UI */
@Bean
public Tracer tracer() {
logger.debug("one tracer");
return tracing().tracer();
}
}
は私の参照です：
https://github.com/openzipkin/brave/tree/master/brave#one-way-tracing
- https://github.com/openzipkin/brave/blob/master/brave/src/test/java/brave/features/async/OneWaySpanTest.java
https://gist.github.com/adriancole/76d94054b77e3be338bd75424ca8ba30