ActiveMQ应用

叁歲伎倆 2021-11-04 16:58 481阅读 0赞
  1. PTP处理模式(Queue)

消息生产者生产消息发送到queue中,然后消息消费者从queue中取出并且消费消息。
消息被消费以后,queue中不再有存储,所以消息消费者不可能消费到已经被消费的消息。
Queue支持存在多个消费者,但是对一个消息而言,只会有一个消费者可以消费、其它的则不能消费此消息了。
当消费者不存在时,消息会一直保存,直到有消费消费
在这里插入图片描述

  1. Publush/Subscribe处理模式 (Topic)

消息生产者(发布)将消息发布到topic中,同时有多个消息消费者(订阅)消费该消息。
和点对点方式不同,发布到topic的消息会被所有订阅者消费。
当生产者发布消息,不管是否有消费者。都不会保存消息
一定要先有消息的消费者,后有消息的生产者。
在这里插入图片描述

  1. PTP和PUB/SUB简单对比
    在这里插入图片描述
  2. ActiveMQ持久化

ActiveMQ中,持久化是指对消息数据的持久化。在ActiveMQ中,默认的消息是保存在内存中的。当内存容量不足的时候,或ActiveMQ正常关闭的时候,会将内存中的未处理的消息持久化到磁盘中。具体的持久化策略由配置文件中的具体配置决定。
ActiveMQ的默认存储策略是kahadb。如果使用JDBC作为持久化策略,则会将所有的需要持久化的消息保存到数据库中。
所有的持久化配置都在conf/activemq.xml中配置,配置信息都在broker标签内部定义。还支持JDBC的持久化方式。

发表评论

表情:
评论列表 (有 0 条评论,481人围观)

还没有评论,来说两句吧...

相关阅读

    相关 ActiveMQ应用场景

    ActiveMQ是一种开放源代码的消息中间件,可以用来构建分布式系统,支持组播和发布/订阅模式。它主要应用在分布式系统的消息传输,比如消息队列、路由等。它可以用于开发移动应用、

    相关 ActiveMQ应用

    1. PTP处理模式(Queue) > 消息生产者生产消息发送到queue中,然后消息消费者从queue中取出并且消费消息。 > 消息被消费以后,queue中不再有存储