elasticsearch集群cluster主要功能详细分析
在源码概述中我们分析过，elasticsearch源码从功能上可以分为分布式功能和数据功能，接下来这几篇会就分布式功能展开。这里首先会对cluster作简单概述，然后对cluster所涉及的主要功能详细分析。
elasticsearch的集群功能代码在cluster包中，通过ClusterService接口对外暴露。
cluster主要包括以下功能：
发现（Discovery）,路由（routing），传送功能（transport），集群状态（clusterstates）等。
发现功能功能主要用于节点启动后发现集群，master向所有节点发布集群状态，选举master节点并引发集群节点变得事件；
routing记录了集群中各个shard的位置，为节点提供数据信息；
transport是节点间交流的主要通道，elasticsearch应用了netty框架实现了功能强大的transport功能；
集群状态（clusterstates）实现了一些集群状态，同时提供了一些方法，在集群每次变得时，master节点都会重新构建clusterstates，并将集群状态发送给每个节点。
节点根据cluster状态来确定某些操作是否能执行。
下图是显示了clusterstate的主要Fields
clusterstate的version是clusterstate的版本每次被更新它都会增加，routingTables包含了集群中所有索引的位置信息，nodes是当前集群中的所有节点，metaData是索引的一些元数据，blocks包含了集群的阻塞状态，
集群一共有三种阻塞级别：read，write和matedata；
status集群的状态有四种：unknown，RECEIVED，BEING_APPLIED，APPLIED。
集群功能的接口clusterservice的继承关系如下所示：
所有实现都在InternalClusterService中，它同时继承了AutoCloseAble接口和LifecycleComponent接口。
上图为clusterservice的方法，这些方法包括集群的启动与关闭，集群状态修改和发布及节点间ping通信等，这些方法只是从从内部看集群是不存在实体的，它的功能是由一个个节点实现的。因此对于集群的操作最终还是对每个节点的操作。单有些操作只能由master来进行，有些则是所有节点都需要进行的操作。每个加入集群后就会增加clusterstatelistener及localmasterlisener，但是clusterstate的发布则只能由master节点来实现。
以上就是对clusterservice的概述，限于篇幅。下一篇会对其进行详细分析，希望大家以后多多支持脚本之家！
相关文章
Java利用apache ftp工具实现文件上传下载和删除功能
这篇文章主要为大家详细介绍了Java利用apache ftp工具实现文件上传下载、删除功能，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2018-06-06
这篇文章主要为大家详细介绍了Java实现多用户注册登录的幸运抽奖，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2020-11-11
Java14对于NullPointerException的新处理方式示例解析
这篇文章主要为大家介绍了Java14对于NullPointerException的新处理方式示例解析,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪2023-09-09
这篇文章主要为大家详细介绍了Spring实现文件上传功能，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2017-09-09
这篇文章主要介绍了Java多线程中的ThreadLocal应用场景及问题解读,ThreadLocal这个类在多线程并发中主要的使用场景是什么呢,我们都知道多线程并发问题实际就是多个线程对公共资源访问和修改问题,需要的朋友可以参考下2023-12-12
这篇文章主要介绍了Java线程中的Thread.yield()详细解析,yield()让当前线程从运行状态 转为 就绪状态,以允许具有相同优先级的其他线程获得运行机会,需要的朋友可以参考下2023-11-11
Springboot Mybatis-Plus数据库单元测试实战(三种方式)
这篇文章主要介绍了Springboot Mybatis-Plus数据库单元测试实战(三种方式),文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2020-12-12
Spring AMQP 是基于 Spring 框架的AMQP消息解决方案,提供模板化的发送和接收消息的抽象层,提供基于消息驱动的 POJO的消息监听等,简化了我们对于RabbitMQ相关程序的开发,本文给大家介绍侦听消息队列的Message Listener类,感兴趣的朋友一起看看吧2023-12-12
这篇文章主要介绍了Java求两集合的交集、并集、差集实例,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2024-08-08
Fork/Join框架是Java7提供用于并行执行任务的框架，是一个把大任务分割成若干个小任务，今天通过本文给大家分享java中fork join原理，感兴趣的朋友一起看看吧2021-04-04
最新评论