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

简介: 1.简介 (1)什么是服务追踪 Sleuth 在微服务架构中,要完成一个功能,通过Rest请求服务API调用服务来完成,整个调用过程可能会聚合多个后台服务器协同完成。在整个链路上,任何一处调用超时 或出错都有可能造成前端请求失败。

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可以查看依赖关系,等等,自行发觉吧,就不上图了。

相关实践学习
【涂鸦即艺术】基于云应用开发平台CAP部署AI实时生图绘板
【涂鸦即艺术】基于云应用开发平台CAP部署AI实时生图绘板
相关文章
|
存储 Java 文件存储
微服务——SpringBoot使用归纳——Spring Boot使用slf4j进行日志记录—— logback.xml 配置文件解析
本文解析了 `logback.xml` 配置文件的详细内容,包括日志输出格式、存储路径、控制台输出及日志级别等关键配置。通过定义 `LOG_PATTERN` 和 `FILE_PATH`,设置日志格式与存储路径;利用 `&lt;appender&gt;` 节点配置控制台和文件输出,支持日志滚动策略(如文件大小限制和保存时长);最后通过 `&lt;logger&gt;` 和 `&lt;root&gt;` 定义日志级别与输出方式。此配置适用于精细化管理日志输出,满足不同场景需求。
3349 1
|
12月前
|
Prometheus 监控 Java
日志收集和Spring 微服务监控的最佳实践
在微服务架构中,日志记录与监控对系统稳定性、问题排查和性能优化至关重要。本文介绍了在 Spring 微服务中实现高效日志记录与监控的最佳实践,涵盖日志级别选择、结构化日志、集中记录、服务ID跟踪、上下文信息添加、日志轮转,以及使用 Spring Boot Actuator、Micrometer、Prometheus、Grafana、ELK 堆栈等工具进行监控与可视化。通过这些方法,可提升系统的可观测性与运维效率。
952 1
日志收集和Spring 微服务监控的最佳实践
|
Java 微服务 Spring
微服务——SpringBoot使用归纳——Spring Boot使用slf4j进行日志记录——使用Logger在项目中打印日志
本文介绍了如何在项目中使用Logger打印日志。通过SLF4J和Logback,可设置不同日志级别(如DEBUG、INFO、WARN、ERROR)并支持占位符输出动态信息。示例代码展示了日志在控制器中的应用,说明了日志配置对问题排查的重要性。附课程源码下载链接供实践参考。
1530 0
|
SQL Java 数据库连接
微服务——SpringBoot使用归纳——Spring Boot使用slf4j进行日志记录—— application.yml 中对日志的配置
在 Spring Boot 项目中,`application.yml` 文件用于配置日志。通过 `logging.config` 指定日志配置文件(如 `logback.xml`),实现日志详细设置。`logging.level` 可定义包的日志输出级别,例如将 `com.itcodai.course03.dao` 包设为 `trace` 级别,便于开发时查看 SQL 操作。日志级别从高到低为 ERROR、WARN、INFO、DEBUG,生产环境建议调整为较高级别以减少日志量。本课程采用 yml 格式,因其层次清晰,但需注意格式要求。
1619 0
|
Java API 开发者
微服务——SpringBoot使用归纳——Spring Boot使用slf4j进行日志记录——slf4j 介绍
在软件开发中,`System.out.println()`常被用于打印信息,但大量使用会增加资源消耗。实际项目推荐使用slf4j结合logback输出日志,效率更高。Slf4j(Simple Logging Facade for Java)是一个日志门面,允许开发者通过统一方式记录日志,无需关心具体日志系统。它支持灵活切换日志实现(如log4j或logback),且具备简洁占位符和日志级别判断等优势。阿里巴巴《Java开发手册》强制要求使用slf4j,以保证日志处理方式的统一性和维护性。使用时只需通过`LoggerFactory`创建日志实例即可。
940 0
|
存储 Windows
【Azure Cloud Service】微软云服务上的日志收集方法
本文介绍了在使用微软云服务(Cloud Service Extended Support)时,如何收集日志以分析未记录在应用日志中的服务异常。由于云服务基于传统虚拟机模式,需通过远程桌面登录实例,查看IIS、Windows Event及云服务组件日志(如WindowsAzureGuestAgent)。此外,可使用CollectGuestLogs.exe工具打包日志,或通过“File Server Resource Manager”检查日志存储配额是否不足。附参考文档链接供深入学习。
496 29
|
XML 安全 Java
【日志框架整合】Slf4j、Log4j、Log4j2、Logback配置模板
本文介绍了Java日志框架的基本概念和使用方法,重点讨论了SLF4J、Log4j、Logback和Log4j2之间的关系及其性能对比。SLF4J作为一个日志抽象层,允许开发者使用统一的日志接口,而Log4j、Logback和Log4j2则是具体的日志实现框架。Log4j2在性能上优于Logback,推荐在新项目中使用。文章还详细说明了如何在Spring Boot项目中配置Log4j2和Logback,以及如何使用Lombok简化日志记录。最后,提供了一些日志配置的最佳实践,包括滚动日志、统一日志格式和提高日志性能的方法。
5231 32
【日志框架整合】Slf4j、Log4j、Log4j2、Logback配置模板
|
监控 安全 Apache
什么是Apache日志?为什么Apache日志分析很重要?
Apache是全球广泛使用的Web服务器软件,支持超过30%的活跃网站。它通过接收和处理HTTP请求,与后端服务器通信,返回响应并记录日志,确保网页请求的快速准确处理。Apache日志分为访问日志和错误日志,对提升用户体验、保障安全及优化性能至关重要。EventLog Analyzer等工具可有效管理和分析这些日志,增强Web服务的安全性和可靠性。
678 9
|
监控 容灾 算法
阿里云 SLS 多云日志接入最佳实践:链路、成本与高可用性优化
本文探讨了如何高效、经济且可靠地将海外应用与基础设施日志统一采集至阿里云日志服务(SLS),解决全球化业务扩展中的关键挑战。重点介绍了高性能日志采集Agent(iLogtail/LoongCollector)在海外场景的应用,推荐使用LoongCollector以获得更优的稳定性和网络容错能力。同时分析了多种网络接入方案,包括公网直连、全球加速优化、阿里云内网及专线/CEN/VPN接入等,并提供了成本优化策略和多目标发送配置指导,帮助企业构建稳定、低成本、高可用的全球日志系统。
1508 55