springboot集成zipkin

Love The Way You Lie 2021-12-12 13:27 263阅读 0赞

## 一：下载zipkin ##

Docker:

docker run -d -p 9411:9411 openzipkin/zipkin

linux

wget -O zipkin.jar 'https://search.maven.org/remote\_content?g=io.zipkin.java&a=zipkin-server&v=LATEST&c=exec'

linux:

访问测试

localhost:9411

### 二：spring配置文件集成 ###

1.导入jar包

在pom文件中添加：

<dependency>
        <groupId>io.zipkin.brave</groupId>
        <artifactId>brave-core</artifactId>
        <version>3.10.0</version>
    </dependency>
    <dependency>
        <groupId>io.zipkin.brave</groupId>
        <artifactId>brave-spancollector-http</artifactId>
        <version>3.10.0</version>
    </dependency>
    <dependency>
        <groupId>io.zipkin.brave</groupId>
        <artifactId>brave-web-servlet-filter</artifactId>
        <version>3.10.0</version>
    </dependency>
    <dependency>
        <groupId>io.zipkin.brave</groupId>
        <artifactId>brave-okhttp</artifactId>
        <version>3.10.0</version>
    </dependency>

2.在配置文件中书写参数

##########请求的项目名##########
    server.servlet.context-path=/
    
    
    ##########zipKin################
    zipkin.serviceName=bbscontent
    zipkin.url=http://47.93.136.21:9411
    zipkin.connectTimeout=6000
    zipkin.readTimeout=6000
    zipkin.flushInterval=1
    zipkin.compressionEnabled=true

3.添加配置类

package com.jfbank.discuz.config;
    
    import com.github.kristofa.brave.Brave;
    import com.github.kristofa.brave.EmptySpanCollectorMetricsHandler;
    import com.github.kristofa.brave.Sampler;
    import com.github.kristofa.brave.SpanCollector;
    import com.github.kristofa.brave.http.DefaultSpanNameProvider;
    import static com.github.kristofa.brave.Brave.Builder;
    import static com.github.kristofa.brave.http.HttpSpanCollector.create;
    
    import com.github.kristofa.brave.http.HttpSpanCollector;
    import com.github.kristofa.brave.okhttp.BraveOkHttpRequestResponseInterceptor;
    import com.github.kristofa.brave.servlet.BraveServletFilter;
    import okhttp3.OkHttpClient;
    
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.boot.context.properties.ConfigurationProperties;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    /**
     *@program: content
     *@description:
     *@author: zhihua
     *@create: 2019-07-11 11:41
     */
    
    
    @Configuration
    public class ZipkinConfig {
    
        /**
         * 服务名称
         */
        @Value("${zipkin.serviceName}")
        private String serviceName;
    
        /**
         * zipkin地址
         */
        @Value("${zipkin.url}")
        private String url;
    
        /**
         * 连接时间
         */
        @Value("${zipkin.connectTimeout}")
        private int connectTimeout;
    
        /**
         * 读取时间
         */
        @Value("${zipkin.readTimeout}")
        private int readTimeout;
    
        /**
         * 每间隔多少秒执行一次Span信息上传
         */
        @Value("${zipkin.flushInterval}")
        private int flushInterval;
    
        /**
         * 是否启动压缩
         */
        @Value("${zipkin.compressionEnabled}")
        private boolean compressionEnabled;
    
        public String getServiceName() {
            return serviceName;
        }
    
        public void setServiceName(String serviceName) {
            this.serviceName = serviceName;
        }
    
        public String getUrl() {
            return url;
        }
    
        public void setUrl(String url) {
            this.url = url;
        }
    
        public int getConnectTimeout() {
            return connectTimeout;
        }
    
        public void setConnectTimeout(int connectTimeout) {
            this.connectTimeout = connectTimeout;
        }
    
        public int getReadTimeout() {
            return readTimeout;
        }
    
        public void setReadTimeout(int readTimeout) {
            this.readTimeout = readTimeout;
        }
    
        public int getFlushInterval() {
            return flushInterval;
        }
    
        public void setFlushInterval(int flushInterval) {
            this.flushInterval = flushInterval;
        }
    
        public boolean isCompressionEnabled() {
            return compressionEnabled;
        }
    
        public void setCompressionEnabled(boolean compressionEnabled) {
            this.compressionEnabled = compressionEnabled;
        }
    
        /**
         * @Description: span（一次请求信息或者一次链路调用）信息收集器
         * @Param:
         * @return: SpanCollector 控制器
         * @Author: zhihua
         * @Date: 2019-07-11 11:41
         */
        @Bean
        public SpanCollector spanCollector() {
            HttpSpanCollector.Config config = HttpSpanCollector.Config.builder()
                    // 默认false，span在transport之前是否会被gzipped
                    .compressionEnabled(compressionEnabled)
                    .connectTimeout(connectTimeout)
                    .flushInterval(flushInterval)
                    .readTimeout(readTimeout)
                    .build();
            return create(url, config, new EmptySpanCollectorMetricsHandler());
        }
    
        /**
         * @Description: 作为各调用链路，只需要负责将指定格式的数据发送给zipkin
         * @Param:
         * @return:
         * @Author: r
         * @Date: 2019-07-11 11:41
         */
        @Bean
        public Brave brave(SpanCollector spanCollector) {
            //调用服务的名称
            Builder builder = new Builder(serviceName);
            builder.spanCollector(spanCollector);
            //采集率
            builder.traceSampler(Sampler.ALWAYS_SAMPLE);
            return builder.build();
        }
    
    
        /**
         * @Description: 设置server的（服务端收到请求和服务端完成处理，并将结果发送给客户端）过滤器
         * @Param:
         * @return: 过滤器
         * @Author: zhihua
         * @Date: 2019-07-11 11:41
         */
        @Bean
        public BraveServletFilter braveServletFilter(Brave brave) {
            BraveServletFilter filter = new BraveServletFilter(brave.serverRequestInterceptor(),
                    brave.serverResponseInterceptor(), new DefaultSpanNameProvider());
            return filter;
        }
    
        /**
         * @Description: 设置client的（发起请求和获取到服务端返回信息）拦截器
         * @Param:
         * @return: OkHttpClient 返回请求实例
         * @Author: zhihua
         * @Date: 2019-07-11 11:41
         */
        @Bean
        public OkHttpClient okHttpClient(Brave brave) {
            OkHttpClient httpClient = new OkHttpClient.Builder()
                    .addInterceptor(new BraveOkHttpRequestResponseInterceptor(
                            brave.clientRequestInterceptor(),
                            brave.clientResponseInterceptor(),
                            new DefaultSpanNameProvider())).build();
            return httpClient;
        }
    }

zipkinUI展示

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZmemhpaHVh_size_16_color_FFFFFF_t_70][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZmemhpaHVh_size_16_color_FFFFFF_t_70]: /images/20211211/8778c59cb7f3458b9c38e7095f781365.png