vernemq

VerneMQ MQTT Broker

补充说明

VerneMQ 是基于 Erlang/OTP 的分布式 MQTT Broker，强调水平扩展和集群能力。适合需要多节点、共享订阅和大规模连接的 IoT 平台。

常用示例

Docker 启动：

docker run -d --name vernemq \
  -p 1883:1883 -p 8883:8883 -p 8888:8888 \
  -e DOCKER_VERNEMQ_ACCEPT_EULA=yes \
  -e DOCKER_VERNEMQ_ALLOW_ANONYMOUS=off \
  vernemq/vernemq

查看集群状态：

vmq-admin cluster show
vmq-admin node status
vmq-admin listener show

加入集群：

vmq-admin cluster join discovery-node=VerneMQ@node1

查看会话和订阅：

vmq-admin session show
vmq-admin topic show

创建用户（配合 vmq_passwd）：

vmq-passwd -c /etc/vernemq/vmq.passwd app

配置 HTTP 认证：

vmq-admin webhooks register hook=auth_on_register \
  endpoint=http://auth-service:8080/mqtt/auth

易错点与排错

• Erlang cookie 不一致，节点无法加入集群。
• 节点主机名使用 localhost，其他节点无法发现。
• 匿名访问未关闭，生产环境存在未授权发布风险。
• 共享订阅的 group 名称不一致，消息被重复消费。
• 会话过期时间设置过短，离线消息丢失。
• 集群分区后出现双主，需要确认网络和 quorum 配置。
• 插件启用顺序错误，认证钩子没有生效。
• 日志中 max_inflight_messages 相关错误通常是消费端确认太慢。