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

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

太阳城申博官网登入,看到这里,那些整天叫嚷着造车、用ppt描绘美好蓝图的企业们,你们脸红了吗?Bytheway,造车不是那么简单的。2011年以来固定资产投资持续下滑,到2016年8月增速见底,目前已经连续3个月回升,预计11月将进一步回暖。但如此一来,上汽将面临着产品自己生产,销售却无法掌控,受制于一汽-大众的尴尬局面,这应该不是上汽可以接受的。  那么既然差速锁这么重要,那么他的工作原理又是什么呢?奔驰等等车型上,有三个开关,他们都是差速锁么?有什么分别?  先来聊聊中央差速锁吧,他是所有差速锁的最基础版本。

韩德君早早陷入犯规危机,哈德森不得不在场上待更长时间。”  袋鼠头,是美团外卖为了迎战“饿了么”而启动的新营销手段。  戒指不再是装饰品!  戴上“魔戒”,可刷卡打电话  见过可以通话的手表,但你见过可以通话、可以当公交卡刷、还可以当门禁卡刷的“魔戒”吗?现场,苏州的一家智能制造公司介绍一种可穿戴戒指首饰,芯片嵌入了多种功能,支持公交一卡通、门禁考勤等,并可开发银行卡支付,更实用的是,以后还可以增加接打电话、心率血糖监测、老人呼救、儿童定位、用户大数据采集等功能。受理号每日发放240个,其中网上预约号30个,现场发号210个;另有解押号每日发放100个;批量业务号24批次120个。

(文/本报记者屈畅实习记者卢俊糖刘思佳线索提供/张女士)免责声明:本文仅代表作者个人观点,与环球网无关。在激活前轮差速锁之后,你只能走直线,要不很容易让前轴因为拐弯受力不均匀而变形,这点需要特别注意。  在一汽-大众奥迪经销商看来,上汽奥迪一旦成立必然会建立独立的网络,这也将与现有经销商产生竞争,经销商的利益必然会受到侵害。奥迪与上汽集团的合作对一汽、一汽-大众没有丝毫的损害。

概述

首先同步下项目概况:

上篇文章分享了,路由中间件 - 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.msc99.com www.38333.com 申博太阳城代理开户登入 www.666sbo.com 太阳城游戏官网 申博最新网址
菲律宾申博现金网登入 www.55sbc.com 菲律宾申博开户直营网 申博怎么申请提款 申博太阳城官方现金直营网 申博现金赌场登入
申博代理直营网 菲律宾申博官网怎么登入 申博会员登录 菲律宾太阳娱乐官方网址 菲律宾太阳网上娱乐99 申博管理平台登入