Spring Cloud微服务之 sleuth+zipkin日志聚合
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中增加依赖
<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日志聚合
第二步:创建日志客户端工程
想要在界面上能看到zipkin server搜集的日志信息及依赖关系,需要在每个工程中增加sleuth与zipkin的依赖,然后增加注册地址,指向到 zipkin server上就可以了。
1.(1)创建product-service工程,并增加依赖。
<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可以查看依赖关系,等等,自行发觉吧,就不上图了。
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
一款很好用的国产静态源代码扫描工具-DMSCA
端玛企业级静态源代码扫描分析服务平台(英文简称:DMSCA)是一个独特的源代码安全漏洞、质量缺陷和逻辑缺陷扫描分析服务平台。该平台可用于识别、跟踪和修复在源代码中的技术和逻辑上的缺陷,让软件开发团队及测试团队快速、准确定位源代码中的安全漏洞、质量和业务逻辑缺陷等问题,并依据提供的专业中肯的修复建议,快速修复。提高软件产品的可靠性、安全性。同时兼容并达到国际、国内相关行业的合规要求。 DMSCA是端玛科技在多年静态分析技术的积累及研发努力的基础上,联合多所国内及国际知名大学、专家共同分析全球静态分析技术的优缺点后、结合当前开发语言的技术现状、源代码缺陷的发展势态和市场后,研发出的新一代源代码企业级分析方案,旨在从根源上识别、跟踪和修复源代码技术和逻辑上的缺陷。该方案克服了传统静态分析工具误报率(False Positive)高和漏报(False Negative)的缺陷。打断了国外产品在高端静态分析产品方面的垄断,形成中国自主可控的高端源代码安全和质量扫描产品,并支持中国自己的源代码检测方面的国家标准(GB/T34944-2017 Java、GB/T34943-2017 C/C++、GB...
- 下一篇
阿里云DDoS 高防IP功能作用与防御原理 高防IP实践教程
阿里云DDoS有什么功能作用?DDoS防御架构原理是什么呢?阿里云DDoS 高防IP这么贵又怎么办?一起来看看吧! 阿里云云盾产品所涉及的产品组件,全部为自主研发产品,拥有充分自主知识产权。结构如下: 云盾DDoS高防IP产品是针对解决互联网服务器(包括非阿里云主机)在遭受大流量的DDoS攻击后导致服务不可用的情况,推出的付费增值服务。您可以通过配置DDoS高防IP,将攻击流量引流到高防IP,确保源站的稳定可靠。 您购买DDoS高防IP服务后,把域名解析到高防IP(Web业务把域名解析指向高防IP;非Web业务,把业务IP替换成高防IP),并配置源站IP。所有公网流量都经过高防IP机房,通过端口协议转发的方式将访问流量通过高防IP转发到源站IP,同时将恶意攻击流量在高防IP上进行清洗过滤后将正常流量返回给源站IP,从而确保源站IP稳定访问。 配置DDoS高防IP服务后,当您遭受DDoS攻击时,无需额外做流量牵引和回注。 DDos简介 DDoSDistributed Denial of Service 即分布式拒绝服务。攻击指借助于客户/服务器技术,将多个计算机联合起来作为攻击平台,对一...
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
推荐阅读
最新文章
- CentOS8编译安装MySQL8.0.19
- SpringBoot2配置默认Tomcat设置,开启更多高级功能
- Windows10,CentOS7,CentOS8安装Nodejs环境
- Docker快速安装Oracle11G,搭建oracle11g学习环境
- CentOS8,CentOS7,CentOS6编译安装Redis5.0.7
- Windows10,CentOS7,CentOS8安装MongoDB4.0.16
- SpringBoot2全家桶,快速入门学习开发网站教程
- CentOS7编译安装Gcc9.2.0,解决mysql等软件编译问题
- 设置Eclipse缩进为4个空格,增强代码规范
- MySQL8.0.19开启GTID主从同步CentOS8