emqx集群部署教程

2024-02-05 11:56:16

一、EMQX介绍

EMQ X (Erlang/Enterprise/Elastic MQTT Broker) 是基于 Erlang/OTP 平台开发的开源物联网 MQTT 消息服务器。

Erlang/OTP是出色的软实时 (Soft-Realtime)、低延时 (Low-Latency)、分布式 (Distributed)的语言平台。

MQTT 是轻量的 (Lightweight)、发布订阅模式 (PubSub) 的物联网消息协议。

EMQ X 设计目标是实现高可靠，并支持承载海量物联网终端的MQTT连接，支持在海量物联网设备间低延时消息路由:

  1. 稳定承载大规模的 MQTT 客户端连接，单服务器节点支持50万到100万连接。
  2. 分布式节点集群，快速低延时的消息路由，单集群支持1000万规模的路由。
  3. 消息服务器内扩展，支持定制多种认证方式、高效存储消息到后端数据库。
  4. 完整物联网协议支持，MQTT、MQTT-SN、CoAP、LwM2M、WebSocket 或私有协议支持。

二、配置说明

EMQ X 的配置文件通常以 .conf 作为后缀名，你可以在 etc 目录找到这些配置文件，主要配置文件包括：

配置文件 说明
etc/emqx.conf EMQ X 配置文件
etc/acl.conf EMQ X 默认 ACL 规则配置文件
etc/plugins/*.conf EMQ X 扩展插件配置文件

EMQ X集群默认占用的Tcp端口如下：

端口 说明
1883 MQTT/TCP 协议端口
11883 MQTT/TCP 协议内部端口，仅用于本机客户端连接
8883 MQTT/SSL 协议端口
8083 MQTT/WS 协议端口
8084 MQTT/WSS 协议端口
8081 管理 API 端口
18083 Dashboard 端口
4369 集群节点发现端口 (EPMD 模式)
4370 集群节点发现端口
5370 集群节点 PRC 通道

三、集群安装部署

阿里云环境规划：

node-02 IP: 192.168.1.202
node-03 IP: 192.168.1.203

分布式集群部署规划：

首先配置好node-02和node-03两台单节点上的emqx，之后，依次启动；node-03执行集群加入命令，加入到node-02上集群；由于阿里云不提供VIP，最后采用阿里云提供负载均衡提供一个集群统一入口。

方法一：云环境机器zip动态手动安装部署集群

安装包下载地址：emqx安装包下载地址

# 下载安装包并解压
[root@node-02 opt]#  wget https://www.emqx.com/en/downloads/broker/v4.0.0/emqx-centos7-v4.0.0.zip
[root@node-02 opt]# unzip emqx-centos7-v4.0.0.zip 
# 修改配置文件
[root@node-02 emqx]# vim etc/emqx.conf 
....
cluster.name = emqxcl   # 集群名称
node.name = node-02@192.168.1.202 # 修改为本机主机名和IP
node.data_dir = data  # 数据存储目录
...
# 启动
[root@node-02 bin]# ./emqx start 
EMQ X Broker v4.0.0 is started successfully!
# 查看节点状态
[root@node-02 bin]# ./emqx_ctl status
Node 'node-02@192.168.1.202' is started
emqx 4.0.0 is running

node-03按照node-02配置进行修改，注意修改相应主机名和IP。

[root@node-03 bin]# ./emqx start 
EMQ X Broker v4.0.0 is started successfully!
# 查看节点状态
[root@node-03 bin]# ./emqx_ctl status
Node 'node-03@192.168.1.203' is started
emqx 4.0.0 is running

node-03执行集群加入命令：

[root@node-03 bin]# ./emqx_ctl cluster join node-02@192.168.1.202
=CRITICAL REPORT==== 16-Sep-2021::11:03:51.502636 ===
[EMQ X] emqx shutdown for join
Join the cluster successfully.
Cluster status: #{running_nodes =>
                      ['node-02@192.168.1.202','node-03@192.168.1.203'],
                  stopped_nodes => []}
# node-03上查看集群状态
[root@node-03 bin]# ./emqx_ctl cluster  status
Cluster status: #{running_nodes =>
                      ['node-02@192.168.1.202','node-03@192.168.1.203'],
                  stopped_nodes => []}
# node-02上查看集群状态
[root@node-02 bin]# ./emqx_ctl cluster  status
Cluster status: #{running_nodes =>
                      ['node-02@192.168.1.202','node-03@192.168.1.203'],
                  stopped_nodes => []}

至此，云环境本机emqx集群部署完成，利用阿里云提供的负载均衡配置一个集群统一入口即可。

方法二： docker环境部署静态集群

docker安装部署参考博文：Centos7 安装 Docker

首先利用docker运行一个单节点emqx，将其中的配置文件复制出来

[root@node-02 ~]#  docker run -d --name emqx --rm emqx/emqx:v4.0.0
# 复制出配置文件
[root@node-02 ~]#  docker cp emqx:/opt/emqx/etc .
# 删除当前容器
[root@node-02 ~]# docker stop emqx
# 将配置文件复制到指定目录，为下一步运行挂载作准备
[root@node-02 ~]# mkdir -p  /data/emqx 
[root@node-02 ~]# mv etc /data/emqx

修改配置文件

[root@node-02 etc]# vim emqx.conf 
...
cluster.name = emqxcl 
cluster.discovery = static
cluster.static.seeds = node-02@192.168.1.202,node-03@192.168.1.203
node.name = node-02@192.168.1.202
...
# 修改下当前目前权限
[root@node-02 ~]#  chown -R 1000:1000 /data/emqx/

运行docker容器

[root@node-02 ~]# docker run -d --name emqx --network host -v /data/emqx/etc:/opt/emqx/etc -v /data/emqx/data:/data/emqx/data emqx/emqx:v4.0.0

node-03按照node-02配置进行修改，启动；查看集群状态

# node-02查看集群状态
[root@node-02 etc]# docker exec -it emqx /bin/sh /opt/emqx/bin/emqx_ctl cluster status
Cluster status: #{running_nodes =>
                      ['node-02@192.168.1.202','node-03@192.168.1.203'],
                  stopped_nodes => []}

方法三：使用 docker-compose 创建简单的 static 集群

docker-compose安装和常用命令参考博文：Docker-compose常用命令整理

创建 docker-compose.yaml 文件

version: '3'

services:
  emqx1:
    image: emqx/emqx:v4.0.0
    environment:
    - "EMQX_NAME=emqx"
    - "EMQX_HOST=node1.emqx.io"
    - "EMQX_CLUSTER__DISCOVERY=static"
    - "EMQX_CLUSTER__STATIC__SEEDS=emqx@node1.emqx.io, emqx@node2.emqx.io"
    healthcheck:
      test: ["CMD", "/opt/emqx/bin/emqx_ctl", "status"]
      interval: 5s
      timeout: 25s
      retries: 5
    networks:
      emqx-bridge:
        aliases:
        - node1.emqx.io

  emqx2:
    image: emqx/emqx:v4.0.0
    environment:
    - "EMQX_NAME=emqx"
    - "EMQX_HOST=node2.emqx.io"
    - "EMQX_CLUSTER__DISCOVERY=static"
    - "EMQX_CLUSTER__STATIC__SEEDS=emqx@node1.emqx.io, emqx@node2.emqx.io"
    healthcheck:
      test: ["CMD", "/opt/emqx/bin/emqx_ctl", "status"]
      interval: 5s
      timeout: 25s
      retries: 5
    networks:
      emqx-bridge:
        aliases:
        - node2.emqx.io

networks:
  emqx-bridge:
    driver: bridge

2.启动 docker-compose 集群

$ docker-compose -p my_emqx up -d

3.查看集群

$ docker exec -it my_emqx_emqx1_1 sh -c "emqx_ctl cluster status"
Cluster status: #{running_nodes => ['emqx@node1.emqx.io','emqx@node2.emqx.io'],
                  stopped_nodes => []}

登录web查看emqx集群状态,登录地址为：http://node_IP:18083
初始账号密码为：admin/public
emqx集群部署教程

不要吝啬，点赞关注吧，么么哒！

上一篇：8php数据类型


下一篇：delphi 响应鼠标进入控件消息