java B2B2C Springboot电子商务平台源码-统一日志管理ELK

深藏阁楼爱情的钟 2022-03-15 03:46 168阅读 0赞

什么是ELK？

ELK是三个开源软件的缩写，分别表示：Elasticsearch , Logstash, Kibana , 它们都是开源软件。新增了一个FileBeat，它是一个轻量级的日志收集处理工具(Agent)，Filebeat占用资源少，适合于在各个服务器上搜集日志后传输给Logstash，官方也推荐此工具。

需要JAVA Spring Cloud大型企业分布式微服务云构建的B2B2C电子商务平台源码 壹零叁八柒柒肆六二六

由于Spring默认使用的就是Logback管理日志，所以无需引入Logback包，但集成ELK时需要按照logstash的日志格式进行传输，所以这里引入编码包。

<dependency>
        <groupId>net.logstash.logback</groupId>
        <artifactId>logstash-logback-encoder</artifactId>
    </dependency>
    复制代码

日志集成 在resources目录下新建logback-spring.xml，重新配置logback日志管理规则；

<?xml version="1.0" encoding="UTF-8"?>
    
    
    
    
    <configuration  scan="true" scanPeriod="10 seconds">
    
        
    
        <contextName>server-user</contextName>
        
        <property name="log.path" value="/Users/luoming/Documents/java/ideaProject/logs" />
    
        
        
        <conversionRule conversionWord="clr" converterClass="org.springframework.boot.logging.logback.ColorConverter" />
        <conversionRule conversionWord="wex" converterClass="org.springframework.boot.logging.logback.WhitespaceThrowableProxyConverter" />
        <conversionRule conversionWord="wEx" converterClass="org.springframework.boot.logging.logback.ExtendedWhitespaceThrowableProxyConverter" />
        
        <property name="CONSOLE_LOG_PATTERN" value="${CONSOLE_LOG_PATTERN:-%clr(%d{yyyy-MM-dd HH:mm:ss.SSS}){faint} %clr(${LOG_LEVEL_PATTERN:-%5p}) %clr(${PID:- }){magenta} %clr(---){faint} %clr([%15.15t]){faint} %clr(%-40.40logger{39}){cyan} %clr(:){faint} %m%n${LOG_EXCEPTION_CONVERSION_WORD:-%wEx}}"/>
    
    
        
        <appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
            
            <filter class="ch.qos.logback.classic.filter.ThresholdFilter">
                <level>debug</level>
            </filter>
            <encoder>
                <Pattern>${CONSOLE_LOG_PATTERN}</Pattern>
                
                <charset>UTF-8</charset>
            </encoder>
        </appender>
    
    
        
    
        
        <appender name="DEBUG_FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
            
            <file>${log.path}/server-user.log</file>
            
            <encoder>
                <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern>
                <charset>UTF-8</charset> 
            </encoder>
            
            <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
                
                <fileNamePattern>${log.path}/debug/log-debug-%d{yyyy-MM-dd}.%i.log</fileNamePattern>
                <timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
                    <maxFileSize>100MB</maxFileSize>
                </timeBasedFileNamingAndTriggeringPolicy>
                
                <maxHistory>15</maxHistory>
            </rollingPolicy>
            
            <filter class="ch.qos.logback.classic.filter.LevelFilter">
                <level>debug</level>
            </filter>
        </appender>
    
        
        <appender name="LOG_FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
            
            <file>${log.path}/server-user-error.log</file>
            
            <encoder>
                <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern>
                <charset>UTF-8</charset> 
            </encoder>
            
            <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
                <fileNamePattern>${log.path}/error/log-error-%d{yyyy-MM-dd}.%i.log</fileNamePattern>
                <timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
                    <maxFileSize>100MB</maxFileSize>
                </timeBasedFileNamingAndTriggeringPolicy>
                
                <maxHistory>15</maxHistory>
            </rollingPolicy>
            
            <filter class="ch.qos.logback.classic.filter.LevelFilter">
                <level>ERROR</level>
            </filter>
        </appender>
    
        
        
        
        
    
    
        
        <appender name="LOGSTASH" class="net.logstash.logback.appender.LogstashTcpSocketAppender">
            <remoteHost>localhost</remoteHost>
            <port>9601</port>
            
            <encoder charset="UTF-8" class="net.logstash.logback.encoder.LogstashEncoder" >
                
                <customFields>{
        "appname":"server-user"}</customFields>
            </encoder>
        </appender>
    
        
        <springProfile name="dev">
            <logger name="com.luying.cloud" level="INFO"/>
        </springProfile>
    
        
        <springProfile name="test">
            <logger name="com.luying.cloud" level="DEBUG"/>
        </springProfile>
    
        
        <springProfile name="prd">
            <logger name="com.luying.cloud" level="WARN" additivity="false">
                <appender-ref ref="CONSOLE"/>
                <appender-ref ref="LOG_FILE"/>
                <appender-ref ref="LOGSTASH" />
            </logger>
        </springProfile>
    
        <root level="INFO">
            <appender-ref ref="CONSOLE" />
            <appender-ref ref="LOGSTASH" />
            
        </root>
    
        
        
        
        
        
        
        
        
        
        
    
    </configuration>
    复制代码

大家仔细看name=”LOGSTASH”的日志分发器，这个分发器的作用就是像logstash发送应用日志。 [java B2B2C Springboot电子商务平台源码 ][java B2B2C Springboot_]

[java B2B2C Springboot_]: https://link.juejin.im?target=http%3A%2F%2Fminglisoft.cn%2Fhonghu%2Ftech.html