集群选举策略配置

配置项作用 #

cluster.election.strategy 配置项用于指定集群主节点选举时使用的策略。选举策略定义了在选举过程中如何判断是否获得足够票数成为主节点的规则。

此配置主要作为插件扩展点，允许通过自定义插件实现特殊的选举约束条件，满足特定的集群部署需求。

配置项类型 #

该配置项为静态配置，需要在 easysearch.yml 配置文件中设置，修改后需要重启节点才能生效。

默认值 #

default

是否必需 #

可选配置项（有默认值）

取值范围 #

default 或插件提供的自定义策略名称

配置格式 #

# easysearch.yml

# 默认配置
cluster.election.strategy: default

# 使用自定义插件提供的策略
cluster.election.strategy: custom_strategy_name

工作原理 #

┌─────────────────────────────────────────────────────────────────┐
│                   选举仲裁判断流程                               │
└─────────────────────────────────────────────────────────────────┘

节点发起选举
    │
    ▼
收集投票
    │
    ├── 检查 committed 配置的仲裁
    │   │
    │   └── joinVotes.isQuorum(lastCommittedConfiguration)
    │
    ├── 检查 accepted 配置的仲裁
    │   │
    │   └── joinVotes.isQuorum(lastAcceptedConfiguration)
    │
    └── 执行自定义策略的额外约束
        │
        └── satisfiesAdditionalQuorumConstraints(...)
            │
            ├── default: 总是返回 true
            └── 自定义策略: 实现特定约束逻辑

默认选举策略 #

default 策略使用标准的选举仲裁计算：

// 默认策略不添加额外约束
public static final ElectionStrategy DEFAULT_INSTANCE = new ElectionStrategy() {
    @Override
    protected boolean satisfiesAdditionalQuorumConstraints(...) {
        return true;  // 不添加额外约束
    }
};

当选满足以下条件时，节点成为主节点：

获得 lastCommittedConfiguration 的仲裁票数
获得 lastAcceptedConfiguration 的仲裁票数
通过自定义策略的额外约束检查（default 策略总是通过）

使用场景 #

1. 默认配置（推荐） #

cluster.election.strategy: default

适用于大多数集群部署场景，使用标准仲裁规则。

2. 自定义选举策略 #

通过插件实现特殊的选举约束：

// 插件实现示例
public class CustomElectionStrategy extends ElectionStrategy {
    @Override
    protected boolean satisfiesAdditionalQuorumConstraints(
            DiscoveryNode localNode,
            long localCurrentTerm,
            long localAcceptedTerm,
            long localAcceptedVersion,
            VotingConfiguration lastCommittedConfiguration,
            VotingConfiguration lastAcceptedConfiguration,
            VoteCollection joinVotes) {

        // 添加自定义约束逻辑
        // 例如：只允许特定属性的节点成为主节点
        return hasRequiredAttributes(localNode);
    }
}

# 配置使用自定义策略
cluster.election.strategy: custom_election_strategy

选举机制说明 #

Voting 配置类型 #

配置类型	说明
lastCommittedConfiguration	最后一次提交的投票配置，集群稳定状态的配置
lastAcceptedConfiguration	最后一次接受的投票配置，可能包含新加入的节点

仲裁计算 #

仲裁 = ⌊N/2⌋ + 1

其中 N 为投票配置中的节点数

例如：

3 节点集群：仲裁 = 2
5 节点集群：仲裁 = 3
7 节点集群：仲裁 = 4

部署场景	推荐策略	说明
标准集群	default	使用默认策略即可
多数据中心	可能需要自定义	确保主节点在特定数据中心
异地多活	可能需要自定义	控制主节点位置
特定约束场景	自定义插件	根据业务需求实现

插件开发示例 #

public class MyDiscoveryPlugin extends DiscoveryPlugin implements Plugin {

    @Override
    public Map<String, ElectionStrategy> getElectionStrategies() {
        Map<String, ElectionStrategy> strategies = new HashMap<>();
        strategies.put("datacenter_aware",
            new ElectionStrategy() {
                @Override
                protected boolean satisfiesAdditionalQuorumConstraints(
                        DiscoveryNode localNode,
                        long localCurrentTerm,
                        long localAcceptedTerm,
                        long localAcceptedVersion,
                        VotingConfiguration lastCommittedConfiguration,
                        VotingConfiguration lastAcceptedConfiguration,
                        VoteCollection joinVotes) {

                    // 只允许主数据中心的节点成为主节点
                    String datacenter = localNode.getAttributes().get("datacenter");
                    return "primary".equals(datacenter);
                }
            });
        return strategies;
    }
}

配置验证 #

# 查看当前选举策略
GET /_cluster/settings?filter_path=*.cluster.election.strategy

# 查看集群状态
GET /_cluster/state

# 查看节点信息
GET /_nodes

注意事项 #

静态配置：修改此配置需要重启节点
集群一致性：集群中所有节点应使用相同的选举策略
插件依赖：自定义策略需要相应的插件支持
可用性影响：不当的自定义策略可能导致无法选出主节点
测试充分：自定义策略应在测试环境充分验证后再用于生产
默认策略推荐：除非有特殊需求，建议使用 default 策略

标签

集群配置选举机制高可用