MQTT协议之websocket方式发布接收消息

旧城等待， 2022-08-05 02:26 300阅读 0赞

ActiveMQ支持MQTT协议并且在JMS和MQTT客户端之间自动进行消息转换。  
为了是ActiveMQ支持MQTT协议，可以在activemq.xml配置文件中做以下配置：  
<transportConnector name="mqtt+nio" uri="mqtt+nio+ssl://localhost:1883"/>  
  
当一个客户端连接MQTT服务器的时候，会发送心跳信号来检测连接是否有效，通常心跳信号默认的时间间隔为10秒钟。ActiveMQ默认会将连接的有效期设置为 1.5\*10=15秒但是，如果客户端设置keep-alive为0的时候，ActiveMQ会一直认为客户端连接有效，而不会自动关闭。这种情况会导致连接的泄露，因此在服务端也设置一个默认的有效连接时间是必要的。  
下面的参数则是在服务端设置一个连接有效时间：  
<transportConnector name="mqtt" uri="mqtt://localhost:1883?transport.defaultKeepAlive=60000"/>  
ActiveMQ9.0版本以后，提供了对WebSocket协议的支持

客户端websocket实现：[https://github.com/i5ting/paho.mqtt.javascript][https_github.com_i5ting_paho.mqtt.javascript]

客户端代码参考：[Mqtt websocket javascript 客户端实例][Mqtt websocket javascript]

参考：

1.[基于 WebSocket 的 MQTT 移动推送方案][WebSocket _ MQTT]

2.[使用ActiveMQ+MQTT实现Android点对点消息通知][ActiveMQ_MQTT_Android]

[https_github.com_i5ting_paho.mqtt.javascript]: https://github.com/i5ting/paho.mqtt.javascript
[Mqtt websocket javascript]: http://blog.itpub.net/28624388/viewspace-1178824/
[WebSocket _ MQTT]: http://www.ibm.com/developerworks/cn/websphere/library/techarticles/1308_xiangr_mqtt/1308_xiangr_mqtt.html
[ActiveMQ_MQTT_Android]: http://blog.csdn.net/kimmking/article/details/17449019