activemq的高级特性:消息存储持久化

activemq的高级特性之消息存储持久化

  有基于文件的,数据库的,内存的。默认的是基于文件的,在安装目录/data/kahadb。在conf/activemq.xml文件中。

    <persistenceAdapter>
      <kahaDB directory="${activemq.data}/kahadb"/>
    </persistenceAdapter>

  把存储持久化换成mysql的数据库。

  1:修改配置文件

    <persistenceAdapter>
      <jdbcPersistenceAdapter dataSource="#mysql-ds" /> 
    </persistenceAdapter>

  在</broker>标签后面添加<bean>

  <bean id="mysql-ds" class="org.apache.commons.dbcp2.BasicDataSource" destroy-method="close">
    <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
    <property name="url" value="jdbc:mysql://localhost:3306/表名?

    relaxAutoCommit=true&amp;useUnicode=true&amp;characterEncoding=utf-8&amp;serverTimezone=UTC"/>
    <property name="username" value="数据库用户名"/>
    <property name="password" value="数据库密码"/>
    <property name="poolPreparedStatements" value="true"/>
  </bean>

  

  注:

    1:表名要自己 创建

    2:class根据activemq不同的版本,写不同的类,具体参考lib/optional文件夹中的commons-dbcp-1.4.jar。

    3:导入连接数据库的jar包

    4:如果数据库是5.7的。可能会出现启动失败,数据库直接挂掉。解决办法:下载 windows6.1-KB976932-X64.exe 安装即可解决。

原文地址:https://www.cnblogs.com/orange-time/p/10638054.html

时间: 2024-10-05 04:40:51

activemq的高级特性:消息存储持久化的相关文章

ActiveMQ中的Destination高级特性(一)

---------------------------------------------------------------------------------------- Destination高级特性----->Composite Destinations 组合队列Composite Destinations : 允许用一个虚拟的destination代表多个destinations,这样就可以通过composite destinations在一个操作中同时向多个queue/topic发

ActiveMQ(09):ActiveMQ消息存储持久化

一.简介 1.1 描述 ActiveMQ不仅支持persistent和non-persistent两种方式,还支持消息的恢复(recovery)方式.重新投递等 1.2 PTP与PUB/SUB 1.2.1 PTP 对于持久化订阅主题,每一个消费者将获得一个消息的复制. 1.2.2 PUB/SUB 对于持久化订阅主题,每一个消费者将获得一个消息的复制. 1.3 有效的消息存储 ActiveMQ提供了一个插件式的消息存储,类似于消息的多点传播,主要实现了如下几种: 1:AMQ消息存储-基于文件的存储

ActiveMQ消息存储持久化

--------------------------------------------------------------------------------------------------- ActiveMQ提供了插件式的消息存储,主要有有如下几种: 1.AMQ消息存储-基于文件的存储方式,是以前的默认消息存储 2.KahaDB消息存储-提供了容量的提升和恢复能力,是现在的默认存储方式 3.JDBC消息存储-消息基于JDBC存储的 4.Memory消息存储-基于内存的消息存储 下面就分别

(升级版)Spark从入门到精通(Scala编程、案例实战、高级特性、Spark内核源码剖析、Hadoop高端)

本课程主要讲解目前大数据领域最热门.最火爆.最有前景的技术——Spark.在本课程中,会从浅入深,基于大量案例实战,深度剖析和讲解Spark,并且会包含完全从企业真实复杂业务需求中抽取出的案例实战.课程会涵盖Scala编程详解.Spark核心编程.Spark SQL和Spark Streaming.Spark内核以及源码剖析.性能调优.企业级案例实战等部分.完全从零起步,让学员可以一站式精通Spark企业级大数据开发,提升自己的职场竞争力,实现更好的升职或者跳槽,或者从j2ee等传统软件开发工程

JMS服务器ActiveMQ的初体验并持久化消息到MySQL数据库中

JMS服务器ActiveMQ的初体验并持久化消息到MySQL数据库中 一.JMS的理解JMS(Java Message Service)是jcp组织02-03年定义了jsr914规范(http://jcp.org/en/jsr/detail?id=914),它定义了消息的格式和消息传递模式:消息包括:消息头,消息扩展属性和消息体,其结构看起来与SOAP非常的相似,但一般情况下,SOAP主要关注远程服务调用,而消息则专注于信息的交换:消息分为:消息生产者,消息服务器和消息消费者.生产者与消费者之间

Redis高级特性及应用场景

Redis高级特性及应用场景 redis中键的生存时间(expire) redis中可以使用expire命令设置一个键的生存时间,到时间后redis会自动删除它. 过期时间可以设置为秒或者毫秒精度. 过期时间分辨率总是 1 毫秒. 过期信息被复制和持久化到磁盘,当 Redis 停止时时间仍然在计算 (也就是说 Redis 保存了过期时间). expire  设置生存时间(单位/秒) expire key seconds(秒) ttl 查看键的剩余生存时间 ttl key persist 取消生存

Redis基础、高级特性与性能调优

本文将从Redis的基本特性入手,通过讲述Redis的数据结构和主要命令对Redis的基本能力进行直观介绍.之后概览Redis提供的高级能力,并在部署.维护.性能调优等多个方面进行更深入的介绍和指导.本文适合使用Redis的普通开发人员,以及对Redis进行选型.架构设计和性能调优的架构设计人员. 目录 概述 Redis的数据结构和相关常用命令 数据持久化 内存管理与数据淘汰机制 Pipelining 事务与Scripting Redis性能调优 主从复制与集群分片 Redis Java客户端的

redis 高级特性 不要太好用

Redis高级特性及应用场景 redis中键的生存时间(expire) redis中可以使用expire命令设置一个键的生存时间,到时间后redis会自动删除它. 过期时间可以设置为秒或者毫秒精度. 过期时间分辨率总是 1 毫秒. 过期信息被复制和持久化到磁盘,当 Redis 停止时时间仍然在计算 (也就是说 Redis 保存了过期时间). expire  设置生存时间(单位/秒) [python] view plain copy expire key seconds(秒) ttl 查看键的剩余

ActiveMQ(3)---ActiveMQ原理分析之消息持久化

持久化消息和非持久化消息的存储原理 正常情况下,非持久化消息是存储在内存中的,持久化消息是存储在文件中的.能够存储的最大消息数据在${ActiveMQ_HOME}/conf/activemq.xml文件中的systemUsage节点 ,SystemUsage配置设置了一些系统内存和硬盘容量 <systemUsage> <systemUsage> <memoryUsage> //该子标记设置整个ActiveMQ节点的“可用内存限制”.这个值不能超过ActiveMQ本身设置