import zipkin2.codec.SpanBytesEncoder; //导入依赖的package包/类
@Test
public void flush_incrementsMetrics() {
  reporter = AsyncReporter.builder(FakeSender.create())
      .metrics(metrics)
      .messageMaxBytes(sizeInBytesOfSingleSpanMessage)
      .messageTimeout(0, TimeUnit.MILLISECONDS)
      .build();

  // Queue up 2 spans
  reporter.report(span);
  reporter.report(span);

  reporter.flush();
  assertThat(metrics.queuedSpans()).isEqualTo(1); // still one span in the backlog
  assertThat(metrics.queuedBytes()).isEqualTo(SpanBytesEncoder.JSON_V2.encode(span).length);
  assertThat(metrics.messages()).isEqualTo(1);
  assertThat(metrics.messageBytes()).isEqualTo(sizeInBytesOfSingleSpanMessage);

  reporter.flush();
  assertThat(metrics.queuedSpans()).isZero();
  assertThat(metrics.queuedBytes()).isZero();
  assertThat(metrics.messages()).isEqualTo(2);
  assertThat(metrics.messageBytes()).isEqualTo(sizeInBytesOfSingleSpanMessage * 2);
}
 

import zipkin2.codec.SpanBytesEncoder; //导入依赖的package包/类
@Bean
Reporter<Span> zipkinReporter(Sender sender) {
  if (apiVersion.compareTo(CONFIG_TRACING_COLLECTOR_API_V1) == 0){
    return AsyncReporter.builder(sender).build(SpanBytesEncoder.JSON_V1);
  }

  return AsyncReporter.builder(sender).build();
}
 

import zipkin2.codec.SpanBytesEncoder; //导入依赖的package包/类
public Tracing() {
  String endpoint = System.getProperty("zipkin.http_endpoint");
  if (endpoint == null) {
    component = new TracingComponent.Current();
    return;
  }
  AsyncReporter<zipkin2.Span> spanReporter =
      AsyncReporter.builder(URLConnectionSender.create(endpoint))
          .build(endpoint.contains("v2") ? SpanBytesEncoder.JSON_V2 : SpanBytesEncoder.JSON_V1);
  brave.Tracing tracing = brave.Tracing.newBuilder()
      .localServiceName(System.getProperty("zipkin.service_name", "cassandra"))
      .spanReporter(spanReporter).build();
  component = new TracingComponent.Explicit(tracing);
}
 

import zipkin2.codec.SpanBytesEncoder; //导入依赖的package包/类
/**
 * Creates and registers the Zipkin Trace exporter to the OpenCensus library. Only one Zipkin
 * exporter can be registered at any point.
 *
 * @param encoder Usually {@link SpanBytesEncoder#JSON_V2}
 * @param sender Often, but not necessarily an http sender. This could be Kafka or SQS.
 * @param serviceName the {@link Span#localServiceName() local service name} of the process.
 * @throws IllegalStateException if a Zipkin exporter is already registered.
 */
public static void createAndRegister(
    SpanBytesEncoder encoder, Sender sender, String serviceName) {
  synchronized (monitor) {
    checkState(handler == null, "Zipkin exporter is already registered.");
    Handler newHandler = new ZipkinExporterHandler(encoder, sender, serviceName);
    handler = newHandler;
    register(Tracing.getExportComponent().getSpanExporter(), newHandler);
  }
}
 

import zipkin2.codec.SpanBytesEncoder; //导入依赖的package包/类
/** Builds an async reporter that encodes zipkin spans as they are reported. */
public AsyncReporter<Span> build() {
  switch (sender.encoding()) {
    case JSON:
      return build(SpanBytesEncoder.JSON_V2);
    default:
      throw new UnsupportedOperationException(sender.encoding().name());
  }
}
 

import zipkin2.codec.SpanBytesEncoder; //导入依赖的package包/类
static FakeSender create() {
  return new AutoValue_FakeSender(
      Encoding.JSON,
      Integer.MAX_VALUE,
      BytesMessageEncoder.forEncoding(Encoding.JSON),
      SpanBytesEncoder.JSON_V2,
      SpanBytesDecoder.JSON_V2,
      spans -> {
      }
  );
}
 

import zipkin2.codec.SpanBytesEncoder; //导入依赖的package包/类
@Test
public void report_incrementsMetrics() {
  reporter = AsyncReporter.builder(FakeSender.create())
      .metrics(metrics)
      .messageTimeout(0, TimeUnit.MILLISECONDS)
      .build();

  reporter.report(span);
  reporter.report(span);
  assertThat(metrics.spans()).isEqualTo(2);
  assertThat(metrics.spanBytes()).isEqualTo(SpanBytesEncoder.JSON_V2.encode(span).length * 2);
}
 

import zipkin2.codec.SpanBytesEncoder; //导入依赖的package包/类
@Test public void encoder() {
  context = new XmlBeans(""
      + "<bean id=\"asyncReporter\" class=\"zipkin2.reporter.beans.AsyncReporterFactoryBean\">\n"
      + "  <property name=\"sender\">\n"
      + "    <util:constant static-field=\"" + getClass().getName() + ".SENDER\"/>\n"
      + "  </property>\n"
      + "  <property name=\"encoder\" value=\"JSON_V2\"/>\n"
      + "</bean>"
  );

  assertThat(context.getBean("asyncReporter", AsyncReporter.class))
      .extracting("encoder")
      .containsExactly(SpanBytesEncoder.JSON_V2);
}
 

import zipkin2.codec.SpanBytesEncoder; //导入依赖的package包/类
static EventData json2MessageWithThreeSpans(String offset, long sequenceNumber) throws Exception {
  List<Span> spans = IntStream.range(0, 3).mapToObj(i -> TestObjects.LOTS_OF_SPANS[i])
      .flatMap(s -> V2SpanConverter.fromSpan(s).stream())
      .collect(Collectors.toList());
  return message(offset, sequenceNumber, SpanBytesEncoder.JSON_V2.encodeList(spans));
}
 

import zipkin2.codec.SpanBytesEncoder; //导入依赖的package包/类
Call<Void> send(zipkin2.Span... spans) {
  return sender.sendSpans(Stream.of(spans)
      .map(SpanBytesEncoder.JSON_V2::encode)
      .collect(toList()));
}
 

import zipkin2.codec.SpanBytesEncoder; //导入依赖的package包/类
Call<Void> send(Span... spans) {
  return sender.sendSpans(Stream.of(spans)
      .map(SpanBytesEncoder.JSON_V2::encode)
      .collect(toList()));
}
 

import zipkin2.codec.SpanBytesEncoder; //导入依赖的package包/类
ZipkinExporterHandler(SpanBytesEncoder encoder, Sender sender, String serviceName) {
  this.encoder = encoder;
  this.sender = sender;
  this.localEndpoint = produceLocalEndpoint(serviceName);
}
 

import zipkin2.codec.SpanBytesEncoder; //导入依赖的package包/类
/** Blocks until the callback completes to allow read-your-writes consistency during tests. */
Call<Void> send(Span... spans) {
  return sender.sendSpans(Stream.of(spans)
      .map(SpanBytesEncoder.JSON_V2::encode)
      .collect(toList()));
}
 

import zipkin2.codec.SpanBytesEncoder; //导入依赖的package包/类
public void setEncoder(SpanBytesEncoder encoder) {
  this.encoder = encoder;
}
 

import zipkin2.codec.SpanBytesEncoder; //导入依赖的package包/类
public SpanBytesEncoder getEncoder() {
	return this.encoder;
}
 

import zipkin2.codec.SpanBytesEncoder; //导入依赖的package包/类
public void setEncoder(SpanBytesEncoder encoder) {
	this.encoder = encoder;
}