MQTT broker 连接
api → mqtt:1883
运行概览
实时采样 · 来自真实网关服务
今日消息吞吐
1.24M
+8.3%
固件版本
–个
—
网关在线时长
7×24
持续值守 · docker compose
协议服务健康度
四个独立服务器进程状态与近 5 分钟负载
| 服务 | 端口 | 状态 | 吞吐趋势 | 操作 |
|---|---|---|---|---|
|
MQTT
amqtt broker
|
1883 | 运行中 |
|
|
|
UDP
datagram protocol
|
9000 | 运行中 | ||
|
WebSocket
websockets
|
9001 | 高负载 | ||
|
FTP
pyftpdlib
|
9021 | 运行中 |
最近事件
固件 esp_1.2.3.bin 上传完成
WebSocket 连接数超过 200 预警线
TLS 证书续期成功，剩余 89 天
新用户 operator2 创建
网关进程重启完成
协议与端口
四个独立服务器可分开部署，也可同进程统一启动
端口映射
docs/07-reference/port-map.md
| 服务 | 传输层 | 端口 | 状态 | 用途 | 复制 |
|---|---|---|---|---|---|
| MQTT | TCP | 1883 | 运行中 | 设备接入、遥测上报与指令下发 | |
| UDP | UDP | 9000 | 运行中 | 低功耗设备高频上报 | |
| WebSocket | TCP | 9001 | 高负载 | Web 控制台实时数据推送 | |
| FTP | TCP | 9021 | 运行中 | 固件上传（esp / beken 自动归类） | |
| API | HTTP | 8080 | 运行中 | 控制台后端接口 | |
| Web 站点 | HTTPS | 443 | 运行中 | 官网与固件下载站 |
设备接入示例
把下面任一片段贴到设备端即可接入
# MQTT（paho-mqtt）
client = mqtt.Client()
client.connect("corepush.cloud", 1883)
client.subscribe("iot/+/telemetry")
# UDP 高频上报
sock.sendto(payload, ("corepush.cloud", 9000))
# WebSocket 实时订阅
ws = websockets.connect("wss://corepush.cloud:9001/stream")
# FTP 固件上传
ftp.storbinary("STOR esp_1.2.3.bin", f)
固件中心
FTP 上传后自动归类并生成 manifest，供设备 OTA 下载
上传新固件
命名约定 <type>_<version>.bin
固件清单
| 设备类型 | 版本 | 大小 | SHA256 | 发布时间 | 操作 |
|---|
共 4 个版本
manifest: /firmware/manifest.json
文件中心
服务器同步空间的文件浏览与下载
同步空间
选择空间进入，浏览服务器上已同步的文件
| 名称 | 大小 | 修改时间 | 操作 |
|---|
MQTT 实时监控
订阅主题、观察实时消息流，并可直接向设备下发指令
实时消息
已连接到 broker
已接收 0 条 · 缓冲区上限 500 条
qos 0 · 自动滚底
订阅主题
支持 + 单层与 # 多层通配符，最多同时订阅 20 个主题。
发布指令
对话记录
DataTap 采集的设备与云端会话流水
会话
3
设备 esp-0A3F 会话
sess_9f2a1c · 18 条消息 · 21:01:12
用户与权限
控制台账号与角色分配
当前版本用户由管理员通过 CLI 创建：iot-gateway-api create-user。页面内的新建入口为下一版规划，此原型中点击将提示未开放。
| ID | 用户名 | 角色 | 状态 | 创建时间 | 操作 |
|---|
角色权限矩阵
admin 可管理用户，operator 可操作固件与 MQTT，viewer 只读
| 功能 | admin | operator | viewer |
|---|---|---|---|
| 查看概览与端口 | 允许 | 允许 | 允许 |
| MQTT 订阅 / 发布 | 允许 | 允许 | 禁止 |
| 上传固件 | 允许 | 允许 | 禁止 |
| 查看对话记录 | 允许 | 允许 | 脱敏 |
| 用户管理 | 允许 | 禁止 | 禁止 |