ActiveMQ中用mqttws3.1创建持久订阅(durable subscriber)

这段时间在研究消息对列相关技术.现在基本确定的方案是:ActiveMQ+mqttws3.1+php(#c)来实现数据的实时传送,以抛弃现在正在用的ajax轮循机制.从apache官网下载ActiveMQ后,直接用现成的demo/mqtt,发现可以用.接下来就开始不停的折腾,和大量的试验了,由于项目的需要,要求能够建立持久连接,以便用户不在线时服务器推送过去的消息,当用户上线后可以第一时间收到.

具体的前端JS代码如下:

 

这个文件是官方自带的,路径是webapps/demo/mqtt/chat.js

这里只加了一个参数cleanSession:false,即高亮的第18行.这样设置参数后就可以实现创建持久监听的效果了.

2 thoughts on “ActiveMQ中用mqttws3.1创建持久订阅(durable subscriber)

  1. 1.你用的是哪个版本的ActiveMQ?我看到现在新版本的路径和你的说的有一点出入。
    2.你是只改了chat.js,还有其他修改?

    • 1.当时用的是5.9.0的这个版本,路径确实有误,正确的应该是webapps/demo/mqtt/chat.js,谢谢提醒
      2.服务端好像也是需要做相关修改的

你的评论是对我最大的鼓励