spring boot 集成 activeMQ 之 pub/sub 的简单应用
之前学习了一波消息机制中的点对点模式,现在又学习了一波订阅模式顺便总结一下。点对点与发布订阅最初是由JMS定义的。这两种模式主要区别或解决的问题就是发送到队列的消息能否重复消费(多订阅)
点对点:
消息生产者生产消息发送到queue中,然后消息消费者从queue中取出并且消费消息。这里要注意:
消息被消费以后,queue中不再有存储,所以消息消费者不可能消费到已经被消费的消息。
Queue支持存在多个消费者,但是对一个消息而言,只会有一个消费者可以消费。
发布/订阅
消息生产者(发布)将消息发布到topic中,同时有多个消息消费者(订阅)消费该消息。和点对点方式不同,发布到topic的消息会被所有订阅者消费。
下面上我这次写的 订阅模式的代码:
1 、先看看pom.xml 和 application.properties 中的信息
2、 定义 一个主题 订阅模式的Topic
3、 订阅模式的生产者
4 、 创建两个消费者,
5、 controller 层 接收要发布的消息
6 测试
测试数据 msg:{"code":"3130704128","speed":"120","front":"61","longitude":"120.662312", "latitude":"45.252612","date":"2018-06-20 10:45:39"}
控制台打印信息:
参考:https://blog.****.net/u010310183/article/details/51680057