zoukankan      html  css  js  c++  java
  • ActiveMQ的消息存储方式

    1. 队列存储
            采取先进先出模式,同一时间,消息只会发送给某一个消费者,只有当该消息被消费并告知已收到时,它才能在代理的存储中被删除。
            对于持久性订阅来说,每一个消费者都会获取消息的拷贝。为了节约空间,代理的存储介质中只存储了一份消息,存储介质的持久订阅对象为其以后的被存储的消息维护了一个指针,消费者消费时,从存储介质中复制一个消息。消息被所有订阅者获取后才能删除。
            2. KahaDB消息存储
            从ActiveMQ5.3后,推荐使用KahaDB存储普通用途的消息。KahaDB是一种基于文件的消息存储机制,为了提高消息存储的可靠性和可恢复性,它整合了一个事务日志。KahaDB拥有高性能和可扩展性等特点。由于KahaDB使用的是基于文件的存储,所以不需要使用第三方数据库。
            KahaDB消息存储机制为所有目的地使用一个索引,其索引使用一个事务日志。
            KahaDB被使用在10000个活动连接的产品环境,每个连接都拥有一个分割的队列。
            KahaDB可以通过配置或硬代码实现,以下是配置方式:

            以下是硬代码方式:

            KahaDB存储方式是所有存储方式中最快捷的一个。
            下表是KahaDB的配置选项:

            3. AMQ消息存储
            AMQ消息存储与KahaDB消息存储类似,由一个提供可靠持续性的事务日志以及高效索引组成,当一个应用中,消息吞吐量是主要需求时,AMQ是最好的选择。但由于它为每个索引使用了两个分隔文件,而每个目的地都有一个索引,所以它不能被使用于每个代理拥有成百上千个队列的情况。ActiveMQ代理没有被完全关闭时,索引的覆盖也会很慢。这是因为所有的索引都需要被重建。
            AMQ消息存储的配置如下所示:

            下表是AMQ存储的配置选项:

            4. JDBC消息存储
            配置方式:

            5. 内存消息存储
            配置方式:

            或者:

  • 相关阅读:
    SQL SERVER2005中将普通表修改为分区表
    手把手教你建立SQL数据库的表分区
    捕获input 文本框内容改变的事件(onchange,onblur,onPropertyChange比较)
    sql语句求排名
    带输出参数的插入语句
    js Base64.encode(str)_decode(str).html
    jquery.base64.js(完美解决中文乱码) 免费版
    sql数据库如何获取某个字段里的最大值?
    C#里封装 继承 多态
    C#中的属性get和set()方法
  • 原文地址:https://www.cnblogs.com/beijingstruggle/p/6402058.html
Copyright © 2011-2022 走看看