ActiveMQ+stomp.js实现保存最后一条记录(last message/value)的方法

由于WEB项目中的需要,要用到自己的消息对列服务器,最终选择了ActiveMQ。这个东东让人有点打脑壳,因为很多文章全是国外的,洋文让我们这些屌丝看起来倍感吃力啊!经过这段时间的折腾,还是初见成效了。在很多项目场景中,我们可能都会只用到消息对列中的最新的一个值,并且没有新值的情况下,一直保存这个值,经过各种尝试,终于找到了解决办法,不敢独享,拿出来分享之。

一、设置ActiveMQ的配置文件如下:

关键是文中高亮的部分60-71行,其它的和原配置文件基本一致。

二、stomp.js程序的配置,代码如下:

注意第46行,订阅的时候必须加activemq.retroactive,不然的话实现不了哦,这里就是关键点。

三、测试

1.访问http://localhost:8161/demo/websocket

2.订阅主题(topic),而不是对列(queue),如:/topic/test

3.连接

4.连接成功后发送一条信息,当前如果可以收到,说明代码没有问题

5.断开连接,再重新连接,连接成功后如果能收到你刚发的那条信息,恭喜你!你也成功了!

就为了这么一个小参数,折腾了我差不多一周的时间,悲催啊,如果你觉得有用,别往了给我个赞啊!

4 thoughts on “ActiveMQ+stomp.js实现保存最后一条记录(last message/value)的方法

  1. Hello i am kavin, its my first time to commenting anyplace, when i read this paragraph i
    thought i could also make comment due to this sensible
    paragraph.

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