开始使用 (Get Started)

EMQ X R3.2 消息服务器简介

EMQ X (Erlang/Enterprise/Elastic MQTT Broker) 是基于 Erlang/OTP 平台开发的开源物联网 MQTT 消息服务器。Erlang/OTP 是出色的软实时(Soft-Realtime)、低延时(Low-Latency)、分布式(Distributed) 的语言平台。MQTT 是轻量的(Lightweight)、发布订阅模式(PubSub) 的物联网消息协议。

EMQ X 面向海量的 移动/物联网/车载 等终端接入，并实现在海量物理网设备间快速低延时的消息路由:

  1. 稳定承载大规模的 MQTT 客户端连接，单服务器节点支持百万连接。

  2. 分布式节点集群，快速低延时的消息路由，单集群支持千万规模的路由。

  3. 消息服务器内扩展，支持定制多种认证方式、高效存储消息到后端数据库。

  4. 完整物联网协议支持，MQTT、MQTT-SN、CoAP、LwM2M、私有 TCP/UDP 协议支持。

MQTT 发布订阅模式简述

MQTT 是基于 发布(Publish)/订阅(Subscribe) 模式来进行通信及数据交换的，与 HTTP 的 请求(Request)/应答(Response) 的模式有本质的不同。

订阅者(Subscriber) 会向 消息服务器(Broker) 订阅一个 主题(Topic) 。成功订阅后，消息服务器会将该主题下的消息转发给所有的订阅者。

主题(Topic)以 ‘/’ 为分隔符区分不同的层级。包含通配符 ‘+’ 或 ‘#’ 的主题又称为 主题过滤器(Topic Filters); 不含通配符的称为 主题名(Topic Names) 例如:

  1. sensor/1/temperature
  3. chat/room/subject
  5. presence/user/feng
  7. sensor/1/#
  9. sensor/+/temperature
  11. uber/drivers/joe/inbox

注解

注: ‘+’ 通配一个层级，’#’ 通配多个层级(必须在末尾)。

注解

注: 发布者(Publisher) 只能向 ‘主题名’ 发布消息，订阅者(Subscriber) 则可以通过订阅 ‘主题过滤器’ 来通配多个主题名称。

EMQ X R3.1 消息服务器功能列表

  • 完整的 MQTT V3.1/V3.1.1 及V5.0协议规范支持

  • QoS0, QoS1, QoS2 消息支持

  • 持久会话与离线消息支持

  • Retained 消息支持

  • Last Will 消息支持

  • TCP/SSL 连接支持

  • MQTT/WebSocket/SSL 支持

  • HTTP消息发布接口支持

  • $SYS/# 系统主题支持

  • 客户端在线状态查询与订阅支持

  • 客户端 ID 或 IP 地址认证支持

  • 用户名密码认证支持

  • LDAP 认证

  • Redis、MySQL、PostgreSQL、MongoDB、HTTP 认证集成

  • 浏览器 Cookie 认证

  • 基于客户端 ID、IP 地址、用户名的访问控制(ACL)

  • 多服务器节点集群(Cluster)

  • 支持 manual、mcast、dns、etcd、k8s 等多种集群发现方式

  • 网络分区自动愈合

  • 消息速率限制

  • 连接速率限制

  • 按分区配置节点

  • 多服务器节点桥接(Bridge)

  • MQTT Broker 桥接支持

  • Stomp 协议支持

  • MQTT-SN 协议支持

  • CoAP 协议支持

  • Stomp/SockJS 支持

  • 延时 Publish ($delay/topic)

  • Flapping 检测

  • 黑名单支持

  • 共享订阅($share/<group>/topic)

  • TLS/PSK 支持

  • 规则引擎支持

五分钟下载启动 EMQ

EMQ X 的每个版本都会发布 CentOS、Ubuntu、Debian、FreeBSD、macOS、Windows、openSUSE 平台程序包与 Docker 镜像。

下载地址: https://www.emqx.io/downloads/broker?osType=Linux

程序包下载后，可直接解压启动运行，例如 Mac 平台:

  1. unzip emqx-macosx-v3.2.0.zip && cd emqx
  3. # 启动emqx
  4. ./bin/emqx start
  6. # 检查运行状态
  7. ./bin/emqx_ctl status
  9. # 停止emqx
  10. ./bin/emqx stop

EMQ X 启动后，MQTT 客户端可通过 1883 端口接入系统。运行日志输出在 log/ 目录。

EMQ X 默认加载 Dashboard 插件，启动 Web 管理控制台。用户可通过 Web 控制台，查看服务器运行状态、统计数据、连接(Connections)、会话(Sessions)、主题(Topics)、订阅(Subscriptions)、插件(Plugins)等。

控制台地址: http://127.0.0.1:18083，默认用户名: admin，密码：public

_images/dashboard.png

开源 MQTT 客户端项目

GitHub: https://github.com/emqtt

emqttc

Erlang MQTT 客户端库

CocoaMQTT

Swift 语言 MQTT 客户端库

QMQTT

QT 框架 MQTT 客户端库

emqtt_benchmark

MQTT 连接测试工具

Eclipse Paho: https://www.eclipse.org/paho/

MQTT.org: https://github.com/mqtt/mqtt.github.io/wiki/libraries