# 自动自发现集群

# 节点发现与自动集群

EMQX 支持基于 Ekka 库的集群自动发现 (Autocluster)。Ekka 是为 Erlang/OTP 应用开发的集群管理库，支持 Erlang 节点自动发现 (Service Discovery)、自动集群 (Autocluster)、脑裂自动愈合 (Network Partition Autoheal)、自动删除宕机节点 (Autoclean)。

EMQX 支持多种节点发现策略:

策略	说明
static	静态节点列表自动集群
dns	DNS A 记录自动集群
etcd	通过 etcd 自动集群
k8s	Kubernetes 服务自动集群

注意：mcast发现策略已被废弃，在未来的版本中会被删除。

# 基于 static 节点列表自动集群

配置固定的节点列表，自动发现并创建集群:

cluster {
    discovery_strategy = static
    static {
        seeds = ["emqx@s1.emqx.io", "emqx@s2.emqx.io"] 
    }
}

1
2
3
4
5
6

# 基于 mcast 组播自动集群

基于 UDP 组播自动发现并创建集群:

cluster {
    discovery_strategy = mcast
    mcast {
        addr = "239.192.0.1"
        ports = [4369, 4370]
        iface = "0.0.0.0"
        ttl = 255
        loop = true
    }
}

1
2
3
4
5
6
7
8
9
10

# 基于 DNS A 记录自动集群

基于 DNS A 记录自动发现并创建集群:

cluster {
    discovery_strategy = dns
    dns {
        name = "localhost"
        record_type = a
    }
}

1
2
3
4
5
6
7

# 基于 DNS SRV 记录自动集群

基于 DNS SRV 记录自动发现并创建集群:

cluster {
    discovery_strategy = dns
    dns {
        name = "localhost"
        record_type = srv
    }
}

1
2
3
4
5
6
7

# 基于 etcd 自动集群

基于 etcd (opens new window) 自动发现并创建集群:

cluster {
    discovery_strategy = etcd
    etcd {
        server = "http://127.0.0.1:2379"
        prefix = emqcl
        node_ttl = 1m
    }
}

1
2
3
4
5
6
7
8

# 基于 kubernetes 自动集群

Kubernetes (opens new window) 下自动发现并创建集群:

cluster {
    discovery_strategy = k8s
    k8s {
        apiserver = "http://10.110.111.204:8080"
        service_name = emqx
        address_type = ip
        app_name = emqx
        suffix = "pod.local"
        namespace = default
    }
}

1
2
3
4
5
6
7
8
9
10
11

提示

Kubernetes 不建议使用 Fannel 网络插件，推荐使用 Calico 网络插件。

← 手动管理集群集群负载均衡 →