分布式解决方案之分布式日志采集elk+kafka 环境的构建

文章目录

          • 一、软件下载列表
            • 1. zookeeper
            • 2. kafka
            • 3. logstash
            • 4. elasticsearch
            • 5. kibana
            • 6. zktools
          • 二、安装zk环境
            • 2.1. 上传安装包
            • 2.2. 解压
            • 2.3. 创建data目录
            • 2.4. 修改配置
            • 2.5.启动zk
          • 三、安装kafka环境
            • 3.1. 上传安装包
            • 3.2. 解压kafka安装包
            • 3.3. 创建data文件夹
            • 3.4. 修改配置
            • 3.5. 启动kafka
          • 四、docker安装ES
            • 4.1. 安装ES
            • 4.2. 验证服务
          • 五、docker安装Kibana
            • 5.1. 创建Kibana容器
            • 5.2. 验证服务
          • 六、构建环境
            • 6.1. 解压logstash
            • 6.2. 安装kafka输入插件
            • 6.3. 安装elasticsearch输入插件
            • 6.4. Kafka logstash配置文件
            • 6.5. 启动logstash
          • 七、Elk整合实际项目

一、软件下载列表
1. zookeeper

zookeeper-3.4.10.tar.gz

wget http://archive.apache.org/dist/zookeeper/zookeeper-3.4.10/zookeeper-3.4.10.tar.gz
2. kafka

kafka_2.12-2.1.1.tgz

wget https://archive.apache.org/dist/kafka/2.1.1/kafka_2.12-2.1.1.tgz
3. logstash

logstash-6.7.2.tar.gz

wget https://artifacts.elastic.co/downloads/logstash/logstash-6.7.2.tar.gz
4. elasticsearch

elasticsearch-6.7.2.tar.gz

wget https://artifacts.elastic.co/downloads/elasticsearch/elasticsearch-6.7.2.tar.gz
5. kibana

kibana-6.7.2-linux-x86_64.tar.gz

wget https://artifacts.elastic.co/downloads/kibana/kibana-6.7.2-linux-x86_64.tar.gz
6. zktools
链接: https://pan.baidu.com/s/1c8m6yBwPc5DBTg5lIrfkKw
提取码:7agv

说明:elasticsearch和kibana 演示采用docker安装方便,后续都更换成docker

二、安装zk环境
2.1. 上传安装包

上传Zookeeper安装包,#进入软件安装目录/app

cd /app
2.2. 解压

解压zookeeper到安装目录

tar -zxvf zookeeper-3.4.10.tar.gz
2.3. 创建data目录
  1. 创建data及logs目录
cd /app/zookeeper-3.4.10
mkdir data
2.4. 修改配置

修改Zookeeper的配置文件

cd /app/zookeeper-3.4.10/conf
cp zoo_sample.cfg zoo.cfg
vim zoo.cfg

修改配置文件:dataDir=/app/zookeeper-3.4.10/data

2.5.启动zk
cd /app/zookeeper-3.4.10/bin
./zkServer.sh start

在这里插入图片描述

三、安装kafka环境
3.1. 上传安装包

1.上传kafka安装包kafka_2.12-2.1.1.tgz到/app 目录下

3.2. 解压kafka安装包
tar -zxvf kafka_2.12-2.1.1.tgz
3.3. 创建data文件夹
  1. 进入到kafka安装目录下,创建data文件夹
cd cd /app/kafka_2.12-2.1.1/
mkdir data
3.4. 修改配置

修改kafka的配置文件

vim config/server.propertieslog.dirs=/app/kafka_2.12-2.1.1/data
listeners=PLAINTEXT://当前服务器ip:9092
advertised.listeners=PLAINTEXT://当前服务器ip:9092

在这里插入图片描述

3.5. 启动kafka
cd /app/kafka_2.12-2.1.1/
bin/kafka-server-start.sh config/server.properties

后台启动:nohup bin/kafka-server-start.sh config/server.properties &

在这里插入图片描述

四、docker安装ES
4.1. 安装ES

1.安装elasticsearch

docker run \
-d \
--name es \
-p 9200:9200 -p 9300:9300 \
-e ES_JAVA_OPTS="-Xms512m -Xmx512m" \
elasticsearch:6.7.2
4.2. 验证服务
[root@localhost ~]# curl 127.0.0.1:9200
{"name" : "A_ZAaLs","cluster_name" : "docker-cluster","cluster_uuid" : "vkEHjf_fRO-11XSDYmjW-A","version" : {"number" : "6.7.2","build_flavor" : "default","build_type" : "docker","build_hash" : "56c6e48","build_date" : "2019-04-29T09:05:50.290371Z","build_snapshot" : false,"lucene_version" : "7.7.0","minimum_wire_compatibility_version" : "5.6.0","minimum_index_compatibility_version" : "5.0.0"},"tagline" : "You Know, for Search"
}
五、docker安装Kibana
5.1. 创建Kibana容器

& Kibana

docker run  \
-it  \
-d  \
-e ELASTICSEARCH_URL=http://192.168.92.137:9200  \
--name kibana  \
--restart=always  \
-p 5601:5601  \
kibana:6.7.2
5.2. 验证服务

测试运行结果

http://192.168.92.137:5601/app/kibana
六、构建环境

logstash 同步到 elasticsearch

Logstash是一个开源数据收集引擎,具有实时管道功能。Logstash可以动态地将来自不同数据源的数据统一起来,并将数据标准化到你所选择的目的地

Logstash输入数据源:

  1. 本地文件
  2. Kafka
  3. Redis/mysql
    Logstash输出数据源:
  4. Es
  5. Mongdb
  6. Redis
  7. Mysql
6.1. 解压logstash
tar -zxvf logstash-6.7.2.tar.gz
6.2. 安装kafka输入插件
cd /app/logstash-6.7.2
bin/logstash-plugin install logstash-input-kafka
6.3. 安装elasticsearch输入插件
bin/logstash-plugin install logstash-output-elasticsearch
6.4. Kafka logstash配置文件
vim /app/logstash-6.7.2/config/mylog.conf

添加以下内容:

input {kafka {bootstrap_servers => "192.168.92.137:9092" # kafka服务端地址topics => "mayikt-log" # 队列名称}
}
filter {#Only matched data are send to output.
}
output {elasticsearch {action => "index"          #The operation on EShosts  => "192.168.92.137:9200"   # ElasticSearch host, can be array.index  => "mayikt_logs"         # The index to write data to.}}
6.5. 启动logstash
cd /app/logstash-6.7.2/bin
./logstash -f ../config/kafka.conf

到目前为止,zookeeper、kakfa、elasticsearch、kibana、logstash-6.7.2 都启动完毕了

七、Elk整合实际项目

https://gblfy.blog.csdn.net/article/details/123434785

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/515916.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

基于https国密算法构建安全数据传输链路

网络数据安全得到前所未有的重视 HTTPS成为解决传输安全问题利器 大家都知道,HTTP 本身是明文传输的,没有经过任何安全处理,网站HTTPS解决方案通过在HTTP协议之上引入证书服务,完美解决网站的安全问题。 下图左侧表示Chrome浏览…

AOP+自定义注解 实现service统一的异常信息处理

返回信息枚举 TipsMsg: public enum TipsMsg {DEFAULT_SUCCESS("0","操作成功"),DEFAULT_FAILED("1","操作失败"),//其他枚举//get//set}自定义注解 ReturnMsg (也是切点) : Target(El…

跟风 Python 的人,后来都怎样了?

许多人觉得 Python 功能强大、就业范围范围广还上手轻松,得来全部费功夫。 但是一旦推开 Python 的大门你会发现,Python 入门容易但精通很难。看似语法掌握熟练,但一面试或者做项目就会被打回原形。 比如: 1)如何写出高…

Kubernetes 是一个“数据库”吗?

作者 | 张磊,阿里云高级技术专家、CNCF 官方大使,CNCF 应用交付领域 co-chair,Kubernetes 项目资深维护者 最近,Kubernetes 社区里有一个关于“Kubernetes is the new database”的论述,引起了很多人的关注。当然&…

云原生下的开发测试

【以下为分享实录,有删节】 测试环境管理之困与阿里巴巴的解决之道 在云原生时代下,软件的迭代速度越来越快,对测试的要求也越来越高,很多开发者开始使用Kubernetes来管理测试环境。在这个过程中,开发者会遇到很多困…

我是程序员,我用这种方式铭记历史

作者 | kokohuang责编 | 晋兆雨头图 | 付费下载于视觉中国✨抗战直播: 以图文方式“直播”1931年9月18日至1945年9月2日14年间抗战的日日夜夜✨开源地址:https://github.com/kokohuang/WarOfResistanceLive✨预览地址:https://kokohuang.github.io/WarOf…

分布式ELK日志采集系统

文章目录1. 传统日志采集存在哪些优缺点2. Elk采集日志的原理3. 为什么需要将日志存储在ElasticSeach 而不是mysql中呢4. 为什么需要使用elkkafka5. elkkafka原理6. elkkafka 环境的构建7. SpingBoot 整合 kafka Elk1.传统日志采集存在哪些问题2.分布式日志采集有哪些方案3.Ela…

从零入门 Serverless | 架构的演进

作者 | 许晓斌 阿里云高级技术专家 本文整理自《Serverless 技术公开课》第 1 讲,点击开始学习。 关注 “Serverless” 公众号,回复 入门 ,即可获取 Serverless 系列文章 PPT。 传统单体应用架构 十多年前主流的应用架构都是单体应用&…

如何使用 Istio 进行多集群部署管理:多控制平面

作者 | 王夕宁 阿里云高级技术专家 导读:本文摘自于阿里云高级技术专家王夕宁撰写的《Istio 服务网格技术解析与实战》一书,讲述了如何使用 Istio 进行多集群部署管理来阐述服务网格对多云环境、多集群即混合部署的支持能力。 前文详情: …

JDK8新特性入门到精通

文章目录一、 接口中默认方法修饰为普通方法1. 在jdk8之前2. 在JDK 1.8开始3. 案例演练二、Lambda表达式2.1. 什么是Lambda表达式2.2. 为什么要使用Lambda表达式2.3. Lambda表达式的规范2.4. 函数接口定义2.5. Lambda基础语法2.6. 方法引入2.7. Lambda实战案例三、java 8 strea…

一文聊“图”,从图数据库到知识图谱

作者 | 穆琼责编 | 晋兆雨头图 | 付费下载于视觉中国随着知识图谱的发展,图数据库一词被越来越多的提到。那么到底什么是图数据库,为什么要用图数据库,如何去建设一个图数据库应用系统,图数据库与知识图谱到底是什么关系。今天为大…

阿里云机器学习PAI DSW 2.0 Alink商业版重磅发布

DSW 2.0:面向AI研发的集成开发平台 DSW(Data Science Workshop)是阿里巴巴PAI团队根据多年的AI算法和产品研发经验积累,围绕提高AI算法研发效率,降低研发成本而推出的一款适用于各类AI开发者的云端机器学习集成开发环…

DSW:面向AI研发的集成开发平台

发布会传送门 产品详情 云原生技术,注重用户体验,提升研发效率 环境搭建是算法研发过程中的重要一环,这里除了硬件选型外,软件环境的安装配置,后续升级往往会耗费不少时间。DSW借助阿里云ECS,Docker和Ku…

程序员应如何理解高并发中的协程

来源 | 码农的荒岛求生责编 | 晋兆雨头图 | 付费下载于视觉中国作为程序员,想必你多多少少听过协程这个词,这项技术近年来越来越多的出现在程序员的视野当中,尤其高性能高并发领域。当你的同学、同事提到协程时如果你的大脑一片空白&#xff…

5G边缘计算行业通识:阿里云ENS技术演进之路

近日,阿里云杨敬宇在CSDN阿里云核心技术竞争力在线峰会上进行了《5G基础设施-阿里云边缘计算的技术演进之路》主题演讲,针对5G时代下,行业和技术的趋势、边缘计算产业通识以及阿里云边缘计算从过去到未来的技术演进之路进行分享。 5GAI需求推…

精讲23种设计模式-策略模式~聚合短信服务和聚合支付服务

文章目录一、设计模式1. 为什么需要使用设计模式2. 设计模式的分类3. 什么是策略模式4. 为什么叫做策略模式5. 策略模式优缺点6. 策略模式应用场景7. Spring框架中使用的策略模式二、策略模式~聚合短信服务2.1. 依赖引入2.2. 抽象公共行为接口2.3. 具体策略接口实现类2.4. 策略…

引领开源新风潮,阿里巴巴编程之夏第二期重磅来袭!

“唯有热爱,可抵岁月漫长”。 2020 年 5 月 25 日,阿里巴巴编程之夏(Alibaba Summer of Code,以下简称 ASoC )第二期正式上线,项目规模再度升级,来自开源社区的 Apache Dubbo、Apache RocketMQ…

powerdesigner逆向工程(sql转pdm)

第一步: File -> Reverse Engineer -> Database 第二步 : Using Script Files -> Add Files

安谋中国发布“玲珑”i3i5 ISP处理器,剑指何方?

随着图像视频处理技术的发展和 5G 时代的来临,除了社交等平台外,以图像、视频为载体的内容渗透到各领域,特别是智能安防、AIoT、智能汽车等新兴领域应用。与此同时,人们对其清晰度、图像分辨率有新的扩展需求,对摄像头…