专栏首页JAVA乐园SpringBoot集成RocketMQ,rocketmq_client.log日志文件配置

SpringBoot集成RocketMQ,rocketmq_client.log日志文件配置

SpringBoot项目集成rocketmq-client

<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-client</artifactId>
     <version>4.7.0</version>
</dependency>

项目启动时会在{user.home}/logs目录下创建一个rocketmq_client.log日志文件,文件全路径是:{user.home}/logs/rocketmqlogs/rocketmq_client.log。如果一个系统部署多个微服务话,会导致所有的微服务的RocketMQ的日志都会打印到该文件里,不容易定位到底是哪个微服务的RocketMQ Client出现了错误。所以需要配置rocketmq_client.log日志目录到各自微服务的日志目录加以区分。

通过源码org.apache.rocketmq.client.log.ClientLogger可以看到,在项目启动时会读取是否启动slf4j配置,读取的配置名称是:

rocketmq.client.logUseSlf4j

如果该配置为true的话,则会直接获取logger名称为RocketmqClientAppender名称为RocketmqClientAppender的配置,以下是源码:

public class ClientLogger {

    public static final String CLIENT_LOG_USESLF4J = "rocketmq.client.logUseSlf4j";
    public static final String CLIENT_LOG_ROOT = "rocketmq.client.logRoot";
    public static final String CLIENT_LOG_MAXINDEX = "rocketmq.client.logFileMaxIndex";
    public static final String CLIENT_LOG_FILESIZE = "rocketmq.client.logFileMaxSize";
    public static final String CLIENT_LOG_LEVEL = "rocketmq.client.logLevel";
    public static final String CLIENT_LOG_ADDITIVE = "rocketmq.client.log.additive";
    public static final String CLIENT_LOG_FILENAME = "rocketmq.client.logFileName";
    public static final String CLIENT_LOG_ASYNC_QUEUESIZE = "rocketmq.client.logAsyncQueueSize";
    public static final String ROCKETMQ_CLIENT_APPENDER_NAME = "RocketmqClientAppender";

    private static final InternalLogger CLIENT_LOGGER;

    private static final boolean CLIENT_USE_SLF4J;

    //private static Appender rocketmqClientAppender = null;

    static {
        // 获取是否启动slf4j配置
        CLIENT_USE_SLF4J = Boolean.parseBoolean(System.getProperty(CLIENT_LOG_USESLF4J, "false"));
        if (!CLIENT_USE_SLF4J) {
            InternalLoggerFactory.setCurrentLoggerType(InnerLoggerFactory.LOGGER_INNER);
            CLIENT_LOGGER = createLogger(LoggerName.CLIENT_LOGGER_NAME);
            createLogger(LoggerName.COMMON_LOGGER_NAME);
            createLogger(RemotingHelper.ROCKETMQ_REMOTING);
        } else {
            // 获取logger
            CLIENT_LOGGER = InternalLoggerFactory.getLogger(LoggerName.CLIENT_LOGGER_NAME);
        }
    }

    // .........
}

通过以上源码分析可以看到如下一小段

System.getProperty(CLIENT_LOG_USESLF4J, "false")

所有在SpringBoot项目启动类中添加以下代码:

public class Application {
    public static void main(String[] args) {
       //添加配置
        System.setProperty(ClientLogger.CLIENT_LOG_USESLF4J,"true");
        SpringApplication.run(Application.class, args);
    }
}

添加完以上代码后,然后在logback-spring.xml配置文件中配置日志的输出,具体配置如下:

<!-- rocketmq日志 -->
    <appender name="RocketmqClientAppender" class="ch.qos.logback.core.rolling.RollingFileAppender">
        <file>${LOG_DIR}/rocketmq_client.log</file>
        <rollingPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
            <fileNamePattern>${LOG_DIR}/history/rocketmq_client.%d{yyyyMMdd}.%i.log</fileNamePattern>
            <maxFileSize>1024M</maxFileSize>
            <!--保留时间,单位:天-->
            <maxHistory>30</maxHistory>
        </rollingPolicy>
        <encoder charset="UTF-8">
            <pattern>%d{yy-MM-dd.HH:mm:ss.SSS} [%-16t] %-5p %-22c{0} %X{ServiceId} - %m%n</pattern>
        </encoder>
    </appender>
    <logger name="RocketmqClient" additivity="false">
        <level value="warn" />
        <appender-ref ref="RocketmqClientAppender"/>
    </logger>

配置完毕,启动项目可以看到日志文件已经输出到指定的位置了。

备注:

 System.setProperty(ClientLogger.CLIENT_LOG_USESLF4J,"true");

这段代码配置java的系统属性,也可以通过JAVA_OPTS方式设置。即在SpringBoot的启动脚本例如Shell脚本加上:

java -jar -Drocketmq.client.logUseSlf4j=true  xxx-1.x.x.jar

本文分享自微信公众号 - JAVA乐园(happyhuangjinjin88),作者:java乐园

原文出处及转载信息见文内详细说明,如有侵权,请联系 yunjia_community@tencent.com 删除。

原始发表时间:2020-11-06

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • SpringCloud常用5大组件作用

    springcloud是微服务架构的集大成者,将一系列优秀的组件进行了整合。基于springboot构建,对我们熟悉spring的程序员来说,上手比较容易。

    java乐园
  • 通俗易懂了解一下分库分表的概念

    以表的主键字段为依据,按照一定策略(取模,hash等),将本来在一个库中的数据拆分到多个库中。

    java乐园
  • 1、Elasticsearch创建Index

    另外Spring框架也提供了spring-data-elasticsearch对Elasticsearch进行CURD操作,但是最底层也是基于Elasticse...

    java乐园
  • 原创 | 私有5G网络的威胁分析

    随着越来越多的国家开始布局5G网络,5G时代的浪潮终于拉开大幕。当5G网络成熟商用之后,不仅提高了网络速度和带宽,更具有革新各种关键领域的潜力,如物联网(IoT...

    绿盟科技研究通讯
  • Future Pattern

    Started: 俗话说一年之计在于春,一天之计在于晨,当我起床的时候,看见表正指向九点钟,十一点下班,十点上班,这是我现在的工作节奏。来北京马上就一个月了,近...

    知然
  • 我发现了一个非常酷的软件,用自然语言编程!

    周六晚上10点半, 张大胖兴冲冲地在微信上找我:“欣哥,我发现一个编程软件,非常酷!”

    AI科技大本营
  • restapi(2)- generic restful CRUD:通用的restful风格数据库表维护工具

    研究关于restapi的初衷是想搞一套通用的平台数据表维护http工具。前面谈过身份验证和使用权限、文件的上传下载,这次来到具体的数据库表维护。我们在这篇...

    用户1150956
  • 实现属于自己的TensorFlow(一) - 计算图与前向传播

    前言 前段时间因为课题需要使用了一段时间TensorFlow,感觉这种框架很有意思,除了可以搭建复杂的神经网络,也可以优化其他自己需要的计算模型,所以一直想自...

    Python中文社区
  • 豆瓣网可用性测试报告

      豆瓣网简介:豆瓣(douban)是一个社区网站。网站由杨勃(网名“阿北”) 创立于2005年3月6日。该网站以书影音起家,提供关于书籍、电影、音乐等作品的信...

    小老鼠
  • 拖动图片改变位置

    在线展示:https://gethtml.cn/project/2020/04/14/index.html

    Dreamy.TZK

扫码关注云+社区

领取腾讯云代金券