一、概述
参考链接:
http://rocketmq.apache.org/docs/logappender-example/
https://www.cnblogs.com/zhangjianbing/p/8992897.html
官网上,支持的日志种类有三种:
log4j、log4j2、logback
这里以logback为例进行配置
使用这个功能需要增加一个maven依赖 !!!!:
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-logappender</artifactId>
<version>4.3.0</version>
</dependency>
二、日志配置文件
使用springboot进行验证
只需要关注 mqAsyncAppender1 及 mqAppender1 即可
<?xml version="1.0" encoding="UTF-8"?>
<!-- 日志级别从低到高分为TRACE < DEBUG < INFO < WARN < ERROR < FATAL,如果设置为WARN,则低于WARN的信息都不会输出 -->
<!-- scan:当此属性设置为true时,配置文件如果发生改变,将会被重新加载,默认值为true -->
<!-- scanPeriod:设置监测配置文件是否有修改的时间间隔,如果没有给出时间单位,默认单位是毫秒。当scan为true时,此属性生效。默认的时间间隔为1分钟。 -->
<!-- debug:当此属性设置为true时,将打印出logback内部日志信息,实时查看logback运行状态。默认值为false。 -->
<configuration scan="true" scanPeriod="10 seconds">
<property name="log.path" value="D:/nmyslog/nmys" />
<contextName>logback</contextName>
<!--输出到控制台-->
<appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
<!--此日志appender是为开发使用,只配置最底级别,控制台输出的日志级别是大于或等于此级别的日志信息-->
<filter class="ch.qos.logback.classic.filter.ThresholdFilter">
<level>info</level>
</filter>
<encoder>
<Pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</Pattern>
<!-- 设置字符集 -->
<charset>UTF-8</charset>
</encoder>
</appender>
<appender name="mqAppender1" class="org.apache.rocketmq.logappender.logback.RocketmqLogbackAppender">
<tag>TagA</tag>
<topic>qqq</topic>
<producerGroup>yourLogGroup</producerGroup>
<nameServerAddress>10.1.11.155:9876</nameServerAddress>
<layout>
<pattern>%date %p %t - %m%n</pattern>
</layout>
</appender>
<appender name="mqAsyncAppender1" class="ch.qos.logback.classic.AsyncAppender">
<queueSize>1024</queueSize>
<discardingThreshold>80</discardingThreshold>
<maxFlushTime>2000</maxFlushTime>
<neverBlock>true</neverBlock>
<appender-ref ref="mqAppender1"/>
</appender>
<root level="info">
<appender-ref ref="mqAsyncAppender1" />
<appender-ref ref="CONSOLE" />
</root>
<!--生产环境:输出到文件-->
</configuration>
三、项目结构
日志文件 logback-spring.xml 放到 static目录下,如图
四、springboot配置文件 application.yml配置
server:
port: 9081
spring:
application:
name: rocketmq
logging:
config: classpath:static/logback-spring.xml
path: D:/asd/asd
最后,随意启动一个Consumer监听logback-spring.xml 中配置的topic即可