ActiveMQ - Kaha持久性填充磁盘
ActiveMQ是一个开源的消息中间件，它实现了Java Message Service (JMS)规范，提供了可靠的消息传递机制。Kaha持久性是ActiveMQ中的一种持久化机制，它将消息存储在磁盘上，以确保消息在重启或故障恢复后仍然可用。
Kaha持久性的主要特点和优势包括：
- 可靠性：Kaha持久性将消息存储在磁盘上，即使在服务器重启或故障恢复后，消息也不会丢失。
- 高性能：Kaha持久性使用高效的存储格式和索引机制，提供了快速的消息读写性能。
- 扩展性：Kaha持久性支持水平扩展，可以通过添加更多的磁盘来增加存储容量。
- 灵活性：Kaha持久性提供了多种配置选项，可以根据实际需求进行调整，如消息存储的位置、存储格式等。
ActiveMQ的Kaha持久性适用于以下场景：
- 高可靠性要求：对于需要确保消息不丢失的应用场景，如金融交易系统、电子商务系统等。
- 消息持久化需求：需要将消息持久化到磁盘上，以便在服务器重启或故障恢复后继续处理。
- 大规模消息存储：对于需要存储大量消息的应用场景，Kaha持久性提供了高性能和可扩展性。
腾讯云提供了一系列与消息队列相关的产品，其中包括腾讯云消息队列 CMQ、腾讯云消息队列 Kafka 等，可以根据具体需求选择适合的产品。以下是腾讯云消息队列 CMQ的产品介绍链接地址：https://cloud.tencent.com/product/cmq
相关·内容
我使用的是ActiveMQ和kahadb 5.7.0。</amq:transportConnectors> <amq:kahaPersistenceAdapter directory="activemq-datatempUsage> </amq:systemUsage>
</amq:broker&
浏览 16提问于2019-11-01得票数 0
回答已采纳
这是我的骆驼路线： <from uri="file:///c:/"/></route>
如果在此过程中出现任何故障，我希望将文件永久存储在Kaha但是我不知道用于存储文件的Kaha DB持久性的blueprint.xml配置。我的Activemq.xml文
浏览 0提问于2016-11-30得票数 0
我有一个wso2 ESB正在与activeMQ (持久性消息传递)进行通信。有时，ESB上的线程会堆叠起来，因为所有线程都在等待activeMQ响应对它的各种调用。最终呼叫出错了。同时，在ActiveMQ日志中，我看到了许多“缓慢的Kaha访问”日志。由于IO/access花费的时间太长，activeMQ似乎停止了对ESB的响应。由于我们继续尝试在ActiveMQ (预期的功能)上排队，我们打开越来越多的连接，使用越来越多的线程，直到线程最大限度地关闭为止。几
浏览 0提问于2015-05-04得票数 0
回答已采纳
我正在阅读，并且无法确定ActiveMQ是否在kahadb或内存中存储非持久性消息订阅者的非持久性消息(并将tempUsage卸载到磁盘)？
浏览 1提问于2018-04-12得票数 0
回答已采纳
我正在使用ActiveMQ，并询问如何以及何时将持久化消息真正交换到磁盘上，同时等待使用者吗？我有一个多个消费者，经常上线和离线。在将j控制台连接到activemq之后，我注意到都没有消耗消息，似乎包含在代理的内存中。它们不会被交换到磁盘上，至少我无法验证这一点。确切地说，activemq什么时候通过将消息存储到磁盘/<e
浏览 1提问于2011-08-10得票数 1
回答已采纳
在我的项目中，我们使用了带Kahadb的activemq队列作为持久性机制。虽然我们有足够的磁盘空间，但我们看到6 6GB的RAM也在增加。知道为什么当持久性在kahadb时堆应该增加吗？
浏览 0提问于2018-10-09得票数 0
3回答
我一直在评估作为候选消息代理的ActiveMQ。我已经编写了一些测试代码，试图了解ActiveMQ的性能限制。更新：
Uri的答案引用了三月份提交的一份ActiveMQ错误报告。所以我猜问题仍然存在，这是ActiveMQ应该(将)做的事情吗？实现？
浏览 0提问于2008-12-05得票数 4
请帮助我最后确定使用Apache和ActiveMQ的异步交付支持架构，我已经逐点解释了我的需求。
我让Jetty接收传入消息，并让ActiveMQ使用Kaha将其存储在磁盘中。Active MQ一旦将ack存储在kaha中，就向客户端发送ack。一旦Dispatcher线程从远程接收方获得响应，它就会从ActiveMQ中删除消息。--> response --> Dispatcher Thread (发送ack从ActiveMQ队列删除消息)->
浏览 3提问于2016-05-20得票数 2
1回答
我使用Java和ActiveMQ从嵌入式-Linux发送消息。我的要求是，如果目标代理不可用，则应持久化消息。我选择KahaDB作为持久性适配器，以便消息能够在代理重新启动后存活下来。其原因是为了限制CPU和磁盘的使用。例如:生成消息1，尝试发送消息。如果成功的话，持久性不应该发生，因为我对重新发送已经发送的数据不感兴趣(或者应该只发生在内存中)。生成消息2,3,4，但目的地代理不可用，然后将消息持久化到磁盘上，以便在borker消息不太可能关闭时存活下来。在反复浏览ActiveMQ文档
浏览 3提问于2016-05-22得票数 0
回答已采纳
我有一个使用ActiveMQ的应用程序，该应用程序接收大约50万到100万条消息，这些消息被写入到ActiveMQ队列中，消费者会将它们捡起来。我有ActiveMQ 5.6，我每月至少看到2到3次这个问题。在运行平稳的代理中，我注意到db.data的文件大小是KB，而不是500 MB或700 MB。下面是示例activemq.xml文件：
<?xml version="1.0" encoding="UTF-8"?/schema/core http:/
浏览 1提问于2014-03-20得票数 4
2回答
当使用ActiveMQ与大量持久性队列(250)á1000持久性TextMessagesá10 KB一起使用时会出现问题。在这些消息填充Persistence Store之后，在代理重新启动之后，我们可以浏览/使用一些队列，直到30秒后调用#检查点。下面的设置已经制作了一段时间，在ActiveMQ文档中应用了一些建议(目的地策略、systemUsage、持久性存储选项等)。行为测试用ActiveMQ: 5.11.2，5.13.0和5.5.1。内存设置: Xmx
浏览 6提问于2016-01-08得票数 6
回答已采纳
对于使用ActiveMQ和JmsTemplate(更准确地说，使用JmsTemplate)和spring框架的生产者，是否有重试机制/解决方案的机制或示例实现？
浏览 2提问于2017-04-10得票数 1
回答已采纳
我必须用activeMQ来做这个。我见过一些例子，但不太明白..有人可以告诉我如何准确地编辑我的代码并实现持久订阅？stompClient.subscribe('/topic/notification', function(response){ },{"activemq.subscriptionName我想我必须更改服务器端<dependency>
<groupId>org.apache.activ
浏览 2提问于2017-01-24得票数 1
回答已采纳
我想设置一个问题是，我已经有了一个MongoDB集群，所以我想避免安装另一个DB。可以使用MongoDB或其他已经可用的东西吗？
浏览 3提问于2013-04-12得票数 4
回答已采纳
我正在使用emqx，我希望将会话持久化到磁盘上，以便在代理出于任何原因重新启动时可以恢复会话。因此，代理很好地将保留的消息保存在磁盘上，而不是客户端会话。
知道为什么吗？是否应该将配置更改为在磁盘上持久化客户端会话？
浏览 8提问于2021-06-04得票数 1
1回答
我已经在ActiveMQ代理中启用了持久性。它将消息保存在db表中，以供队列中的消息使用。Problem ActiveMQ没有为主题在数据库中保存消息。附在下面。我正在寻找表activemq_msgs.中的消息
如果我检查这个表中的一个队列，它就会被填充。但是主题中的消息并没有被持久化。<broker xmlns="http://activemq.apache.org/schema/core" brokerName=&qu
浏览 0提问于2018-02-04得票数 0
1回答
我是ActiveMQ的新手，在ActiveMQ中发送和存储大量的大消息(最大的消息大约是100 in )时遇到了一些困难。消息是持久化的，所以据我所知，它们存储在硬盘中，而不是内存中。但奇怪的是，当数据库大小( ActiveMQ文件夹)达到2.8Gb (占4GBJVM堆的70%)时，KahaDB就会崩溃。似乎ActiveMQ仍然将所有消息存储在内存中。ERROR | Forwarding of acks failed | org.apache.activemq.store.kahadb.MessageDa
浏览 1提问于2019-08-05得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
