文档章节

Spring Cloud微服务之 sleuth+zipkin日志聚合

编程SHA
 编程SHA
发布于 03/25 12:54
字数 1395
阅读 58
收藏 4

1.简介

(1)什么是服务追踪 Sleuth

在微服务架构中,要完成一个功能,通过Rest请求服务API调用服务来完成,整个调用过程可能会聚合多个后台服务器协同完成。在整个链路上,任何一处调用超时

或出错都有可能造成前端请求失败。这时跟踪记录这些请求的调用的情况就要复杂的多,这就需要一个专门的工具来处理,spring cloud sleuth组件就是用于跟踪记录的工具

Sleuth就相当于为微服务架构引入了一套记录体系,包含两部分,一个是 trace ID;另一个是 span ID,随时记录一个请求的每一步操作。

(2)什么是日志聚合 Zipkin

如果想学习Java工程化、高性能及分布式、深入浅出。微服务、Spring,MyBatis,Netty源码分析的朋友可以加我的Java高级交流:787707172,群里有阿里大牛直播讲解技术,以及Java大型互联网技术的视频免费分享给大家。

zipkin 是 Dpper的开源实现,支持多种语言。Sleuth已经将每个请求从开始调用到完成的每一步都进行了记录,但是这些log信息会很分散,使用起来不太方便,就

需要有一个工具可以将这些信息进行收集和汇总,并且显示可视化的结果,便于分析和定位。这就需要创建一个 Zipkin Server用于收集和展示这些调用链路的信息,他

的使用也很方便。

2.如何使用

本例需要创建三个工程:

product-sevice 普通客户端工程,提供一个rest接口(项目创建参考第三节)

order-service 普通客户端工程,用于调用product-service服务(项目创建参考第三节)

zipkin-service 日志服务工程,用于追踪记录请求链路。

第一步:创建 zipkin-service,作为Zipkin Server。

工程目录如图:

Spring Cloud微服务之 sleuth+zipkin日志聚合

 

(1)首先在 pom.xml中增加依赖

<dependency>
			<groupId>io.zipkin.java</groupId>
			<artifactId>zipkin-autoconfigure-ui</artifactId>
			<scope>runtime</scope>
		</dependency>
		<dependency>
			<groupId>io.zipkin.java</groupId>
			<artifactId>zipkin-server</artifactId>
		</dependency>

(2)在启动类增加@EnableZipkinServer注解,用来开启Zipkin Server的功能。

package com.hole;
 
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import zipkin.server.EnableZipkinServer;
 
@EnableDiscoveryClient
@EnableZipkinServer
@SpringBootApplication
public class ZipkinServiceApplication {
	private static Logger logger = LoggerFactory.getLogger(ZipkinServiceApplication.class);
 
	public static void main(String[] args) {
		SpringApplication.run(ZipkinServiceApplication.class, args);
	}
}

(3)application.properties配置如下:

spring.application.name=zipkin-service
server.port=9411
eureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka/

(4)启动 Zipkin Server,访问 http://localhost:9411/,此时因为还没有服务请求关联的zipkin server,所以服务名里列表里是空的,如图:

Spring Cloud微服务之 sleuth+zipkin日志聚合

 

如果想学习Java工程化、高性能及分布式、深入浅出。微服务、Spring,MyBatis,Netty源码分析的朋友可以加我的Java高级交流:787707172,群里有阿里大牛直播讲解技术,以及Java大型互联网技术的视频免费分享给大家。

第二步:创建日志客户端工程

想要在界面上能看到zipkin server搜集的日志信息及依赖关系,需要在每个工程中增加sleuth与zipkin的依赖,然后增加注册地址,指向到 zipkin server上就可以了。

1.(1)创建product-service工程,并增加依赖。

<dependency>
			<groupId>org.springframework.cloud</groupId>
			<artifactId>spring-cloud-starter-sleuth</artifactId>
		</dependency>
		<dependency>
			<groupId>org.springframework.cloud</groupId>
			<artifactId>spring-cloud-sleuth-zipkin</artifactId>
		</dependency>

(2)application.properties配置增加配置,指向 zipkin server服务地址。

spring.zipkin.base-url=http://localhost:9411/

(3)启动类代码增加 /hello 接口,并在接口入口处做一个日志打印,代码如下

package com.hole;
 
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
 
@EnableDiscoveryClient
@SpringBootApplication
@RestController
public class ProductServiceApplication {
	private static Logger logger = LoggerFactory.getLogger(ProductServiceApplication.class);
 
	public static void main(String[] args) {
		SpringApplication.run(ProductServiceApplication.class, args);
	}
 
	@RequestMapping(value = "/hello",method = RequestMethod.GET)
	public ResponseEntity<String> hello(){
		logger.info("called by product-service");
		return new ResponseEntity<String>("hello product service!", HttpStatus.OK);
	}
}

2.(1)创建order-service工程。

依赖和配置同 product-sevice。

(2)启动类增加 /product/hello接口,目的是调动 product-service接口。在接口入口位置做一个日志打印。

package com.hole;
 
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;
 
@EnableDiscoveryClient
@SpringBootApplication
@RestController
public class OrderServiceApplication {
	private static Logger logger = LoggerFactory.getLogger(OrderServiceApplication.class);
 
	@Bean
	@LoadBalanced
	RestTemplate restTemplate(){
		return new RestTemplate();
	}
 
	@Autowired
	RestTemplate restTemplate;
 
	public static void main(String[] args) {
		SpringApplication.run(OrderServiceApplication.class, args);
	}
 
	@RequestMapping(value = "/hello",method = RequestMethod.GET)
	public ResponseEntity<String> hello(){
		return new ResponseEntity<String>("hello order service!", HttpStatus.OK);
	}
 
	@RequestMapping(value = "/product/hello",method = RequestMethod.GET)
	public String productHello(){
		logger.info("order-service calling product-service!");
		return restTemplate.getForEntity("http://PRODUCT-SERVICE/hello",String.class).getBody();
	}
}

第三步:启动项目并验证。

(1)启动全部项目,启动成功后在监控页面查看结果。

(2)访问 order-service 服务的 /product/hello接口,结果访问成功。可以多刷新几次

Spring Cloud微服务之 sleuth+zipkin日志聚合

 

(3)访问 zipkin server(9411端口),查看日志服务列表,发现service name下拉框已有下拉选项,验证成功。

Spring Cloud微服务之 sleuth+zipkin日志聚合

 

点击 Find Traces 查看结果可以看到它的完整链路条,点击链条可以看到调用链条,点击 Dependencies可以查看依赖关系,等等,自行发觉吧,就不上图了。

欢迎工作一到八年的Java工程师朋友们加入Java高级交流:787707172

本群提供免费的学习指导 架构资料 以及免费的解答

不懂得问题都可以在本群提出来 之后还会有直播平台和讲师直接交流噢

© 著作权归作者所有

编程SHA
粉丝 21
博文 207
码字总数 503378
作品 0
长沙
私信 提问
微服务开发架构——Spring Cloud常见问题与总结Turbine 聚合数据不完整

个人GitHub地址:https://github.com/leebingbin/ 在使用Spring Cloud的过程中,难免会遇到一些问题。所以对Spring Cloud的常用问题做一些总结。 三、Turbine 聚合数据不完整 在某些版本的S...

Mr_ET
2017/11/01
141
0
微服务开发架构——Spring Cloud常见问题与总结Spring Cloud 定位问题思路总结

个人GitHub地址:https://github.com/leebingbin/ 在使用Spring Cloud的过程中,难免会遇到一些问题。所以对Spring Cloud的常用问题做一些总结。 五、Spring Cloud 定位问题思路总结 根据市场...

Mr_ET
2017/11/02
151
0
这些优秀的 Spring Cloud 开源软件,你知道几个?

Spring Cloud是一系列框架的有序集合。它利用Spring Boot的开发便利性巧妙地简化了分布式系统基础设施的开发,如服务发现注册、配置中心、消息总线、负载均衡、断路器、数据监控等,都可以用...

技术小能手
2018/08/30
0
0
FEBS Cloud v1.1 发布,整合 Spring Cloud Alibaba

FEBS Cloud是一款使用Spring Cloud Greenwich.SR3、Spring Cloud OAuth2 & Spring Cloud Alibaba构建的低耦合权限管理系统,前端(FEBS Cloud Web)采用vue element admin构建。FEBS意指:F...

mrbird
09/22
799
0
用Spring Cloud Stream实现Event Driven Architectures

微服务的出现和原生的云架构触发了DDD,CQRS和Event Sourcing的复苏。所有这些方式实现的核心是Domain Event(领域事件), 它是分布式系统中实现一整套DDD架构及实现最终一致性的主要机制。...

Big_BoBo
2017/10/19
550
0

没有更多内容

加载失败,请刷新页面

加载更多

不就是SELECT COUNT语句吗,竟然能被面试官虐的体无完肤

数据库查询相信很多人都不陌生,所有经常有人调侃程序员就是CRUD专员,这所谓的CRUD指的就是数据库的增删改查。 在数据库的增删改查操作中,使用最频繁的就是查询操作。而在所有查询操作中,...

HollisChuang
23分钟前
4
0
乐观锁和悲观锁

乐观锁和悲观锁 在并发环境下,事务的隔离性很难保证,因此会出现很多并发一致性的问题 事务的特性:原子性、一致性、隔离性、持久性 1、丢失修改:T1和T2两个事务对同一个数据进行修改,T1先...

大瑞清_liurq
32分钟前
5
0
Scrum敏捷价值观与原则

Scrum是一种迭代式增量软件开发过程,通常用于敏捷软件开发。如果还不知道Scrum敏捷开发的朋友们,请出门左转,点击 Scrum 了解。 敏捷价值观 个体和互动 高于 流程和工具 工作的软件 高于 ...

醉美閑聖
32分钟前
4
0
android焦点

final RelativeLayout relativeLayout=new RelativeLayout(context); relativeLayout.setClickable(true); relativeLayout.setFocusable(true); rel......

安卓工程师王恒
34分钟前
4
0
IP地址分配与中继设备简介

1. TCP/IP模型 TCP/IP协议是在OSI参考模型出现之间就被开发的,并广泛部署在计算机网络中。但是,后来由于概念混淆,TCP/IP模型的层次和名称往往与OSI模型的层次名称相互借用。如图1.所示。 ...

xiangyunyan
35分钟前
5
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部