Skip to content

EMQX Cloud

EMQX Cloud 是 EMQ 提供的全托管 MQTT 云服务。EMQX Neuron 没有专门的 EMQX Cloud 应用,用 MQTT 应用接入即可——EMQX Cloud 提供的就是标准 MQTT 接入点。

与连接自建 Broker 的差别集中在端口、认证和 TLS 三处,按部署类型不同。

连接参数

配置项Serverless 版专有版
服务器地址部署的连接地址,在 EMQX Cloud 控制台的部署管理页查看同左
服务器端口8883,不开放明文端口默认 1883;配置 TLS 后可用 8883
SSL必须开启使用 8883 时开启
CA 证书单向认证,下载 CA 后上传按所配置的证书填写
用户名、密码在控制台客户端认证 → 默认认证中创建同左

其余参数(上报格式、断网缓存、反控主题等)与 MQTT 应用一致,见 MQTT · 应用配置

TIP

Serverless 版对 SNI 有要求,服务器地址须填部署的完整域名,不能用 IP,否则连接会被拒绝。

配置步骤

  1. 在 EMQX Cloud 控制台创建部署,在部署管理页记下连接地址与端口。
  2. 客户端认证 → 默认认证中新建一组用户名密码。
  3. 回到 EMQX Neuron,按添加应用创建一个 MQTT 类型的北向应用。
  4. 在应用配置中填入上表的参数,Serverless 版需同时打开 SSL 并上传 CA 证书。

EMQX Cloud 的连接配置:服务器地址、端口 8883、用户名密码、SSL 开启并上传 CA

  1. 提交后应用进入运行中,连接状态显示为连接

北向应用列表中 emqx-cloud 已连接

  1. 订阅南向数据,指定要上报的采集组。

为 emqx-cloud 添加订阅

上报是否正常可在应用的数据统计页看发送消息数:

emqx-cloud 的数据统计:发送消息数持续增长

云端侧可在 EMQX Cloud 控制台的在线消息查看,或用 MQTTX 订阅对应主题验证,见 MQTT · 使用 MQTTX 查看数据。默认主题为 /neuron/{应用名}/{驱动名}/{组名},报文示例:

json
{
  "node": "modbus-tcp",
  "group": "group-1",
  "timestamp": 1790219933821,
  "values": { "sine": -15741, "square": -10, "random": 99, "setpoint": 68 },
  "errors": {},
  "metas": {}
}

继续流向数据仓库

数据进了 EMQX 之后,可由 EMQX 的数据集成直接写入分析平台,边缘侧不需要改动。

SnowflakeDatabricks
对接方式原生连接器经 Amazon S3
数据形态结构化表,列在规则里定义原始 JSON 文件,查询时解析
点位增减要同时改表结构和规则 SQL不用改,新点位自动出现在 JSON 里
适合点位集合稳定、要直接出报表点位多变、先入湖再建模

全部可用的下游系统见 EMQX 数据集成

延伸阅读

端口与认证的完整说明见 EMQX Cloud 文档的 Serverless 连接指引专有版连接指引