Java删除activemq_activemq 持久化消息删除调用是什么方法

展开全部

ActiveMQ的另一个问题就是只要是软件就有可能挂掉，挂掉不可怕，怕的是挂掉之后把信息给丢了32313133353236313431303231363533e78988e69d8331333337383935，所以本节分析一下几种持久化方式：

一、持久化为文件

ActiveMQ默认就支持这种方式，只要在发消息时设置消息为持久化就可以了。

打开安装目录下的配置文件：

D:ActiveMQapache-activemqconfactivemq.xml在越80行会发现默认的配置项：

注意这里使用的是kahaDB，是一个基于文件支持事务的消息存储器，是一个可靠，高性能，可扩展的消息存储器。

他的设计初衷就是使用简单并尽可能的快。KahaDB的索引使用一个transaction log，并且所有的destination只使用一个index，有人测试表明：如果用于生产环境，支持1万个active connection，每个connection有一个独立的queue。该表现已经足矣应付大部分的需求。

然后再发送消息的时候改变第二个参数为：

MsgDeliveryMode.Persistent

Message保存方式有2种

PERSISTENT：保存到磁盘，consumer消费之后，message被删除。

NON_PERSISTENT：保存到内存，消费之后message被清除。

注意：堆积的消息太多可能导致内存溢出。

然后打开生产者端发送一个消息：

wps30F4.tmp

不启动消费者端，同时在管理界面查看：

wps3105.tmp

发现有一个消息正在等待，这时如果没有持久化，ActiveMQ宕机后重启这个消息就是丢失，而我们现在修改为文件持久化，重启ActiveMQ后消费者仍然能够收到这个消息。

wps3106.tmp

二、持久化为数据库

我们从支持Mysql为例，先从http://dev.mysql.com/downloads/connector/j/下载mysql-connector-java-5.1.34-bin.jar包放到：

D:ActiveMQapache-activemqlib目录下。

打开并修改配置文件：

复制代码

xmlns:xsi=”http://www.w3.org/2001/XMLSchema-instance”

xsi:schemaLocation=”http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd

http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd”>

file:${activemq.conf}/credentials.properties

lazy-init=”false” scope=”singleton”

init-method=”start” destroy-method=”stop”>

已赞过

已踩过

你对这个回答的评价是/p>

评论

收起

文章知识点与官方知识档案匹配，可进一步学习相关知识Java技能树首页概览92564 人正在系统学习中 相关资源：凯利公司 KDZ 系列有刷串励、永磁、他励电机控制器设置软件.rar