消息如何从 ActiveMQ 读取并传递到相应的队列？

Question

我想知道队列如何从将数据存储为滚动日志的 activemq 代理（kahaDB）获取数据。没有特定于队列的日志。不同队列的所有消息都将存储在同一个日志日志文件中。那么它如何有效地从中检索消息。

任何人都知道内部数据是如何从日志文件中获取并在内部逐步发送到相应队列的。比如使用了多少线程。比如详细。

生产者生成的消息存储在 kahadb 日志文件中，索引存储在元数据缓存中。当消费者调用receive()时，受尊重的目标数据如何映射到日志中，以及它如何在内部准确地传递给消费者。和消息流。

Answer 1

ActiveMQ 的 KahaDB 使用滚动附加日志，因为它是一种将数据存储到消息系统磁盘的非常有效的方式。这种方法的好处是无需在使用消息后对数据存储进行碎片整理。为消息的位置维护一个索引（基于每个队列），因此消费者可以快速传递消息。

其他消息传递系统也采用这种方法。

当使用通用数据库作为后端（尤其是 Oracle）时，通常需要运行管理任务来保持数据文件的清洁和高效运行。回想一下——消息系统正在非常快速地创建和删除数据。这种模式通常不是数据库旨在高效执行的开箱即用模式。