1. 凋谢端口
EMQ X 默认提供 5 个 Listener,它们将占用以下端口:
端口 | 阐明 |
---|---|
1883 | MQTT/TCP 协定端口 |
11883 | MQTT/TCP 协定外部端口,仅用于本机客户端连贯 |
8883 | MQTT/SSL 协定端口 |
8083 | MQTT/WS 协定端口 |
8084 | MQTT/WSS 协定端口 |
云服务器可在平安组端口放行
或者输出一下命令凋谢相应端口号firewall-cmd --zone=public --add-port=1883-11883/tcp --permanent
//永恒firewall-cmd --zone=public --add-port=1883-11883/tcp
//长期firewall-cmd --zone=public --add-port=1883/tcp --permanent
// 永恒凋谢1883端口firewall-cmd --zone=public --remove-port=1883/tcp --permanent
//永恒敞开1883端口firewall-cmd --reload
// 在不扭转状态的条件下从新加载防火墙--配置立刻失效
注:应用宝塔的小伙伴切记不要遗记宝塔那边也同样须要端口放行
2. 下载MqttSDK
MqttSDK下载链接:MqttSDK
下载并解压导入到idea中
外围抽象类:MessageHandler,用final润饰ServerMqttClient进步代码安全性。
3. 登录EMQ X 治理控制台
应用浏览器关上地址 http://服务器ip:18083 ,如需登录输出默认用户名admin
与默认明码 public
,登录进入 Dashboard
能够看到此时没有任何客户端连贯上
4. 音讯的公布订阅
执行main办法,再看Dashboard 客户端,此时能够看到有一个用户连贯上来了【注:因为EMQ没有配置登录认证,匿名登录的话是所有用户都能够连贯上来的】
在控制台点击WebSocket,订阅主题emq
,QoS(0:最多一次的传输 /1:至多一次的传输 /2:只有一次的传输),这里为了保障音讯必达,咱们抉择QoS=2
批改代码:订阅的主题为java
,公布message的主题为emq
,执行main办法后同时在Dashboard
点击公布订阅,能够看到控制台打印的日志,以及控制台收到的主题音讯
至此java连贯EMQ,以及模仿主题音讯的公布订阅就OK了!
【参考文档】EMQ官网链接:EMQ官网返回上一级
[Centos8.0-EMQ之搭建部署]:Centos8.0-EMQ之搭建部署返回下一级
[EMQ之数据长久化]