[jaeger] 四、微服务之调用链(Feign+SpringCloud)

符文杰9527 · · 2592 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

终于到了我们的重点,微服务了。

与使用OkHttp3来实现的客户端类似,Feign接口本来也就是一个Http调用,依然可以使用Http头传值的方式,将 Trace 往下传。

本文更多的是关于 SpringCloud 的一些知识,你需要了解一些基本的 Spring 相关的知识。

更多系列,请关注公众号小姐姐味道,本文相关代码的github地址,见:

https://github.com/sayhiai/example-jaeger-opentracing-tutorial-004复制代码

安装Consul

SpringCloud的注册中心,我们选用Consul。

consul也是用golang开发的。从consul官网下载二进制包以后,解压。

./consul agent  -bind127.0.0.1-data-dir . -node my-register-center -bootstrap-expect1-ui -dev复制代码

使用以上脚本快速启动,即可使用。

访问 http://localhost:8500/ui/ 可以看到Consul的web页面。

构建微服务服务端和客户端

maven依赖

以bom方式引入springboot和springcloud的组件。

spring-boot-dependencies2.1.3.RELEASEspring-cloud-dependenciesGreenwich.SR1复制代码

都是热乎乎的新鲜版本。

接下来下,引入其他必须的包

opentracing-util0.32.0jaeger-client0.35.0logback-classic1.2.3opentracing-spring-jaeger-cloud-starter2.0.0spring-boot-starter-webspring-boot-starter-aopspring-boot-starter-actuatorspring-cloud-starter-consul-discoveryspring-cloud-starter-openfeign复制代码

构建服务端

服务端App的端口是 8888

@SpringBootApplication@EnableAutoConfiguration@EnableDiscoveryClient@ComponentScan(basePackages = {"com.sayhiai.example.jaeger.totorial04.controller",})public class App extends SpringBootServletInitializer {publicstaticvoidmain(String[] args) {SpringApplication.run(App.class, args);    }}复制代码

在application.yml中,配置Consul作为配置中心。

cloud:    consul:      host:127.0.0.1      port:8500      discovery:        register:true        tags:version=1.0,author=xjjdog        healthCheckPath:/actuator/health        healthCheckInterval:5s复制代码

创建Rest服务 /hello

@PostMapping("/hello")@ResponseBodypublicString hello(@RequestBodyString name) {return"hello "+ name;}复制代码

构建Feign客户端

Feign客户端的App端口是 9999 ,同样是一个SpringCloud服务。

创建FeignClient

@FeignClient("love-you-application")public interface LoveYouClient {@PostMapping("/hello")@ResponseBodypublic String hello(@RequestBodyString name);}复制代码

创建调用入口 /test

@GetMapping("/test")@ResponseBodypublicString hello() {    String rs = loveYouClient.hello("小姐姐味道");returnrs;}复制代码

集成jaeger

目前,已经有相关SpringCloud的轮子了,我们就不重复制造了。

首先,我们看一下使用方法,然后,说明一下背后的原理。了解原理之后,你将很容易的给自己开发的中间件加入Trace功能。

轮子在这里,引入相应maven包即可使用:

https://github.com/opentracing-contrib/java-spring-jaeger复制代码

io.opentracing.contribopentracing-spring-jaeger-cloud-starter复制代码

加入配置生效

在 application.yml 中,加入以下配置,就可以得到调用链功能了。

配置指明了trace的存放地址,并将本地log打开。

opentracing.jaeger.http-sender.url:http://10.30.94.8:14268/api/tracesopentracing.jaeger.log-spans:true复制代码

访问 localhost:9999/test,会得到以下调用链。

可以看到。Feign的整个调用过程都被记录下来了。

原理

Feign的调用

Feign通过Header传递参数

首先看下Feign的Request构造函数。

publicstaticRequestcreate(Stringmethod,Stringurl, Map> headers,byte[] body, Charset charset) {    returnnewRequest(method, url, headers, body, charset);}复制代码

如代码,完全可以通过在headers参数中追加我们需要的信息进行传递。

接着源代码往下找: Client**->** LoadBalancerFeignClient execute() -> executeWithLoadBalancer() -> IClient**->**

再往下,IClient实现有OkHttpLoadBalancingClient RibbonLoadBalancingHttpClient(基于apache的包) 等,它们都可以很容易的设置其Header

最终,我们的请求还是由这些底层的库函数发起,默认的是HttpURLConnection。

读过Feign和Ribbon源码的人都知道,这部分代码不是一般的乱,但好在上层的Feign是一致的。

使用委托包装Client

通过实现 feign.Client 接口,结合委托,可以重新封装 execute 方法,然后将信息 inject进Feign的scope中。

使用Aop自动拦截Feign调用

@AspectclassTracingAspect{@Around("execution (* feign.Client.*(..)) && !within(is(FinalType))")publicObjectfeignClientWasCalled(finalProceedingJoinPoint pjp)throwsThrowable{    Object bean = pjp.getTarget();if(!(beaninstanceofTracingClient)) {      Object[] args = pjp.getArgs();returnnewTracingClientBuilder((Client) bean, tracer)          .withFeignSpanDecorators(spanDecorators)          .build()          .execute((Request) args[0], (Request.Options) args[1]);    }returnpjp.proceed();  }}复制代码

利用spring boot starter技术,我们不需要任何其他改动,就可以拥有trace功能了。

Web端的发送和接收

了解spring的人都知道,最适合做http头信息添加和提取的地方,就是拦截器和过滤器。

发送

对于普通的http请求客户端来说,是通过添加一个 ClientHttpRequestInterceptor 拦截器来实现的。过程不再表诉,依然是使用inject等函数进行头信息设置。

接收

而对于接收,则使用的是Filter进行实现的。通过实现一个普通的servlet filter。可以通过 extract 函数将trace信息提取出来,然后将context作为Request的attribute进行传递。

相关代码片段如下。

if(servletRequest.getAttribute(SERVER_SPAN_CONTEXT) !=null) {    chain.doFilter(servletRequest, servletResponse);}else{    SpanContext extractedContext = tracer.extract(Format.Builtin.HTTP_HEADERS,newHttpServletRequestExtractAdapter(httpRequest));finalSpan span = tracer.buildSpan(httpRequest.getMethod()).asChildOf(extractedContext).withTag(Tags.SPAN_KIND.getKey(), Tags.SPAN_KIND_SERVER).start();httpRequest.setAttribute(SERVER_SPAN_CONTEXT, span.context());复制代码

就这样,整个链条就穿插起来啦。


有疑问加站长微信联系(非本文作者)

本文来自:简书

感谢作者:符文杰9527

查看原文:[jaeger] 四、微服务之调用链(Feign+SpringCloud)

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

2592 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传