0
点赞
收藏
分享

微信扫一扫

Elasticsearch 集群分布式模型与选主与脑裂问题

90哦吼 2022-05-31 阅读 80
elasticsearches数据分布式架构大数据


文章目录

  • ​​1. 分布式特性​​
  • ​​2. 节点​​
  • ​​3. Coordinating Node​​
  • ​​4. Demo 启动节点与Cerebro 介绍​​
  • ​​5. Demo 创建一个新的索引​​
  • ​​6. Data Node​​
  • ​​7. Master Node​​
  • ​​8. Master Eligible Nodes & 选主流程​​
  • ​​9. 集群状态​​
  • ​​10. 增加一个新的从节点​​
  • ​​11. 增加一个新的主节点​​
  • ​​12. Master Eligbile Nodes & 选主的过程​​
  • ​​13. 脑裂问题​​
  • ​​14. 如何避免脑裂问题​​
  • ​​15. 配置节点类型​​
  • ​​16. 本节回顾​​

1. 分布式特性

ES 的分布式架构带来的好处

  • 储存的水平扩容，支持 PB 级数据
  • 提高系统的可用性，部分节点停止服务，整个集群的服务不受影响

ES 的分布式架构

  • 不同的集群通过不同的名字来区分，默认名字 “es”
  • 通过配置文件的修改，或者在命令行中 - E cluster.name=’**** ‘设定

2. 节点

节点是一个 ES 的实例

  • 其本质就是一个 JAVA 进程
  • 一台机器可以运行多个 ES 进程，但是生产环境一般建议一台机器就运行一个 ES 实例

每一个节点都有名字，通过配置文件配置，或者启动时候 - E node.nam=geektime 指定
每一个节点在启动之后，都会分配一个 UID，保存在 data 目录下

3. Coordinating Node

处理请求的节点，叫 ​​Coordinating Node​​

  • 路由请求到正确的节点，例如创建索引的请求，需要路由到 Master 节点

所有节点默认都是 ​​Coordinating Node​​ 通过将其他类型设置成 False ，使其成为 Dedicated Coordinating Node

4. Demo 启动节点与Cerebro 介绍

启动一个节点

bin/elasticsearch -E node.name=node1 -E cluster.name=geektime -E path.data=node1_data -E http.port=9200
bin/elasticsearch -E node.name=node2 -E cluster.name=geektime -E path.data=node2_data -E http.port=9201
bin/elasticsearch -E node.name=node3 -E cluster.name=geektime -E path.data=node3_data -E http.port=9203

or

bin/elasticsearch -E node.name=node1 -E cluster.name=geektime -E path.data=node1_data -E network.host=192.168.211.61 -E  http.port=9200 -E transport.tcp.port=9300  -E node.master=true -E node.data=true -E bootstrap.system_call_filter=false -E discovery.zen.minimum_master_nodes=1  -E discovery.zen.ping.unicast.hosts="192.168.211.61:9300","192.168.211.61:9301","192.168.211.61:9301" -E gateway.recover_after_nodes=1

部署cerebro
​​​https://github.com/lmenezes/cerebro/releases​​

./bin/cerebro

登录​​http://192.168.211.61:9000/​​

5. Demo 创建一个新的索引

发送创建索引的请求

  • Settings 3 Primary 和 1 个 Replica
  • 请求可以发送到任何的节点，处理你请求的节点，叫做 Coordinating Node
  • 创建 / 删除 索引的请求，只能被 Master 节点处理

Elasticsearch 集群分布式模型与选主与脑裂问题_分布式架构
Elasticsearch 集群分布式模型与选主与脑裂问题_elasticsearch_02
Elasticsearch 集群分布式模型与选主与脑裂问题_分布式架构_03

6. Data Node

可以保存数据的节点，叫做 ​​Data Node​​

  • 节点启动后，默认就是数据节点。可以设置 node.data:false 禁止

Data Node 的职责

  • 保存分片数据。在数据扩展上起到了至关重要的作用（由 Master Node 决定把分片分发到数据节点上）

通过增加数据节点

  • 可以解决数据水平扩展和解决数据单点的问题

7. Master Node

Master Node 的职责

  • 处理创建，删除索引等请求 / 决定分片被分配到哪个节点 / 负责索引的创建与删除
  • 维护并且更新 Cluster State

Master Node 的最佳实践

  • Master 节点非常重要，在部署上需要考虑解决单点的问题
  • 为一个集群设置多个 Master 节点 / 每个节点值承担 Master 的单一角色

8. Master Eligible Nodes & 选主流程

一个集群，支持配置多个 ​​Master Eligble​​​ 节点。这些节点可以在必要时（如 Master 节点出现故障，网络故障时）参与选主流程，成为 Master 节点
每个节点启动后，默认就是一个 Master eligible 节点

  • 可以设置​​node.data:false​​

当集群内的第一 Master eligible 节点时候，它会将自己选举成 Master 节点

9. 集群状态

集群状态信息（Cluster State），维护了一个集群中，必要的信息

  • 所有的节点信息
  • 所有的索引和其相关的 Mapping 与 Setting 信息
  • 分片的路由信息

在每个节点都保存了集群的状态信息
但是，只有 Master 节点才能修改集群的状态信息，并负责同步给其他节点

因为，任意节点都能修改信息会导致 Cluster State 信息不一致

10. 增加一个新的从节点

本地执行：

bin/elasticsearch -E node.name=node2 -E cluster.name=geektime -E
path.data=node2_data -E http.port=9201

虚拟机执行：

bin/elasticsearch -E node.name=node2 -E cluster.name=geektime -E path.data=node2_data -E network.host=192.168.211.61 -E  http.port=9201 -E transport.tcp.port=9301  -E node.master=false -E node.data=true -E bootstrap.system_call_filter=false -E discovery.zen.minimum_master_nodes=1  -E discovery.zen.ping.unicast.hosts="192.168.211.61:9300","192.168.211.61:9301","192.168.211.61:3202" -E gateway.recover_after_nodes=1

Nodes API 看到新增节点
发现 Replica 被分配
仔细发现：数据节点（data node）标志是一个​​​立体盒子​​​，主节点（master node）是一个​​五角星​​​Elasticsearch 集群分布式模型与选主与脑裂问题_es_04

11. 增加一个新的主节点

虚拟机执行：

$ bin/elasticsearch -E node.name=node3 -E cluster.name=geektime -E path.data=node3_data -E network.host=192.168.211.61 -E  http.port=9202 -E transport.tcp.port=9302  -E node.master=true -E node.data=true -E bootstrap.system_call_filter=false -E discovery.zen.minimum_master_nodes=1  -E discovery.zen.ping.unicast.hosts="192.168.211.61:9300","192.168.211.61:9301","192.168.211.61:9301" -E gateway.recover_after_nodes=1

Elasticsearch 集群分布式模型与选主与脑裂问题_elasticsearch_05

12. Master Eligbile Nodes & 选主的过程

  • 互相 ping 对方。Node Id 低的会被成为被选举的节点
  • 其他节点会加入集群，但是不承担 Master 节点的角色。一旦发现被选中的主节点丢失，救护选举除新的 Master 节点
    Elasticsearch 集群分布式模型与选主与脑裂问题_数据_06

13. 脑裂问题

​​Split-Brain​​ ，分布式系统的经典网络问题，当出现网络问题，一个节点和其他节点无法连接

  • Node 2 和 Node 3 会被重新选举 Master
  • Node 1 自己还是作为 Master，组成一个集群，同时更新 Cluster State
  • 导致 2 个 master，维护不同的 cluster state。当网络恢复是，无法选择正确恢复

（下图疑问） 这个不是应该根据 Node Id 选 2 吗？
Elasticsearch 集群分布式模型与选主与脑裂问题_分布式架构_07

14. 如何避免脑裂问题

限定一个选举条件，这是 ​​quorum​​（仲裁），只有在 Master eligble 节点数大于 quorum 时，才能进行选举

  • Quorum = (master 节点总数 / 2) +1
  • 当 3 个 master eligible 时，设置 discovery.zen.minimum_master_nodes 为 2
    ，即可避免脑裂

从 7.0 开始，无需这个配置

  • 移除 minimum_master_nodes 参数，让 ES 自己选择可以形成冲裁的节点
  • 电信的主节点选举现在只需要很短的时间可以完成。集群的伸缩变得更加安全，更容易，并且可能造成丢失数据的系统配置选项更少了
  • 节点更清楚的记录它们的状态，有助于诊断为什么它们不能加入集群或为什么无法选举除主节点

15. 配置节点类型

节点类型

配置参数

默认值

maste eligible

node.master

true

datan

node.data

true

ingest

node.ingest

ture

coordinating only

⽆

设置上⾯三个参数全部为 false

machine

learning node.ml

true (需要 enable x-pack)

16. 本节回顾

ES 天生的分布式架构。为了实现数据可用性

  • 部署多台 Data Nodes，可以实现数据存储的水平扩展

提高服务可用性

  • Master 节点非常重要。设置多台​​Master Eligible Nodes​​​，同时设置合理的​​quorum​​ 数，避免脑裂问题
  • 设置多台​​Coordinating Node​​ ，提升查询的可用性和性能

举报

相关推荐

Elasticsearch-20.集群分布式模型及选主与脑裂问题和分片与集群的故障转移

elasticsearch搜索引擎经验分享数据分析

Elasticsearch实战-ES集群-集群职责及脑裂

elasticsearch大数据

Redis——Redis集群脑裂问题

kubernetesdockerlinux

Elasticsearch部分节点不能发现集群(脑裂)问题处理

elasticsearch集群java.net系统/运维

Keepalived 脑裂问题的起因与解决

keepalived服务器高可用.net编程语言

浅说集群与分布式

服务器Java后端开发

ElasticSearch（15）脑裂

elasticsearchbig data分布式

ElasticSearch分布式集群搭建

hadoopelasticsearchelastic数据仓库大数据yyds干货盘点

Redis集群脑裂

redis数据库

分布式与集群的区别

架构运维
0 条评论