今天就跟大家聊聊有關(guān)什么是spring-cloud-sleuth+zipkin源碼，可能很多人都不太了解，為了讓大家更加了解，小編給大家總結(jié)了以下內(nèi)容，希望大家根據(jù)這篇文章可以有所收獲。

創(chuàng)新互聯(lián)建站是一家專業(yè)提供南安企業(yè)網(wǎng)站建設(shè),專注與做網(wǎng)站、成都做網(wǎng)站、H5建站、小程序制作等業(yè)務(wù)。10年已為南安眾多企業(yè)、政府機(jī)構(gòu)等服務(wù)。創(chuàng)新互聯(lián)專業(yè)網(wǎng)站設(shè)計公司優(yōu)惠進(jìn)行中。

1.1. 前言

??粗略看了下spring cloud sleuth core源碼，發(fā)現(xiàn)內(nèi)容真的有點多，它支持了很多類型的鏈路追蹤，我就找其中一個比較有代表性的深入剖析下源碼結(jié)構(gòu)和內(nèi)容

1.2. spring-cloud-sleuth-core源碼解析

1.2.1. 結(jié)構(gòu)

1. 可以看到源碼中支持的追蹤類型有很多，支持async，hystrix，websocket，rxjava，Spring mvc，servlet，spring restTemplate，feign，zuul等等，這里我著重探討spring web mvc的鏈路追蹤

2. 打開web包，找到TraceWebAutoConfiguration，這里配置了主要的初始化類
   

1.2.2. 過濾器注冊

1. 當(dāng)啟動初始化程序時，跟蹤代碼如下

    @Bean
    public FilterRegistrationBean traceWebFilter(TraceFilter traceFilter) {
        FilterRegistrationBean filterRegistrationBean = new FilterRegistrationBean(
                traceFilter);
        filterRegistrationBean.setDispatcherTypes(ASYNC, ERROR, FORWARD, INCLUDE,
                REQUEST);
        filterRegistrationBean.setOrder(TraceFilter.ORDER);
        return filterRegistrationBean;
    }

    @Bean
    @ConditionalOnMissingBean
    public TraceFilter traceFilter(BeanFactory beanFactory,
            SkipPatternProvider skipPatternProvider) {
        return new TraceFilter(beanFactory, skipPatternProvider.skipPattern());
    }

1. 初始化traceFilter，進(jìn)行過濾器注冊

1.2.3. 攔截器注冊

1. 然后看TraceWebMvcConfigurer類，它會進(jìn)行攔截器的注冊

@Configuration
class TraceWebMvcConfigurer extends WebMvcConfigurerAdapter {
    @Autowired BeanFactory beanFactory;

    @Bean
    public TraceHandlerInterceptor traceHandlerInterceptor(BeanFactory beanFactory) {
        return new TraceHandlerInterceptor(beanFactory);
    }

    @Override
    public void addInterceptors(InterceptorRegistry registry) {
        registry.addInterceptor(this.beanFactory.getBean(TraceHandlerInterceptor.class));
    }
}

1. 在TraceHandlerInterceptor類中，preHandle,afterCompletion方法可以看出，這是對請求進(jìn)行攔截進(jìn)行span的包裝

    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response,
            Object handler) throws Exception {
        String spanName = spanName(handler);
        boolean continueSpan = getRootSpanFromAttribute(request) != null;
        Span span = continueSpan ? getRootSpanFromAttribute(request) : getTracer().createSpan(spanName);
        if (log.isDebugEnabled()) {
            log.debug("Handling span ">

    @Override
    public void afterCompletion(HttpServletRequest request, HttpServletResponse response,
            Object handler, Exception ex) throws Exception {
        if (isErrorControllerRelated(request)) {
            if (log.isDebugEnabled()) {
                log.debug("Skipping closing of a span for error controller processing");
            }
            return;
        }
        Span span = getRootSpanFromAttribute(request);
        if (ex != null) {
            getErrorParser().parseErrorTags(span, ex);
        }
        if (getNewSpanFromAttribute(request) != null) {
            if (log.isDebugEnabled()) {
                log.debug("Closing span " + span);
            }
            Span newSpan = getNewSpanFromAttribute(request);
            getTracer().continueSpan(newSpan);
            getTracer().close(newSpan);
            clearNewSpanCreatedAttribute(request);
        }
    }

1.2.4. zipkin端點提交

1. 這里首先會初始化HttpZipkinSpanReporter類，，用來進(jìn)行span端點提交，然后初始化ZipkinSpanListenerspan的監(jiān)聽器，用來監(jiān)聽并調(diào)用端點提交，以上配置再下圖位置
   

1.2.5. 調(diào)用http接口時，進(jìn)入過濾器

1. 首先進(jìn)入TraceFilter中的過濾方法doFilter，這里會做span的創(chuàng)建

private Span createSpan(HttpServletRequest request,
            boolean skip, Span spanFromRequest, String name) {
        if (spanFromRequest != null) {
            if (log.isDebugEnabled()) {
                log.debug("Span has already been created - continuing with the previous one");
            }
            return spanFromRequest;
        }
        //加入調(diào)用鏈路ZipkinHttpSpanExtractor，此鏈路在TraceHttpAutoConfiguration中配置實例化，調(diào)用鏈還沒有時，返回為空，作為頭節(jié)點
        Span parent = spanExtractor().joinTrace(new HttpServletRequestTextMap(request));
        if (parent != null) {
            if (log.isDebugEnabled()) {
                log.debug("Found a parent span ">

1.2.6. 進(jìn)入攔截器

1. 在preHandle方法中，對span進(jìn)行包裝，然后把span放入請求頭header中

2. 最后再DefaultTracer中進(jìn)行span的關(guān)閉和spanReporter的提交

看完上述內(nèi)容，你們對什么是spring-cloud-sleuth+zipkin源碼有進(jìn)一步的了解嗎？如果還想了解更多知識或者相關(guān)內(nèi)容，請關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝大家的支持。

分享標(biāo)題：什么是spring-cloud-sleuth+zipkin源碼
標(biāo)題鏈接：http://www.rwnh.cn/article34/pgsgpe.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供微信小程序、關(guān)鍵詞優(yōu)化、商城網(wǎng)站、手機(jī)網(wǎng)站建設(shè)、網(wǎng)頁設(shè)計公司、服務(wù)器托管

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)