Question

activemq 怎么处理持久化

Answer 1

　　如果消息是持久化的，activemq收到消息后会存储在持久性cursor中。对于非持久化消息，会存储在File Cursor中。从名称上File Cursor是持久性cursor，实际上activemq把FilePendingMessageCursor作为非持久性cursor。
　　File Cursor首先在内存中保存消息的引用，如果内存使用量达到上限，那么会把消息引用保存到临时文件中，这样就不会因为有大量消息没有被消费而导致OOM。
　　当消息consumer启动时，mq收到消息会激活broker上的DurableTopicSubscrition，该subscription会检查当前的消息cursor里是否有消息，如果有就会dispatch这些消息，这样consumer就能收到之前发送的消息了。转载，仅供参考。