dubbo＋zipkin调用链监控

收集器抽象。

因为Zipkin同时支持http和Kafka报告，所以需要配置抽象。

摘要Zipkin收集器-配置。

主要针对下面两种集合的一些配置定义，核心是发件人接口的定义，Http和Kafka是两个完全不同的实现。

公共抽象发件人getSender()；

第二个是有用的构造函数，用于匹配构建收集器所需的一些参数。

齐普金厄尔。

如果它是一个http集合，那么它对应于Zipkin API域名；如果它是Kafka，它对应于Kafka集群的地址。

主题。

仅当收集模式为Kafka有效而http有效时，才传递空值。

公共抽象-ZipkinCollection-配置(StringserviceName，StringzipkinUrl，StringTopic)。，。

配置报告模式，其中统一使用异常上传，并配置超时报告。

受保护的AsyncReportspanReport()。

下面两个方法是与应用程序构建范围结合使用的。

注意sampler()方法，默认情况下它没有任何意义，要查看数据，我们需要将其配置为Sampler.ALWAYS_SAMPLE，以便实际向Zipkin服务器报告数据。

受保护的跟踪()受保护的跟踪getTracking()。

配置。

主要是为了实现getSender方法，您可以借用这个对象OkHttpSender来快速构建使用v2的API版本。

Publicclass HttpZipkinCollection torConfigurationConfiguration@覆盖public Sender getSender()。(？。

OkHttpSender类需要引用包。

2zipkin-发送者-okhttp 3$。

卡夫卡-齐普金收集器-配置。

还实现了getSender方法。

公共类KafkaZipkinCollection-Configuration扩展抽象-ZipkinCollection-Configuration@覆盖public Sender getSender(){返回KafkaSender。NewBuilder()。BootstrapServers(Super.getZipkinUrl()。主题(超级.get)