activemq持久订阅后kahadb的log在不断增加,可以手动删除吗? 5C

activemq持久订阅后kahadb的log在不断增加,可以手动删除吗?
log存在的一个原因就是一些消费者始终没有在线导致数据不能自动删除,
但是项目测试中有一些clientId不会再使用了,请问这种情况下可以删除旧的
log吗?

0

3个回答

0
hgq0916
hgq0916 文章中说的配置对持久订阅没有效果,我之前试过的
大约一年之前 回复

如果不大的话保留着最好,万一用到呢

0
0
hgq0916
hgq0916 404
大约一年之前 回复
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
ActiveMQ之定期清理离线的持久订阅者
概述 通常,我们不希望系统中存在长时间离线的持久订阅者,因为Broker需要为它们保留它们订阅的topic的所有消息。而且随着时间的推移,将会导致达到存储限制,从而导致系统变慢。 当然,你可以通过JConsole或Web Console等管理工具来手动取消不活跃的持久订阅者。但显然可以采取更多措施来帮助管理。 过期消息 一些应用程序发送的消息有一定的过期时间。如果这些消息存储在Broker上供离线...
activeMQ结合mysql进行持久化
ActiveMQ有几种存储方式,默认使用的是文件索引的方式,在这里我采使用MySQL进行消息持久化过程 1.打开activemq.xml,找到,将默认的注释掉,加入如下的设置: 其中dataSource指定了所用数据源的名字为mysql-ds。需要在activemq.xml文件中的标签之外配置数据源。下面是MySql的配置信息。 ...
activeMQ 的kahadb存储引擎分析
很久没更新blog了,前几天看到淘宝开源了Meta,估计notify也要开源了。其实消息中间件的一个非常重要的核心部件就是持久化存储,可能Meta的功能定位使得它在这一块的实现相对notify和activemq就简单些。趁着有点时间,把activeMQ的kahadb存储引擎做了个分析,希望能对jms实现感兴趣的朋友有点帮助。1. 概述Kahadb是activemq从版本5.4之后的默认消息存储引擎...
关于ActiveMQ中Topic持久化配置问题
说明:记录一下在ActiveMQ中踩过的坑。 关键字:jms:listener-container,topic订阅持久化。 Demo的目录结构(说明中有各个文件的作用) 不懂ActiveMQ的可以,在网上搜搜,有很多很好的博客,在这里我只简单的介绍怎么用,标注一些坑。哪里不足,欢迎提出。前提:activeMQ(解压之后的文件夹)–conf –activemq.xml applicat
如何实现ActiveMq的Topic的持久订阅
原文地址:http://www.mytju.com/classcode/news_readNews.asp?newsID=486   (1)使用queue,即队列时,每个消息只有一个消费者,所以,持久化很简单,只要保存到数据库即可。然后,随便一个消费者取走处理即可。某个消费者关掉一阵子,也无所谓。(2)使用topic,即订阅时,每个消息可以有多个消费者,就麻烦一些。首先,假设消费者都是普通...
由activemq消息存储满导致的服务器崩溃
1.通过jstack 出来的线程有巨量的锁死现象"http://*:3050-8188" daemon prio=10 tid=0x00007fc597d60800 nid=0x9f03 waiting on condition [0x00007fc2d3df9000] java.lang.Thread.State: WAITING (parking)at sun.misc.Unsafe.par
ActiveMQ的消息持久化到Mysql数据库
1、将连接Mysql数据库的jar文件,放到ActiveMQ的lib目录下        2、修改ActiveMQ的conf目录下的active.xml文件,修改数据持久化的方式        2.1  修改原来的kshadb的持久化数据的方式 -->        2.2  连接Mysql的配置(注意配置文件放置的位置)
activemq持久订阅工作原理
对activemq消息订阅模式来说有两种:持久订阅/非持久订阅。 非持久订阅consumer只能消费在该consumer激活状态时传送给对应topic的消息才能被该consumer消费,一旦该consumer 挂掉到下次启动期间发布到该topic的消息不能被该consumer重新恢复时使用!!! 持久订阅:订阅之后,无论消息是否是在该consumer激活或者down掉期间发送的,最终都会被该c...
ActiveMQ的持久化方式
ActiveMQ持久化方式:AMQ、KahaDB、JDBC、LevelDB。1、AMQAMQ是一种文件存储形式,它具有写入速度快和容易恢复的特点。消息存储在一个个文件中,文件的默认大小为32M,如果一条消息的大小超过了32M,那么这个值必须设置大一点。当一个存储文件中的消息已经全部被消费,那么这个文件将被标识为可删除,在下一个清除阶段,这个文件被删除。AMQ适用于ActiveMQ5.3之前的版本。
关于ActiveMq的持久化订阅
1. ActiveMq 客户端 2 修改 clientId 与 durableSubscriptionName的值,每次启动 都会在ActiveMq实列注册持久定阅者,通过控制台可以看到多个持久订阅者,如图 数据库中表记录如下select * from ...
ActiveMQ订阅模式持久化实现
我的诉求是,建一个订阅通道,然后多个客户端监听,当某个客户端掉线后,再上线的时候可以收到它没有接收到的消息。 本文主要参考了《使用Spring配置ActiveMQ的发布订阅模式》(http://nettm.iteye.com/blog/1828268),将他们复制粘贴过来,基本上就ok了。 在找到这篇文章前,《如何实现ActiveMq的Topic的持久订阅》(http://www.my
JMS学习十一(Spring+ActiveMQ消息持久化,Topic持久化订阅)
消息持久化就是将消息保存到磁盘,这样的好处就是如果服务挂了,则消息还保存在磁盘不会丢失,服务起来后还能找到消息并在此发送,消息的持久化和消息的发送模型是没有关系的。 消息持久化的配置很方便的,所以其他的那些就不写出来了,可以看看上一篇文章中的同步异步实现方式。这里只把持久化配置的列出来。 <bean class="org.springframework.j
spring+activemq topic持久化订阅
spring +activemq topic消息持久化订阅实例,整个项目中有activemq和spring的整合的所有实例,topic的持久化配置是在ApplicationContext3C、ApplicationContext3C2以及ApplicationContext3P三个中,消息生产者:QueueProducer 、消息消费者1:SimpleJMSReceiver 消息消费者2:SimpleJMSReceiver2
ActiveMQ中的KahaDB消息日志的恢复机制和可靠性
         ActiveMQ很好的支持了消息的持久性(Persistence)。消息持久性对于可靠消息传递来说应该是一种比较好的方法,有了消息持久化,即使发送者和接受者不是同时在线或者消息中心在发送者发送消息后宕机了,在消息中心重新启动后仍然可以将消息发送出去,如果把这种持久化和ReliableMessaging结合起来应该是很好的保证了消息的可靠传送。       消息持久性的原理很简...
springboot activemq 2 持久化消息 与 持久化订阅
接着上一节http://blog.csdn.net/cons_step_by_step/article/details/78300427。 改动1.减少springboot重复创建session的问题 jmsTemplate的地方加入了CachingConnectionFactory,这样配置可以 @Bean(name = "myJmsTemplate") public JmsTem
kahadb详解
详细介绍了kahadb的原理,以及一些需要注意事项,限于作者水平,如有错误请指正,谢谢!
eclipse paho包对于ActiveMQ持久化订阅者的设置
在实现基于ActiveMQ的电影推送系统的过程中,因为是Android端的应用程序,而在查阅网上的各种资料发现,Android端直接用原生的MQTT来做推送的比较少,而eclipse paho这个封装好的API似乎比较好用在Android端的推送上,于是就采用这个包来做。推送的大致流程可以查看这个网页:基于paho包的Android demo 将逻辑写在Service可以使程序在后台执行
activeMQ持久化策略介绍与配置方式
activeMQ中对于投递模式设置为持久化的消息,broker接收到到消息之后,会先把消息存储到存储介质,然后再转发到消息的监听者,activeMQ提供以下几种消息持久化策略。 KahaDB存储 KahaDB是默认的持久化策略,所有消息顺序添加到一个日志文件中,同时另外有一个索引文件记录指向这些日志的存储地址,还有一个事务日志用于消息回复操作。是一个专门针对消息持久化的解决方案,它对典型的消...
activemq发布订阅消息持久化
一:消息生产者MessageProducer调用setDeliverMode设置发布消息持久化方式,不设置默认也是持久化 import org.apache.activemq.ActiveMQConnectionFactory; import javax.jms.*; public class TopicProducer { public static void main(Str...
ActiveMQ的消息持久化机制
ActiveMQ的消息持久化机制 ActiveMQ的持久化机制包含 JDBC: 持久化到数据库 AMQ :日志文件(已基本不用) KahaDB : AMQ基础上改进,默认选择 LevelDB :谷歌K/V数据库 在activemq.xml中查看默认的broker持久化机制。  默认消息持久化到ActiveMQ路径下的data目录下。   1. 将持久化方式改为JDBC的方...
ActiveMQ 持久化配置
修改配置文件activemq.xml修改persistenceAdapter将下面这段配置,注释掉<persistenceAdapter> <kahaDB directory="${activemq.data}/kahadb"/> </persistenceAdapter> 然后更新成下面的配置:<persistenceAdapter> <jdbcPersistenceAdapter
ActiveMQ配置自动清除数据
备注:(删除不活动的队列(Delete Inactive Destinations)) 一般情况下,ActiveMQ的Topic和Queue在不使用之后,可以通过web控制台或是JMX方式来删除掉。 当然,也可以通过配置,使得broker可以自动探测到无用的队列(一定时间内为空的队列)并删除掉,回收响应资源。 实现定时自动清理无效的Topic和Queue需要设置三个属性。 active
基于kahadb的activemq高可用集群部署配置示例
基于kahadb的activemq高可用集群部署配置示例,两个broker分别部署在两台机器上,一台机子上面,两个实例组成一个broker对外提供高可用服务,两个broker通过桥接形成集群服务
ActiveMQ的持久化订阅
默认情况下,ActiveMQ的发布订阅模式是不做持久化处理的,也就是说,采用发布订阅模式,发布者发布消息时,如果消费者不在线,该消息就丢失了,即便消费者再上线,也不会收到离线时的消息。我们可以做一些设置,使得消费者上线后,也能收到离线时的消息。代码如下。 pom文件<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http
初入activeMQ,spring+activeMQ的整合实现发布订阅
*spring+activeMQ整合一直想写博客,技术用的都太多,但是都不久,总是忘记,老大让搞老项目,今天自己在公司搞了MQ,记录一下:介绍就不需要了,网上一大堆,我喜欢直接上干货,直接撸,看起来也爽。 spring的原理就不用说了,首先spring里面配置能够扫描到这个xml我的xml命名为applicationContext-activemq-container.xml 需要spring加载
ActiveMQ整合spring实现持久化消息接收
       在我们生产过程中往往存在两个项目接口调用场景,但是这中场景下我们很难保证百分百的网络问题和服务问题,所在就会导致我们在调用接口的时候连接超时或者访问不到的情况发生,以致我们的数据丢失。         出现以上问题不用担心,本文就是重点介绍如何通过ActiveMQ的持久化操作解决请求丢失数据。 首先我们需要了解一下ActiveMQ的持久化方式,多的不说我们这里介绍两种持久化方式,...
ActiveMQ通信方式点对点和订阅发布
ActiveMQ通信方式点对点和订阅发布两种方式的一个DEMO
消息中间件-activemq实战之整合Spring(四)
前面的理论准备已经很充分,这一节我们来实战:将activemq整合到Spring框架才行中,因为Spring已经集成了JMS,这也为我们配置activermq带来了方便。1. Spring对jms的支持因为Spring已经将JMS集成到框架里面了,对jms做了自己的封装,我们使用起来更加方便,在Spring中使用jms比较麻烦的就是配置,在Spring中配置JMS大体需要8个部分: Connecti
activeMQ消息详解(续) 订阅(主题)消息(消息持久化)
activeMQ 持久化消息 订阅消息
ActiveMQ源码分析之KahaDB索引存储
前一篇我们分析完了KahaDB消息的存储机制,接下来将分析KahaDB的索引存储机制,跟索引存储相关的文件有*.data,*.redo,*.free。当Broker接收到Producer发送的消息数据之后将会将消息存储起来,而当Producer发送提交事务命令的时候,Broker会为刚才保存的消息生成对应的索引,存储在KahaDB中,以提升消息读取的效率。 Broker接收到的事务信息如下: ...
ActiveMQ的消息存储持久化(一)
                                 ActiveMQ的消息存储持久化(一) 概述 ActiveMQ不仅支持persistent【持久的】和non-persistent【非持久的】两种方式,还支持消息的recovery【恢复】方式。 PTP Queue的存储是很简单的,就是一个FIFO的Queue。 PUB/SUB 对于持久化订阅主题,每一个消费者将获得...
ActiveMQ安装及启动遇到的问题
首先去官方网站下载:http://activemq.apache.org/  我下载的时候最新的是 ActiveMQ 5.15.0 Release版  然后解压,我的电脑是win7 64位,所以点击 apache-activemq-5.15.0\bin\win64\activemq.bat运行 发现报错了 Failed to start Apache ActiveMQ (localhost
ActiveMq持久订阅小例子
public class ProducerTopic { public static void main(String[] args) throws JMSException { String user = ActiveMQConnectionFactory.DEFAULT_USER; String password = ActiveMQConnectionF
activemq消息队列的大小配置的配置
           在网上有人问,如何在activemq.xml里面配置消息队列的大小,这样才保证队列不会溢出!如果采用非持久化消息,那么当大量发送失败时候,首先大量占用内存。造成消息堆积,容易造成内存溢出,所以个人比较倾向于持久化消息的同时配合其他方式的master/slave或者failover机制,尽量保持消息的畅通。当我们开发的Java的使用应用程序的时候,有的时候需要为java应用指...
ActiveMQ源码分析之KahaDB消息存储
KahaDB是ActiveMQ从版本5.4之后的默认消息存储引擎,消息存储机制是消息中间件最重要的核心部件和性能提升点。KahaDB的存储主要分为索引存储和消息存储部分。 KahaDB的索引是B+树,而其最基础的存储机制则是基于“随机存取文件”设计的。相对于连续存储的文件来说这种方式比较耗时,但是设计思路比较简单。 相对的,Kahadb的消息即数据存储机制则是基于“连续存储”文件设计的,这种存...
kahadb 默认属性配置
KahaDB KahaDB是基于文件的本地数据库储存形式,虽然没有AMQ的速度快,但是它具有强扩展性,恢复的时间比AMQ短,从5.4版本之后KahaDB做为默认的持久化方式。默认配置如下:           Java   1 2 3              kahaDB
activemq订阅模式以及消息时长和确认机制
代码如下: [java] view plain copy   package com.activemq;   import org.apache.activemq.ActiveMQConnectionFactory;   import javax.jms.*;       public class TopicPub {        pu
ActiveMQ实战(五)--Spring整合ActiveMQ实现点对点与主题发布订阅通信
一、项目结构 二、加入Maven依赖 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 ht
activemq中的订阅模式以及消息时长和确认机制
直接上代码 发布主题 package com.activemq; import org.apache.activemq.ActiveMQConnectionFactory; import javax.jms.*; public class TopicPub { public static void main(String[] args) throws JMSException {
activeMQ持久化消息和非持久化消息的存储原理
正常情况下,非持久化消息是存储在内存中的,持久化消息是存储在文件中的。能够存储的最大消息数在/conf/activemq.xml文件中的systemUsage节点配置,如下: &amp;amp;lt;systemUsage&amp;amp;gt; &amp;amp;lt;systemUsage&amp;amp;gt; &amp;amp;lt;memoryUsage&amp;amp;gt; //该子标记设置整个ActiveMQ节点的“可...