[系列] go-gin-api 路由中间件 - Jaeger 链路追踪(六)

本文来源:http://www.sss088.com/www_autohome_com_cn/

太阳城申博官网登入,  在今年的“618”促销期间,网易考拉海购公开的补贴规模在亿元级,与竞品的对标商品相比,平均拥有价格优势。时间:2016-10-0314:06:52来源:贵阳网-贵阳晚报根据《国务院关于印发注册资本登记制度改革方案的通知》(国发〔2014〕7号)及《市人民政府办公厅关于印发贵阳市注册登记全过程电子试点工作方案的通知》(筑府办函〔2016〕136号)关于“推行电子营业执照和全程电子化登记管理”的部署安排,我市将在今年年底正式实施企业注册登记全程电子化工作。  不管怎么样,富士康周三披露称,该公司正在就展现其拓展当前美国运营业务的可能投资事宜进行初步磋商。2016-09-1809:38  继去年《剑网3》在珠海进行了六周年大型宣传后。

蛋糕越大,竞争越激烈,违规就会越多。所以空间祖巫排名实力第二。用自己的努力、专业和成功,赢得客户的信任,这是我们每个服务提供方应该努力的方向,也是我们在市场上活下去的机会。还魂丹不仅给了我们挑战BOSS的二次机会,还节约了玩游戏的时间,所以还魂丹应该存在。

UCloud凭借自身在人员配备、技术实力、产品性能、资源储备等方面的突出表现获得认证。新华社发(邹峥摄)  10月13日,在加拿大多伦多动物园举行的龙凤胎熊猫宝宝周岁庆祝活动中,工作人员与特制的生日蛋糕合影。时间:2016-12-0809:12:19来源:中国新闻网据外媒报道,印度尼西亚苏门答腊岛北部亚齐省(Aech)外海当地时间7日发生6.5级强震。  若回归互联网生态发展,有几点值得细细品味:  当互联网人口红利结束,一切回归用户体验  互联网内容生态的用户体验核心即为内容,在消费升级的背景下,用户是乐意为喜欢的内容付费的,无论乐视也好、腾讯也好、还是芒果TV也好,会员制度已经被越来越多人接受。

目录

概述

首先同步下项目概况:

上篇文章分享了,路由中间件 - Jaeger 链路追踪(理论篇),这篇文章咱们接着分享:路由中间件 - Jaeger 链路追踪(实战篇)。

这篇文章,确实让大家久等了,主要是里面有一些技术点都是刚刚研究的,没有存货。

先看下咱们要实现的东西:

API 调用了 5 个服务,其中 4 个 gRPC 服务,1 个 HTTP 服务,服务与服务之间又相互调用:

  • Speak 服务,又调用了 Listen 服务 和 Sing 服务。
  • Read 服务,又调用了 Listen 服务 和 Sing 服务。
  • Write 服务,又调用了 Listen 服务 和 Sing 服务。

咱们要实现的就是查看 API 调用的链路。

关于一些理论的东西,大家可以去看看上篇文章或查阅一些资料,这篇文章就是实现怎么用。

OK,开整。

Jaeger 部署

咱们使用 All in one 的方式,进行本地部署。

下载地址:/www_jaegertracing_io/download/

我的电脑是 macOS 选择 -> Binaries -> macOS

下载后并解压,会发现以下文件:

  • example-hotrod
  • jaeger-agent
  • jaeger-all-in-one
  • jaeger-collector
  • jaeger-ingester
  • jaeger-query

进入到解压后的目录执行:

./jaeger-all-in-one

目测启动后,访问地址:

/127_0_0_1:16686/

到这,Jaeger 已经部署成功了。

准备测试服务

准备的五个测试服务如下:

听(listen)

  • 端口:9901
  • 通讯:gRPC

说(speak)

  • 端口:9902
  • 通讯:gRPC

读(read)

  • 端口:9903
  • 通讯:gRPC

写(write)

  • 端口:9904
  • 通讯:gRPC

唱(sing)

  • 端口:9905
  • 通讯:HTTP

听、说、读、写、唱,想这几个服务的名称就花了好久 ~

我默认大家都会写 grpc 服务,如果不会写的,可以查看下我原来的文章《Go gRPC Hello World》。

应用示例

实例化 Tracer

func NewJaegerTracer(serviceName string, jaegerHostPort string) (opentracing.Tracer, io.Closer, error) {

    cfg := &jaegerConfig.Configuration {
        Sampler: &jaegerConfig.SamplerConfig{
            Type  : "const", /固定采样
            Param : 1,       /1=全采样、0=不采样
        },

        Reporter: &jaegerConfig.ReporterConfig{
            LogSpans           : true,
            LocalAgentHostPort : jaegerHostPort,
        },

        ServiceName: serviceName,
    }

    tracer, closer, err := cfg.NewTracer(jaegerConfig.Logger(jaeger.StdLogger))
    if err != nil {
        panic(fmt.Sprintf("ERROR: cannot init Jaeger: %v\n", err))
    }
    opentracing.SetGlobalTracer(tracer)
    return tracer, closer, err
}

HTTP 注入

injectErr := jaeger.Tracer.Inject(span.Context(), opentracing.HTTPHeaders, opentracing.HTTPHeadersCarrier(req.Header))
if injectErr != nil {
    log.Fatalf("%s: Couldn't inject headers", err)
}

HTTP 拦截

spCtx, err := opentracing.GlobalTracer().Extract(opentracing.HTTPHeaders, opentracing.HTTPHeadersCarrier(c.Request.Header))
if err != nil {
    ParentSpan = Tracer.StartSpan(c.Request.URL.Path)
    defer ParentSpan.Finish()
} else {
    ParentSpan = opentracing.StartSpan(
        c.Request.URL.Path,
        opentracing.ChildOf(spCtx),
        opentracing.Tag{Key: string(ext.Component), Value: "HTTP"},
        ext.SpanKindRPCServer,
    )
    defer ParentSpan.Finish()
}

gRPC 注入

func ClientInterceptor(tracer opentracing.Tracer, spanContext opentracing.SpanContext) grpc.UnaryClientInterceptor {
    return func(ctx context.Context, method string,
        req, reply interface{}, cc *grpc.ClientConn,
        invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error {

        span := opentracing.StartSpan(
            "call gRPC",
            opentracing.ChildOf(spanContext),
            opentracing.Tag{Key: string(ext.Component), Value: "gRPC"},
            ext.SpanKindRPCClient,
        )

        defer span.Finish()

        md, ok := metadata.FromOutgoingContext(ctx)
        if !ok {
            md = metadata.New(nil)
        } else {
            md = md.Copy()
        }

        err := tracer.Inject(span.Context(), opentracing.TextMap, MDReaderWriter{md})
        if err != nil {
            span.LogFields(log.String("inject-error", err.Error()))
        }

        newCtx := metadata.NewOutgoingContext(ctx, md)
        err = invoker(newCtx, method, req, reply, cc, opts...)
        if err != nil {
            span.LogFields(log.String("call-error", err.Error()))
        }
        return err
    }
}

gRPC 拦截

func serverInterceptor(tracer opentracing.Tracer) grpc.UnaryServerInterceptor {
    return func(ctx context.Context,
        req interface{},
        info *grpc.UnaryServerInfo,
        handler grpc.UnaryHandler) (resp interface{}, err error) {

        md, ok := metadata.FromIncomingContext(ctx)
        if !ok {
            md = metadata.New(nil)
        }

        spanContext, err := tracer.Extract(opentracing.TextMap, MDReaderWriter{md})
        if err != nil && err != opentracing.ErrSpanContextNotFound {
            grpclog.Errorf("extract from metadata err: %v", err)
        } else {
            span := tracer.StartSpan(
                info.FullMethod,
                ext.RPCServerOption(spanContext),
                opentracing.Tag{Key: string(ext.Component), Value: "gRPC"},
                ext.SpanKindRPCServer,
            )
            defer span.Finish()

            ParentContext = opentracing.ContextWithSpan(ctx, span)
        }

        return handler(ParentContext, req)
    }
}

上面是一些核心的代码,涉及到的全部代码我都会上传到 github,供下载。

运行

启动服务

/启动 Listen 服务
cd listen && go run main.go

/启动 Speak 服务
cd speak && go run main.go

/启动 Read 服务
cd read && go run main.go

/启动 Write 服务
cd write && go run main.go

/启动 Sing 服务
cd sing && go run main.go

/启动 go-gin-api 服务
cd go-gin-api && go run main.go

访问路由

太阳城申博官网登入/127_0_0_1:9999/jaeger_test

效果

就到这吧。

API 源码地址

/github_com/xinliangnote/go-gin-api

Service 源码地址

/github_com/xinliangnote/go-jaeger-demo

go-gin-api 系列文章

posted @ 2019-09-28 21:07 新亮笔记 阅读(...) 评论(...) 编辑 收藏
四川申博官网登入 www.988msc.com 菲律宾申博管理网 菲律宾太阳娱乐场登入 申博官网代理登入 菲律宾申博官网怎么登入
www.360msc.com www.sbc188.com 申博游戏中心直营网 申博真人游戏直营网 申博游戏手机版登入 太阳城在线开户登入
菲律宾申博官方直营网 申博138真人在线娱乐直营网 申博太阳开户优惠直营网 申博代理直营网 申博|菲律宾申博登入 菲律宾申博娱乐登入