rocket mq Logappender示例——支持log4j等

╰+哭是因爲堅強的太久メ 2022-06-08 04:53 235阅读 0赞

# Logappender示例 #

RocketMQ logappender提供了log4j appender，log4j2 appender和logback appender，用于使用，下面是配置示例。

#### log4j的 ####

当使用log4j属性配置文件时，配置如下。

log4j.appender.mq=org.apache.rocketmq.logappender.log4j.RocketmqLog4jAppender
    log4j.appender.mq.Tag=yourTag
    log4j.appender.mq.Topic=yourLogTopic
    log4j.appender.mq.ProducerGroup=yourLogGroup
    log4j.appender.mq.NameServerAddress=yourRocketmqNameserverAddress
    log4j.appender.mq.layout=org.apache.log4j.PatternLayout
    log4j.appender.mq.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss} %-4r [%t] (%F:%L) %-5p - %m%n

当使用log4j xml配置文件时，将其配置为此，并添加一个异步appender：

#### log4j2 ####

当使用log4j2，配置为这个。如果你想要无阻塞，只需配置一个asyncAppender作为参考。

#### 的logback ####

使用logback时，还需要一个asyncAppender。

<appender name="mqAppender1" class="org.apache.rocketmq.logappender.logback.RocketmqLogbackAppender">
        <tag>yourTag</tag>
        <topic>yourLogTopic</topic>
        <producerGroup>yourLogGroup</producerGroup>
        <nameServerAddress>yourRocketmqNameserverAddress</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>