一. 简介
EMQ 2.0 (Erlang/Enterprise/Elastic MQTT Broker) 是基于 Erlang/OTP 语言平台开发,支持大规模连接和分布式集群,发布订阅模式的开源 MQTT 消息服务器。2.0版本开始emqttd消息服务自正式简称EMQ
EMQ 2.0 完整支持 MQTT V3.1/V3.1.1 版本协议规范,并扩展支持 WebSocket、Stomp、CoAP、MQTT-SN 或私有 TCP 协议。EMQ 2.0 消息服务器支持单节点100万连接与多节点分布式集群:
EMQ 2.0 为大规模客户端连接 (C1000K+) 的移动推送、移动消息、物联网、车联网、智能硬件等应用,提供一个完全开放源码、安装部署简便、企业级稳定可靠、可弹性扩展、易于定制开发的 MQTT 消息服务器。
二. 安装部署
在官网下载系统匹配的版本,下载地址:http://emqtt.com/downloads
我们有三个节点:bigdata0000,bigdata002,bigdata004
解压文件(3个节点都操作)
unzip emqttd-centos7-v2.3.11.zip
cd emqttd
vim ./etc/emp.conf 修改IP地址
启动EMQ服务,三台都要启动
./bin/emqttd start
将节点加入集群中,在bigdata002,bigdata004上执行
./bin/emqttd_ctl cluster join emq@bigdata000
访问web页面
http://bigdata000:18083
用户名admin,密码public
在控制台页面我们可以看到集群的整个概述,包括系统信息,版本,运行时间等等。
在连接和会话页面我们可以看到客户端连接信息
主题页面我们可以看到发布/订阅的主题
订阅页面我们看到客户端订阅的主题信息
在工具的Websocket我们可以模拟发送订阅消息
三. 客户端测试
发布者
订阅者:
回调
发送者发送消息
消费者订阅消息
领取专属 10元无门槛券
私享最新 技术干货