vlambda博客
学习文章列表

基于 Nacos 配置中心的动态日志配置方案

JAVA乐园
专注于Java技术栈,推送 Spring全家桶,Dubbo,Zookeeper,Redis,Linux,Nginx,多线程等相关技术知识,文章以解决实际问题为主,欢迎探讨。
302篇原创内容
Official Account

上面这两篇文章只是从技术角度说了,可以实现动态日志配置。但是并没有形成适用生产环境使用的方案。今天介绍一种基于 Nacos 配置中心的动态配置日志级别的方案。


0x01:安装 Nacos 配置中心

配置中心 Nacos 的官网

官网:https://nacos.io/zh-cn/docs/quick-start.html

下载安装包

基于 Nacos 配置中心的动态日志配置方案

需要注意一下 Nacos 需要 64 位操作系统和 64 位的JDK,如果不是 64 位的启动时会出现以下异常。

 at com.alipay.sofa.jraft.core.NodeImpl.init(NodeImpl.java:138)
        at com.alipay.sofa.jraft.RaftServiceFactory.createAndInitRaftNode(RaftServiceFactory.java:47)
        at com.alipay.sofa.jraft.RaftGroupService.start(RaftGroupService.java:129)
        at com.alibaba.nacos.core.distributed.raft.JRaftServer.createMultiRaftGroup(JRaftServer.java:268)
        at com.alibaba.nacos.core.distributed.raft.JRaftProtocol.addRequestProcessors(JRaftProtocol.java:163)
        at com.alibaba.nacos.naming.core.v2.service.impl.PersistentClientOperationServiceImpl.<init>(PersistentClientOperationServiceImpl.java:92)
        at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
        at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
        at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
        at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
        at org.springframework.beans.BeanUtils.instantiateClass(BeanUtils.java:175)
        ... 57 common frames omitted
Caused by: java.lang.UnsupportedOperationException: Cannot determine JNI library name for ARCH='x86' OS='windows 10' name='rocksdb'
        at org.rocksdb.util.Environment.getJniLibraryName(Environment.java:88)
        at org.rocksdb.NativeLibraryLoader.<clinit>(NativeLibraryLoader.java:19)
        ... 74 common frames omitted

启动命令

startup.cmd -m standalone

因为启动脚本默认使用集群模式启动,为了不需要使用命令还,改动一下启动脚本,修改如下

基于 Nacos 配置中心的动态日志配置方案

启动成功,显示如下日志

2021-05-14 22:00:34,140 INFO Initializing ExecutorService 'taskScheduler'
2021-05-14 22:00:34,178 INFO Exposing 16 endpoint(s) beneath base path '/actuator'
2021-05-14 22:00:34,465 INFO Tomcat started on port(s): 8848 (http) with context path '/nacos'
2021-05-14 22:00:34,473 INFO Nacos started successfully in stand alone mode. use embedded storage

访问 Nacos 配置中心,对应的账号和密码 nacos / nacos

http://192.168.10.6:8848/nacos/index.html


0x02: 在配置中心创建配置文件 dynamics-log.json

内容如下

{
    "logger": [
        {
            "name":"ROOT",
            "level":"debug"
        }
    ]
}


0x03:pom.xml 文件引入依赖

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

    <modelVersion>4.0.0</modelVersion>

    <groupId>com.olive</groupId>
    <artifactId>valid-demo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <packaging>jar</packaging>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.8.RELEASE</version>
        <relativePath /> 
    </parent>
    <name>valid-demo</name>
    <url>http://maven.apache.org</url>
    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba.nacos</groupId>
            <artifactId>nacos-client</artifactId>
            <version>0.5.0</version>
        </dependency>

    </dependencies>
</project>

主要多引入 Nacos 客户端(nacos-client )依赖


0x04:编译监听器

要达到动态的效果,一般有 PUSH 和 PULL 两种方式。Nacos 内部提供了监听器,只要实现相关方法就可以对不同的 data-id  进行监听。大致代码如下:

import java.util.concurrent.Executor;

import javax.annotation.PostConstruct;

import org.springframework.context.annotation.Configuration;

import com.alibaba.nacos.api.NacosFactory;
import com.alibaba.nacos.api.config.ConfigService;
import com.alibaba.nacos.api.config.listener.Listener;
import com.alibaba.nacos.api.exception.NacosException;

@Configuration
public class LoggerDynamicsConfig {

    private String serverAddr = "127.0.0.1:";

    private String dataId = "dynamics-log.json";

    private String group = "DEFAULT_GROUP";

    private long timeoutMs = 50000L;

    @PostConstruct
    public void init() {
        try {
            ConfigService configService = NacosFactory.createConfigService(serverAddr);
            String configInfo = configService.getConfig(dataId, group, timeoutMs);
            System.out.println("configInfo = " + configInfo);   
            configService.addListener(dataId, group, new Listener() {
                @Override
                public void receiveConfigInfo(String configInfo) {
                    System.out.println("recieve configInfo : " + configInfo);
                }

                @Override
                public Executor getExecutor() {
                    return null;
                }
            });
        } catch (NacosException e) {
            e.printStackTrace();
        }
    }
}

启动服务,可以看到控制台打印如下日志,说明可以获取到 Nacos 配置中心的配置项。

2021-05-14 22:13:56.265 [main] INFO  c.alibaba.nacos.client.identify.CredentialWatcher - [] [] [] No credential found
configInfo = {
    "logger": [
        {
            "name":"ROOT",
            "level":"debug"
        }
    ]
}
recieve configInfo : {
    "logger": [
        {
            "name":"ROOT",
            "level":"debug"
        }
    ]
}
2021-05-14 22:13:56.563 [main] INFO  o.s.scheduling.concurrent.ThreadPoolTaskExecutor - Initializing ExecutorService 'applicationTaskExecutor'

动态在 Nacos 配置中心修改一下,可以看到控制台打印如下日志,说明服务是可以动态监听到配置的改变的。

recieve configInfo : {
    "logger": [
        {
            "name":"ROOT",
            "level":"debug"
        }, {
            "name":"com.spring",
            "level":"info"
        }
    ]
}


0x05:动态日志改造说明

  • 在 receiveConfigInfo() 方法中,把拿到的配置 json 串构造成一个对象数组,比如定义为 LoggerConfig[]。

  • 基于 [  ] 改造,把 LoggerController 的 printAllLogger() 方法改成一个获取所有日志对象的方法,比如

public List<Logger> getAllLogger(){
     //TODO

}
  • 对配置动态变化构造的 LoggerConfig[] 数组与调用 getAllLogger() 获取的所有日志对象进行遍历比较,进行动态更新

喜欢,在看