logstash的部署和使用

Myth丶恋晨 2022-05-17 08:04 267阅读 0赞

1、下载logstash

https://www.elastic.co/downloads/elasticsearch

2、修改配置

cd config
       vim log4j_es.conf
       
        input {
            log4j {
                host => "127.0.0.1"
                port => 4560
            }
        }
        output {
            stdout {
              codec => rubydebug
            }
            elasticsearch{
                hosts => ["localhost:9200"]
                index => "log4j-%{+YYYY.MM.dd}"
                document_type => "log4j_type"
            }
        }

’3、启动logstash

./bin/logstash -f config/log4j_es.conf

**4. Log4j记录日志到Logstash**

4-1) 新建maven项目

pom中的关键dependency配置如下：

4-2) log4j.properties(放在resources文件夹下)

### 设置###
    log4j.rootLogger = debug,stdout,D,E,logstash
    
    ### 输出信息到控制抬 ###
    log4j.appender.stdout = org.apache.log4j.ConsoleAppender
    log4j.appender.stdout.Target = System.out
    log4j.appender.stdout.layout = org.apache.log4j.PatternLayout
    log4j.appender.stdout.layout.ConversionPattern = [%-5p] %d{yyyy-MM-dd HH:mm:ss,SSS} method:%l%n%m%n
    
    ### 输出DEBUG 级别以上的日志到=/Users/bee/Documents/elk/log4j/debug.log###
    log4j.appender.D = org.apache.log4j.DailyRollingFileAppender
    log4j.appender.D.File = /Users/KG/Documents/logs/elk/debug.log
    log4j.appender.D.Append = true
    log4j.appender.D.Threshold = DEBUG
    log4j.appender.D.layout = org.apache.log4j.PatternLayout
    log4j.appender.D.layout.ConversionPattern = %-d{yyyy-MM-dd HH:mm:ss}  [ %t:%r ] - [ %p ]  %m%n
    
    ### 输出ERROR 级别以上的日志到=/Users/bee/Documents/elk/log4j/error.log  ###
    log4j.appender.E = org.apache.log4j.DailyRollingFileAppender
    log4j.appender.E.File =/Users/KG/Documents/logs/elk/error.log
    log4j.appender.E.Append = true
    log4j.appender.E.Threshold = ERROR
    log4j.appender.E.layout = org.apache.log4j.PatternLayout
    log4j.appender.E.layout.ConversionPattern = %-d{yyyy-MM-dd HH:mm:ss}  [ %t:%r ] - [ %p ]  %m%n
    
    #输出日志到logstash
    log4j.appender.logstash=org.apache.log4j.net.SocketAppender
    log4j.appender.logstash.RemoteHost=127.0.0.1
    log4j.appender.logstash.port=4560
    log4j.appender.logstash.ReconnectionDelay=60000
    log4j.appender.logstash.LocationInfo=true

4-3) Java代码(ElkLog4jTest.java)：

package org.genesis.arena.elk;
    
    import org.apache.log4j.Logger;
    
    /**
     * Created by KG on 17/3/27.
     */
    public class ElkLog4jTest {
        private static final Logger logger = Logger.getLogger(ElkLog4jTest.class);
        public static void main(String[] args) throws Exception {
            logger.debug("This is a debug message!");
            logger.info("This is info message!");
            logger.warn("This is a warn message!");
            logger.error("This is error message!");
    
            try{
                System.out.println(5/0);
            }catch(Exception e){
                logger.error(e);
            }
        }
    }

5、展示效果

![70][]

[70]: /images/20220517/4e808aaaa4ab41e3b117431aab81a576.png