阿里云-云小站(无限量代金券发放中)
【腾讯云】云服务器、云数据库、COS、CDN、短信等热卖云产品特惠抢购

基于ElasticSearch+Logstash+Kibana的日志分析、存储、展示

258次阅读
没有评论

共计 4892 个字符,预计需要花费 13 分钟才能阅读完成。

ELK 简介

ELK 是一套完整的日志解决方案,由 ElasticSearch、Logstash、Kibana 这三款开源软件组成。

  • EastiSearch 是基于 Lucene 开发的分布式存储检引擎,用来存储各类日志;
  • Logstash 对日志进行收集、分析,并将其存储供以后使用:
  • Kibana 是基于 Node.js 开发的展示工具,为 Logstah 和 ElasticSearch 提供用于日志展示的 Web 界面,还用于帮助汇总、分析和搜索重要日志数据。

ELK 官网 https://www.elastic.co/products 分别提供包进行下载安装。

ELK 工作原理

  • 在所有需要收集日志的服务上部署 Logstash, 作为署 Logstash agent 用于监控并过滤所收集的日志,将过滤后的内容整合在一起,最终全部交给 EastiSearch 检索引擎;
  • 用 EastiSearch 进行自定义检索;
  • 再通过 Kibana 通过结合自定义检索内容生成图表,进行日志数据展示。

部署 ElasticSearch

1. 安装 ElasticSearch

rpm –import https://packages.elastic.co/GPG-KEY-elasticsearch

vim elasticsearch.repo        #配置 yum 源

[elasticsearch-2.x]
name=Elasticsearch repository for 2.x packages
baseurl=http://packages.elastic.co/elasticsearch/2.x/CentOS
gpgcheck=1
gpgkey=http://packages.elastic.co/GPG-KEY-elasticsearch
enable=1

yum install elasticsearch -y    #yum 安装 elasticsearch

2. 安装 Java

yum install java -y 

java -version

基于 ElasticSearch+Logstash+Kibana 的日志分析、存储、展示

3. 修改配置文件 elasticsearch.yml

cd /etc/elasticsearch/

vim elasticsearch.yml

#17 行 集群名称
cluster.name: yun

#23 行 节点名称
node.name: node1

#33 行 工作目录
path.data: /data/es-data
path.logs: /var/log/elasticsearch/

#43 行 防止交换 swap 分区
bootstrap.memory_lock: true

#54 行 监听网络
network.host: 0.0.0.0

#58 行 端口
http.port: 9200

4. 创建配置文件中的工作目录,并修改其属性

mkdir -p /data/es-data

chown -R elasticsearch:elasticsearch /data/es-data/

5. 启动 ElasticSearch 服务,并查看其端口 9200

systemctl start elasticsearch.service

netstat -ntap | grep 9200  #稍微等待一会

基于 ElasticSearch+Logstash+Kibana 的日志分析、存储、展示

6. 通过浏览器访问 9200 端口

http://192.168.26.144:9200

基于 ElasticSearch+Logstash+Kibana 的日志分析、存储、展示

7.ES 交互

通过 RESTful API(通过 json 格式交互)

curl -i -XGET ‘http://192.168.175.132:9200/_count?pretty’ -d ‘{
“query”: {
    “match_all”: {}
}
}’

`基于 ElasticSearch+Logstash+Kibana 的日志分析、存储、展示

8. 安装插件

# 安装 ES 插件 elasticsearch-head
  /usr/share/elasticsearch/bin/plugin install mobz/elasticsearch-head

# 安装 ES 插件 elasticsearch-kopf
 /usr/share/elasticsearch/bin/plugin install lmenezes/elasticsearch-kopf

安装完成后在 plugins 目录下可以看到 head 和 kopf
基于 ElasticSearch+Logstash+Kibana 的日志分析、存储、展示

可以在 web 界面上输入数据,再查询
基于 ElasticSearch+Logstash+Kibana 的日志分析、存储、展示
基于 ElasticSearch+Logstash+Kibana 的日志分析、存储、展示

9. 部署 ES 多集群

在第二台服务器上同时安装 ES 服务同上,需要注意的是修改配置文件 elasticsearch.yml 有些许不同。

cd /etc/elasticsearch/

vim elasticsearch.yml

#17 行 集群名称
cluster.name: yun

#23 行 节点名称
node.name: node2

#69 行 自动发现机制
discovery.zen.ping.unicast.hosts: [“192.168.26.144”, “192.168.26.147”]

基于 ElasticSearch+Logstash+Kibana 的日志分析、存储、展示
启动 elasticsearch

systemctl start elasticsearch.service

netstat -ntap | grep 9200

同样在第一台服务器 node1 中配置文件修改, 再重启服务

#69 行 单播列表自动发现机制
discovery.zen.ping.unicast.hosts: [“192.168.26.147”, “192.168.26.144”]

访问 head 可以看到 ES 的主分片和副本分片

http://192.168.26.144:9200/_plugin/head/

基于 ElasticSearch+Logstash+Kibana 的日志分析、存储、展示
访问 kopf 可以看到 ES 的集群节点信息

http://192.168.26.144:9200/_plugin/kopf/

基于 ElasticSearch+Logstash+Kibana 的日志分析、存储、展示

9. 生产环境注意内存解锁和文件限制

less /var/log/elasticsearch/yun.log  #查看集群日志提示不让锁内存

基于 ElasticSearch+Logstash+Kibana 的日志分析、存储、展示
修改配置文件 /etc/security/limits.conf

vim /etc/security/limits.conf
# 末尾插入
# allow user ‘elasticsearch’ mlockall
elasticsearch soft memlock unlimited
elasticsearch hard memlock unlimited
* soft nofile 65535       
* hard nofile 65535

重启生效

systemctl restart elasticsearch.service

部署 Logstash

1. 安装 Logstash

rpm –import https://packages.elastic.co/GPG-KEY-elasticsearch

vim /etc/yum.repos.d/ogstash.repo  #配置 yum 源

[logstash-2.1]
name=Logstash repository for 2.1.x packages
baseurl=http://packages.elastic.co/logstash/2.1/centos
gpgcheck=1
gpgkey=http://packages.elastic.co/GPG-KEY-elasticsearch
enable=1

yum install logstash -y

2. 创建链接,识别 logstash 命令

ln -s /opt/logstash/bin/logstash /usr/bin/

3. 配置 Logstash 收集

Logstash 使用 input 和 output 定义收集日志时的输入和输出。

  • input 常用的输入源有:
    file、syslog、redis、log4j、apache log 或 nginx log, 或者其他一些自定义的 log 格式。
  • output 常用的输出有:
    elasticsearch 比较常用,fle: 写入文件,redis: 写入队列,hdfs: 写入 HDFS, 需插件支持,zabbix: zabbix 监控,mongodb: 写入 mongodb 库,除此之外编码插件 codes 也比较常用,经常用来处理 json 数据或者多行数据源。

(1)定义输入和输出流,类似管道

logstash -e ‘input {stdin{} } output {stdout{} }’

(2)详细格式显示

logstash -e ‘input {stdin{} } output {stdout{ codec => rubydebug} }’

基于 ElasticSearch+Logstash+Kibana 的日志分析、存储、展示
(3)写入到 elasticsearch 中

logstash -e ‘input {stdin{} } output {elasticsearch { hosts => [“192.168.26.144:9200”] } }’

基于 ElasticSearch+Logstash+Kibana 的日志分析、存储、展示
基于 ElasticSearch+Logstash+Kibana 的日志分析、存储、展示
(4)写入 ES 和同时生成文本

logstash -e ‘input {stdin{} } output {elasticsearch { hosts => [“192.168.26.144:9200”] } stdout {codec => rubydebug} }’

基于 ElasticSearch+Logstash+Kibana 的日志分析、存储、展示
基于 ElasticSearch+Logstash+Kibana 的日志分析、存储、展示

(5)编写配置文件将事件生成到 ES

vim /etc/logstash/conf.d/01-logstash.conf

input {stdin {} }
output {
  elasticsearch {hosts => [“localhost:9200”] }
  stdout {codec => rubydebug}
}logstash -f /etc/logstash/conf.d/01-logstash.conf  #配置文件生效

基于 ElasticSearch+Logstash+Kibana 的日志分析、存储、展示
基于 ElasticSearch+Logstash+Kibana 的日志分析、存储、展示

5. 使用 logstash 收集日志(系统日志、java 异常日志、事件优化处理)

编写配置文件将日志生成到 ES 中

vim /root/file.conf

input {

      file {
          path => “/var/log/messages”              #系统日志
          type => “system”
          start_position => “beginning”
      }
      file {
                    path => “/var/log/elasticsearch/yun.log”  #java 异常日志
                    type => “es-error”
                    start_position => “beginning” 
                    codec => multiline {#多行优化处理
                    pattern => “^\[“
                    negate => true
                    what => “previous”
                }
            }
}

output {

    if [type] == “system” {
        elasticsearch {
            hosts => [“192.168.26.144:9200”]
            index => “system-%{+YYYY.MM.dd}”
        }
    }

    if [type] == “es-error” {
        elasticsearch {
            hosts => [“192.168.26.144:9200”]
            index => “es-error-%{+YYYY.MM.dd}”
        }
    }
}

logstash -f /root/file.conf  #日志生成到 ES 上

基于 ElasticSearch+Logstash+Kibana 的日志分析、存储、展示
基于 ElasticSearch+Logstash+Kibana 的日志分析、存储、展示
基于 ElasticSearch+Logstash+Kibana 的日志分析、存储、展示

部署 kibana

1. 安装 kibana

wget https://download.elastic.co/kibana/kibana/kibana-4.3.1-linux-x64.tar.gz

tar zxvf kibana-4.3.1-linux-x64.tar.gz -C /opt/

mv /opt/kibana-4.3.1-linux-x64/ /usr/local/

cd /usr/local
mv kibana-4.3.1-linux-x64/ kibana2.��辑 kibana 配置文件

vim /usr/local/kibana/config/kibana.yml

#2 行
server.port: 5601

#5 行
server.host: “0.0.0.0”

#12 行 ES 地址
elasticsearch.url: “http://192.168.26.144:9200”

#20 行
kibana.index: “.kibana”

基于 ElasticSearch+Logstash+Kibana 的日志分析、存储、展示

3. 启动 kibana

yum install screen -y
screen  #开启
/usr/local/kibana/bin/kibana

基于 ElasticSearch+Logstash+Kibana 的日志分析、存储、展示
ctrl+a+d 进行丢入后台

4. 访问 kibana

基于 ElasticSearch+Logstash+Kibana 的日志分析、存储、展示
基于 ElasticSearch+Logstash+Kibana 的日志分析、存储、展示
基于 ElasticSearch+Logstash+Kibana 的日志分析、存储、展示
基于 ElasticSearch+Logstash+Kibana 的日志分析、存储、展示

正文完
星哥玩云-微信公众号
post-qrcode
 0
星锅
版权声明:本站原创文章,由 星锅 于2022-01-21发表,共计4892字。
转载说明:除特殊说明外本站文章皆由CC-4.0协议发布,转载请注明出处。
【腾讯云】推广者专属福利,新客户无门槛领取总价值高达2860元代金券,每种代金券限量500张,先到先得。
阿里云-最新活动爆款每日限量供应
评论(没有评论)
验证码
【腾讯云】云服务器、云数据库、COS、CDN、短信等云产品特惠热卖中