SpringBoot(三) - Slf4j+logback 日志,异步请求,定时任务

时间:2022-10-14 12:07:23

1、Slf4j+logback 日志

SpringBoot框架的默认日志实现:slf4j + logback;

默认日志级别:info,对应了实际生产环境日志级别;

1.1 日志级别

# 常见的日志框架中,日志级别都包含五种,优先级从低到高:
trace < debug < info < warn < error 

#日志输出规则是:
自动设置的日志级及更高级别,进行日志输出;
比如当前日志级别是info,那么日志输出的级别包含:info,warn,error,凡是业务的这三个级别,都会输出到日志文件

1.1.1 trace 日志级别

trace 日志级别,了解,实际开发中,几乎不会使用此级别;(配置文件指定为 trace 级别才会输出);

logger.trace("------------ trace 日志级别,了解,实际开发中,几乎不会使用此级别 ------------------");

1.1.2 debug 日志级别

  1. debug 日志级别,掌握,实际开发中,此日志级别作为调试日志使用,是线上调试问题定位的有效手段;
  2. 强调:线上一般默认是不开debug日志,因此日志级别记录的日志极为详情,会产生大量的日志内容及文件;
  3. 发现线上问题,不好定位时,临时开启debug;
logger.debug("------------ {} 日志级别,{},实际开发中,此日志级别作为调试日志使用,是线上调试问题定位的有效手段 ------------------","debug","掌握");

1.1.3 info 日志级别

info 日志级别,掌握,实际开发中,此日志级别是核心业务环境日志,不需要记录特别详细,一般都是接口 入和出,方便版本上线查看业务是否正常使用;

logger.info("------------ {} 日志级别,{},实际开发中,此日志级别时核心业务环境日志,不需要记录特别详细 ------------","info","掌握");

1.1.4 warn 日志级别

warn 日志级别,掌握,实际开发中,此日志级别是业务警告日志,警告日志不一定是错误,可能业务异常流程,或者数据错误判断;

logger.warn("------------ {} 日志级别,{},实际开发中,此日志级别时业务警告日志 ------------","warn","掌握");

1.1.5 error 日志级别

error 日志级别,掌握,实际开发中,此日志级别是核心业务错误,凡是系统中出现了异常或者程序错误,都必须使用error日志,级别最高,确保必须输出,可以有效的记录线上业务的错误;

logger.error("------------ {} 日志级别,{},实际开发中,此日志级别是核心业务错误 ------------","error","掌握");

1.2 日志使用

1.2.1 创建日志对象

//创建日志对象
Logger logger = LoggerFactory.getLogger(getClass());

logger.trace("");
logger.debug("");
logger.info("");
logger.warn("");
logger.error("");

1.2.2 @Slf4j 注解

@Slf4j
public class ChargeResultNotifySchedule{

    log.trace("");
    log.debug("");
    log.info("");
    log.warn("");
    log.error("");
    
}

1.3 配置文件配置日志 信息

1.3.1 测试默认日志级别

1.3.1.1 直接运行测试类

SpringBoot(三) - Slf4j+logback 日志,异步请求,定时任务

1.3.1.2 测试类增加 @RunWith(SpringRunner.class) 注解

测试类增加 @RunWith(SpringRunner.class) 注解 运行的是SpringBoot项目测试,会读取到配置文件;

SpringBoot(三) - Slf4j+logback 日志,异步请求,定时任务

1.3.2 修改配置文件信息

1.3.2.1 修改默认日志级别为 debug
# 默认日志级别为 info ,更改默认日志级别debug
logging:
  level:
    com:
      kgc:
        sbt: debug

SpringBoot(三) - Slf4j+logback 日志,异步请求,定时任务

1.4 指定日志输出

1.4.1 指定日志输出到指定文件

  1. 默认日志只输出到控制台;
  2. 指定输出到指定文件,默认会加载到根路径下;
  3. 所有的日志,都是追加记录,不会执行覆盖;
logging:
	file: kh96-logging.log

日志输出到根目录下的指定文件名下:

SpringBoot(三) - Slf4j+logback 日志,异步请求,定时任务

1.4.2 指定日志输入到指定目录下

不指定文件名,SpringBoot中的logback会由默认的日志名spring.log;

logging:
	path: D:/KEGONGCHANG/DaiMa/IDEA/KH96/SpringBoot/SpringBoot/TempFile/kh96-logging2

默认名:

SpringBoot(三) - Slf4j+logback 日志,异步请求,定时任务

输出文件:

SpringBoot(三) - Slf4j+logback 日志,异步请求,定时任务

1.4.3 指定输出格式

# 了解 %d日期,%thread 线程名称,%-5leavel 日志级别 %logger{50} 日志类路径 %msg 日志内容
logging:
	pattern:
    console: "%d{yyyy-MM-dd HH:mm:ss} +++ [%thread] +++ %-5level +++ %logger{100} +++ %msg%n"
    file: "%d{yyyy-MM-dd HH:mm:ss} +++ [%thread] +++ %-5level +++ %logger{100} +++ %msg%n

SpringBoot(三) - Slf4j+logback 日志,异步请求,定时任务

1.4.4 指定输入格式文件

网上由很多;

<?xml version="1.0" encoding="UTF-8"?>
<!--
    scan:配置文件发生改变,是否被重新加载,默认值为true。
    scanPeriod:设置监测配置文件是否有修改的时间间隔,当scan为true时,此属性生效。默认的时间间隔为1分钟。
    debug:是否打印出logback内部日志信息,实时查看logback运行状态。默认值为false。
-->
<configuration scan="true" scanPeriod="60 seconds" debug="false">
    <!-- 日志的根目录,可以自动创建log目录,一般公司都是统一的日志目录,不能乱写 -->
    <property name="LOG_HOME" value="D:/KEGONGCHANG/DaiMa/IDEA/KH96/SpringBoot/SpringBoot/TempFile/log" />
    <!-- 日志文件名称 -->
    <property name="appName" value="log-sbt-kh96"/>
    <!-- 控制台输出 -->
    <appender name="stdout" class="ch.qos.logback.core.ConsoleAppender">
        <!--
        日志输出格式:
			%d{日期时间格式},
			%thread:线程名,
			%-5level:级别从左显示5个字符宽度
			%logger{60} 表示logger名字最长60个字符,否则按照句点分割。 
			%msg:记录的日志消息,
			%n是换行符
        -->
        <layout class="ch.qos.logback.classic.PatternLayout">
            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{60} - %msg%n</pattern>
        </layout>
    </appender>

    <!-- 滚动文件记录,先将日志记录到指定文件,当符合某个条件时,将日志记录到其他文件 -->  
    <appender name="appLogAppender" class="ch.qos.logback.core.rolling.RollingFileAppender">
        <!-- 指定服务器记录日志文件的名称 -->
        <file>${LOG_HOME}/${appName}.log</file>
        <!--
            当发生滚动时,决定 RollingFileAppender 的行为,涉及文件移动和重命名
            TimeBasedRollingPolicy: 最常用的滚动策略,它根据时间来制定滚动策略,既负责滚动也负责触发滚动。
        -->
        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
            <!--
                滚动时产生的文件的存放位置及文件名称 %d{yyyy-MM-dd}:按天进行日志滚动
                %i:当文件大小超过maxFileSize时,按照i进行文件滚动
            -->
            <fileNamePattern>${LOG_HOME}/${appName}-%d{yyyy-MM-dd}-%i.log</fileNamePattern>
            <!-- 
                可选节点,控制保留的归档文件的最大数量,超出数量就删除旧文件。假设设置每天滚动,
                且maxHistory是30,则只保存最近30天的文件,删除之前的旧文件。注意,删除旧文件时,
                那些为了归档而创建的目录也会被删除。
            -->
            <MaxHistory>30</MaxHistory>
            <!-- 
                当日志文件超过maxFileSize指定的大小是,根据上面提到的%i进行日志文件滚动 注意此处配置SizeBasedTriggeringPolicy是无法实现按文件大小进行滚动的,必须配置timeBasedFileNamingAndTriggeringPolicy
            -->
            <timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
                <maxFileSize>30MB</maxFileSize>
            </timeBasedFileNamingAndTriggeringPolicy>
        </rollingPolicy>
        <!-- 日志输出格式: -->     
        <layout class="ch.qos.logback.classic.PatternLayout">
            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [ %thread ] - [ %-5level ] [ %logger{60} : %line ] - %msg%n</pattern>
        </layout>
    </appender>

    <!-- 
		logger主要用于存放日志对象,也可以定义日志类型、级别
		name:表示匹配的logger类型前缀,也就是包的前半部分
		level:要记录的日志级别,包括 TRACE < DEBUG < INFO < WARN < ERROR
		additivity:作用在于当前logger配置是否使用 rootLogger配置的appender进行输出,即此logger的打印信息是否向上级传递
		  false:表示只用当前logger的appender-ref
          true:表示当前logger的appender-ref和rootLogger的appender-ref都有效
    -->
    <!-- 此种没有指定自己的appender-ref,所以直接使用root标签的配置 -->
    <logger name="com.kgc.sbt" level="debug" />
    <logger name="org.springframework" level="debug"/>

    <!-- 
        root与logger是父子关系,没有特别定义则默认为root,任何一个类只会和一个logger对应,
        要么是定义的logger,要么是root,判断的关键在于找到这个logger,然后判断这个logger的appender和level。
    -->
    <root level="debug">
        <appender-ref ref="stdout" />
        <appender-ref ref="appLogAppender" />
    </root>
</configuration> 

2、异步请求

2.1 异步请求处理实现类

@Service
@Slf4j
public class ChargeServiceImpl implements ChargeService{

    @Override
    @Async  
    //开启异步线程注解,如果是同一个类中的其他方法,添加此异步处理注解,异步是不生效的
    //使用的是Spring内置的线程池
    public void executesAsynCharge(String chargeTel, Double chargeMoney) {
        try {
            TimeUnit.MILLISECONDS.sleep(2000);
        }catch (Exception e){
            e.printStackTrace();
        }
        log.info("********* 异步渠道 充值成功,充值手机号:{},充值金额:{} ************",chargeTel,chargeMoney);

    }
}

2.2 主启动类

主启动类上必须增加@EnableAsync 注解,开启异步处理功能;

@SpringBootApplication
@EnableAsync //开启异步处理功能
public class Springboot03AsyztimerApplication {

    public static void main(String[] args) {
        SpringApplication.run(Springboot03AsyzyimerApplication.class, args);
    }

}

2.3 请求调用异步处理方法

@RestController
@Slf4j
public class ChargeController {

    @Autowired
    ChargeService chargeService;
    
    @GetMapping("/asyncCharge")
    public  String asyncCharge(@RequestParam("chargeTel") String chargeTel,@RequestParam("chargeMoney") Double chargeMoney){

        log.info("------ 开始充值,充值手机号:{},充值金额:{} 开始调用充值渠道充值 --------- ",chargeTel,chargeMoney);
//        log startTimeMillis = System.currentTimeMillis(); //旧的获取当前时间毫秒数
        long startTimeMillis = Instant.now().toEpochMilli();

        //调用充值渠道 异步 充值
        chargeService.executesAsynCharge(chargeTel,chargeMoney);

        long finishTimeMillis = Instant.now().toEpochMilli();
        log.info("------ 结束充值,充值手机号:{},充值金额:{} ,充值总耗时:{}-----------",chargeTel,chargeMoney,finishTimeMillis-startTimeMillis);

        return String.format("%s充值%s成功!",chargeTel,chargeMoney);

    }
    
}

3、定时任务

3.1 场景

异步充值结果,定时批量回调订单;

public void chargeResultNotifyMethodOne(){

        //模拟从数据库获取5笔需要回调的充值订单,进行批量回调结果
        List<String> chargeOrderList = Arrays.asList("KH001","KH002","KH003","KH004","KH005");

        //循环处理需要回调的5笔订单
        log.info("---------- 开始 执行批量回调充值结果------------");

        chargeOrderList.forEach(chargeOrderNo->{
            log.info("***** 充值订单:{},回调重接成功! ******");

            try{
                TimeUnit.MILLISECONDS.sleep(100);
            }catch (Exception e){
                e.printStackTrace();
            }

            log.info("---------- 结束 执行批量回调充值结果 ------------");
        });

}

3.2 注解

3.2.1 @Scheduled(fixedDelay = 5 * 1000)

fixedDelay :计时规则: 从上一次执行结束 开始计时 到 下一次定时任务开始 ,不关心前一次定时任务耗时多久;

3.2.2 @Scheduled(fixedRate = 5 * 1000)

fixedRate: 计时规则:从上一次定时任务执行开始 开始计时 到 下一次定时任务开始,如果上一次定时任务 超过定时,上一次执行完后,下一次立即执行;

cron表达式:既可以是实现循环时间间隔,执行定时任务,也可以执行某个时刻的定时任务,通过指定表达式实现的,灵活度是三种最高的
1)循环定时: 每次执行的定时任务时间点,是由cron表达是决定的,其实都是预置好的;比如5秒,5秒执行一次定时
2)定点定时:在指定的某个时刻,执行一次定时任务

秒 分 时 日 月 周
@Scheduled(cron = "*/5 * * * * ?")

3.2.4 @EnableScheduling

@SpringBootApplication
@EnableScheduling //开启定时任务功能
public class Springboot03AsyztimerApplication {

    public static void main(String[] args) {
        SpringApplication.run(Springboot03AsyzyimerApplication.class, args);
    }

}