Emqtt集群配置 ==================== :: ## 集群名 cluster.name = emqcl ## Cluster discovery strategy: manual | static | mcast | dns | etcd | k8s cluster.discovery = manual ## Cluster Autoheal: on | off cluster.autoheal = on ## Clean down node of the cluster cluster.autoclean = 5m EMQ Autodiscovery Strategy:: manual: 手工命令创建集群 static: Autocluster by static node list(静态节点列表自动集群) mcast: Autocluster by UDP Multicast(UDP 组播方式自动集群) dns: Autocluster by DNS A Record(DNS A 记录自动集群) etcd: Autocluster using etcd(通过 etcd 自动集群) k8s: Autocluster on Kubernetes(Kubernetes 服务自动集群) 1.手工命令创建集群:: 默认配置为手动创建集群,节点通过 $ ./bin/emqttd_ctl join 命令加入 2.基于 static 节点列表自动集群:: cluster.discovery = static ## Cluster with static node list cluster.static.seeds = emq1@127.0.0.1,ekka2@127.0.0.1 3.Autocluster by IP Multicast:: cluster.discovery = mcast ##-------------------------------------------------------------------- ## Cluster with multicast cluster.mcast.addr = 239.192.0.1 cluster.mcast.ports = 4369,4370 cluster.mcast.iface = 0.0.0.0 cluster.mcast.ttl = 255 cluster.mcast.loop = on 4.Autocluster by DNS A Record:: cluster.discovery = dns ##-------------------------------------------------------------------- ## Cluster with DNS cluster.dns.name = localhost cluster.dns.app = ekka 5.Autocluster using etcd:: cluster.discovery = etcd ##-------------------------------------------------------------------- ## Cluster with Etcd cluster.etcd.server = http://127.0.0.1:2379 cluster.etcd.prefix = emqcl cluster.etcd.node_ttl = 1m 6.Autocluster on Kubernetes:: cluster.discovery = k8s ##-------------------------------------------------------------------- ## Cluster with k8s cluster.k8s.apiserver = http://10.110.111.204:8080 cluster.k8s.service_name = ekka ## Address Type: ip | dns cluster.k8s.address_type = ip ## The Erlang application name cluster.k8s.app_name = ekka