EMQX入门

EMQX概述

• EMQX 是一款开源 (opens new window)的大规模分布式 MQTT 消息服务器，功能丰富，专为物联网和实时通信应用而设计。EMQX 5.0 单集群支持 MQTT 并发连接数高达 1 亿条，单服务器的传输与处理吞吐量可达每秒百万级 MQTT 消息，并保证延迟在亚毫秒级。
• EMQX 支持多种协议，包括 MQTT (3.1、3.1.1 和 5.0)、HTTP、QUIC 和 WebSocket 等，保证各种网络环境和硬件设备的可访问性。EMQX 还提供了全面的 SSL/TLS 功能支持，比如双向认证以及多种身份验证机制，为物联网设备和应用程序提供可靠和高效的通信基础设施。

支持的操作系统

Operating system	Versions supported	x86_64/amd64	arm64
Ubuntu	Ubuntu 18.04 Ubuntu 20.04 Ubuntu 22.04	Yes	Yes
Debian	Debian 10 Debian 11 Debian 12	Yes	Yes
CentOS/RHEL	CentOS 7 Rocky Linux 8 Rocky Linux 9	Yes	Yes
Amazon Linux	Amazon Linux 2 Amazon Linux 2023	Yes	Yes
macOS	macOS 11 macOS 12 macOS 13(Homebrew)	Yes	Yess
Windows	Windows Server 2019	Yes	Yes

硬件规格

• 根据客户端连接的数量、消息速率、消息大小和启用的特性，EMQX的最小硬件规格会有所不同。
• 下面是在简单工作负载下运行EMQX的硬件规范，支持100,000个客户机连接和每秒100,000条消息的吞吐量。

	最低配置	推荐配置
Node	1	2
CPU	1 core	16 core
Memory	512 MB	32 GB
Disk space	1 GB	50 GB

• 在生产环境中，您可以使用Server Estimate(打开新窗口)计算器来计算各种最大连接和消息吞吐量下推荐的硬件规格。

安装EMQX broker

on windows

1. 下载EMQ X的安装包 https://www.emqx.com/zh/try?product=broker，旋转对应的版本和平台。
2. 解压安装包，进入路径，执行命令,启动emqx:

   PS C:\Users\hyan> cd D:\EMQX\
   PS D:\EMQX> .\bin\emqx start
   EMQX_NODE__DB_ROLE [node.role]: core
   EMQX_NODE__DB_BACKEND [node.db_backend]: mnesia
   

on docker

1. 安装docker。
2. 在命令行工具中输入如下命令，下载并运行最新版 EMQX。

   hyan@ubuntu-22:~$ sudo docker run -d --name emqx -p 1883:1883 -p 8083:8083 -p 8084:8084 -p 8883:8883 -p 18083:18083 emqx/emqx:latest
   74900a169adde450688f1fffaa7a753231d989f913bbbf3acec3b8ac40baa640
   hyan@ubuntu-22:~$ sudo docker ps
   CONTAINER ID   IMAGE              COMMAND                  CREATED          STATUS         PORTS                                                                                                                                                                                                                               NAMES
   74900a169add   emqx/emqx:latest   "/usr/bin/docker-ent…"   11 seconds ago   Up 9 seconds   4370/tcp, 0.0.0.0:1883->1883/tcp, :::1883->1883/tcp, 0.0.0.0:8083-8084->8083-8084/tcp, :::8083-8084->8083-8084/tcp, 5369/tcp, 0.0.0.0:8883->8883/tcp, :::8883->8883/tcp, 0.0.0.0:18083->18083/tcp, :::18083->18083/tcp, 11883/tcp   emqx
   

on linux

• 下载 emqx zip 文件,并解压安装,然后启动emqx:

  hyan@ubuntu-22:~$ wget https://www.emqx.com/zh/downloads/broker/5.1.3/emqx-5.1.3-ubuntu22.04-amd64.tar.gz
  hyan@ubuntu-22:~$ mkdir -p emqx && tar -zvxf emqx-5.1.3-ubuntu22.04-amd64.tar.gz -C emqx
  hyan@ubuntu-22:~$ ./emqx/bin/emqx start
  WARNING: Default (insecure) Erlang cookie is in use.
  WARNING: Configure node.cookie in /home/hyan/emqx/etc/emqx.conf or override from environment variable EMQX_NODE__COOKIE
  WARNING: NOTE: Use the same cookie for all nodes in the cluster.
  EMQX 5.1.3 is started successfully!
  

登录EMQX（MQTT服务器）

• 打开浏览器，输入你的ip:18083，如： http://localhost:18083 或者 http://127.0.0.1:18083
• 用户名： admin
• 初始密码： public

EMQX 常用命令

• EMQX 提供了 emqx 命令行工具，方便用户对 EMQX 进行启动、关闭、进入控制台等操作。

  emqx start # 后台启动 EMQX Broker；
  emqx stop # 关闭 EMQX Broker；
  emqx restart # 重启 EMQX Broker；
  emqx console # 使用控制台启动 EMQX Broker；
  emqx foreground # 使用控制台启动 EMQX Broker，与 emqx console 不同，emqx foreground 不支持输入 Erlang 命令；
  emqx ping # Ping EMQX Broker。
  emqx_ctl status # 查看 EMQX 的状态。
  

如何在 EMQX 中使用 Keep Alive

• 在 EMQX 中，用户可以通过配置来自定义 Keep Alive 机制的行为，主要配置字段有:

zone.${zoneName}.server_keepalive
server_keepalive 类型 默认值   整型 无

• 如果没有设置这个值，则 EMQX 会按照客户端创建连接时的 Keep Alive 的值，来控制 Keep Alive 的行为。
• 如果设置了这个值，则 Broker 会对该 zone 下面所有的连接，强制启用 Keep Alive 机制，并且会使用这个值，覆盖客户端连接请求中的值。

zone.${zoneName}.keepalive_backoff
keepalive_backoff 类型 默认值   浮点数 0.75

• MQTT 协议中要求 Broker 在 1.5 倍 Keep Alive 时间内，如果没有收到客户端的任何协议包，则认定客户端断开了连接。而在 EMQX 中，我们引入了退让系数(keepalive backoff)，并将这个系数通过配置暴露出来，方便用户更灵活的控制 Broker 端的 Keep Alive 行为。在引入退让系数后，EMQX 通过下面的公式来计算最大超时时间:

Keepalive * backoff * 2

• backoff 默认值为0.75，因此在用户不修改该配置的情况下，EMQX 的行为完全符合 MQTT 标准。