ApiBoot新特性GlobalLogging详解

简介: 其实理解起来比较简单,类似于我们平时一直在使用的`logback`、`log4j`这种的日志框架的其中一个功能部分,`minbox-logging`分布式日志框架目前独立于`api-boot-plugins`,已经加入了`minbox-projects`开源组织,之前博客有一系列的文章来讲解了`ApiBoot Logging`(内部是集成的`minbox-logging`)日志组件的使用以及极简的配置方式,可以访问[ApiBoot 组件系列文章使用汇总](https://blog.minbox.org/apiboot-all-articles.html)了解日志组件的使用详情。

全局日志是一个什么概念呢?

其实理解起来比较简单,类似于我们平时一直在使用的logbacklog4j这种的日志框架的其中一个功能部分,minbox-logging分布式日志框架目前独立于api-boot-plugins,已经加入了minbox-projects开源组织,之前博客有一系列的文章来讲解了ApiBoot Logging(内部是集成的minbox-logging)日志组件的使用以及极简的配置方式,可以访问ApiBoot 组件系列文章使用汇总了解日志组件的使用详情。

<hr/>

什么是全局日志?

在之前ApiBoot Logging分布式日志组件可以实现日志采集日志上报日志统一存储集成Spring Security集成Openfeign等功能,随着ApiBoot Logging 2.2.1.RELEASE版本的发布引入了一个新的概念,那就是GlobalLog

用过ApiBoot Logging日志组件的同学应该都有了解,它只会记录每一次发送请求相关的一些信息,如:请求参数、请求地址、请求头信息、响应内容等,并没有提供业务代码中的debuginfoerror等级日志的采集方式,就不要提上报这种日志到Logging Admin了。

新版本的发布给我们带来了春天,ApiBoot Logging为了方便代码的调试,执行时业务数据的监控,支持了采集业务代码内的不同等级的日志,而且还支持采集Exception的堆栈信息,方便定位错误,及时纠正。

了解GlobalLogging接口

为了支持业务全局日志,新版本中引入了GlobalLogging接口,我们先来看看这个接口的源码,如下所示:


/**
 * Global log collection interface
 * Provide debug, info, and error log collection
 *
 * @author 恒宇少年
 */
public interface GlobalLogging {
    /**
     * Collect Debug Level Logs
     *
     * @param msg log content
     */
    void debug(String msg);

    /**
     * Collect Debug Level Logs
     *
     * @param format    Unformatted log content
     * @param arguments List of parameters corresponding to log content
     */
    void debug(String format, Object... arguments);

    /**
     * Collect Info Level Logs
     *
     * @param msg log content
     */
    void info(String msg);

    /**
     * Collect Info Level Logs
     *
     * @param format    Unformatted log content
     * @param arguments List of parameters corresponding to log content
     */
    void info(String format, Object... arguments);

    /**
     * Collect Error Level Logs
     *
     * @param msg log content
     */
    void error(String msg);

    /**
     * Collect Error Level Logs
     *
     * @param msg       log content
     * @param throwable Exception object instance
     */
    void error(String msg, Throwable throwable);

    /**
     * Collect Error Level Logs
     *
     * @param format    Unformatted log content
     * @param arguments List of parameters corresponding to log content
     */
    void error(String format, Object... arguments);
}

GlobalLogging接口内提供了三种类型的日志采集方法,分别是:debuginfoerror,这个版本只是对日志的等级进行了划分,并没有添加限制或者过滤机制。

GlobalLogging当前版本有一个实现类org.minbox.framework.logging.client.global.support.GlobalLoggingMemoryStorage,该类实现了GlobalLogging内的全部方法,并将采集到的日志保存到了GlobalLoggingThreadLocal,方便统一上报到Logging Admin

为了方便后期修改Global Log的存储方式,ApiBoot Logging提供了一个配置参数api.boot.logging.global-logging-storage-away,该配置的默认值为memory,对应GlobalLoggingMemoryStorage实现类。

GlobalLogging自动化配置

ApiBoot Logging根据api.boot.logging.global-logging-storage-away配置参数,条件判断自动化配置了GlobalLogging接口的实现类,如下所示:

package org.minbox.framework.api.boot.autoconfigure.logging;
import ...
/**
 * the "minbox-logging" global log storage configuration
 *
 * @author 恒宇少年
 */
@Configuration
@ConditionalOnClass(GlobalLogging.class)
public class ApiBootLoggingGlobalLogStorageAutoConfiguration {
    /**
     * Instance global log memory mode storage
     *
     * @return {@link GlobalLoggingMemoryStorage}
     */
    @Bean
    @ConditionalOnProperty(prefix = API_BOOT_LOGGING_PREFIX,
        name = "global-logging-storage-away", havingValue = "memory", matchIfMissing = true)
    public GlobalLogging globalLogging() {
        return new GlobalLoggingMemoryStorage();
    }
}

根据globalLogging()方法上的条件注入注解@ConditionalOnProperty配置内容可以了解到,当我们在application.yml配置文件内添加api.boot.logging.global-logging-storage-away=memory时或者缺少该配置时,该方法会被调用并且创建一个GlobalLoggingMemoryStorage对象实例,并将该实例对象写入到IOC容器内,这样我们在使用GlobalLogging实例时,只需要注入就可以了,如下所示:

/**
  * {@link GlobalLogging}
  *
  * @see org.minbox.framework.logging.client.global.AbstractGlobalLogging
  * @see org.minbox.framework.logging.client.global.support.GlobalLoggingMemoryStorage
  */
@Autowired
private GlobalLogging logging;

使用GlobalLogging

采集的方式很简单,我们只需要注入GlobalLogging对象,使用该接口提供的方法即可,如下所示:

/**
 * 测试用户控制器
 *
 * @author 恒宇少年
 */
@RestController
@RequestMapping(value = "/user")
public class UserController {
    /**
     * {@link GlobalLogging}
     *
     * @see org.minbox.framework.logging.client.global.AbstractGlobalLogging
     * @see org.minbox.framework.logging.client.global.support.GlobalLoggingMemoryStorage
     */
    @Autowired
    private GlobalLogging logging;

    /**
     * 测试获取用户名
     *
     * @return
     */
    @GetMapping(value = "/name")
    public String getUserName() {
        logging.debug("这是一条debug级别的日志");
        logging.info("这是一条info级别的日志");
        return "用户名:恒宇少年";
    }
}

当我们调用GlobalLogging提供的不同日志等级的方法时,会自动将日志相关信息写入到GlobalLoggingThreadLocal的集合内,等到上报请求日志时一并提交给Logging Admin,由Logging Admin进行保存。

GlobalLogging表结构

GlobalLogging相关的全局日志采集到Logging Admin需要进行保存,所有对应添加了一个名为logging_global_logs信息表,结构如下所示:

CREATE TABLE `logging_global_logs` (
  `lgl_id` varchar(36) COLLATE utf8mb4_general_ci NOT NULL COMMENT '日志主键',
  `lgl_request_log_id` varchar(36) COLLATE utf8mb4_general_ci NOT NULL COMMENT '请求日志编号,关联logging_request_logs主键',
  `lgl_level` varchar(20) COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '日志等级',
  `lgl_content` mediumtext COLLATE utf8mb4_general_ci COMMENT '日志内容',
  `lgl_caller_class` varchar(200) COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '日志输出的类名',
  `lgl_caller_method` varchar(50) COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '日志输出的方法名称',
  `lgl_caller_code_line_number` int(11) DEFAULT NULL COMMENT '日志输出的代码行号',
  `lgl_exception_stack` mediumtext COLLATE utf8mb4_general_ci COMMENT 'error等级的日志异常堆栈信息',
  `lgl_create_time` mediumtext COLLATE utf8mb4_general_ci COMMENT '日志发生时间',
  PRIMARY KEY (`lgl_id`),
  KEY `logging_global_logs_logging_request_logs_lrl_id_fk` (`lgl_request_log_id`),
  CONSTRAINT `logging_global_logs_logging_request_logs_lrl_id_fk` FOREIGN KEY (`lgl_request_log_id`) REFERENCES `logging_request_logs` (`lrl_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci COMMENT='全局日志信息表';

采集Exception堆栈信息

使用GlobalLogging可以采集遇到异常的详细堆栈信息,可以让我们直接定位到问题出现的位置,在第一时间解决出现的问题,具体使用如下所示:

try {
  int a = 5 / 0;
} catch (Exception e) {
  logging.error(e.getMessage(), e);
}

运行测试

我们来运行本章的源码,看下日志采集的效果。

输出的采集日志

{
    "endTime":1576561372604,
    "globalLogs":[{
        "callerClass":"org.minbox.chapter.user.service.UserController",
        "callerCodeLineNumber":33,
        "callerMethod":"getUserName",
        "content":"这是一条debug级别的日志,发生时间:{}",
        "createTime":1576561372585,
        "level":"debug"
    },{
        "callerClass":"org.minbox.chapter.user.service.UserController",
        "callerCodeLineNumber":34,
        "callerMethod":"getUserName",
        "content":"这是一条info级别的日志,发生时间:1576561372586",
        "createTime":1576561372586,
        "level":"info"
    },{
        "callerClass":"org.minbox.chapter.user.service.UserController",
        "callerCodeLineNumber":43,
        "callerMethod":"aa",
        "content":"出现了异常.",
        "createTime":1576561372586,
        "exceptionStack":"java.lang.ArithmeticException: / by zero\n\tat org.minbox.chapter.user.service.UserController.aa(UserController.java:41)\n\tat org.minbox.chapter.user.service.UserController.getUserName(UserController.java:35)\n\tat sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)\n\tat sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)\n\t....",
        "level":"error"
    }],
    "httpStatus":200,
    "requestBody":"",
    "requestHeaders":{
        "accept":"*/*",
        "host":"localhost:10000",
        "user-agent":"curl/7.64.1"
    },
    "requestIp":"0:0:0:0:0:0:0:1",
    "requestMethod":"GET",
    "requestParam":"{}",
    "requestUri":"/user/name",
    "responseBody":"用户名:恒宇少年",
    "responseHeaders":{},
    "serviceId":"user-service",
    "serviceIp":"127.0.0.1",
    "servicePort":"10000",
    "spanId":"41a0c852-812b-4a2e-aa4a-228b87ce52f6",
    "startTime":1576561372577,
    "timeConsuming":27,
    "traceId":"42ca9f5a-5977-49cf-909d-a23614a47a6b"
}
上面是控制台输出的一个请求日志的详细内容,其中 globalLogs字段就是我们采集的全局日志列表。

存储的采集日志

我们来确认下采集日志上报到Logging Admin后是否保存到了logging_global_logs日志表内,如下所示:

mysql> select * from logging_global_logs order by lgl_create_time asc\G;
*************************** 1. row ***************************
                     lgl_id: 112e36ff-e781-4f11-8f21-2196823cde38
         lgl_request_log_id: f91382e2-2d79-499e-b1df-4757c1ffdbc5
                  lgl_level: info
                lgl_content: 这是一条info级别的日志,发生时间:1576561856333
           lgl_caller_class: org.minbox.chapter.user.service.UserController
          lgl_caller_method: getUserName
lgl_caller_code_line_number: 34
        lgl_exception_stack: NULL
            lgl_create_time: 1576561856333
*************************** 2. row ***************************
                     lgl_id: f1d172a6-5cce-4df0-bc29-fe27ac441089
         lgl_request_log_id: f91382e2-2d79-499e-b1df-4757c1ffdbc5
                  lgl_level: debug
                lgl_content: 这是一条debug级别的日志,发生时间:{}
           lgl_caller_class: org.minbox.chapter.user.service.UserController
          lgl_caller_method: getUserName
lgl_caller_code_line_number: 33
        lgl_exception_stack: NULL
            lgl_create_time: 1576561856333
*************************** 3. row ***************************
                     lgl_id: d95d850d-3bc9-4689-928a-32c6089ff7a2
         lgl_request_log_id: f91382e2-2d79-499e-b1df-4757c1ffdbc5
                  lgl_level: error
                lgl_content: 出现了异常.
           lgl_caller_class: org.minbox.chapter.user.service.UserController
          lgl_caller_method: getUserName
lgl_caller_code_line_number: 38
        lgl_exception_stack: java.lang.ArithmeticException: / by zero
        at org.minbox.chapter.user.service.UserController.getUserName(UserController.java:36)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
                        ...
            lgl_create_time: 1576561856334
3 rows in set (0.01 sec)
这里异常的堆栈信息比较多,做出了省略。

敲黑板,划重点

本章把GlobalLog全局日志的概念进行了详细的描述,建议将一些重要逻辑判断性质的GlobalLog进行采集上报,防止logging_global_logs表内的数据量过大。

详细的使用方式请参考本章的源码。

代码示例

如果您喜欢本篇文章请为源码仓库点个Star,谢谢!!!
本篇文章示例源码可以通过以下途径获取,目录为apiboot-logging-use-global-log

相关实践学习
日志服务之使用Nginx模式采集日志
本文介绍如何通过日志服务控制台创建Nginx模式的Logtail配置快速采集Nginx日志并进行多维度分析。
相关文章
|
2天前
|
SpringCloudAlibaba 负载均衡 Dubbo
SpringCloudAlibaba:3.2dubbo的高级特性
SpringCloudAlibaba:3.2dubbo的高级特性
23 1
|
2天前
|
安全 Java Spring
Spring Security 5.7 最新配置细节(直接就能用),WebSecurityConfigurerAdapter 已废弃
Spring Security 5.7 最新配置细节(直接就能用),WebSecurityConfigurerAdapter 已废弃
63 0
|
2天前
|
安全 Java 数据安全/隐私保护
第1章 Spring Security 概述(2024 最新版)(上)
第1章 Spring Security 概述(2024 最新版)
33 0
|
2天前
|
安全 Java API
第1章 Spring Security 概述(2024 最新版)(下)
第1章 Spring Security 概述(2024 最新版)
25 0
|
7月前
|
Java Go Kotlin
Spring框架的未来:Spring 6的新特性预览
Spring框架的未来:Spring 6的新特性预览
219 0
|
8月前
|
安全 Java Spring
用的挺顺手的 Spring Security 配置类,居然就要被官方弃用了?
用过 WebSecurityConfigurerAdapter的都知道对Spring Security十分重要,总管Spring Security的配置体系。但是马上这个类要废了,你没有看错,这个类将在5.7版本被@Deprecated所标记了,未来这个类将被移除。
|
12月前
|
小程序 Java 网络安全
Spring Boot 3.1 正式发布,更新了一大批新特性。。学不动了!
Spring Boot 3.1 正式发布,更新了一大批新特性。。学不动了!
|
数据可视化 前端开发 Java
Spring Boot 基础教程:集成 Swagger2,构建强大的 API 文档
主要对 Swagger 进行了简单介绍,并用 Spring Boot 集成 Swagger,同时还进行简单的测试,构建我们自己的 API 接口文档。
249 0
Spring Boot 基础教程:集成 Swagger2,构建强大的 API 文档
|
Kubernetes NoSQL Java
Spring Cloud 2020.0.5 发布,新特性一览,别掉队了。。
Spring Cloud 最近版本更新: Spring Cloud 2021.0.0 发布 Spring Cloud 2020.0.4 发布
Spring Cloud 2020.0.5 发布,新特性一览,别掉队了。。
|
Java Maven Spring
Spring Boot 2.2.2 发布,新增 2 个新特性!
Spring Boot 2.2.2 发布咯! Spring Boot 2.2.1 发布,一个有点坑的版本! 2.2.1 发布没过一个月,2.2.2 就来了。 Maven依赖给大家奉上:
134 0
Spring Boot 2.2.2 发布,新增 2 个新特性!