在 kubernetes 上集群 EMQ X

kubernetes（k8s） 是 Google 的开源容器集群管理系统，是一个完备的分布式系统支撑平台。EMQ X 节点可以使用 kubernetes 的服务发现功能组建集群。

k8s的功能非常强大，关于它的部署和配置的详细说明超过了本文档的范围，有兴趣的读者请参阅k8s文档在线。

配置 EMQ X 节点

您需要在各个 EMQ X 节点上编辑 ‘etc/emqx.conf’文件中的cluster段落和node段落。

配置 k8s 集群方式

您需要为 k8s 自动集群指定 kubernetes API服务器，EMQ X 在 k8s 上的服务名，地址类型，用于建立node.name的 app_name 和 k8s上使用的命名空间。

  1. cluster.discovery = k8s
  2. ##--------------------------------------------------------------------
  3. ## Cluster using Kubernetes
  5. ## Kubernetes API server list, seperated by ','.
  6. ##
  7. ## Value: String
  8. cluster.k8s.apiserver = http://192.168.1.162:8081
  10. ## The service name helps lookup EMQ nodes in the cluster.
  11. ##
  12. ## Value: String
  13. cluster.k8s.service_name = emqx
  15. ## The address type is used to extract host from k8s service.
  16. ##
  17. ## Value: ip | dns
  18. cluster.k8s.address_type = ip
  20. ## The app name helps build 'node.name'.
  21. ##
  22. ## Value: String
  23. cluster.k8s.app_name = emqx
  25. ## Kubernetes Namespace
  26. ##
  27. ## Value: String
  28. cluster.k8s.namespace = default

检验是否集群成功

在配置完成后，依次启动集群的各个节点。然后在任意节点上执行命令查询集群状态：

  1. ./emqx_ctl cluster status

看到以下结果则表示集群建立成功：

  1. Cluster status: [{running_nodes,['emqx@192.168.1.162','emqx@192.168.1.165']}]

关闭集群内一个节点，再次查询集群状态，应该能看到以下结果：

  1. Cluster status: [{running_nodes,['emqx2@192.168.1.165']},
  2.                  {stopped_nodes,['emqx1@192.168.1.162']}]