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

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

0

3个回答

0
hgq0916
hgq0916 文章中说的配置对持久订阅没有效果,我之前试过的
10 个月之前 回复

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

0
0
hgq0916
hgq0916 404
10 个月之前 回复
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
Activemq数据安全机制——Activemq中的KahaDB消息日志的恢复机制
KahaDB 支持多种机制在系统异常关闭后重启并恢复。包括检测数据文件丢失和还原损坏的metadata。这些特性并不能完全保证系统异常关闭不造成消息丢失。如果需要保证系统的高可靠性,建议部署到容灾系统上。例如RAID磁盘阵列中。  当broker正常关闭时, KahaDB message store会将所有的缓存数据刷到文件系统中。尤其是这些数据:  1、所有未处理的日志数据  2、所有
ActiveMQ配置自动清除数据
备注:(删除不活动的队列(Delete Inactive Destinations)) 一般情况下,ActiveMQ的Topic和Queue在不使用之后,可以通过web控制台或是JMX方式来删除掉。 当然,也可以通过配置,使得broker可以自动探测到无用的队列(一定时间内为空的队列)并删除掉,回收响应资源。 实现定时自动清理无效的Topic和Queue需要设置三个属性。 active
activeMQ 的kahadb存储引擎分析
activeMQ 的kahadb存储引擎分析 很久没更新blog了,前几天看到淘宝开源了Meta,估计notify也要开源了。其实消息中间件的一个非常重要的核心部件就是持久化存储,可能Meta的功能定位使得它在这一块的实现相对notify和activemq就简单些。趁着有点时间,把activeMQ的kahadb存储引擎做了个分析,希望能对jms实现感兴趣的朋友有点帮助。 1.
ActiveMQ持久订阅设置
在JMS中,Topic实现publish和subscribe语义。一条消息被publish时,它将发到所有感兴趣的订阅者,所以零到多个subscriber将接收到消息的一个拷贝。但是在消息代理接收到消息时,只有激活订阅的subscriber能够获得消息的一个拷贝。     JMS Queue执行load balancer语义。一条消息仅能被一个consumer收到。如果在message发送的时候
Activemq中的KahaDB消息日志的恢复机制
KahaDB 支持多种机制在系统异常关闭后重启并恢复。包括检测数据文件丢失和还原损坏的metadata。这些特性并不能完全保证系统异常关闭不造成消息丢失。如果需要保证系统的高可靠性,建议部署到容灾系统上。例如RAID磁盘阵列中。 当broker正常关闭时, KahaDB message store会将所有的缓存数据刷到文件系统中。尤其是这些数据: 1、所有未处理的日志数据 2、所...
KahaDB简介
KahaDB简介      ActiveMQ 5.3以后,出现了KahaDB。她是一个基于文件支持事务的消息存储器,是一个可靠,高性能,可扩展的消息存储器。      她的设计初衷就是使用简单并尽可能的快。KahaDB的索引使用一个transaction log,并且所有的destination只使用一个index,有人测试表明:如果用于生产环境,支持1万个active con
ActiveMQ的持久化订阅
默认情况下,ActiveMQ的发布订阅模式是不做持久化处理的,也就是说,采用发布订阅模式,发布者发布消息时,如果消费者不在线,该消息就丢失了,即便消费者再上线,也不会收到离线时的消息。我们可以做一些设置,使得消费者上线后,也能收到离线时的消息。代码如下。 pom文件<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http
ActiveMQ系列—ActiveMQ性能优化(下1)(消息存储方案 KahaDB)
序1:存储方案配置在介绍ActiveMQ的存储方案之前,首先需要明确的是ActiveMQ中的几种“容量”描述:ActiveMQ的内核是Java编写的,也就是说如果服务端没有Java运行环境ActiveMQ是无法运行的。ActiveMQ启动时,启动脚本使用wrapper包装器来启动JVM。JVM相关的配置信息在启动目录的“wrapper.conf”配置文件中。各位读者可以通过改变其中的配置项,设置JV
如何实现ActiveMQ的Topic的持久订阅。
(1)使用queue,即队列时,每个消息只有一个消费者,所以,持久化很简单,只要保存到数据库即可 。然后,随便一个消费者取走处理即可。某个消费者关掉一阵子,也无所谓。 (2)使用topic,即订阅时,每个消息可以有多个消费者,就麻烦一些。 首先,假设消费者都是普通的消费者, ------------------------ activemq启动后,发布消息1,可惜,现在没有消
ActiveMQ的持久化方式
ActiveMQ持久化方式:AMQ、KahaDB、JDBC、LevelDB。1、AMQAMQ是一种文件存储形式,它具有写入速度快和容易恢复的特点。消息存储在一个个文件中,文件的默认大小为32M,如果一条消息的大小超过了32M,那么这个值必须设置大一点。当一个存储文件中的消息已经全部被消费,那么这个文件将被标识为可删除,在下一个清除阶段,这个文件被删除。AMQ适用于ActiveMQ5.3之前的版本。
activemq中持久订阅者和非持久订阅者区别
1、消息的传输类型: 上文已经讲过,activemq支持两只传输的模式:持久化和非持久化。可以通过MessageProducer 类的 setDeliveryMode方法设置传输模式: MessageProducer producer = ...; producer.setDeliveryMode(DeliveryMode.PERSISTENT); 持久传输和非持久传输最大的区别是:采用持久
ActiveMQ使用笔记(二)ActiveMQ消息持久化一
原文地址:http://www.huaishao8.com/config/activemq/122.html 在broker中设置属性persistent=”true”(默认是true),同时发送的消息也应该是persitent类型的。ActiveMQ消息持久化有三种方式:AMQ、KahaDB、JDBC。 1、AMQ AMQ是一种文件存储形式,它具有写入速度快和容易恢复的特点。消
JMS学习七(ActiveMQ消息持久化)
上一篇文章中消息的持久化订阅有个前提条件就是消息的持久化,也就是将发送的消息保存磁盘,之后能再次获取,ActiveMQ提供了好几种消息持久化方案比如kahaDB 、JDBC等,下面来一个个看。
ActiveMQ中的消息的持久化和非持久化 以及 持久订阅者 和 非持久订阅者之间的区别与联系
①DeliveryMode 这是传输模式。ActiveMQ支持两种传输模式:持久传输和非持久传输(persistent and non-persistent delivery),默认情况下使用的是持久传输。 可以通过MessageProducer 类的 setDeliveryMode方法设置传输模式: MessageProducer producer = ...; produce
由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持久订阅工作原理
对activemq消息订阅模式来说有两种:持久订阅/非持久订阅。 非持久订阅consumer只能消费在该consumer激活状态时传送给对应topic的消息才能被该consumer消费,一旦该consumer 挂掉到下次启动期间发布到该topic的消息不能被该consumer重新恢复时使用!!! 持久订阅:订阅之后,无论消息是否是在该consumer激活或者down掉期间发送的,最终都会被该c...
ActiveMQ订阅模式持久化实现
我的诉求是,建一个订阅通道,然后多个客户端监听,当某个客户端掉线后,再上线的时候可以收到它没有接收到的消息。 本文主要参考了《使用Spring配置ActiveMQ的发布订阅模式》(http://nettm.iteye.com/blog/1828268),将他们复制粘贴过来,基本上就ok了。 在找到这篇文章前,《如何实现ActiveMq的Topic的持久订阅》(http://www.my
关于ActiveMq的持久化订阅
1. ActiveMq 客户端 2 修改 clientId 与 durableSubscriptionName的值,每次启动 都会在ActiveMq实列注册持久定阅者,通过控制台可以看到多个持久订阅者,如图 数据库中表记录如下select * from ...
如何实现ActiveMQ的Topic的持久订阅
消息持久化就是将消息保存到磁盘,这样的好处就是如果服务挂了,则消息还保存在磁盘不会丢失,服务起来后还能找到消息并在此发送,消息的持久化和消息的发送模型是没有关系的。 消息持久化的配置很方便的,所以其他的那些就不写出来了,可以看看上一篇文章中的同步异步实现方式。这里只把持久化配置的列出来。   [html] view plain copy    &amp;lt;!-- spring 使用jmsTe...
activeMQ消息详解(续) 订阅(主题)消息(消息持久化)
activeMQ 持久化消息 订阅消息
ActiveMQ之Topic的持久订阅
非持久化订阅持续到它们订阅对象的生命周期。这意味着,客户端只能在订阅者活动时看到相关主题发布的消息。如果订阅者不活动,它会错过相关主题的消息。如果花费较大的开销,订阅者可以被定义为durable(持久化的)。持久化的订阅者注册一个带有JMS保持的唯一标识的持久化订阅(subscription)。带有相同标识的后续订阅者会再续前一个订阅者的订阅状态。如果持久化订阅没有活动的订阅者,JMS会保持订阅消息,直到消息被订阅接收或者过期。
activeMQ结合mysql进行持久化
ActiveMQ有几种存储方式,默认使用的是文件索引的方式,在这里我采使用MySQL进行消息持久化过程 1.打开activemq.xml,找到,将默认的注释掉,加入如下的设置: 其中dataSource指定了所用数据源的名字为mysql-ds。需要在activemq.xml文件中的标签之外配置数据源。下面是MySql的配置信息。 ...
ActiveMQ整合spring实现持久化消息接收
       在我们生产过程中往往存在两个项目接口调用场景,但是这中场景下我们很难保证百分百的网络问题和服务问题,所在就会导致我们在调用接口的时候连接超时或者访问不到的情况发生,以致我们的数据丢失。         出现以上问题不用担心,本文就是重点介绍如何通过ActiveMQ的持久化操作解决请求丢失数据。 首先我们需要了解一下ActiveMQ的持久化方式,多的不说我们这里介绍两种持久化方式,...
ActiveMQ的消息存储持久化(一)
                                 ActiveMQ的消息存储持久化(一) 概述 ActiveMQ不仅支持persistent【持久的】和non-persistent【非持久的】两种方式,还支持消息的recovery【恢复】方式。 PTP Queue的存储是很简单的,就是一个FIFO的Queue。 PUB/SUB 对于持久化订阅主题,每一个消费者将获得...
Spring+ActiveMQ消息持久化,Topic持久化订阅
消息持久化就是将消息保存到磁盘,这样的好处就是如果服务挂了,则消息还保存在磁盘不会丢失,服务起来后还能找到消息并在此发送,消息的持久化和消息的发送模型是没有关系的。 消息持久化的配置很方便的,所以其他的那些就不写出来了,可以看看上一篇文章中的同步异步实现方式。这里只把持久化配置的列出来。 [html] view plain copy  print?
spring+activemq topic持久化订阅
spring +activemq topic消息持久化订阅实例,整个项目中有activemq和spring的整合的所有实例,topic的持久化配置是在ApplicationContext3C、ApplicationContext3C2以及ApplicationContext3P三个中,消息生产者:QueueProducer 、消息消费者1:SimpleJMSReceiver 消息消费者2:SimpleJMSReceiver2
springboot activemq 2 持久化消息 与 持久化订阅
接着上一节http://blog.csdn.net/cons_step_by_step/article/details/78300427。 改动1.减少springboot重复创建session的问题 jmsTemplate的地方加入了CachingConnectionFactory,这样配置可以 @Bean(name = "myJmsTemplate") public JmsTem
ActiveMQ 自动删除功能
备注:(删除不活动的队列(Delete Inactive Destinations)) 一般情况下,ActiveMQ的Topic和Queue在不使用之后,可以通过web控制台或是JMX方式来删除掉。 当然,也可以通过配置,使得broker可以自动探测到无用的队列(一定时间内为空的队列)并删除掉,回收响应资源。 实现定时自动清理无效的Topic和Queue需要设置三个属性。 activemq.x...
eclipse paho包对于ActiveMQ持久化订阅者的设置
在实现基于ActiveMQ的电影推送系统的过程中,因为是Android端的应用程序,而在查阅网上的各种资料发现,Android端直接用原生的MQTT来做推送的比较少,而eclipse paho这个封装好的API似乎比较好用在Android端的推送上,于是就采用这个包来做。推送的大致流程可以查看这个网页:基于paho包的Android demo 将逻辑写在Service可以使程序在后台执行
ActiveMQ系列—ActiveMQ性能优化(下2)(消息存储方案 LevelDB)
10、KahaDB存储方案 LevelDb是能够处理十亿级别规模Key-Value型数据持久性存储的C++ 程序库,由Google发起并开源。LevelDB只能由本操作系统的其他进程调用,所以它不具有网络性。如果您需要网络上的远程进程操作LevelDB,那么就要自行封装服务层。 10.1、LevelDB基本结构LevelDB中的核心设计算法是跳跃表(Skip List),核心操作策略是对磁盘上的
快速上手MQ之activeMQ(4)--消息持久化
消息持久化顾名思义就是把发布的消息进行落地,这样activeMQ宕机也不会导致那些未被消费的消息给弄消失,这样保证消息都能被消费。 activeMQ消息持久化有JDBC,AMQ,KahaDB和LevelDB等这几种,默认采用的是KahaDB,本篇讲的是如何采用jdbc的新式把消息存入数据库的例子; activeMQ默认采用的KahaDB,消息会落地到安装目录下的\data\kahadb这个目录
JMS学习十一(Spring+ActiveMQ消息持久化,Topic持久化订阅)
消息持久化就是将消息保存到磁盘,这样的好处就是如果服务挂了,则消息还保存在磁盘不会丢失,服务起来后还能找到消息并在此发送,消息的持久化和消息的发送模型是没有关系的。 消息持久化的配置很方便的,所以其他的那些就不写出来了,可以看看上一篇文章中的同步异步实现方式。这里只把持久化配置的列出来。 <bean class="org.springframework.j
ActiveMQ消息持久化到Mysql数据库
1、把连接MySQL数据库的jar文件,放到ActiveMQ的lib目录下 2、修改ActiveMQ的conf目录下的activemq.xml文件,修改数据持久化的方式2.1 修改原来的kahadb的持久化数据的方式<!-- <persistenceAdapter> <kahaDB directory="${activemq.data}/kahadb"/> </persistenceAd
关于ActiveMQ中Topic持久化配置问题
说明:记录一下在ActiveMQ中踩过的坑。 关键字:jms:listener-container,topic订阅持久化。 Demo的目录结构(说明中有各个文件的作用) 不懂ActiveMQ的可以,在网上搜搜,有很多很好的博客,在这里我只简单的介绍怎么用,标注一些坑。哪里不足,欢迎提出。前提:activeMQ(解压之后的文件夹)–conf –activemq.xml applicat
ActiveMQ 持久化配置
修改配置文件activemq.xml修改persistenceAdapter将下面这段配置,注释掉<persistenceAdapter> <kahaDB directory="${activemq.data}/kahadb"/> </persistenceAdapter> 然后更新成下面的配置:<persistenceAdapter> <jdbcPersistenceAdapter
activemq消息队列的大小配置的配置
           在网上有人问,如何在activemq.xml里面配置消息队列的大小,这样才保证队列不会溢出!如果采用非持久化消息,那么当大量发送失败时候,首先大量占用内存。造成消息堆积,容易造成内存溢出,所以个人比较倾向于持久化消息的同时配合其他方式的master/slave或者failover机制,尽量保持消息的畅通。当我们开发的Java的使用应用程序的时候,有的时候需要为java应用指...
ActiveMQ的kahadb写入消息性能测试(包括SSD硬盘)
测试用例如下列表所示,由此可以看出 1、SSD硬盘可以提升写入大概20%的性能 2、1K以内的消息,SATA硬盘一秒大概可以写入6000 3、1K以内的消息,SSD大概能写入7800 4、batch、filesize、甚至同步异步对其写入影响都不大。 有时间再测试下更大消息和更多场景,再结合现象和源码分析一下。 128字节的消息 -------------------------
基于kahadb的activemq高可用集群部署配置示例
基于kahadb的activemq高可用集群部署配置示例,两个broker分别部署在两台机器上,一台机子上面,两个实例组成一个broker对外提供高可用服务,两个broker通过桥接形成集群服务
ActiveMQ基于文件共享的主从配置方案
ActiveMq 基于文件共享的主从配置方案
ActiveMQ消息的发布与订阅
消息的发布与订阅 Publish类 package com.cb01; import javax.jms.Connection; import javax.jms.ConnectionFactory; import javax.jms.Destination; import javax.jms.JMSException; import javax.jms.MessageProducer; i
文章热词 设计制作学习 机器学习教程 Objective-C培训 交互设计视频教程 颜色模型
相关热词 mysql关联查询两次本表 native底部 react extjs glyph 图标 python可以培训吗 云计算可以学吗