第三十二章 elk（3）- broker架構 + 引入logback

實際中最好用的日志框架是logback，我們現在會直接使用logback通過tcp協議向logstash-shipper輸入日志數據。在上一節的基礎上修改！！！

一、代碼

1、pom.xml

        <!-- logstash-logback -->
        <dependency>
            <groupId>net.logstash.logback</groupId>
            <artifactId>logstash-logback-encoder</artifactId>
            <version>4.6</version>
        </dependency>

2、application.properties

#set logstash shipper host
logstash.host=127.0.0.1
#set logstash shipper port
logstash.port=4560
logstash.level=info

3、LogstashProperties.java

package com.xxx.secondboot.logstash;

import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;

import lombok.Getter;
import lombok.Setter;

@Component
@ConfigurationProperties(prefix = "logstash")
@Getter
@Setter
public class LogstashProperties {
    private String host;
    private int    port;
    private String level;
}

4、LogstashConfig.java

package com.xxx.secondboot.logstash;

import java.net.InetSocketAddress;

import javax.annotation.PostConstruct;

import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import ch.qos.logback.classic.Level;
import ch.qos.logback.classic.Logger;
import net.logstash.logback.appender.LogstashTcpSocketAppender;
import net.logstash.logback.encoder.LogstashEncoder;

/**
 * 該類是可以配置成xml配置文件的，但是那樣的話，就不能由客戶端指定參數了
 */
@Component
public class LogstashConfig {
    @Autowired
    private LogstashProperties logstashProperties;

    @PostConstruct
    public void init() {
        Logger rootLogger = (Logger) LoggerFactory.getLogger(Logger.ROOT_LOGGER_NAME);
        LogstashTcpSocketAppender appender = new LogstashTcpSocketAppender();
        appender.setName("stash");
        appender.addDestinations(new InetSocketAddress(logstashProperties.getHost(), logstashProperties.getPort()));
       
        LogstashEncoder encoder = new LogstashEncoder();
        encoder.setCustomFields("{ \"service\":\"" + "myboot2" + "\"}");//服務名會在日志中顯示（可以方便的知道該日志是哪個服務的）
        encoder.start();
        
        appender.setEncoder(encoder);
        appender.setContext(rootLogger.getLoggerContext());
        appender.start();
        rootLogger.addAppender(appender);
        rootLogger.setLevel(Level.toLevel(logstashProperties.getLevel()));
    }
}

注意：

• init()方法在LogstashConfig bean構建之后執行，之后的日志信息都會寫入到LogstashTcpSocketAppender中去
• 2、3、4其實也可以沒有，直接使用xml配置即可（參考：https://github.com/logstash/logstash-logback-encoder/tree/logstash-logback-encoder-4.7），但是這樣的話，就無法有我們自己指定logstash參數了，或者需要在xml中指定（這里的配置不在consul中配置），而配在application.properties中（實際上就是配在了consul中）

5、AdviceController.java

private static final Logger LOGGER = LoggerFactory.getLogger(AdviceController.class);

    @RequestMapping(value = "/testLog", method = RequestMethod.GET)
    public String testLog() {
        LOGGER.info("test info");
        LOGGER.debug("test debug");
        LOGGER.error("test error");
        LOGGER.warn("test warn");
        return "test logstash-logback";
    }

 

二、測試

在上一節的基礎上修改logstash-shipper的配置文件：（輸入為tcp，配置參考：https://github.com/logstash/logstash-logback-encoder/tree/logstash-logback-encoder-4.7）

input {
    tcp {
        mode => "server"
        host => "127.0.0.1"
        port => 4560
        codec => "json_lines"
    }
}

filter {
    
}

output {
    redis{
        data_type => "list"
        host => ["127.0.0.1:6379"]
        key => "microservice:logstash:redis"
    }
}

之后運行啟動程序，這時候kibana就會打印出啟動日志了，在日志中有servicename的體現，之后訪問swagger，我們會發現3條不同級別的日志都進入kibana進行展示了。