前言
基于上一个章节，我们已经将ELK完整的构建完成，本章节将实际在微服务工程项目中接入ELK，并进行简单的数据检索验证。
本章概要
1、微服务工程改造；
2、启动ELK相关组件；
3、日志采集输出验证；
微服务工程改造
本次改造的工程基于springcloud学习章节的demo工程展开，本次仅改造eurekaserver(springcloud-eureka-register)工程。
1、在pom.xml增加logstash-logback-encoder模块，提供日志记录编码：
<dependency>
<groupId>net.logstash.logback</groupId>
<artifactId>logstash-logback-encoder</artifactId>
<version>4.9</version>
</dependency>
2、在logback-spring.xml中添加logstash日志记录配置：
<!-- logstash采集日志源 -->
<appender name="LOGSTASH" class="ch.qos.logback.core.rolling.RollingFileAppender">
<encoder class="net.logstash.logback.encoder.LogstashEncoder">
</encoder>
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<fileNamePattern>log/logstash-%d{yyyy-MM-dd}.log</fileNamePattern>
</rollingPolicy>
</appender>
<root level="INFO">
<appender-ref ref="LOGSTASH" />
</root>
3、添加日志记录，启动eurekaserver服务；
package com.shf.springcloud.eureka.register;
public class RegisterApp
{
private static final Logger logger=LoggerFactory.getLogger(RegisterApp.class);
@RequestMapping("/hello")
public String home() {
logger.info("hello world");
return "Hello Docker World.";
}
}
小节：以上我们工程改造完成，能够正常按照logstash实现日志的记录。
启动ELK相关组件
依次启动Elasticsearch、logstash、kibana3个服务应用，简单回顾下logstash中的配置：
input {
file {
path => "D:/learnworkspace/springcloud-netfilx-demo/springcloud-eureka-register/log/*.log"
}
stdin { }
}
filter {
}
output {
elasticsearch {
hosts => ["localhost:9200"]
}
stdout { codec => rubydebug }
}
其中file中的path正是指向上一个步骤中的日志文件路径。
日志采集输出验证
我们可以通过多个途径进行日志收集搜索验证：
1、控制台数据显示；
2、通过Curl直接查询ES；
3、通过Kibana查询；
控制台数据显示
通过Curl直接查询ES
curl -XGET 127.0.0.1:9200/_search?pretty&q=host=songhaifeng
通过Kibana查询
-
首先通过Console实现查询：GET /_search?pretty&q=message:hello world
版权声明：本文来源CSDN，感谢博主原创文章，遵循 CC 4.0 by-sa 版权协议，转载请附上原文出处链接和本声明。
原文链接：https://blog.csdn.net/songhaifengshuaige/article/details/70832972
站方申明：本站部分内容来自社区用户分享，若涉及侵权，请联系站方删除。
