RocketMQ

九、RocketMQ Logappender Example 日

2019-04-11  本文已影响30人  ASD_92f7

一、概述

参考链接:
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进行验证
只需要关注 mqAsyncAppender1mqAppender1 即可

 <?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即可

上一篇 下一篇

猜你喜欢

热点阅读