ActiveMQ应用

叁歲伎倆 2021-11-04 16:58 393阅读 0赞

1.  PTP处理模式(Queue)

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

1.  Publush/Subscribe处理模式 （Topic）

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

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

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

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nbmluZ2tpZA_size_16_color_FFFFFF_t_70]: /images/20211104/5f23e290197d47e3b93c88284fde2beb.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nbmluZ2tpZA_size_16_color_FFFFFF_t_70 1]: /images/20211104/41b029e845fd4aef8a5935db5bec3e7f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nbmluZ2tpZA_size_16_color_FFFFFF_t_70 2]: /images/20211104/08472ef96b2c49a9b9018693c597c886.png