使用 Zipkin 实现链路追踪

Docker

docker-compose.yml

services:
  elasticsearch:
    image: openzipkin/zipkin-elasticsearch7
    container_name: elasticsearch
    ports:
      - 9200:9200
  zipkin:
    image: openzipkin/zipkin-slim
    container_name: zipkin
    environment:
      - STORAGE_TYPE=elasticsearch
      - ES_HOSTS=elasticsearch
      - JAVA_OPTS=-Xms4g -Xmx4g -XX:+ExitOnOutOfMemoryError
    ports:
      - 9411:9411
    depends_on:
      - elasticsearch
  dependencies:
    image: openzipkin/zipkin-dependencies
    container_name: dependencies
    entrypoint: crond -f
    environment:
      - STORAGE_TYPE=elasticsearch
      - ES_HOSTS=elasticsearch
      - JAVA_OPTS=-Xms4g -Xmx4g -XX:+ExitOnOutOfMemoryError
    depends_on:
      - elasticsearch

Dubbo

引入依赖

<dependency>
	<groupId>io.zipkin.brave</groupId>
	<artifactId>brave-instrumentation-dubbo</artifactId>
	<version>5.13.9</version>
</dependency>
<dependency>
	<groupId>io.zipkin.reporter2</groupId>
	<artifactId>zipkin-sender-okhttp3</artifactId>
	<version>2.16.3</version>
</dependency>

编写配置

@Configuration
@ConditionalOnProperty("zipkin.base-url")
public class ZipkinConfig
{
    @Value("${spring.application.name:${dubbo.application.name:default}}")
    private String localServiceName;

    @Value("${zipkin.base-url:http://localhost:9411}/api/v2/spans")
    private String endpoint;

    @Bean
    public Tracing tracing()
    {
        return Tracing.newBuilder().localServiceName(localServiceName)
                .addSpanHandler(AsyncZipkinSpanHandler.create(OkHttpSender.create(endpoint))).build();
    }
}

Web

引入依赖

<dependency>
	<groupId>io.zipkin.brave</groupId>
	<artifactId>brave-instrumentation-spring-webmvc</artifactId>
	<version>5.13.9</version>
</dependency>
<dependency>
	<groupId>io.zipkin.reporter2</groupId>
	<artifactId>zipkin-sender-okhttp3</artifactId>
	<version>2.16.3</version>
</dependency>

编写配置

@Configuration
@ConditionalOnProperty("zipkin.base-url")
@Import({DelegatingTracingFilter.class, SpanCustomizingAsyncHandlerInterceptor.class})
public class WebZipkinConfig implements WebMvcConfigurer
{
    @Resource
    private SpanCustomizingAsyncHandlerInterceptor interceptor;

    @Resource
    private Tracing tracing;

    @Override
    public void addInterceptors(InterceptorRegistry registry)
    {
        registry.addInterceptor(interceptor);
    }

    @Bean
    public HttpTracing httpTracing()
    {
        return HttpTracing.create(tracing);
    }
}