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)

  • 发表于:
  • 原文链接https://kuaibao.qq.com/s/20181011A05SJ500?refer=cp_1026
  • 腾讯「云+社区」是腾讯内容开放平台帐号(企鹅号)传播渠道之一,根据《腾讯内容开放平台服务协议》转载发布内容。
  • 如有侵权,请联系 yunjia_community@tencent.com 删除。

扫码关注云+社区

领取腾讯云代金券